public class CreateTableMonitorRequest extends Object implements org.apache.avro.generic.IndexedRecord
GPUdb.createTableMonitor(CreateTableMonitorRequest)
.
tableName
) and
forwards copies to subscribers via ZMQ. After this call completes, subscribe to the returned topicId
on the GPUdb 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 GPUdb.clearTableMonitor(ClearTableMonitorRequest)
.Constructor and Description |
---|
CreateTableMonitorRequest()
Constructs a CreateTableMonitorRequest object with default parameters.
|
CreateTableMonitorRequest(String tableName,
Map<String,String> options)
Constructs a CreateTableMonitorRequest object with the specified parameters.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
Object |
get(int index)
This method supports the Avro framework and is not intended to be called directly by the user.
|
static org.apache.avro.Schema |
getClassSchema()
This method supports the Avro framework and is not intended to be called directly by the user.
|
Map<String,String> |
getOptions() |
org.apache.avro.Schema |
getSchema()
This method supports the Avro framework and is not intended to be called directly by the user.
|
String |
getTableName() |
int |
hashCode() |
void |
put(int index,
Object value)
This method supports the Avro framework and is not intended to be called directly by the user.
|
CreateTableMonitorRequest |
setOptions(Map<String,String> options) |
CreateTableMonitorRequest |
setTableName(String tableName) |
String |
toString() |
public CreateTableMonitorRequest()
public static org.apache.avro.Schema getClassSchema()
public String getTableName()
public CreateTableMonitorRequest setTableName(String tableName)
tableName
- Name of the table to monitor. Must not refer to a collection.this
to mimic the builder pattern.public CreateTableMonitorRequest setOptions(Map<String,String> options)
options
- Optional parameters.this
to mimic the builder pattern.public org.apache.avro.Schema getSchema()
getSchema
in interface org.apache.avro.generic.GenericContainer
public Object get(int index)
get
in interface org.apache.avro.generic.IndexedRecord
index
- the position of the field to getIndexOutOfBoundsException
public void put(int index, Object value)
put
in interface org.apache.avro.generic.IndexedRecord
index
- the position of the field to setvalue
- the value to setIndexOutOfBoundsException
Copyright © 2016. All rights reserved.