public enum StreamingStartingStrategy extends java.lang.Enum<StreamingStartingStrategy>
Enum Constant and Description |
---|
INCREMENTAL_FROM_EARLIEST_SNAPSHOT
Start incremental mode from the earliest snapshot inclusive.
|
INCREMENTAL_FROM_LATEST_SNAPSHOT
Start incremental mode from the latest snapshot inclusive.
|
INCREMENTAL_FROM_SNAPSHOT_ID
Start incremental mode from a snapshot with a specific id inclusive.
|
INCREMENTAL_FROM_SNAPSHOT_TIMESTAMP
Start incremental mode from a snapshot with a specific timestamp inclusive.
|
TABLE_SCAN_THEN_INCREMENTAL
Do a regular table scan then switch to the incremental mode.
|
Modifier and Type | Method and Description |
---|---|
static StreamingStartingStrategy |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static StreamingStartingStrategy[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final StreamingStartingStrategy TABLE_SCAN_THEN_INCREMENTAL
The incremental mode starts from the current snapshot exclusive.
public static final StreamingStartingStrategy INCREMENTAL_FROM_LATEST_SNAPSHOT
If it is an empty map, all future append snapshots should be discovered.
public static final StreamingStartingStrategy INCREMENTAL_FROM_EARLIEST_SNAPSHOT
If it is an empty map, all future append snapshots should be discovered.
public static final StreamingStartingStrategy INCREMENTAL_FROM_SNAPSHOT_ID
public static final StreamingStartingStrategy INCREMENTAL_FROM_SNAPSHOT_TIMESTAMP
If the timestamp is between two snapshots, it should start from the snapshot after the timestamp.
public static StreamingStartingStrategy[] values()
for (StreamingStartingStrategy c : StreamingStartingStrategy.values()) System.out.println(c);
public static StreamingStartingStrategy valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is null