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

Class SpannerChangeStreamSourceConfig<T>

java.lang.Object

io.github.flink.gcp.connector.spanner.source.SpannerChangeStreamSourceConfig<T>

All Implemented Interfaces:

Serializable

@Internal
public final class SpannerChangeStreamSourceConfig<T>
extends Object
implements Serializable

Immutable configuration assembled by SpannerChangeStreamSourceBuilder.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
Duration	getAbsentRetentionFallback()
String	getChangeStreamName()
SpannerChangeStreamCoordinatorClientFactory	getCoordinatorClientFactory()
DatabaseDestination	getDatabase()
SpannerChangeStreamDeserializationSchema<T>	getDeserializer()
Instant	getEndTimestamp()
long	getHeartbeatMillis()
int	getMaxConcurrentQueriesPerSubtask()
SpannerChangeStreamQueryClientFactory	getQueryClientFactory()
SpannerChangeStreamRecordFilter	getRecordFilter()
StartPosition	getResumeFallback()
SpannerRpcPriority	getRpcPriority()
String	getServiceAccountKeyFile()
StartPosition	getStartPosition()
boolean	isExportClientMetricsToFlink()	Returns whether the coordinator and the readers export their clients' own metrics through Flink's metric system.

Methods inherited from class java.lang.Object

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

Method Details

getDatabase

public DatabaseDestination getDatabase()

getDeserializer

public SpannerChangeStreamDeserializationSchema<T> getDeserializer()

getChangeStreamName

public String getChangeStreamName()

getStartPosition

public StartPosition getStartPosition()

getResumeFallback

@Nullable
public StartPosition getResumeFallback()

getAbsentRetentionFallback

public Duration getAbsentRetentionFallback()

getHeartbeatMillis

public long getHeartbeatMillis()

getRpcPriority

public SpannerRpcPriority getRpcPriority()

getMaxConcurrentQueriesPerSubtask

public int getMaxConcurrentQueriesPerSubtask()

getServiceAccountKeyFile

@Nullable
public String getServiceAccountKeyFile()

getRecordFilter

public SpannerChangeStreamRecordFilter getRecordFilter()

getEndTimestamp

@Nullable
public Instant getEndTimestamp()

getQueryClientFactory

public SpannerChangeStreamQueryClientFactory getQueryClientFactory()

getCoordinatorClientFactory

public SpannerChangeStreamCoordinatorClientFactory getCoordinatorClientFactory()

isExportClientMetricsToFlink

public boolean isExportClientMetricsToFlink()

Returns whether the coordinator and the readers export their clients' own metrics through Flink's metric system. The Cloud Monitoring choice is the client factories', which build the clients.