Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.core.bulk | |
org.nuxeo.ecm.core.bulk.actions | |
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.ecm.platform.audit.listener | |
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 | |
org.nuxeo.runtime.stream |
Modifier and Type | Method and Description |
---|---|
void |
StreamAuditStorageWriter.AuditStorageLogWriterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
static Record |
BulkRecords.of(String commandId,
long currentCount,
List<String> documentIds) |
Modifier and Type | Method and Description |
---|---|
static String |
BulkRecords.commandIdFrom(Record record) |
static List<String> |
BulkRecords.docIdsFrom(Record record) |
protected void |
StreamBulkProcessor.BulkDocumentScrollerComputation.processRecord(ComputationContext context,
Record record) |
void |
StreamBulkProcessor.BulkDocumentScrollerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamBulkProcessor.CounterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamBulkProcessor.KeyValueWriterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
void |
SetPropertiesAction.SetPropertyComputation.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.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
protected void |
StreamAuditEventListener.writeEntry(LogAppender<Record> appender,
LogEntry entry) |
Modifier and Type | Field and Description |
---|---|
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)
Get a 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 |
ComputationContext.produceRecord(String streamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
Settings |
Settings.setCodec(String streamName,
Codec<Record> codec)
Set 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
|
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) |
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) |
Constructor and Description |
---|
ComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<LogPartition>> defaultAssignments,
LogManager manager,
Codec<Record> inputCodec,
Codec<Record> outputCodec) |
ComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<LogPartition>> defaultAssignments,
LogManager manager,
Codec<Record> inputCodec,
Codec<Record> outputCodec) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager,
Codec<Record> inputCodec,
Codec<Record> outputCodec) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager,
Codec<Record> inputCodec,
Codec<Record> outputCodec) |
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 |
---|
LatencyTrackerComputation(LogManager manager,
List<String> logNames,
String computationName,
int intervalSecond,
int count,
boolean verbose,
Codec<Record> codec) |
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 |
Modifier and Type | Method and Description |
---|---|
Codec<Record> |
StreamProcessorDescriptor.getDefaultCodec(CodecService codecService) |
Copyright © 2018 Nuxeo. All rights reserved.