Uses of Class
org.nuxeo.lib.stream.log.LogPartition

Packages that use LogPartition

Package	Description
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.log	The Log interface with Chronicle and Kafka implementation.
org.nuxeo.lib.stream.log.chronicle
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.log.kafka
org.nuxeo.lib.stream.pattern.consumer
org.nuxeo.lib.stream.pattern.consumer.internals

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

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

Modifier and Type	Field	Description
protected List<LogPartition>	ComputationRunner.defaultAssignment
protected List<List<LogPartition>>	ComputationPool.defaultAssignments

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

Modifier and Type	Method	Description
protected List<List<LogPartition>>	LogStreamProcessor.getDefaultAssignments(ComputationMetadataMapping meta)

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

Modifier and Type	Method	Description
LogTailer<Record>	LogStreamManager.createTailer(Name computationName, Collection<LogPartition> streamPartitions)
void	ComputationRunner.onPartitionsAssigned(Collection<LogPartition> partitions)
void	ComputationRunner.onPartitionsRevoked(Collection<LogPartition> partitions)

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

Constructor	Description
ComputationPool(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<LogPartition>> defaultAssignments, LogStreamManager streamManager, ComputationPolicy policy)
ComputationRunner(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<LogPartition> defaultAssignment, LogStreamManager streamManager, ComputationPolicy policy)

Uses of LogPartition in org.nuxeo.lib.stream.log

Methods in org.nuxeo.lib.stream.log that return LogPartition

Modifier and Type	Method	Description
static LogPartition	LogPartition.of(Name name, int partition)
LogPartition	LogOffset.partition()	Returns the tuple Log name and partition.

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

Modifier and Type	Method	Description
Collection<LogPartition>	LogTailer.assignments()	Returns the list of Log name, partitions tuples currently assigned to this tailer.

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

Modifier and Type	Method	Description
LogOffset	LogTailer.commit(LogPartition partition)	Commit current position for the partition.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, LogPartition partition)	Deprecated. since 11.1 use (Name) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, LogPartition partition, Codec<M> codec)	Deprecated. since 11.1 use LogManager.createTailer(Name, LogPartition, Codec) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, LogPartition partition)	Creates a tailer for a consumer group and assign a single partition.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, LogPartition partition, Codec<M> codec)	Creates a tailer for a consumer group and assign a single partition.
LogOffset	LogTailer.offsetForTimestamp(LogPartition partition, long timestamp)	Look up the offset for the given partition by timestamp.
void	LogTailer.reset(LogPartition partition)	Reset the committed position for this group on this partition, next read for this partition will be done from the beginning.

Method parameters in org.nuxeo.lib.stream.log with type arguments of type LogPartition

Modifier and Type	Method	Description
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, Collection<LogPartition> partitions)	Deprecated. since 11.1 use (Name) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, Collection<LogPartition> partitions, Codec<M> codec)	Deprecated. since 11.1 use LogManager.createTailer(Name, Name, Codec) (Name)} instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, Collection<LogPartition> partitions)	Creates a tailer for a consumer group and assign multiple partitions.
<M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, Collection<LogPartition> partitions, Codec<M> codec)	Creates a tailer for a consumer group and assign multiple partitions.
<M extends Externalizable> LogTailer<M>	UnifiedLogManager.createTailer(Name group, Collection<LogPartition> partitions, Codec<M> codec)
void	RebalanceListener.onPartitionsAssigned(Collection<LogPartition> partitions)
default void	RebalanceListener.onPartitionsLost(Collection<LogPartition> partitions)
void	RebalanceListener.onPartitionsRevoked(Collection<LogPartition> partitions)

Uses of LogPartition in org.nuxeo.lib.stream.log.chronicle

Fields in org.nuxeo.lib.stream.log.chronicle declared as LogPartition

Modifier and Type	Field	Description
protected LogPartition	ChronicleLogTailer.partition

Fields in org.nuxeo.lib.stream.log.chronicle with type parameters of type LogPartition

Modifier and Type	Field	Description
protected List<LogPartition>	ChronicleCompoundLogTailer.logPartitions

Methods in org.nuxeo.lib.stream.log.chronicle that return types with arguments of type LogPartition

Modifier and Type	Method	Description
Collection<LogPartition>	ChronicleCompoundLogTailer.assignments()
Collection<LogPartition>	ChronicleLogTailer.assignments()

Methods in org.nuxeo.lib.stream.log.chronicle with parameters of type LogPartition

Modifier and Type	Method	Description
LogOffset	ChronicleCompoundLogTailer.commit(LogPartition partition)
LogOffset	ChronicleLogTailer.commit(LogPartition partition)
LogTailer<M>	ChronicleLogAppender.createTailer(LogPartition partition, Name group, Codec<M> codec)
LogOffset	ChronicleCompoundLogTailer.offsetForTimestamp(LogPartition partition, long timestamp)
LogOffset	ChronicleLogTailer.offsetForTimestamp(LogPartition partition, long timestamp)
void	ChronicleCompoundLogTailer.reset(LogPartition partition)
void	ChronicleLogTailer.reset(LogPartition partition)

Method parameters in org.nuxeo.lib.stream.log.chronicle with type arguments of type LogPartition

