kinetica.CreateTableMonitorRequest.Options

A set of string constants for the parameter CreateTableMonitorRequest.options. More…

Static Public Attributes
const string	EVENT = “event”
	Type of modification event on the target table to be monitored by this table monitor.

const string	INSERT = “insert”
	Get notifications of new record insertions.

const string	UPDATE = “update”
	Get notifications of update operations.

const string	DELETE = “delete”
	Get notifications of delete operations.

const string	MONITOR_ID = “monitor_id”
	ID to use for this monitor instead of a randomly generated one.

const string	DATASINK_NAME = “datasink_name”
	Name of an existing data sink to send change data notifications to.

const string	MAX_CONSECUTIVE_FAILURES = “max_consecutive_failures”
	Maximum number of consecutive failed notification attempts before suspending the stream.

const string	FAILED_NOTIFICATIONS_TABLE_NAME = “failed_notifications_table_name”
	Name of a table to which failed stream notifications are written when the stream is suspended.

const string	DESTINATION = “destination”
	Destination for the output data in format ‘destination_type://path[:port]’.

const string	KAFKA_TOPIC_NAME = “kafka_topic_name”
	Name of the Kafka topic to publish to if DESTINATION in CreateTableMonitorRequest.options is specified and is a Kafka broker.

const string	INCREASING_COLUMN = “increasing_column”
	Column on subscribed table that will increase for new records (e.g., TIMESTAMP).

const string	EXPRESSION = “expression”
	Filter expression to limit records for notification.

const string	JOIN_TABLE_NAMES = “join_table_names”
	A comma-separated list of tables (optionally with aliases) to include in the join.

const string	JOIN_COLUMN_NAMES = “join_column_names”
	A comma-separated list of columns or expressions to include from the joined tables.

const string	JOIN_EXPRESSIONS = “join_expressions”
	Filter or join expressions to apply when combining the tables.

const string	REFRESH_METHOD = “refresh_method”
	Method controlling when the table monitor reports changes to the CreateTableMonitorRequest.table_name.

const string	ON_CHANGE = “on_change”
	Report changes as they occur.

const string	PERIODIC = “periodic”
	Report changes periodically at rate specified by REFRESH_PERIOD.

const string	REFRESH_PERIOD = “refresh_period”
	When REFRESH_METHOD is PERIODIC, specifies the period in seconds at which changes are reported.

const string	REFRESH_START_TIME = “refresh_start_time”
	When REFRESH_METHOD is PERIODIC, specifies the first time at which changes are reported.

Detailed Description

A set of string constants for the parameter CreateTableMonitorRequest.options.

Optional parameters.

Definition at line 37 of file CreateTableMonitor.cs.

Member Data Documentation

◆ DATASINK_NAME

const string kinetica.CreateTableMonitorRequest.Options.DATASINK_NAME = “datasink_name”

static

Name of an existing data sink to send change data notifications to.

Definition at line 95 of file CreateTableMonitor.cs.

◆ DELETE

const string kinetica.CreateTableMonitorRequest.Options.DELETE = “delete”

static

Get notifications of delete operations.

The deleted row count information is forwarded to the subscribers.

Definition at line 86 of file CreateTableMonitor.cs.

◆ DESTINATION

const string kinetica.CreateTableMonitorRequest.Options.DESTINATION = “destination”

static

Destination for the output data in format ‘destination_type://path[:port]’.

Supported destination types are ‘http’, ‘https’ and ‘kafka’.

Definition at line 118 of file CreateTableMonitor.cs.

◆ EVENT

const string kinetica.CreateTableMonitorRequest.Options.EVENT = “event”

static

Type of modification event on the target table to be monitored by this table monitor.

Supported values:

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.

The default value is INSERT.

Definition at line 71 of file CreateTableMonitor.cs.

◆ EXPRESSION

const string kinetica.CreateTableMonitorRequest.Options.EXPRESSION = “expression”

static

Filter expression to limit records for notification.

Definition at line 132 of file CreateTableMonitor.cs.

◆ FAILED_NOTIFICATIONS_TABLE_NAME

const string kinetica.CreateTableMonitorRequest.Options.FAILED_NOTIFICATIONS_TABLE_NAME = “failed_notifications_table_name”

static

Name of a table to which failed stream notifications are written when the stream is suspended.

The database will attempt to send notifications persisted in this table when the stream is resumed. The table has the following columns: rank (long), job_id (long), uuid (uuid), timestamp (timestamp), error_msg (string), payload (bytes). Leave this option empty to disable persisting failed notification events.

Definition at line 112 of file CreateTableMonitor.cs.

◆ INCREASING_COLUMN

const string kinetica.CreateTableMonitorRequest.Options.INCREASING_COLUMN = “increasing_column”

static

Column on subscribed table that will increase for new records (e.g., TIMESTAMP).

Definition at line 128 of file CreateTableMonitor.cs.

◆ INSERT

const string kinetica.CreateTableMonitorRequest.Options.INSERT = “insert”

static

Get notifications of new record insertions.

The new row images are forwarded to the subscribers.

Definition at line 76 of file CreateTableMonitor.cs.

◆ JOIN_COLUMN_NAMES

const string kinetica.CreateTableMonitorRequest.Options.JOIN_COLUMN_NAMES = “join_column_names”

static

A comma-separated list of columns or expressions to include from the joined tables.

Column references can use table names or aliases defined in ‘join_table_names’. Each column can optionally be aliased using ‘as’. The selected columns will also appear in the notification output.

Definition at line 150 of file CreateTableMonitor.cs.

◆ JOIN_EXPRESSIONS

const string kinetica.CreateTableMonitorRequest.Options.JOIN_EXPRESSIONS = “join_expressions”

static

Filter or join expressions to apply when combining the tables.

Expressions are standard SQL-style conditions and can reference any table or alias listed in ‘join_table_names’. This corresponds to the WHERE clause of the underlying join, and can include conditions to filter the delta rows.

Definition at line 158 of file CreateTableMonitor.cs.

◆ JOIN_TABLE_NAMES

const string kinetica.CreateTableMonitorRequest.Options.JOIN_TABLE_NAMES = “join_table_names”

static

A comma-separated list of tables (optionally with aliases) to include in the join.

The monitored table CreateTableMonitorRequest.table_name must be included, representing only the newly inserted rows (deltas) since the last notification. Other tables can be any existing tables or views. Aliases can be used with the ‘table_name as alias’ syntax.

Definition at line 142 of file CreateTableMonitor.cs.

◆ KAFKA_TOPIC_NAME

const string kinetica.CreateTableMonitorRequest.Options.KAFKA_TOPIC_NAME = “kafka_topic_name”

static

Name of the Kafka topic to publish to if DESTINATION in CreateTableMonitorRequest.options is specified and is a Kafka broker.

Definition at line 124 of file CreateTableMonitor.cs.

◆ MAX_CONSECUTIVE_FAILURES

const string kinetica.CreateTableMonitorRequest.Options.MAX_CONSECUTIVE_FAILURES = “max_consecutive_failures”

static

Maximum number of consecutive failed notification attempts before suspending the stream.

A value of -1 (default) disables auto-suspend. This value is by rank and not overall.

Definition at line 101 of file CreateTableMonitor.cs.

◆ MONITOR_ID

const string kinetica.CreateTableMonitorRequest.Options.MONITOR_ID = “monitor_id”

static

ID to use for this monitor instead of a randomly generated one.

Definition at line 90 of file CreateTableMonitor.cs.

◆ ON_CHANGE

const string kinetica.CreateTableMonitorRequest.Options.ON_CHANGE = “on_change”

static

Report changes as they occur.

Definition at line 187 of file CreateTableMonitor.cs.

◆ PERIODIC

const string kinetica.CreateTableMonitorRequest.Options.PERIODIC = “periodic”

static

Report changes periodically at rate specified by REFRESH_PERIOD.

Definition at line 192 of file CreateTableMonitor.cs.

◆ REFRESH_METHOD

const string kinetica.CreateTableMonitorRequest.Options.REFRESH_METHOD = “refresh_method”

static

Method controlling when the table monitor reports changes to the CreateTableMonitorRequest.table_name.

Supported values:

ON_CHANGE: Report changes as they occur.
PERIODIC: Report changes periodically at rate specified by REFRESH_PERIOD.

The default value is ON_CHANGE.

Definition at line 184 of file CreateTableMonitor.cs.

◆ REFRESH_PERIOD

const string kinetica.CreateTableMonitorRequest.Options.REFRESH_PERIOD = “refresh_period”

static

When REFRESH_METHOD is PERIODIC, specifies the period in seconds at which changes are reported.

Definition at line 200 of file CreateTableMonitor.cs.

◆ REFRESH_START_TIME

const string kinetica.CreateTableMonitorRequest.Options.REFRESH_START_TIME = “refresh_start_time”

static

When 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’.

Definition at line 209 of file CreateTableMonitor.cs.

◆ UPDATE

const string kinetica.CreateTableMonitorRequest.Options.UPDATE = “update”

static

Get notifications of update operations.

The modified row count information is forwarded to the subscribers.

Definition at line 81 of file CreateTableMonitor.cs.

The documentation for this struct was generated from the following files:

_build/public-os_ubuntu24.04-arch_amd64-cc_gcc_13.3.0/install/Kinetica/Protocol/CreateTableMonitor.cs
Kinetica/Protocol/CreateTableMonitor.cs

​ Static Public Attributes

​Detailed Description

​Member Data Documentation

​◆ DATASINK_NAME

​◆ DELETE

​◆ DESTINATION

​◆ EVENT

​◆ EXPRESSION

​◆ FAILED_NOTIFICATIONS_TABLE_NAME

​◆ INCREASING_COLUMN

​◆ INSERT

​◆ JOIN_COLUMN_NAMES

​◆ JOIN_EXPRESSIONS

​◆ JOIN_TABLE_NAMES

​◆ KAFKA_TOPIC_NAME

​◆ MAX_CONSECUTIVE_FAILURES

​◆ MONITOR_ID

​◆ ON_CHANGE

​◆ PERIODIC

​◆ REFRESH_METHOD

​◆ REFRESH_PERIOD

​◆ REFRESH_START_TIME

​◆ UPDATE

Static Public Attributes

Detailed Description

Member Data Documentation

◆ DATASINK_NAME

◆ DELETE

◆ DESTINATION

◆ EVENT

◆ EXPRESSION

◆ FAILED_NOTIFICATIONS_TABLE_NAME

◆ INCREASING_COLUMN

◆ INSERT

◆ JOIN_COLUMN_NAMES

◆ JOIN_EXPRESSIONS

◆ JOIN_TABLE_NAMES

◆ KAFKA_TOPIC_NAME

◆ MAX_CONSECUTIVE_FAILURES

◆ MONITOR_ID

◆ ON_CHANGE

◆ PERIODIC

◆ REFRESH_METHOD

◆ REFRESH_PERIOD

◆ REFRESH_START_TIME

◆ UPDATE