public class PositionCommand extends Command
Modifier and Type | Field and Description |
---|---|
static String |
AFTER_DATE_OPT |
static Duration |
FIRST_READ_TIMEOUT |
protected static String |
NAME |
static Duration |
READ_TIMEOUT |
static String |
TO_WATERMARK_OPT |
Constructor and Description |
---|
PositionCommand() |
Modifier and Type | Method and Description |
---|---|
protected <T extends Externalizable> |
createTailer(LogManager manager,
String name,
int partition,
String group) |
protected LogLag |
getLag(LogManager manager,
String group,
String name,
int partition) |
protected static long |
getTimestampFromDate(String dateIso8601) |
protected String |
labelFor(int partition) |
protected String |
labelFor(String name,
int partition) |
String |
name() |
protected boolean |
positionAfterDate(LogManager manager,
String group,
String name,
int partition,
long timestamp) |
protected boolean |
positionToWatermark(LogManager manager,
String group,
String name,
int partition,
long timestamp) |
protected boolean |
reset(LogManager manager,
String group,
String name,
int partition) |
boolean |
run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
protected LogOffset |
searchWatermarkOffset(LogTailer<Record> tailer,
long timestamp) |
protected boolean |
toEnd(LogManager manager,
String group,
String name,
int partition) |
void |
updateOptions(org.apache.commons.cli.Options options) |
getRecordCodec, getRecordRenderer
public static final Duration FIRST_READ_TIMEOUT
public static final Duration READ_TIMEOUT
protected static final String NAME
public static final String AFTER_DATE_OPT
public static final String TO_WATERMARK_OPT
public PositionCommand()
protected static long getTimestampFromDate(String dateIso8601)
public void updateOptions(org.apache.commons.cli.Options options)
updateOptions
in class Command
public boolean run(LogManager manager, org.apache.commons.cli.CommandLine cmd) throws InterruptedException
run
in class Command
InterruptedException
protected boolean toEnd(LogManager manager, String group, String name, int partition)
protected LogLag getLag(LogManager manager, String group, String name, int partition)
protected <T extends Externalizable> LogTailer<T> createTailer(LogManager manager, String name, int partition, String group)
protected boolean reset(LogManager manager, String group, String name, int partition)
protected boolean positionAfterDate(LogManager manager, String group, String name, int partition, long timestamp)
protected boolean positionToWatermark(LogManager manager, String group, String name, int partition, long timestamp) throws InterruptedException
InterruptedException
protected LogOffset searchWatermarkOffset(LogTailer<Record> tailer, long timestamp) throws InterruptedException
InterruptedException
Copyright © 2018 Nuxeo. All rights reserved.