public interface TablePublisher
extends java.io.Closeable
Table.getTablePublisher(String)
where a publisher name is specified. Tuples
published will include the name of the publisher and the specified sequenceNumber for tracking and recoverability
purposes.Modifier and Type | Field and Description |
---|---|
static int |
PUBLISH_BUFFER_SIZE_DEFAULT
The default number of tuples buffered on the client side before publishing to the server.
|
static long |
PUBLISH_INTERVAL_DEFAULT
The default time between buffer flushes when the buffer does not fill up completely.
|
static java.util.concurrent.TimeUnit |
PUBLISH_INTERVAL_TIME_UNIT_DEFAULT
Default publish interval units:
TimeUnit.MILLISECONDS . |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes client and server resources held by the publisher
|
void |
flush()
Force the currently buffered tuples to be sent to the server.
|
Schema |
getSchema()
Schema needed to create tuples for the publish method.
|
void |
publish(long sequenceNumber,
java.lang.Boolean CQSDelete,
Tuple tuple)
Publish a tuple with a sequenceNumber.
|
void |
publish(long sequenceNumber,
Tuple tuple)
Publish a tuple with a sequenceNumber.
|
void |
publish(Tuple tuple)
Publish a tuple without regard for recovering since no sequence number is specified.
|
static final int PUBLISH_BUFFER_SIZE_DEFAULT
static final long PUBLISH_INTERVAL_DEFAULT
TablePublisher.PUBLISH_INTERVAL_TIME_UNIT_DEFAULT
units.static final java.util.concurrent.TimeUnit PUBLISH_INTERVAL_TIME_UNIT_DEFAULT
TimeUnit.MILLISECONDS
.Schema getSchema()
void publish(long sequenceNumber, Tuple tuple) throws LiveViewException
sequenceNumber
- the identifier known to the publishertuple
- the tuple to publishLiveViewException
- if any server side exception occurs during publishingvoid publish(long sequenceNumber, java.lang.Boolean CQSDelete, Tuple tuple) throws LiveViewException
sequenceNumber
- the identifier known to the publisherCQSDelete
- - true if you wish to delete the row defined by the primary key valuestuple
- the tuple to publish. If CQSDelete is true the row which matches the primary key vaules is removed.LiveViewException
- if any server side exception occurs during publishingvoid publish(Tuple tuple) throws LiveViewException
tuple
- the tuple to publishLiveViewException
- if any server side exception occurs during publishingvoid flush() throws LiveViewException
LiveViewException
void close()
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable