7 using System.Collections.Generic;
32 public class CreateTableMonitorRequest : KineticaData
64 public const string EVENT =
"event";
69 public const string INSERT =
"insert";
74 public const string UPDATE =
"update";
79 public const string DELETE =
"delete";
107 public const string EXPRESSION =
"expression";
159 public const string ON_CHANGE =
"on_change";
163 public const string PERIODIC =
"periodic";
341 public IDictionary<string, string>
options {
get;
set; } =
new Dictionary<string, string>();
510 IDictionary<string, string>
options =
null)
520 public class CreateTableMonitorResponse : KineticaData
529 public const string TTL =
"ttl";
562 public string topic_id {
get;
set; }
630 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.
const string REFRESH_START_TIME
When REFRESH_METHOD is PERIODIC, specifies the first time at which changes are reported.
const string UPDATE_TOPIC_ID
The topic id for 'update' EVENT in options
const string DELETE
Get notifications of delete operations.
const string DESTINATION
Destination for the output data in format 'destination_type://path[:port]'.
const string MONITOR_ID
ID to use for this monitor instead of a randomly generated one
string table_name
Value of table_name.
const string INSERT_TYPE_SCHEMA
The JSON Avro schema of the table in table_name
CreateTableMonitorRequest()
Constructs a CreateTableMonitorRequest object with default parameters.
IDictionary< string, string > info
Additional information.
const string DATASINK_NAME
Name of an existing data sink to send change data notifications to
const string JOIN_TABLE_NAMES
A comma-separated list of tables (optionally with aliases) to include in the join.
const string UPDATE
Get notifications of update operations.
const string PERIODIC
Report changes periodically at rate specified by REFRESH_PERIOD.
const string TTL
For insert_table/delete_table events, the ttl of the table.
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 > options
Optional parameters.
string topic_id
The ZMQ topic ID to subscribe to for table events.
const string EVENT
Type of modification event on the target table to be monitored by this table monitor.
const string JOIN_EXPRESSIONS
Optional filter or join expressions to apply when combining the tables.
const string ON_CHANGE
Report changes as they occur.
const string JOIN_COLUMN_NAMES
A comma-separated list of columns or expressions to include from the joined tables.
const string UPDATE_TYPE_SCHEMA
The JSON Avro schema for 'update' events
const string INSERT_TOPIC_ID
The topic id for 'insert' EVENT in options
const string INCREASING_COLUMN
Column on subscribed table that will increase for new records (e.g., TIMESTAMP).
const string DELETE_TOPIC_ID
The topic id for 'delete' EVENT in options
const string EXPRESSION
Filter expression to limit records for notification
string type_schema
JSON Avro schema of the table, for use in decoding published records.
string table_name
Name of the table to monitor, in [schema_name.
const string REFRESH_METHOD
Method controlling when the table monitor reports changes to the table_name.
const string REFRESH_PERIOD
When REFRESH_METHOD is PERIODIC, specifies the period in seconds at which changes are reported.
const string INSERT
Get notifications of new record insertions.
const string DELETE_TYPE_SCHEMA
The JSON Avro schema for 'delete' events