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 In-Memory and Kafka implementation.
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.log.kafka
org.nuxeo.lib.stream.log.mem
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 final 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

Modifier	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.internals

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

Modifier and Type	Field	Description
protected final 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

Modifier	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.log.mem

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

Modifier and Type	Method	Description
Collection<LogPartition>	MemCompoundLogTailer.assignments()
Collection<LogPartition>	MemLogTailer.assignments()

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

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

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

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

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

Modifier	Constructor	Description
	MemLogTailer(MemLog log, LogPartition partition, 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 final 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

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