Kinetica C# API  Version 7.1.10.0
 All Classes Namespaces Files Functions Variables Enumerations Enumerator Properties Pages
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 
10 
11 namespace kinetica
12 {
13 
43  {
44 
159  public struct Options
160  {
161 
190  public const string EVENT = "event";
191 
194  public const string INSERT = "insert";
195 
199  public const string UPDATE = "update";
200 
204  public const string DELETE = "delete";
205 
208  public const string MONITOR_ID = "monitor_id";
209 
213  public const string DATASINK_NAME = "datasink_name";
214 
218  public const string DESTINATION = "destination";
219 
223  public const string KAFKA_TOPIC_NAME = "kafka_topic_name";
224 
227  public const string INCREASING_COLUMN = "increasing_column";
228 
231  public const string EXPRESSION = "expression";
232 
252  public const string REFRESH_METHOD = "refresh_method";
253 
255  public const string ON_CHANGE = "on_change";
256 
259  public const string PERIODIC = "periodic";
260 
264  public const string REFRESH_PERIOD = "refresh_period";
265 
270  public const string REFRESH_START_TIME = "refresh_start_time";
271  } // end struct Options
272 
273 
278  public string table_name { get; set; }
279 
392  public IDictionary<string, string> options { get; set; } = new Dictionary<string, string>();
393 
394 
398 
520  IDictionary<string, string> options = null)
521  {
522  this.table_name = table_name ?? "";
523  this.options = options ?? new Dictionary<string, string>();
524  } // end constructor
525 
526  } // end class CreateTableMonitorRequest
527 
528 
529 
534  {
535 
578  public struct Info
579  {
580 
583  public const string INSERT_TOPIC_ID = "insert_topic_id";
584 
587  public const string UPDATE_TOPIC_ID = "update_topic_id";
588 
591  public const string DELETE_TOPIC_ID = "delete_topic_id";
592 
595  public const string INSERT_TYPE_SCHEMA = "insert_type_schema";
596 
598  public const string UPDATE_TYPE_SCHEMA = "update_type_schema";
599 
601  public const string DELETE_TYPE_SCHEMA = "delete_type_schema";
602  } // end struct Info
603 
604 
607  public string topic_id { get; set; }
608 
611  public string table_name { get; set; }
612 
615  public string type_schema { get; set; }
616 
657  public IDictionary<string, string> info { get; set; } = new Dictionary<string, string>();
658 
659  } // end class CreateTableMonitorResponse
660 
661 
662 
663 
664 } // 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(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 &#39;delete&#39; events
const string EXPRESSION
Filter expression to limit records for notification
const string UPDATE_TOPIC_ID
The topic id for &#39;update&#39; 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 &#39;delete&#39; event in options
const string UPDATE_TYPE_SCHEMA
The JSON Avro schema for &#39;update&#39; 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 &lt;member name=&quot;table_name&quot;&gt;
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 &#39;destination_type://path[:port]&#39;.
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 &#39;insert&#39; event in options
string type_schema
JSON Avro schema of the table, for use in decoding published records.