7 using System.Collections.Generic;
64 public const string EVENT =
"event";
69 public const string INSERT =
"insert";
74 public const string UPDATE =
"update";
79 public const string DELETE =
"delete";
281 public IDictionary<string, string>
options {
get;
set; } =
new Dictionary<string, string>();
416 IDictionary<string, string>
options =
null)
435 public const string TTL =
"ttl";
536 public IDictionary<string, string>
info {
get;
set; } =
new Dictionary<string, string>();
CreateTableMonitorRequest(string table_name, IDictionary< string, string > options=null)
Constructs a CreateTableMonitorRequest object with the specified parameters.
A set of results returned by Kinetica.createTableMonitor.
const string REFRESH_START_TIME
When REFRESH_METHOD is PERIODIC, specifies the first time at which changes are reported.
A set of parameters for Kinetica.createTableMonitor.
const string EVENT
Type of modification event on the target table to be monitored by this table monitor.
CreateTableMonitorRequest()
Constructs a CreateTableMonitorRequest object with default parameters.
const string DELETE
Get notifications of delete operations.
const string INSERT
Get notifications of new record insertions.
const string DELETE_TYPE_SCHEMA
The JSON Avro schema for 'delete' events
string table_name
Value of table_name.
const string EXPRESSION
Filter expression to limit records for notification
const string UPDATE_TOPIC_ID
The topic id for 'update' EVENT in options
A set of string constants for the parameter info.
IDictionary< string, string > options
Optional parameters.
const string REFRESH_METHOD
Method controlling when the table monitor reports changes to the table_name.
const string TTL
For insert_table/delete_table events, the ttl of the table.
const string DELETE_TOPIC_ID
The topic id for 'delete' EVENT in options
const string UPDATE_TYPE_SCHEMA
The JSON Avro schema for 'update' events
const string PERIODIC
Report changes periodically at rate specified by REFRESH_PERIOD.
const string INSERT_TYPE_SCHEMA
The JSON Avro schema of the table in table_name
const string ON_CHANGE
Report changes as they occur.
const string REFRESH_PERIOD
When REFRESH_METHOD is PERIODIC, specifies the period in seconds at which changes are reported.
string topic_id
The ZMQ topic ID to subscribe to for table events.
const string MONITOR_ID
ID to use for this monitor instead of a randomly generated one
const string INCREASING_COLUMN
Column on subscribed table that will increase for new records (e.g., TIMESTAMP).
string table_name
Name of the table to monitor, in [schema_name.
const string DESTINATION
Destination for the output data in format 'destination_type://path[:port]'.
A set of string constants for the parameter options.
const string DATASINK_NAME
Name of an existing data sink to send change data notifications to
const string UPDATE
Get notifications of update operations.
KineticaData - class to help with Avro Encoding for Kinetica
const string KAFKA_TOPIC_NAME
Name of the Kafka topic to publish to if DESTINATION in options is specified and is a Kafka broker
IDictionary< string, string > info
Additional information.
const string INSERT_TOPIC_ID
The topic id for 'insert' EVENT in options
string type_schema
JSON Avro schema of the table, for use in decoding published records.