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

Packages that use LogPartition

Package	Description
org.nuxeo.importer.stream.automation
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.importer.stream.automation

Method parameters in org.nuxeo.importer.stream.automation with type arguments of type LogPartition

Modifier and Type	Method and Description
void	RandomDocumentProducers.onPartitionsAssigned(Collection<LogPartition> partitions)
void	RandomDocumentProducers.onPartitionsRevoked(Collection<LogPartition> partitions)

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 and Description
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 and 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 and Description
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 and Description
ComputationPool(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<LogPartition>> defaultAssignments, LogManager manager)
ComputationRunner(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<LogPartition> defaultAssignment, LogManager logManager)

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

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

Modifier and Type	Method and Description
static LogPartition	LogPartition.of(String 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 and 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 and Description
LogOffset	LogTailer.commit(LogPartition partition) Commit current position for the partition.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, LogPartition partition) Create a tailer for a consumer group and assign a single partition.
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 and Description
<M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, Collection<LogPartition> partitions) Create a tailer for a consumer group and assign multiple partitions.
void	RebalanceListener.onPartitionsAssigned(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 and Description
protected LogPartition	ChronicleLogTailer.partition

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

Modifier and Type	Field and 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 and Description
Collection<LogPartition>	ChronicleLogTailer.assignments()
Collection<LogPartition>	ChronicleCompoundLogTailer.assignments()

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

Modifier and Type	Method and Description
LogOffset	ChronicleLogTailer.commit(LogPartition partition)
LogOffset	ChronicleCompoundLogTailer.commit(LogPartition partition)
LogTailer<M>	ChronicleLogAppender.createTailer(LogPartition partition, String group)
void	ChronicleLogTailer.reset(LogPartition partition)
void	ChronicleCompoundLogTailer.reset(LogPartition partition)

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

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

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

Constructor and Description
ChronicleLogTailer(String basePath, net.openhft.chronicle.queue.ExcerptTailer cqTailer, LogPartition partition, String 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 and Description
protected LogPartition	LogOffsetImpl.partition

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

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

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

Modifier and Type	Method and Description
protected void	AbstractLogManager.checkInvalidAssignment(String group, LogPartition partition)

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

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

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

Constructor and Description
LogOffsetImpl(LogPartition partition, long offset)
LogPartitionGroup(String 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 and 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 and Description
Collection<LogPartition>	KafkaLogTailer.assignments()
protected static List<List<LogPartition>>	KafkaUtils.assignments(org.apache.kafka.clients.consumer.internals.PartitionAssignor 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 and Description
protected void	KafkaLogManager.checkValidPartition(LogPartition partition)
LogOffset	KafkaLogTailer.commit(LogPartition partition)
void	KafkaLogTailer.reset(LogPartition partition)

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

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

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 and 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 and 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 and Description
protected LogTailer<M>	ConsumerRunner.createTailer(LogManager manager, List<LogPartition> defaultAssignments)
void	ConsumerRunner.onPartitionsAssigned(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 and Description
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments)