Package org.nuxeo.lib.stream.tools.command

Class PositionCommand

java.lang.Object

org.nuxeo.lib.stream.tools.command.Command

org.nuxeo.lib.stream.tools.command.PositionCommand

public class PositionCommand
extends Command

Manipulates the consumer position to the beginning, end or a specific timestamp

Since:

10.1

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AFTER_DATE_OPT
static final Duration	FIRST_READ_TIMEOUT
protected static final String	NAME
static final Duration	READ_TIMEOUT
static final String	TO_OFFSET_OPT
static final String	TO_WATERMARK_OPT

Constructor Summary

Constructors

Constructor	Description
PositionCommand()

Method Summary

Modifier and Type	Method	Description
protected <T extends Externalizable> LogTailer<T>	createTailer(LogManager manager, Name name, int partition, Name group)
protected LogLag	getLag(LogManager manager, Name group, Name name, int partition)
protected static long	getTimestampFromDate(String dateIso8601)
protected String	labelFor(int partition)
protected String	labelFor(Name name, int partition)
String	name()
protected boolean	positionAfterDate(LogManager manager, Name group, Name name, int partition, long timestamp)
protected boolean	positionToOffset(LogManager manager, Name group, Name name, int partition, long offset)
protected boolean	positionToWatermark(LogManager manager, Name group, Name name, int partition, long timestamp, String codec)
protected boolean	reset(LogManager manager, Name group, Name 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, Name group, Name name, int partition)
void	updateOptions(org.apache.commons.cli.Options options)

Methods inherited from class org.nuxeo.lib.stream.tools.command.Command

getRecordCodec, getRecordRenderer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

FIRST_READ_TIMEOUT

public static final Duration FIRST_READ_TIMEOUT

READ_TIMEOUT

public static final Duration READ_TIMEOUT

NAME

protected static final String NAME

See Also:

• Constant Field Values

AFTER_DATE_OPT

public static final String AFTER_DATE_OPT

See Also:

• Constant Field Values

TO_WATERMARK_OPT

public static final String TO_WATERMARK_OPT

See Also:

• Constant Field Values

TO_OFFSET_OPT

public static final String TO_OFFSET_OPT

See Also:

• Constant Field Values

Constructor Details

PositionCommand

public PositionCommand()

Method Details

getTimestampFromDate

protected static long getTimestampFromDate(String dateIso8601)

name

public String name()

Specified by:

name in class Command

updateOptions

public void updateOptions(org.apache.commons.cli.Options options)

Specified by:

updateOptions in class Command

run

public boolean run(LogManager manager,
 org.apache.commons.cli.CommandLine cmd)
            throws InterruptedException

Specified by:

run in class Command

Throws:

InterruptedException

toEnd

protected boolean toEnd(LogManager manager,
 Name group,
 Name name,
 int partition)

labelFor

protected String labelFor(int partition)

labelFor

protected String labelFor(Name name,
 int partition)

getLag

protected LogLag getLag(LogManager manager,
 Name group,
 Name name,
 int partition)

createTailer

protected <T extends Externalizable> LogTailer<T> createTailer(LogManager manager,
 Name name,
 int partition,
 Name group)

reset

protected boolean reset(LogManager manager,
 Name group,
 Name name,
 int partition)

positionAfterDate

protected boolean positionAfterDate(LogManager manager,
 Name group,
 Name name,
 int partition,
 long timestamp)

positionToWatermark

protected boolean positionToWatermark(LogManager manager,
 Name group,
 Name name,
 int partition,
 long timestamp,
 String codec)
                               throws InterruptedException

Throws:

InterruptedException

searchWatermarkOffset

protected LogOffset searchWatermarkOffset(LogTailer<Record> tailer,
 long timestamp)
                                   throws InterruptedException

Throws:

InterruptedException

positionToOffset

protected boolean positionToOffset(LogManager manager,
 Name group,
 Name name,
 int partition,
 long offset)