public class NoSQLSubscriptionConfig extends Object
Modifier and Type | Class and Description |
---|---|
static class |
NoSQLSubscriptionConfig.Builder
Builder to construct a NoSQLSubscriptionConfig instance
|
Modifier and Type | Method and Description |
---|---|
String |
getCkptTableName()
Gets the name of checkpoint table associated with subscription
|
StreamPosition |
getInitialPosition()
Returns the initial stream position to be used when creating a
Subscription.
|
NoSQLStreamMode |
getStreamMode()
Returns the start stream mode.
|
NoSQLSubscriberId |
getSubscriberId()
Gets the subscriber ID of the configuration.
|
Set<String> |
getTables()
Returns the tables to be associated with a subscription.
|
String |
toString() |
boolean |
useNewCheckpointTable()
Returns true if the subscription should attempt to create the checkpoint
table if it doesn't already exist.
|
public String getCkptTableName()
public StreamPosition getInitialPosition()
onNext()
by the Publisher
will signal
the element following this position in the
stream.
If stream mode is
NoSQLStreamMode.FROM_NOW
,
NoSQLStreamMode.FROM_CHECKPOINT
, or
NoSQLStreamMode.FROM_EXACT_CHECKPOINT
, it always
returns null since these modes do not use the initial position
specified in config.
public NoSQLSubscriberId getSubscriberId()
public Set<String> getTables()
public boolean useNewCheckpointTable()
public NoSQLStreamMode getStreamMode()
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.