7 using System.Collections.Generic;
113 public const string EVENT =
"event";
170 public IDictionary<string, string>
options {
get; set; } =
new Dictionary<string, string>();
219 IDictionary<string, string>
options = null)
221 this.table_name = table_name ??
"";
222 this.options =
options ??
new Dictionary<string, string>();
248 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}).
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.
string table_name
Value of .
IDictionary< string, string > options
Optional parameters.
string topic_id
The ZMQ topic ID to subscribe to for inserted records.
string table_name
Name of the table to monitor.
const string UPDATE
Get notifications of update operations.
KineticaData - class to help with Avro Encoding for Kinetica
IDictionary< string, string > info
Additional information.
string type_schema
JSON Avro schema of the table, for use in decoding published records.