Uses of Class
org.nuxeo.lib.stream.computation.Record
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
-
Uses of Record in org.nuxeo.audit.storage.stream
Modifier and TypeMethodDescriptionvoid
StreamAuditStorageWriter.AuditStorageLogWriterComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.automation.core.operations.services.workmanager
Modifier and TypeMethodDescriptionvoid
WorkManagerRunWorkInFailure.WorkFailureComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.core.blob.stream
Modifier and TypeMethodDescriptionprotected Record
BlobDomainEventProducer.buildRecordFromEvent
(String name, BlobEventContext ctx) Modifier and TypeMethodDescriptionvoid
StreamOrphanBlobGC.BlobGCComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.core.bulk.action.computation
Modifier and TypeMethodDescriptionvoid
AbstractBulkComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) void
ExposeBlob.processRecord
(ComputationContext context, String documentIdsStreamName, Record record) void
MakeBlob.processRecord
(ComputationContext context, String documentIdsStreamName, Record record) void
SortBlob.processRecord
(ComputationContext context, String inputStreamName, Record record) void
ZipBlob.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.core.bulk.computation
Modifier and TypeMethodDescriptionvoid
BulkScrollerComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) protected void
BulkScrollerComputation.processRecord
(ComputationContext context, Record record) void
BulkStatusComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.core.bulk.introspection
Modifier and TypeMethodDescriptionprotected com.fasterxml.jackson.databind.JsonNode
void
StreamIntrospectionComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.core.event.stream
Modifier and TypeMethodDescriptionDomainEventProducer.getDomainEvents()
Produces Domain Event Records from the accumulated Nuxeo Core events. -
Uses of Record in org.nuxeo.ecm.core.model.stream
Modifier and TypeMethodDescriptionprotected Record
DocumentDomainEventProducer.buildRecordFromEvent
(String eventName, DocumentDomainEventContext ctx) Modifier and TypeMethodDescriptionvoid
StreamDocumentGC.DocumentGCComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.core.work
Modifier and TypeMethodDescriptionBaseOverflowRecordFilter.beforeAppend
(Record record) protected String
BaseOverflowRecordFilter.getUniqRecordKey
(Record record) void
WorkComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.platform.audit.impl
Modifier and TypeMethodDescriptionvoid
StreamAuditWriter.AuditLogWriterComputation.batchFailure
(ComputationContext context, String inputStreamName, List<Record> records) void
StreamAuditWriter.AuditLogWriterComputation.batchProcess
(ComputationContext context, String inputStreamName, List<Record> records) -
Uses of Record in org.nuxeo.ecm.platform.audit.listener
-
Uses of Record in org.nuxeo.ecm.platform.audit.stream
Modifier and TypeMethodDescriptionprotected Record
AuditDomainEventProducer.buildRecordFromEvent
(LogEntry entry) -
Uses of Record in org.nuxeo.ecm.platform.video.computation
Modifier and TypeMethodDescriptionvoid
RecomputeVideoInfoComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) -
Uses of Record in org.nuxeo.ecm.restapi.server.jaxrs.management
Modifier and TypeMethodDescriptionStreamServlet.createTailer
(LogManager manager, StreamServlet.CatParams params) -
Uses of Record in org.nuxeo.elasticsearch.bulk
Modifier and TypeMethodDescriptionvoid
BulkIndexComputation.processRecord
(ComputationContext context, String inputStream, Record record) void
IndexCompletionComputation.processRecord
(ComputationContext context, String inputStream, Record record) -
Uses of Record in org.nuxeo.lib.stream.computation
Modifier and TypeFieldDescriptionAbstractBatchComputation.batchRecords
Settings.codecs
Settings.defaultCodec
Modifier and TypeMethodDescriptiondefault Record
Called after reading a record.default Record
RecordFilter.beforeAppend
(Record record) Called before appending a record to a stream.static Record
Creates a record using current timestamp and default flagModifier and TypeMethodDescriptionGets the codec for a stream.Gets the codec for a stream.Modifier and TypeMethodDescriptiondefault void
RecordFilter.afterAppend
(Record record, LogOffset offset) Called after a record is appended to a stream.default Record
Called after reading a record.Appends a record to a processor's source stream.default Record
RecordFilter.beforeAppend
(Record record) Called before appending a record to a stream.void
AbstractBatchComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) 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 TypeMethodDescriptionabstract 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.Sets the codec for a stream.Sets the codec for a stream.ModifierConstructorDescriptionDefault concurrency and partition to use if not specified explicitly.Settings
(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy) Settings
(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy, RecordFilterChain defaultFilter) Settings
(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy, RecordFilterChain defaultFilter, boolean defaultExternal) -
Uses of Record in org.nuxeo.lib.stream.computation.internals
Modifier and TypeMethodDescriptionvoid
RecordFilterChainImpl.afterAppend
(Record record, LogOffset offset) RecordFilterChainImpl.beforeAppend
(Record record) void
ComputationContextImpl.produceRecord
(String streamName, Record record) ComputationContextImpl.produceRecordImmediate
(String streamName, Record record) Writes to an output stream immediately. -
Uses of Record in org.nuxeo.lib.stream.computation.log
Modifier and TypeMethodDescriptionLogStreamManager.createTailer
(Name computationName, Collection<LogPartition> streamPartitions) LogStreamManager.getCodec
(Collection<Name> streams) LogStreamProcessor.getCodecForStreams
(String name, Set<String> streams) LogStreamManager.subscribe
(Name computationName, Collection<Name> streams, RebalanceListener listener) Modifier and TypeMethodDescriptionprotected void
ComputationRunner.checkRecordFlags
(Record record) protected io.opencensus.trace.Span
ComputationRunner.getSpanFromRecord
(Record record) protected void
ComputationRunner.processRecordWithRetry
(String from, Record record) protected void
ComputationRunner.processRecordWithTracing
(String from, Record record) -
Uses of Record in org.nuxeo.lib.stream.tools.command
Modifier and TypeMethodDescriptionCommand.getRecordCodec
(String codec) DumpCommand.getTailer
(LogManager manager, Name name, int partition, Name group, String codec) Modifier and TypeMethodDescriptionvoid
LatencyTrackerComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) Modifier and TypeMethodDescriptionprotected void
LatencyCommand.latency
(LogManager manager, Codec<Record> codec) protected void
LatencyCommand.latency
(LogManager manager, Name name, Codec<Record> codec) protected LogOffset
PositionCommand.searchWatermarkOffset
(LogTailer<Record> tailer, long timestamp) ModifierConstructorDescriptionLatencyDatadogComputation
(LogManager manager, List<Name> logNames, String apiKey, List<String> tags, String basePrefix, String computationName, int intervalSecond, int count, boolean partition, boolean verbose, Codec<Record> codec) LatencyMonitorComputation
(LogManager manager, List<Name> logNames, String host, int port, boolean udp, String basePrefix, String computationName, int intervalSecond, int count, boolean partition, boolean verbose, Codec<Record> codec) LatencyMonitorComputation
(LogManager manager, List<Name> logNames, String host, int port, boolean udp, String basePrefix, String computationName, int intervalSecond, int count, boolean verbose, Codec<Record> codec) Deprecated.LatencyTrackerComputation
(LogManager manager, List<Name> logNames, String computationName, int intervalSecond, int count, boolean verbose, Codec<Record> codec, int outputStream) -
Uses of Record in org.nuxeo.lib.stream.tools.renderer
Modifier and TypeMethodDescriptionprotected String
Renderer.renderAvroMessage
(AvroSchemaStore store, Record record) protected String
Renderer.tryToRenderAvroData
(AvroSchemaStore store, Record record) -
Uses of Record in org.nuxeo.runtime.codec
Modifier and TypeClassDescriptionclass
AvroRecordCodec<T extends Record>
Instead of having an Avro Record envelop that contains a data encoded in Avro, this structure is a flat Avro message joining schemas of the Record and data. -
Uses of Record in org.nuxeo.runtime.pubsub
-
Uses of Record in org.nuxeo.runtime.stream
Modifier and TypeMethodDescriptionvoid
StreamMetricsComputation.processRecord
(ComputationContext context, String inputStreamName, Record record) Modifier and TypeMethodDescriptionboolean
StreamMetricsComputation.LatencyMetric.update
(LogManager manager, Codec<Record> codec)