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

Class Command

java.lang.Object

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

Direct Known Subclasses:

AppendCommand, CatCommand, CopyCommand, DumpCommand, HelpCommand, LagCommand, LatencyCommand, MonitorCommand, PositionCommand, RestoreCommand, TailCommand, TestCommand, TrackerCommand, WorkCatCommand

public abstract class Command
extends Object

Since:

9.3

Constructor Summary

Constructors

Constructor	Description
Command()

Method Summary

Modifier and Type	Method	Description
protected Codec<Record>	getRecordCodec(String codec)
protected Renderer	getRecordRenderer(String render, String avroSchemaStorePath, int dataSize)
abstract String	name()
abstract boolean	run(LogManager manager, org.apache.commons.cli.CommandLine cmd)
abstract void	updateOptions(org.apache.commons.cli.Options options)

Methods inherited from class java.lang.Object

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

Constructor Detail

Command

public Command()

Method Detail

name

public abstract String name()

updateOptions

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

run

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

Throws:

InterruptedException

getRecordRenderer

protected Renderer getRecordRenderer(String render,
                                     String avroSchemaStorePath,
                                     int dataSize)

getRecordCodec

protected Codec<Record> getRecordCodec(String codec)