Modifier and Type	Method	Description
protected <M extends Externalizable> LogTailer<M>	ChronicleLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)

Constructors in org.nuxeo.lib.stream.log.chronicle with parameters of type LogPartition

Constructor	Description
ChronicleLogTailer(Codec<M> codec, String basePath, net.openhft.chronicle.queue.ExcerptTailer cqTailer, LogPartition partition, Name group, ChronicleRetentionDuration retention)

Uses of LogPartition in org.nuxeo.lib.stream.log.internals

Fields in org.nuxeo.lib.stream.log.internals declared as LogPartition

Modifier and Type	Field	Description
protected LogPartition	LogOffsetImpl.partition

Methods in org.nuxeo.lib.stream.log.internals that return LogPartition

Modifier and Type	Method	Description
LogPartition	LogPartitionGroup.getLogPartition()
LogPartition	LogOffsetImpl.partition()

Methods in org.nuxeo.lib.stream.log.internals with parameters of type LogPartition

Modifier and Type	Method	Description
protected void	AbstractLogManager.checkInvalidAssignment(Name group, LogPartition partition)
protected <M extends Externalizable> void	AbstractLogManager.checkInvalidCodec(LogPartition partition, Codec<M> codec)

Method parameters in org.nuxeo.lib.stream.log.internals with type arguments of type LogPartition

Modifier and Type	Method	Description
<M extends Externalizable> LogTailer<M>	AbstractLogManager.createTailer(Name group, Collection<LogPartition> partitions, Codec<M> codec)
protected abstract <M extends Externalizable> LogTailer<M>	AbstractLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)
protected <M extends Externalizable> Codec<M>	AbstractLogManager.guessCodec(Collection<LogPartition> partitions)

Constructors in org.nuxeo.lib.stream.log.internals with parameters of type LogPartition

Constructor	Description
LogOffsetImpl(LogPartition partition, long offset)
LogPartitionGroup(Name group, LogPartition mqp)

Uses of LogPartition in org.nuxeo.lib.stream.log.kafka

Fields in org.nuxeo.lib.stream.log.kafka with type parameters of type LogPartition

Modifier and Type	Field	Description
protected Collection<LogPartition>	KafkaLogTailer.partitions

Methods in org.nuxeo.lib.stream.log.kafka that return types with arguments of type LogPartition

Modifier and Type	Method	Description
Collection<LogPartition>	KafkaLogTailer.assignments()
protected static List<List<LogPartition>>	KafkaUtils.assignments(org.apache.kafka.clients.consumer.ConsumerPartitionAssignor assignor, int threads, Map<String,Integer> streams)
static List<List<LogPartition>>	KafkaUtils.rangeAssignments(int threads, Map<String,Integer> streams)
static List<List<LogPartition>>	KafkaUtils.roundRobinAssignments(int threads, Map<String,Integer> streams)

Methods in org.nuxeo.lib.stream.log.kafka with parameters of type LogPartition

Modifier and Type	Method	Description
protected void	KafkaLogManager.checkValidPartition(LogPartition partition)
LogOffset	KafkaLogTailer.commit(LogPartition partition)
LogOffset	KafkaLogTailer.offsetForTimestamp(LogPartition partition, long timestamp)
void	KafkaLogTailer.reset(LogPartition partition)

Method parameters in org.nuxeo.lib.stream.log.kafka with type arguments of type LogPartition

Modifier and Type	Method	Description
protected static String	KafkaLogTailer.buildId(Name group, Collection<LogPartition> partitions)
static <M extends Externalizable> KafkaLogTailer<M>	KafkaLogTailer.createAndAssign(Codec<M> codec, NameResolver resolver, Collection<LogPartition> partitions, Name group, Properties consumerProps)
protected <M extends Externalizable> LogTailer<M>	KafkaLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)

Uses of LogPartition in org.nuxeo.lib.stream.pattern.consumer

Fields in org.nuxeo.lib.stream.pattern.consumer with type parameters of type LogPartition

Modifier and Type	Field	Description
protected List<List<LogPartition>>	ConsumerPool.defaultAssignments

Methods in org.nuxeo.lib.stream.pattern.consumer that return types with arguments of type LogPartition

Modifier and Type	Method	Description
protected List<List<LogPartition>>	ConsumerPool.getDefaultAssignments()

Uses of LogPartition in org.nuxeo.lib.stream.pattern.consumer.internals

Method parameters in org.nuxeo.lib.stream.pattern.consumer.internals with type arguments of type LogPartition

Modifier and Type	Method	Description
protected LogTailer<M>	ConsumerRunner.createTailer(LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments)
void	ConsumerRunner.onPartitionsAssigned(Collection<LogPartition> partitions)
void	ConsumerRunner.onPartitionsLost(Collection<LogPartition> partitions)
void	ConsumerRunner.onPartitionsRevoked(Collection<LogPartition> partitions)

Constructor parameters in org.nuxeo.lib.stream.pattern.consumer.internals with type arguments of type LogPartition

Constructor	Description
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments)	Deprecated. since 11.1, due to serialization issue with java 11, use ConsumerRunner(ConsumerFactory, ConsumerPolicy, LogManager, Codec, List) which allows to give a codec to tailer.
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments)