Uses of Class
org.nuxeo.lib.stream.computation.Record

Packages that use Record

Package	Description
org.nuxeo.audit.directory.storage
org.nuxeo.audit.impl
org.nuxeo.audit.listener
org.nuxeo.audit.stream
org.nuxeo.ecm.automation.core.operations.services.workmanager
org.nuxeo.ecm.core.blob.stream
org.nuxeo.ecm.core.bulk.action.computation
org.nuxeo.ecm.core.bulk.computation
org.nuxeo.ecm.core.bulk.introspection
org.nuxeo.ecm.core.event.stream
org.nuxeo.ecm.core.model.stream
org.nuxeo.ecm.core.search.index
org.nuxeo.ecm.core.work
org.nuxeo.ecm.platform.video.computation
org.nuxeo.ecm.restapi.server.management
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.codec
org.nuxeo.runtime.pubsub
org.nuxeo.runtime.stream

Uses of Record in org.nuxeo.audit.directory.storage

Methods in org.nuxeo.audit.directory.storage with parameters of type Record

Modifier and Type	Method	Description
void	StreamAuditStorageWriter.AuditStorageLogWriterComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of Record in org.nuxeo.audit.impl

Method parameters in org.nuxeo.audit.impl with type arguments of type Record

Modifier and Type	Method	Description
void	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.audit.listener

Methods in org.nuxeo.audit.listener that return Record

Modifier and Type	Method	Description
protected Record	StreamAuditEventListener.recordOf(String partitionKey, LogEntry entry)
protected Record	StreamAuditEventListener.recordOf(LogEntry entry)

Uses of Record in org.nuxeo.audit.stream

Fields in org.nuxeo.audit.stream with type parameters of type Record

Modifier and Type	Field	Description
protected final List<Record>	AuditDomainEventProducer.records

Methods in org.nuxeo.audit.stream that return Record

Modifier and Type	Method	Description
protected Record	AuditDomainEventProducer.buildRecordFromEvent(LogEntry entry)

Methods in org.nuxeo.audit.stream that return types with arguments of type Record

Modifier and Type	Method	Description
List<Record>	AuditDomainEventProducer.getDomainEvents()

Uses of Record in org.nuxeo.ecm.automation.core.operations.services.workmanager

Methods in org.nuxeo.ecm.automation.core.operations.services.workmanager with parameters of type Record

Modifier and Type	Method	Description
void	WorkManagerRunWorkInFailure.WorkFailureComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of Record in org.nuxeo.ecm.core.blob.stream

Fields in org.nuxeo.ecm.core.blob.stream with type parameters of type Record

Modifier and Type	Field	Description
protected final List<Record>	BlobDomainEventProducer.records

Methods in org.nuxeo.ecm.core.blob.stream that return Record

Modifier and Type	Method	Description
protected Record	BlobDomainEventProducer.buildRecordFromEvent(String name, BlobEventContext ctx)

Methods in org.nuxeo.ecm.core.blob.stream that return types with arguments of type Record

Modifier and Type	Method	Description
List<Record>	BlobDomainEventProducer.getDomainEvents()

Methods in org.nuxeo.ecm.core.blob.stream with parameters of type Record

Modifier and Type	Method	Description
void	StreamOrphanBlobGC.BlobGCComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of Record in org.nuxeo.ecm.core.bulk.action.computation

Methods in org.nuxeo.ecm.core.bulk.action.computation with parameters of type Record

Modifier and Type	Method	Description
void	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

Methods in org.nuxeo.ecm.core.bulk.computation with parameters of type Record

Modifier and Type	Method	Description
void	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

Methods in org.nuxeo.ecm.core.bulk.introspection with parameters of type Record

Modifier and Type	Method	Description
protected com.fasterxml.jackson.databind.JsonNode	StreamIntrospectionComputation.getJson(Record record)
void	StreamIntrospectionComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of Record in org.nuxeo.ecm.core.event.stream

Methods in org.nuxeo.ecm.core.event.stream that return types with arguments of type Record

Modifier and Type	Method	Description
abstract List<Record>	DomainEventProducer.getDomainEvents()	Produces Domain Event Records from the accumulated Nuxeo Core events.

Uses of Record in org.nuxeo.ecm.core.model.stream

Fields in org.nuxeo.ecm.core.model.stream with type parameters of type Record

Modifier and Type	Field	Description
protected final List<Record>	DocumentDomainEventProducer.records

Methods in org.nuxeo.ecm.core.model.stream that return Record

Modifier and Type	Method	Description
protected Record	DocumentDomainEventProducer.buildRecordFromEvent(String eventName, DocumentDomainEventContext ctx)

Methods in org.nuxeo.ecm.core.model.stream that return types with arguments of type Record

Modifier and Type	Method	Description
List<Record>	DocumentDomainEventProducer.getDomainEvents()

Methods in org.nuxeo.ecm.core.model.stream with parameters of type Record

Modifier and Type	Method	Description
void	StreamDocumentGC.DocumentGCComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of Record in org.nuxeo.ecm.core.search.index

Methods in org.nuxeo.ecm.core.search.index that return types with arguments of type Record

Modifier and Type	Method	Description
List<Record>	IndexingDomainEventProducer.getDomainEvents()

Method parameters in org.nuxeo.ecm.core.search.index with type arguments of type Record

Modifier and Type	Method	Description
void	IndexingProcessor.AsynchronousIndexingComputation.batchFailure(ComputationContext context, String inputStreamName, List<Record> records)
void	IndexingProcessor.SynchronousIndexingComputation.batchFailure(ComputationContext context, String inputStreamName, List<Record> records)
protected void	IndexingProcessor.AsynchronousIndexingComputation.batchProcess(ComputationContext context, String inputStreamName, List<Record> records)
protected void	IndexingProcessor.SynchronousIndexingComputation.batchProcess(ComputationContext context, String inputStreamName, List<Record> records)
protected void	IndexingDomainEventProducer.markLastRecordAsEndOfBatch(List<Record> ret)

Uses of Record in org.nuxeo.ecm.core.work

Fields in org.nuxeo.ecm.core.work with type parameters of type Record

Modifier and Type	Field	Description
static final Codec<Record>	WorkManagerImpl.DEAD_LETTER_QUEUE_CODEC

Methods in org.nuxeo.ecm.core.work that return Record

Modifier and Type	Method	Description
Record	BaseOverflowRecordFilter.afterRead(Record record, LogOffset offset)
Record	BaseOverflowRecordFilter.beforeAppend(Record record)

Methods in org.nuxeo.ecm.core.work that return types with arguments of type Record

Modifier and Type	Method	Description
protected Codec<Record>	StreamWorkManager.getCodec()

Methods in org.nuxeo.ecm.core.work with parameters of type Record

Modifier and Type	Method	Description
Record	BaseOverflowRecordFilter.afterRead(Record record, LogOffset offset)
Record	BaseOverflowRecordFilter.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.video.computation

Fields in org.nuxeo.ecm.platform.video.computation declared as Record

Modifier and Type	Field	Description
protected Record	RecomputeVideoInfoComputation.record

Methods in org.nuxeo.ecm.platform.video.computation with parameters of type Record

Modifier and Type	Method	Description
void	RecomputeVideoInfoComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of Record in org.nuxeo.ecm.restapi.server.management

Methods in org.nuxeo.ecm.restapi.server.management that return types with arguments of type Record

Modifier and Type	Method	Description
protected LogTailer<Record>	StreamServlet.createTailer(LogManager manager, StreamServlet.CatParams params)

Method parameters in org.nuxeo.ecm.restapi.server.management with type arguments of type Record

Modifier and Type	Method	Description
void	SseRenderer.accept(LogRecord<Record> record)

Uses of Record in org.nuxeo.lib.stream.computation

Fields in org.nuxeo.lib.stream.computation with type parameters of type Record

Modifier and Type	Field	Description
protected List<Record>	AbstractBatchComputation.batchRecords
protected final Map<Name,Codec<Record>>	Settings.codecs
protected final Codec<Record>	Settings.defaultCodec

Methods in org.nuxeo.lib.stream.computation that return Record

Modifier and Type	Method	Description
default Record	RecordFilter.afterRead(Record record, LogOffset offset)	Called after reading a record.
default Record	RecordFilter.beforeAppend(Record record)	Called before appending a record to a stream.
static Record	Record.of(String key, byte[] data)	Creates a record using current timestamp and default flag

Methods in org.nuxeo.lib.stream.computation that return types with arguments of type Record

Modifier and Type	Method	Description
Codec<Record>	Settings.getCodec(String streamName)	Gets the codec for a stream.
Codec<Record>	Settings.getCodec(Name streamName)	Gets the codec for a stream.

Methods in org.nuxeo.lib.stream.computation with parameters of type Record

Modifier and Type	Method	Description
default void	RecordFilter.afterAppend(Record record, LogOffset offset)	Called after a record is appended to a stream.
default Record	RecordFilter.afterRead(Record record, LogOffset offset)	Called after reading a record.
LogOffset	StreamManager.append(String stream, Record 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)

Method parameters in org.nuxeo.lib.stream.computation with type arguments of type Record

Modifier and Type	Method	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.
Settings	Settings.setCodec(Name streamName, Codec<Record> codec)	Sets the codec for a stream.

Constructor parameters in org.nuxeo.lib.stream.computation with type arguments of type Record

