org.apache.paimon.consumer

Class ConsumerManager

java.lang.Object

org.apache.paimon.consumer.ConsumerManager

All Implemented Interfaces:

Serializable

public class ConsumerManager
extends Object
implements Serializable

Manage consumer groups.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConsumerManager(FileIO fileIO, Path tablePath)
ConsumerManager(FileIO fileIO, Path tablePath, String branchName)

Method Summary

Modifier and Type	Method and Description
Optional<Consumer>	consumer(String consumerId)
Map<String,Long>	consumers() Get all consumer.
void	deleteConsumer(String consumerId)
void	expire(java.time.LocalDateTime expireDateTime)
List<String>	listAllIds() List all consumer IDs.
OptionalLong	minNextSnapshot()
void	resetConsumer(String consumerId, Consumer consumer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConsumerManager

public ConsumerManager(FileIO fileIO,
                       Path tablePath)

ConsumerManager

public ConsumerManager(FileIO fileIO,
                       Path tablePath,
                       String branchName)

Method Detail

consumer

public Optional<Consumer> consumer(String consumerId)

resetConsumer

public void resetConsumer(String consumerId,
                          Consumer consumer)

deleteConsumer

public void deleteConsumer(String consumerId)

minNextSnapshot

public OptionalLong minNextSnapshot()

expire

public void expire(java.time.LocalDateTime expireDateTime)

consumers

public Map<String,Long> consumers()
                           throws IOException

Get all consumer.

Throws:

IOException

listAllIds

public List<String> listAllIds()

List all consumer IDs.