Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.core.bulk.action.computation | |
org.nuxeo.ecm.core.bulk.computation | |
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.ecm.platform.audit.listener | |
org.nuxeo.elasticsearch.bulk | |
org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
org.nuxeo.lib.stream.computation.internals | |
org.nuxeo.lib.stream.computation.log |
Computation pattern implemented with Log
|
org.nuxeo.lib.stream.tools.command | |
org.nuxeo.lib.stream.tools.renderer | |
org.nuxeo.runtime.pubsub |
Modifier and Type | Method and Description |
---|---|
void |
StreamAuditStorageWriter.AuditStorageLogWriterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
void |
ZipBlob.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
SortBlob.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
MakeBlob.processRecord(ComputationContext context,
String documentIdsStreamName,
Record record) |
void |
ExposeBlob.processRecord(ComputationContext context,
String documentIdsStreamName,
Record record) |
void |
AbstractBulkComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
protected void |
BulkScrollerComputation.processRecord(ComputationContext context,
Record record) |
void |
BulkStatusComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
BulkScrollerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
protected Codec<Record> |
StreamWorkManager.getCodec() |
Modifier and Type | Method and Description |
---|---|
void |
WorkComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
void |
StreamAuditWriter.AuditLogWriterComputation.batchFailure(ComputationContext context,
String inputStreamName,
List<Record> records) |
void |
StreamAuditWriter.AuditLogWriterComputation.batchProcess(ComputationContext context,
String inputStreamName,
List<Record> records) |
Modifier and Type | Method and Description |
---|---|
protected void |
StreamAuditEventListener.writeEntry(LogAppender<Record> appender,
LogEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
IndexCompletionComputation.processRecord(ComputationContext context,
String inputStream,
Record record) |
void |
BulkIndexComputation.processRecord(ComputationContext context,
String inputStream,
Record record) |
Modifier and Type | Field and Description |
---|---|
protected List<Record> |
AbstractBatchComputation.batchRecords |
protected Map<String,Codec<Record>> |
Settings.codecs |
protected Codec<Record> |
Settings.defaultCodec |
Modifier and Type | Method and Description |
---|---|
static Record |
Record.of(String key,
byte[] data)
Creates a record using current timestamp and default flag
|
Modifier and Type | Method and Description |
---|---|
Codec<Record> |
Settings.getCodec(String streamName)
Gets the codec for a stream.
|
Modifier and Type | Method and Description |
---|---|
void |
Computation.processRecord(ComputationContext context,
String inputStreamName,
Record record)
Process an incoming record on one of the computation's input streams.
|
void |
AbstractBatchComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
ComputationContext.produceRecord(String streamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractBatchComputation.batchFailure(ComputationContext context,
String inputStreamName,
List<Record> records)
Called when the retry policy has failed.
|
protected abstract void |
AbstractBatchComputation.batchProcess(ComputationContext context,
String inputStreamName,
List<Record> records)
Called when:
- the batch capacity is reached - the time threshold is reached - the inputStreamName has changed If this method raises an exception the retry policy is applied. |
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 Map<String,List<Record>> |
ComputationContextImpl.streamRecords |
Modifier and Type | Method and Description |
---|---|
List<Record> |
ComputationContextImpl.getRecords(String streamName) |
Modifier and Type | Method and Description |
---|---|
void |
ComputationContextImpl.produceRecord(String streamName,
Record record) |
LogOffset |
ComputationContextImpl.produceRecordImmediate(String streamName,
Record record)
Writes to an output stream immediately.
|
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 |
protected LogTailer<Record> |
ComputationRunner.tailer |
Modifier and Type | Method and Description |
---|---|
protected Codec<Record> |
LogStreamProcessor.getCodecForStreams(String name,
Set<String> streams) |
Modifier and Type | Method and Description |
---|---|
protected void |
ComputationRunner.checkRecordFlags(Record record) |
protected void |
ComputationRunner.processRecordWithRetry(String from,
Record record) |
Modifier and Type | Field and Description |
---|---|
protected Codec<Record> |
LatencyTrackerComputation.codec |
Modifier and Type | Method and Description |
---|---|
protected Codec<Record> |
Command.getRecordCodec(String codec) |
protected LogTailer<Record> |
DumpCommand.getTailer(LogManager manager,
String name,
int partition,
String group,
String codec) |
Modifier and Type | Method and Description |
---|---|
void |
LatencyTrackerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
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) |
protected LogOffset |
PositionCommand.searchWatermarkOffset(LogTailer<Record> tailer,
long timestamp) |
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 |
---|---|
protected String |
Renderer.renderAvroMessage(AvroSchemaStore store,
Record record) |
protected String |
Renderer.tryToRenderAvroData(AvroSchemaStore store,
Record record) |
Modifier and Type | Method and Description |
---|---|
void |
TextRenderer.accept(LogRecord<Record> record) |
void |
MarkdownRenderer.accept(LogRecord<Record> record) |
Modifier and Type | Field and Description |
---|---|
protected LogAppender<Record> |
StreamPubSubProvider.appender |
protected Codec<Record> |
StreamPubSubProvider.codec |
Copyright © 2019 Nuxeo. All rights reserved.