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

Class ChangeStreamStartPositionMapper

java.lang.Object

io.github.flink.gcp.connector.spanner.table.ChangeStreamStartPositionMapper

@Internal
public final class ChangeStreamStartPositionMapper
extends Object

Maps Table API startup options to the shared change-stream start position.

Method Summary

Modifier and Type	Method	Description
static StartPosition	resumeFallback(org.apache.flink.configuration.ReadableConfig config)
static StartPosition	startup(org.apache.flink.configuration.ReadableConfig config)
static void	validate(org.apache.flink.configuration.ReadableConfig config, Map<String,String> supplied)

Methods inherited from class java.lang.Object

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

Method Details

startup

public static StartPosition startup(org.apache.flink.configuration.ReadableConfig config)

resumeFallback

@Nullable
public static StartPosition resumeFallback(org.apache.flink.configuration.ReadableConfig config)

validate

public static void validate(org.apache.flink.configuration.ReadableConfig config,
 Map<String,String> supplied)