Kinetica   C#   API  Version 7.2.3.0
CreateTableMonitor.cs
Go to the documentation of this file.
1 /*
2  * This file was autogenerated by the Kinetica schema processor.
3  *
4  * DO NOT EDIT DIRECTLY.
5  */
6 
7 using System.Collections.Generic;
8 
9 namespace kinetica
10 {
33  {
37  public struct Options
38  {
64  public const string EVENT = "event";
65 
69  public const string INSERT = "insert";
70 
74  public const string UPDATE = "update";
75 
79  public const string DELETE = "delete";
80 
83  public const string MONITOR_ID = "monitor_id";
84 
88  public const string DATASINK_NAME = "datasink_name";
89 
94  public const string DESTINATION = "destination";
95 
99  public const string KAFKA_TOPIC_NAME = "kafka_topic_name";
100 
103  public const string INCREASING_COLUMN = "increasing_column";
104 
107  public const string EXPRESSION = "expression";
108 
130  public const string REFRESH_METHOD = "refresh_method";
131 
133  public const string ON_CHANGE = "on_change";
134 
137  public const string PERIODIC = "periodic";
138 
143  public const string REFRESH_PERIOD = "refresh_period";
144 
151  public const string REFRESH_START_TIME = "refresh_start_time";
152  } // end struct Options
153 
158  public string table_name { get; set; }
159 
281  public IDictionary<string, string> options { get; set; } = new Dictionary<string, string>();
282 
286 
416  IDictionary<string, string> options = null)
417  {
418  this.table_name = table_name ?? "";
419  this.options = options ?? new Dictionary<string, string>();
420  } // end constructor
421  } // end class CreateTableMonitorRequest
422 
427  {
431  public struct Info
432  {
435  public const string TTL = "ttl";
436 
441  public const string INSERT_TOPIC_ID = "insert_topic_id";
442 
447  public const string UPDATE_TOPIC_ID = "update_topic_id";
448 
453  public const string DELETE_TOPIC_ID = "delete_topic_id";
454 
457  public const string INSERT_TYPE_SCHEMA = "insert_type_schema";
458 
460  public const string UPDATE_TYPE_SCHEMA = "update_type_schema";
461 
463  public const string DELETE_TYPE_SCHEMA = "delete_type_schema";
464  } // end struct Info
465 
468  public string topic_id { get; set; }
469 
473  public string table_name { get; set; }
474 
477  public string type_schema { get; set; }
478 
536  public IDictionary<string, string> info { get; set; } = new Dictionary<string, string>();
537  } // end class CreateTableMonitorResponse
538 } // end namespace kinetica
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
Definition: KineticaData.cs:14
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.