Package com.linkedin.venice.beam.consumer

Class VeniceChangelogConsumerIO

java.lang.Object

com.linkedin.venice.beam.consumer.VeniceChangelogConsumerIO

public final class VeniceChangelogConsumerIO
extends Object

Beam Connector for Venice Change data capture IO. Uses VeniceChangelogConsumer underneath to pull messages from configured venice store.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	VeniceChangelogConsumerIO.Read<K,V>

Method Summary

Modifier and Type	Method	Description
static <K, V> VeniceChangelogConsumerIO.Read<K,V>	read()

Methods inherited from class java.lang.Object

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

Method Details

read

public static <K,
V>
VeniceChangelogConsumerIO.Read<K,V> read()