Modifier	Constructor	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)
	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

Fields in org.nuxeo.lib.stream.computation.internals with type parameters of type Record

Modifier and Type	Field	Description
protected final Map<String,List<Record>>	ComputationContextImpl.streamRecords

Methods in org.nuxeo.lib.stream.computation.internals that return Record

Modifier and Type	Method	Description
Record	RecordFilterChainImpl.afterRead(Record record, LogOffset offset)
Record	RecordFilterChainImpl.beforeAppend(Record record)

Methods in org.nuxeo.lib.stream.computation.internals that return types with arguments of type Record

Modifier and Type	Method	Description
List<Record>	ComputationContextImpl.getRecords(String streamName)

Methods in org.nuxeo.lib.stream.computation.internals with parameters of type Record

Modifier and Type	Method	Description
void	RecordFilterChainImpl.afterAppend(Record record, LogOffset offset)
Record	RecordFilterChainImpl.afterRead(Record record, LogOffset offset)
Record	RecordFilterChainImpl.beforeAppend(Record record)
void	ComputationContextImpl.produceRecord(String streamName, Record record)
LogOffset	ComputationContextImpl.produceRecordImmediate(String streamName, Record record)	Writes to an output stream immediately.

Uses of Record in org.nuxeo.lib.stream.computation.log

Fields in org.nuxeo.lib.stream.computation.log with type parameters of type Record

Modifier and Type	Field	Description
static final Codec<Record>	LogStreamManager.INTERNAL_CODEC
protected final LogTailer<Record>	ComputationRunner.tailer

Methods in org.nuxeo.lib.stream.computation.log that return types with arguments of type Record

Modifier and Type	Method	Description
LogTailer<Record>	LogStreamManager.createTailer(Name computationName, Collection<LogPartition> streamPartitions)
protected Codec<Record>	LogStreamManager.getCodec(Collection<Name> streams)
protected Codec<Record>	LogStreamProcessor.getCodecForStreams(String name, Set<String> streams)
LogTailer<Record>	LogStreamManager.subscribe(Name computationName, Collection<Name> streams, RebalanceListener listener)

Methods in org.nuxeo.lib.stream.computation.log with parameters of type Record

Modifier and Type	Method	Description
LogOffset	LogStreamManager.append(String streamUrn, Record record)
protected 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

Fields in org.nuxeo.lib.stream.tools.command with type parameters of type Record

Modifier and Type	Field	Description
protected final Codec<Record>	LatencyTrackerComputation.codec

Methods in org.nuxeo.lib.stream.tools.command that return types with arguments of type Record

Modifier and Type	Method	Description
protected Codec<Record>	Command.getRecordCodec(String codec)
protected LogTailer<Record>	DumpCommand.getTailer(LogManager manager, Name name, int partition, Name group, String codec)

Methods in org.nuxeo.lib.stream.tools.command with parameters of type Record

Modifier and Type	Method	Description
void	LatencyTrackerComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Method parameters in org.nuxeo.lib.stream.tools.command with type arguments of type Record

Modifier and Type	Method	Description
protected 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)

Constructor parameters in org.nuxeo.lib.stream.tools.command with type arguments of type Record

Modifier	Constructor	Description
	LatencyDatadogComputation(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

Methods in org.nuxeo.lib.stream.tools.renderer with parameters of type Record

Modifier and Type	Method	Description
protected String	Renderer.renderAvroMessage(AvroSchemaStore store, Record record)
protected String	Renderer.tryToRenderAvroData(AvroSchemaStore store, Record record)

Method parameters in org.nuxeo.lib.stream.tools.renderer with type arguments of type Record

Modifier and Type	Method	Description
void	MarkdownRenderer.accept(LogRecord<Record> record)
void	TextRenderer.accept(LogRecord<Record> record)

Uses of Record in org.nuxeo.runtime.codec

Classes in org.nuxeo.runtime.codec with type parameters of type Record

Modifier and Type	Class	Description
class	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

Fields in org.nuxeo.runtime.pubsub with type parameters of type Record

Modifier and Type	Field	Description
protected LogAppender<Record>	StreamPubSubProvider.appender
protected Codec<Record>	StreamPubSubProvider.codec

Uses of Record in org.nuxeo.runtime.stream

Fields in org.nuxeo.runtime.stream with type parameters of type Record

Modifier and Type	Field	Description
protected final Codec<Record>	StreamMetricsComputation.codec

Methods in org.nuxeo.runtime.stream with parameters of type Record

Modifier and Type	Method	Description
void	StreamMetricsComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Method parameters in org.nuxeo.runtime.stream with type arguments of type Record

Modifier and Type	Method	Description
boolean	StreamMetricsComputation.LatencyMetric.update(LogManager manager, Codec<Record> codec)