Uses of Interface
org.nuxeo.lib.stream.log.LogOffset
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
The Log interface with In-Memory and Kafka implementation.
-
Uses of LogOffset in org.nuxeo.ecm.core.work
-
Uses of LogOffset in org.nuxeo.lib.stream.computation
Modifier and TypeMethodDescriptionAppends a record to a processor's source stream.ComputationContext.getLastOffset()
-
Uses of LogOffset in org.nuxeo.lib.stream.computation.internals
Modifier and TypeMethodDescriptionComputationContextImpl.getLastOffset()
ComputationContextImpl.produceRecordImmediate
(String streamName, Record record) Writes to an output stream immediately.Modifier and TypeMethodDescriptionvoid
RecordFilterChainImpl.afterAppend
(Record record, LogOffset offset) void
ComputationContextImpl.setLastOffset
(LogOffset lastOffset) -
Uses of LogOffset in org.nuxeo.lib.stream.computation.log
-
Uses of LogOffset in org.nuxeo.lib.stream.log
Modifier and TypeMethodDescriptionAppend a message into a partition, returnsLogOffset
position of the message.default LogOffset
Same asLogAppender.append(int, Externalizable)
, the queue is chosen using a hash of parameters "key".LogTailer.commit
(LogPartition partition) Commit current position for the partition.LogOffset.nextOffset()
Returns the next offset corresponding to the next position in the same partition.LogRecord.offset()
LogTailer.offsetForTimestamp
(LogPartition partition, long timestamp) Look up the offset for the given partition by timestamp.Modifier and TypeMethodDescriptionvoid
Set the current position for a single partition.boolean
Wait for consumer to process a message up to the offset. -
Uses of LogOffset in org.nuxeo.lib.stream.log.internals
-
Uses of LogOffset in org.nuxeo.lib.stream.log.kafka
Modifier and TypeMethodDescriptionKafkaLogTailer.commit
(LogPartition partition) KafkaLogTailer.offsetForTimestamp
(LogPartition partition, long timestamp) -
Uses of LogOffset in org.nuxeo.lib.stream.log.mem
Modifier and TypeMethodDescriptionMemCompoundLogTailer.commit
(LogPartition partition) MemLogTailer.commit
(LogPartition partition) MemCompoundLogTailer.offsetForTimestamp
(LogPartition partition, long timestamp) MemLogTailer.offsetForTimestamp
(LogPartition partition, long timestamp) -
Uses of LogOffset in org.nuxeo.lib.stream.tools.command
Modifier and TypeMethodDescriptionprotected LogOffset
RestoreCommand.findOffset
(LogManager manager, LogPartitionGroup key, Latency latency) protected LogOffset
PositionCommand.searchWatermarkOffset
(LogTailer<Record> tailer, long timestamp) Modifier and TypeMethodDescriptionprotected Map<LogPartitionGroup,
LogOffset> RestoreCommand.searchOffsets
(LogManager manager, Map<LogPartitionGroup, Latency> latencies) Modifier and TypeMethodDescriptionprotected void
RestoreCommand.updatePosition
(LogManager manager, LogPartitionGroup key, LogOffset offset) Modifier and TypeMethodDescriptionprotected void
RestoreCommand.updatePositions
(LogManager manager, Map<LogPartitionGroup, LogOffset> offsets)