public class RestoreCommand extends Command
Modifier and Type | Field and Description |
---|---|
protected String |
codec |
protected long |
date |
protected boolean |
dryRun |
protected static String |
GROUP |
protected String |
input |
protected List<String> |
logNames |
protected static String |
NAME |
protected boolean |
verbose |
Constructor and Description |
---|
RestoreCommand() |
Modifier and Type | Method and Description |
---|---|
protected Latency |
decodeLatency(byte[] data) |
protected LogOffset |
findOffset(LogManager manager,
LogPartitionGroup key,
Latency latency) |
protected List<String> |
getLogNames(LogManager manager,
String names) |
String |
name() |
protected Map<LogPartitionGroup,Latency> |
readLatencies(LogManager manager) |
protected boolean |
restorePosition(LogManager manager) |
boolean |
run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
protected Map<LogPartitionGroup,LogOffset> |
searchOffsets(LogManager manager,
Map<LogPartitionGroup,Latency> latencies) |
void |
updateOptions(org.apache.commons.cli.Options options) |
protected void |
updatePosition(LogManager manager,
LogPartitionGroup key,
LogOffset offset) |
protected void |
updatePositions(LogManager manager,
Map<LogPartitionGroup,LogOffset> offsets) |
getRecordCodec, getRecordRenderer
protected static final String NAME
protected static final String GROUP
protected boolean verbose
protected long date
protected boolean dryRun
public RestoreCommand()
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 restorePosition(LogManager manager) throws InterruptedException
InterruptedException
protected void updatePositions(LogManager manager, Map<LogPartitionGroup,LogOffset> offsets)
protected void updatePosition(LogManager manager, LogPartitionGroup key, LogOffset offset)
protected Map<LogPartitionGroup,LogOffset> searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies) throws InterruptedException
InterruptedException
protected LogOffset findOffset(LogManager manager, LogPartitionGroup key, Latency latency) throws InterruptedException
InterruptedException
protected Map<LogPartitionGroup,Latency> readLatencies(LogManager manager) throws InterruptedException
InterruptedException
protected Latency decodeLatency(byte[] data)
protected List<String> getLogNames(LogManager manager, String names)
Copyright © 2018 Nuxeo. All rights reserved.