Package io.github.flink.gcp.connector.bigtable.source

Class BigtableChangeStreamSource<T>

java.lang.Object

io.github.flink.gcp.connector.bigtable.source.BigtableChangeStreamSource<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>, org.apache.flink.api.connector.source.SourceReaderFactory<T,ChangeStreamPartitionSplit>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

@PublicEvolving
public final class BigtableChangeStreamSource<T>
extends Object
implements org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

FLIP-27 source for Bigtable Change Streams.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
static <T> BigtableChangeStreamSourceBuilder<T>	builder()	Returns a builder for a Bigtable Change Streams source.
org.apache.flink.api.connector.source.SplitEnumerator<ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<ChangeStreamPartitionSplit> context)
org.apache.flink.api.connector.source.SourceReader<T,ChangeStreamPartitionSplit>	createReader(org.apache.flink.api.connector.source.SourceReaderContext context)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<BigtableChangeStreamEnumeratorState>	getEnumeratorCheckpointSerializer()
org.apache.flink.api.common.typeinfo.TypeInformation<T>	getProducedType()
org.apache.flink.core.io.SimpleVersionedSerializer<ChangeStreamPartitionSplit>	getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<ChangeStreamPartitionSplit> context, BigtableChangeStreamEnumeratorState checkpoint)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.connector.source.Source

declareWatermarks

Method Details

builder

public static <T>
BigtableChangeStreamSourceBuilder<T> builder()

Returns a builder for a Bigtable Change Streams source.

Type Parameters:

T - the record type produced

Returns:

the builder

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

Specified by:

getBoundedness in interface org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>

createReader

public org.apache.flink.api.connector.source.SourceReader<T,ChangeStreamPartitionSplit> createReader(org.apache.flink.api.connector.source.SourceReaderContext context)
                                                                                              throws Exception

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<T,ChangeStreamPartitionSplit>

Throws:

Exception

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<ChangeStreamPartitionSplit> context)
                                                                                                                                       throws Exception

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>

Throws:

Exception

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<ChangeStreamPartitionSplit> context,
 BigtableChangeStreamEnumeratorState checkpoint)
                                                                                                                                        throws Exception

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>

Throws:

Exception

getSplitSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<ChangeStreamPartitionSplit> getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<BigtableChangeStreamEnumeratorState> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<T,ChangeStreamPartitionSplit,BigtableChangeStreamEnumeratorState>

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<T> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>