Package | Description |
---|---|
org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
org.nuxeo.lib.stream.computation.log |
Computation pattern implemented with Log
|
org.nuxeo.lib.stream.log |
The Log interface with Chronicle and Kafka implementation.
|
org.nuxeo.lib.stream.log.internals | |
org.nuxeo.lib.stream.tools.command |
Modifier and Type | Method and Description |
---|---|
Latency |
StreamProcessor.getLatency(String computationName)
Returns the latency for a computation.
|
Modifier and Type | Method and Description |
---|---|
Latency |
LogStreamProcessor.getLatency(String computationName) |
Modifier and Type | Method and Description |
---|---|
static Latency |
Latency.fromJson(String json) |
default <M extends Externalizable> |
LogManager.getLatency(String name,
String group,
Codec<M> codec,
Function<M,Long> timestampExtractor,
Function<M,String> keyExtractor)
Returns the latency between consumer
group and producers for a Log. |
default <M extends Externalizable> |
LogManager.getLatency(String name,
String group,
Function<M,Long> timestampExtractor,
Function<M,String> keyExtractor)
Deprecated.
10.2 use
LogManager.getLatency(String, String, Codec, Function, Function) instead. |
static Latency |
Latency.noLatency(long upper,
LogLag lag) |
static Latency |
Latency.of(List<Latency> latencies) |
Modifier and Type | Method and Description |
---|---|
<M extends Externalizable> |
LogManager.getLatencyPerPartition(String name,
String group,
Codec<M> codec,
Function<M,Long> timestampExtractor,
Function<M,String> keyExtractor)
Returns the lag with latency.
|
default <M extends Externalizable> |
LogManager.getLatencyPerPartition(String name,
String group,
Function<M,Long> timestampExtractor,
Function<M,String> keyExtractor)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Latency |
Latency.of(List<Latency> latencies) |
Modifier and Type | Method and Description |
---|---|
<M extends Externalizable> |
AbstractLogManager.getLatencyPerPartition(String name,
String group,
Codec<M> codec,
Function<M,Long> timestampExtractor,
Function<M,String> keyExtractor) |
Modifier and Type | Method and Description |
---|---|
protected Latency |
RestoreCommand.decodeLatency(byte[] data) |
Modifier and Type | Method and Description |
---|---|
protected List<Latency> |
LatencyTrackerComputation.getLatenciesForPartition(LogPartitionGroup logGroup,
Codec<Record> codec) |
protected Map<LogPartitionGroup,Latency> |
RestoreCommand.readLatencies(LogManager manager) |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
LatencyTrackerComputation.encodeLatency(Latency latency) |
protected LogOffset |
RestoreCommand.findOffset(LogManager manager,
LogPartitionGroup key,
Latency latency) |
Modifier and Type | Method and Description |
---|---|
protected void |
LatencyCommand.renderLatency(String group,
List<Latency> latencies) |
protected Map<LogPartitionGroup,LogOffset> |
RestoreCommand.searchOffsets(LogManager manager,
Map<LogPartitionGroup,Latency> latencies) |
Copyright © 2019 Nuxeo. All rights reserved.