public static final class CreateTableMonitorRequest.Options extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DATASINK_NAME
|
static String |
DESTINATION
Destination for the output data in format
'destination_type://path[:port]'.
|
static String |
EVENT
Type of modification event on the target table to be monitored by
this table monitor.
|
static String |
EXPRESSION
Filter expression to limit records for notification
|
static String |
INCREASING_COLUMN
Column on subscribed table that will increase for new records (e.g.,
TIMESTAMP).
|
static String |
INSERT
Get notifications of new record insertions.
|
static String |
KAFKA_TOPIC_NAME
Name of the Kafka topic to publish to if
DESTINATION in options is specified and is a
Kafka broker |
static String |
MONITOR_ID
ID to use for this monitor instead of a randomly generated one
|
static String |
ON_CHANGE
Report changes as they occur.
|
static String |
PERIODIC
Report changes periodically at rate specified by
REFRESH_PERIOD . |
static String |
REFRESH_METHOD
Method controlling when the table monitor reports changes to the
tableName . |
static String |
REFRESH_PERIOD
When
REFRESH_METHOD is PERIODIC , specifies the period in seconds at which
changes are reported. |
static String |
REFRESH_START_TIME
When
REFRESH_METHOD is PERIODIC , specifies the first time at which
changes are reported. |
static String |
UPDATE
Get notifications of update operations.
|
public static final String EVENT
INSERT
: Get notifications of new
record insertions. The new row images are forwarded to the
subscribers.
UPDATE
: Get notifications of update
operations. The modified row count information is forwarded
to the subscribers.
DELETE
: Get notifications of delete
operations. The deleted row count information is forwarded
to the subscribers.
INSERT
.public static final String INSERT
public static final String UPDATE
public static final String DELETE
public static final String MONITOR_ID
public static final String DATASINK_NAME
public static final String DESTINATION
public static final String KAFKA_TOPIC_NAME
DESTINATION
in options
is specified and is a
Kafka brokerpublic static final String INCREASING_COLUMN
public static final String EXPRESSION
public static final String REFRESH_METHOD
tableName
.
Supported values:
ON_CHANGE
: Report changes as they
occur.
PERIODIC
: Report changes
periodically at rate specified by REFRESH_PERIOD
.
ON_CHANGE
.public static final String ON_CHANGE
public static final String PERIODIC
REFRESH_PERIOD
.public static final String REFRESH_PERIOD
REFRESH_METHOD
is PERIODIC
, specifies the period in seconds at which
changes are reported.public static final String REFRESH_START_TIME
REFRESH_METHOD
is PERIODIC
, specifies the first time at which
changes are reported. Value is a datetime string with format
'YYYY-MM-DD HH:MM:SS'.Copyright © 2025. All rights reserved.