Class VitessSource
- java.lang.Object
-
- org.apache.flink.cdc.connectors.vitess.VitessSource
-
public class VitessSource extends Object
A builder to build a SourceFunction which can read and process vitess database changes. The Vitess connector subscribes to VTGate's VStream gRPC service. VTGate is a lightweight, stateless gRPC server, which is part of the Vitess cluster setup.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classVitessSource.Builder<T>Builder class ofVitessSource.
-
Constructor Summary
Constructors Constructor Description VitessSource()
-
-
-
Method Detail
-
builder
public static <T> VitessSource.Builder<T> builder()
-
-