7 using System.Collections.Generic;
190 public const string EVENT =
"event";
392 public IDictionary<string, string>
options {
get; set; } =
new Dictionary<string, string>();
520 IDictionary<string, string>
options = null)
522 this.table_name = table_name ??
"";
523 this.options =
options ??
new Dictionary<string, string>();
657 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(string,IDictionary{string, string}).
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(string,IDictionary{string, string}).
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 .
const string EXPRESSION
Filter expression to limit records for notification
const string UPDATE_TOPIC_ID
The topic id for 'update' event in options
IDictionary< string, string > options
Optional parameters.
const string REFRESH_METHOD
Method controlling when the table monitor reports changes to the table_name.
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 <member name="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]'.
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.