Version:

Create Table Monitor

Creates a monitor that watches for new records inserted into a particular table (identified by input parameter table_name) and forwards copies to subscribers via ZMQ. After this call completes, subscribe to the returned output parameter topic_id on the ZMQ table monitor port (default 9002). Each time an insert operation on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that was inserted. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with Clear Table Monitor.

Input Parameter Description

Name Type Description
table_name string Name of the table to monitor. Must not refer to a collection.
options map of string to strings Optional parameters. The default value is an empty map ( {} ).

Output Parameter Description

Name Type Description
topic_id string The ZMQ topic ID to subscribe to for inserted records.
table_name string Value of input parameter table_name.
type_schema string JSON Avro schema of the table, for use in decoding published records.