Package com.linkedin.davinci.consumer
-
Interface Summary Interface Description BootstrappingVeniceChangelogConsumer<K,V> This interface is meant for users where local state must be built off of the entirety of a venice data set (i.e.VeniceChangelogConsumer<K,V> Venice change capture consumer to provide value change callback.VeniceChangelogConsumerClientFactory.ViewClassGetter -
Class Summary Class Description ChangeEvent<T> ChangelogClientConfig<T extends org.apache.avro.specific.SpecificRecord> ImmutableChangeCapturePubSubMessage<K,V> LocalBootstrappingVeniceChangelogConsumer<K,V> This is a wrapper class on top of InternalBootstrappingVeniceChangelogConsumerImpl.RecordChangeEventReadOnlySchemaRepository TODO: This class is a bit of a hack.ReplicationMetadataSchemaRepository RmdDeserializerCache<T> Container for the deserializers of a single store.VeniceAfterImageConsumerImpl<K,V> VeniceChangeCoordinate VeniceChangelogConsumerClientFactory VeniceChangelogConsumerImpl<K,V> -
Exception Summary Exception Description VeniceCoordinateOutOfRangeException