Package | Description |
---|---|
org.nuxeo.ecm.core.bulk | |
org.nuxeo.ecm.core.work | |
org.nuxeo.elasticsearch.bulk | |
org.nuxeo.lib.stream.codec | |
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.chronicle | |
org.nuxeo.lib.stream.log.internals | |
org.nuxeo.lib.stream.log.kafka | |
org.nuxeo.lib.stream.tools.command | |
org.nuxeo.runtime.codec | |
org.nuxeo.runtime.pubsub |
Modifier and Type | Method and Description |
---|---|
static Codec<BulkBucket> |
BulkCodecs.getBucketCodec() |
static Codec<BulkCommand> |
BulkCodecs.getCommandCodec() |
static Codec<DataBucket> |
BulkCodecs.getDataBucketCodec() |
static Codec<BulkStatus> |
BulkCodecs.getStatusCodec() |
Modifier and Type | Method and Description |
---|---|
protected Codec<Record> |
StreamWorkManager.getCodec() |
Modifier and Type | Field and Description |
---|---|
protected Codec<BulkStatus> |
IndexCompletionComputation.codec |
protected Codec<DataBucket> |
BulkIndexComputation.codec |
Modifier and Type | Class and Description |
---|---|
class |
AvroBinaryCodec<T>
Avro Binary format, there is no header, the schema must be the same for encoder and decoder.
|
class |
AvroConfluentCodec<T>
Use the Confluent Avro encoding which differs from Avro message, the schema store is a REST Confluent Schema
Registry.
|
class |
AvroJsonCodec<T>
JSON Avro format for debugging purpose.
|
class |
AvroMessageCodec<T>
Avro Single object encoding: magic 2 bytes + schema fingerprint 8 bytes + avro binary.
|
class |
NoCodec
Special no operation codec, can be used as marker.
|
class |
SerializableCodec<T extends Serializable>
Java
Serializable encoding. |
Modifier and Type | Field and Description |
---|---|
protected Codec<Record> |
Settings.defaultCodec |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Codec<Record>> |
Settings.codecs |
Modifier and Type | Method and Description |
---|---|
Codec<Record> |
Settings.getCodec(String streamName)
Gets the codec for a stream.
|
Modifier and Type | Method and Description |
---|---|
Settings |
Settings.setCodec(String streamName,
Codec<Record> codec)
Sets the codec for a stream.
|
Constructor and Description |
---|
Settings(int defaultConcurrency,
int defaultPartitions,
Codec<Record> defaultCodec)
Default concurrency and partition to use if not specified explicitly.
|
Settings(int defaultConcurrency,
int defaultPartitions,
Codec<Record> defaultCodec,
ComputationPolicy defaultPolicy) |
Modifier and Type | Field and Description |
---|---|
protected Codec<Record> |
ComputationRunner.inputCodec |
protected Codec<Record> |
ComputationPool.inputCodec |
protected Codec<Record> |
ComputationRunner.outputCodec |
protected Codec<Record> |
ComputationPool.outputCodec |
Modifier and Type | Method and Description |
---|---|
protected Codec<Record> |
LogStreamProcessor.getCodecForStreams(String name,
Set<String> streams) |
Modifier and Type | Method and Description |
---|---|
Codec<M> |
LogTailer.getCodec()
Returns the codec used to read the records.
|
Codec<M> |
LogAppender.getCodec()
Returns the codec used to write record.
|
Modifier and Type | Method and Description |
---|---|
<M extends Externalizable> |
LogManager.createTailer(String group,
Collection<LogPartition> partitions,
Codec<M> codec)
Creates a tailer for a consumer
group and assign multiple partitions . |
default <M extends Externalizable> |
LogManager.createTailer(String group,
LogPartition partition,
Codec<M> codec)
Creates a tailer for a consumer
group and assign a single partition . |
default <M extends Externalizable> |
LogManager.createTailer(String group,
String name,
Codec<M> codec)
Creates a tailer for a consumer
group and assigns all partitions of the Log. |
<M extends Externalizable> |
LogManager.getAppender(String name,
Codec<M> codec)
Gets an appender for the Log named
name , uses codec to encode records. |
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. |
<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.
|
<M extends Externalizable> |
LogManager.subscribe(String group,
Collection<String> names,
RebalanceListener listener,
Codec<M> codec)
Creates a tailer for a consumer
group and subscribe to multiple Logs. |
Modifier and Type | Field and Description |
---|---|
protected Codec<M> |
ChronicleLogTailer.codec |
protected Codec<M> |
ChronicleLogAppender.codec |
protected Codec<M> |
ChronicleCompoundLogTailer.codec |
Modifier and Type | Method and Description |
---|---|
Codec<M> |
ChronicleLogTailer.getCodec() |
Codec<M> |
ChronicleLogAppender.getCodec() |
Codec<M> |
ChronicleCompoundLogTailer.getCodec() |
Modifier and Type | Method and Description |
---|---|
static <M extends Externalizable> |
ChronicleLogAppender.create(Codec<M> codec,
File basePath,
int size)
Create a new log.
|
static <M extends Externalizable> |
ChronicleLogAppender.create(Codec<M> codec,
File basePath,
int size,
ChronicleRetentionDuration retention)
Create a new log
|
<M extends Externalizable> |
ChronicleLogManager.createAppender(String name,
Codec<M> codec) |
LogTailer<M> |
ChronicleLogAppender.createTailer(LogPartition partition,
String group,
Codec<M> codec) |
protected <M extends Externalizable> |
ChronicleLogManager.doCreateTailer(Collection<LogPartition> partitions,
String group,
Codec<M> codec) |
protected <M extends Externalizable> |
ChronicleLogManager.doSubscribe(String group,
Collection<String> names,
RebalanceListener listener,
Codec<M> codec) |
static <M extends Externalizable> |
ChronicleLogAppender.open(Codec<M> codec,
File basePath)
Open an existing log.
|
static <M extends Externalizable> |
ChronicleLogAppender.open(Codec<M> codec,
File basePath,
ChronicleRetentionDuration retention)
Open an existing log.
|
Constructor and Description |
---|
ChronicleLogAppender(Codec<M> codec,
File basePath,
ChronicleRetentionDuration retention)
Open an existing Log
|
ChronicleLogAppender(Codec<M> codec,
File basePath,
int size,
ChronicleRetentionDuration retention)
Create a new Log
|
ChronicleLogTailer(Codec<M> codec,
String basePath,
net.openhft.chronicle.queue.ExcerptTailer cqTailer,
LogPartition partition,
String group,
ChronicleRetentionDuration retention) |
Modifier and Type | Method and Description |
---|---|
protected <M extends Externalizable> |
AbstractLogManager.guessCodec(Collection<LogPartition> partitions) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractLogManager.checkInvalidCodec(LogPartition partition,
Codec codec) |
protected abstract <M extends Externalizable> |
AbstractLogManager.createAppender(String name,
Codec<M> codec) |
<M extends Externalizable> |
AbstractLogManager.createTailer(String group,
Collection<LogPartition> partitions,
Codec<M> codec) |
protected abstract <M extends Externalizable> |
AbstractLogManager.doCreateTailer(Collection<LogPartition> partitions,
String group,
Codec<M> codec) |
protected abstract <M extends Externalizable> |
AbstractLogManager.doSubscribe(String group,
Collection<String> names,
RebalanceListener listener,
Codec<M> codec) |
<M extends Externalizable> |
AbstractLogManager.getAppender(String name,
Codec<M> codec) |
<M extends Externalizable> |
AbstractLogManager.getLatencyPerPartition(String name,
String group,
Codec<M> codec,
Function<M,Long> timestampExtractor,
Function<M,String> keyExtractor) |
protected boolean |
AbstractLogManager.sameCodec(Codec codec1,
Codec codec2) |
protected boolean |
AbstractLogManager.sameCodec(Codec codec1,
Codec codec2) |
<M extends Externalizable> |
AbstractLogManager.subscribe(String group,
Collection<String> names,
RebalanceListener listener,
Codec<M> codec) |
Modifier and Type | Field and Description |
---|---|
protected Codec<M> |
KafkaLogTailer.codec |
protected Codec<M> |
KafkaLogAppender.codec |
protected Codec<M> |
KafkaLogTailer.decodeCodec |
protected Codec<M> |
KafkaLogAppender.encodingCodec |
Modifier and Type | Method and Description |
---|---|
Codec<M> |
KafkaLogTailer.getCodec() |
Codec<M> |
KafkaLogAppender.getCodec() |
Modifier and Type | Method and Description |
---|---|
static <M extends Externalizable> |
KafkaLogTailer.createAndAssign(Codec<M> codec,
KafkaNamespace ns,
Collection<LogPartition> partitions,
String group,
Properties consumerProps) |
static <M extends Externalizable> |
KafkaLogTailer.createAndSubscribe(Codec<M> codec,
KafkaNamespace ns,
Collection<String> names,
String group,
Properties consumerProps,
RebalanceListener listener) |
<M extends Externalizable> |
KafkaLogManager.createAppender(String name,
Codec<M> codec) |
protected <M extends Externalizable> |
KafkaLogManager.doCreateTailer(Collection<LogPartition> partitions,
String group,
Codec<M> codec) |
protected <M extends Externalizable> |
KafkaLogManager.doSubscribe(String group,
Collection<String> names,
RebalanceListener listener,
Codec<M> codec) |
static <M extends Externalizable> |
KafkaLogAppender.open(Codec<M> codec,
KafkaNamespace ns,
String name,
Properties producerProperties,
Properties consumerProperties) |
Constructor and Description |
---|
KafkaLogTailer(Codec<M> codec,
KafkaNamespace ns,
String group,
Properties consumerProps) |
Modifier and Type | Field and Description |
---|---|
protected Codec<Record> |
LatencyTrackerComputation.codec |
Modifier and Type | Method and Description |
---|---|
protected Codec<Record> |
Command.getRecordCodec(String codec) |
Modifier and Type | Method and Description |
---|---|
protected List<Latency> |
LatencyTrackerComputation.getLatenciesForPartition(LogPartitionGroup logGroup,
Codec<Record> codec) |
protected void |
LatencyCommand.latency(LogManager manager,
Codec<Record> codec) |
protected void |
LatencyCommand.latency(LogManager manager,
String name,
Codec<Record> codec) |
Constructor and Description |
---|
LatencyMonitorComputation(LogManager manager,
List<String> logNames,
String host,
int port,
boolean udp,
String basePrefix,
String computationName,
int intervalSecond,
int count,
boolean verbose,
Codec<Record> codec) |
LatencyTrackerComputation(LogManager manager,
List<String> logNames,
String computationName,
int intervalSecond,
int count,
boolean verbose,
Codec<Record> codec) |
Modifier and Type | Method and Description |
---|---|
<T> Codec<T> |
CodecServiceImpl.getCodec(String codecName,
Class<T> objectClass) |
<T> Codec<T> |
CodecService.getCodec(String codecName,
Class<T> objectClass)
Returns a codec able to code and decode object of type T
|
<T> Codec<T> |
SerializableCodecFactory.newCodec(Class<T> objectClass) |
<T> Codec<T> |
NoCodecFactory.newCodec(Class<T> objectClass) |
<T> Codec<T> |
CodecFactory.newCodec(Class<T> objectClass)
Returns a codec object enables to encode/decode object ot class T.
|
<T> Codec<T> |
AvroCodecFactory.newCodec(Class<T> objectClass) |
Modifier and Type | Field and Description |
---|---|
protected Codec<Record> |
StreamPubSubProvider.codec |
Copyright © 2019 Nuxeo. All rights reserved.