Package com.linkedin.venice.beam.consumer

package com.linkedin.venice.beam.consumer

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>
VeniceChangelogConsumerIO.Read.SeekWhence
VeniceChangelogConsumerProvider<K,V>	Interface to provide a configured VeniceChangelogConsumer instance.
VeniceCheckpointMark
VeniceCheckpointMark.Coder
VeniceMessageCoder<K,V>	Uses KvCoder to encode/decode PubSubMessage key and value.