public class PositionCommand extends Command
Modifier and Type | Field and Description |
---|---|
static Duration |
FIRST_READ_TIMEOUT |
protected static String |
NAME |
static Duration |
READ_TIMEOUT |
Constructor and Description |
---|
PositionCommand() |
Modifier and Type | Method and Description |
---|---|
protected static long |
getTimestampFromDate(String dateIso8601) |
String |
name() |
protected boolean |
positionAfterDate(LogManager manager,
String group,
String name,
long timestamp) |
protected boolean |
positionToWatermark(LogManager manager,
String group,
String name,
long timestamp) |
protected boolean |
reset(LogManager manager,
String group,
String name) |
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) |
void |
updateOptions(org.apache.commons.cli.Options options) |
getRecordRenderer
public static final Duration FIRST_READ_TIMEOUT
public static final Duration READ_TIMEOUT
protected static final String NAME
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)
protected boolean reset(LogManager manager, String group, String name)
protected boolean positionAfterDate(LogManager manager, String group, String name, long timestamp)
protected boolean positionToWatermark(LogManager manager, String group, String name, long timestamp) throws InterruptedException
InterruptedException
protected LogOffset searchWatermarkOffset(LogTailer<Record> tailer, long timestamp) throws InterruptedException
InterruptedException
Copyright © 2018 Nuxeo. All rights reserved.