NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setChangeTimeoutMs(long changeTimeoutMs) |
Sets the subscription change timeout in milliseconds.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setCreateNewCheckpointTable(boolean allow) |
Sets if publisher is allowed to create a new checkpoint table if
it does not exist.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setEmptyStreamDuration(int emptyStreamSecs) |
Sets the empty stream duration.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setLocalWritesOnly(boolean localWritesOnly) |
Sets that when subscribing multi-region tables, whether only local
writes are streamed.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setMaxReconnect(long maxReconnect) |
Sets the max number of reconnect if stream is down
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setStartStreamPosition(StreamPosition position) |
Sets the start stream position.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setStreamMode(NoSQLStreamMode mode) |
Sets the stream mode.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setStreamOperationDeserializer(StreamOperation.Deserializer deserializer) |
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setSubscribedTables(java.lang.String... tables) |
Sets the subscribed tables under given namespace.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setSubscribedTables(java.util.Set<java.lang.String> tables) |
Sets the subscribed tables under given namespace.
|
NoSQLSubscriptionConfig.Builder |
NoSQLSubscriptionConfig.Builder.setSubscriberId(NoSQLSubscriberId id) |
Sets the subscriber id which owns the subscription.
|