Package com.linkedin.venice.beam.consumer

Interface Summary

Interface	Description
VeniceChangelogConsumerProvider<K,V>	Interface to provide a configured VeniceChangelogConsumer instance.

Class Summary

Class	Description
CheckPointProperties	Properties used by VeniceChangelogConsumer to seek checkpoints.
LocalVeniceChangelogConsumerProvider<K,V>	Provides a configured VeniceChangelogConsumer instance.
PubSubMessageCoder<K,V>	Uses AvroCoder to encode/decode PubSubMessages.
VeniceChangelogConsumerIO	Beam Connector for Venice Change data capture IO.
VeniceChangelogConsumerIO.Read<K,V>
VeniceCheckpointMark
VeniceCheckpointMark.Coder
VeniceMessageCoder<K,V>	Uses KvCoder to encode/decode PubSubMessage key and value.

Enum Summary

Enum	Description
VeniceChangelogConsumerIO.Read.SeekWhence