Package | Description |
---|---|
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.renderer |
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 | Method and Description |
---|---|
static Record |
Record.of(String key,
byte[] data) |
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 | 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 LogTailer<Record> |
ComputationRunner.tailer |
Modifier and Type | Method and Description |
---|---|
protected void |
ComputationRunner.checkRecordFlags(Record record) |
Modifier and Type | Method and Description |
---|---|
void |
TextRenderer.accept(LogRecord<Record> record) |
void |
MarkdownRenderer.accept(LogRecord<Record> record) |
Copyright © 2018 Nuxeo. All rights reserved.