Package | Description |
---|---|
com.buabook.kdb | |
com.buabook.kdb.data | |
com.buabook.kdb.interfaces | |
com.buabook.kdb.publisher |
Modifier and Type | Method and Description |
---|---|
static boolean |
Flips.isNullOrEmpty(KdbTable table) |
Modifier and Type | Field and Description |
---|---|
private KdbTable |
KdbTableIterator.table |
Modifier and Type | Method and Description |
---|---|
static KdbTable |
KdbTable.buildFromRowList(String name,
List<KdbDict> rows)
|
static KdbTable |
KdbTable.fromObject(Object object)
Generates a new
KdbTable object from an object. |
Modifier and Type | Method and Description |
---|---|
void |
KdbTable.append(KdbTable that)
Appends the specified table onto the current table (similar to the kdb+
uj function) |
Constructor and Description |
---|
KdbTableIterator(KdbTable table) |
Modifier and Type | Method and Description |
---|---|
void |
IKdbTableConsumer.consume(KdbTable table)
Consumes the specified kdb table to perform some action on the received data.
|
Modifier and Type | Field and Description |
---|---|
private ConcurrentLinkedQueue<KdbTable> |
KdbPublisherThread.publishBuffer
Buffer for all tables that are to be published on this thread to the KDB process
|
Modifier and Type | Method and Description |
---|---|
void |
KdbPublisherThread.publish(KdbTable table) |
Boolean |
KdbPublisher.publish(KdbTable table)
Allows a table (as an internal
KdbTable to be published to the target KDB process |
Modifier and Type | Method and Description |
---|---|
void |
KdbPublisherManager.publish(List<KdbProcess> servers,
List<KdbTable> tables)
Provides the ability to publish a number of
KdbTable 's to a specified list of
kdb processes. |
void |
KdbPublisherThread.publish(List<KdbTable> tables)
This method adds the list of tables to the publish buffer (
KdbPublisherThread.publishBuffer ) ready for
publishing to the kdb process on the next iteration of the main thread loop. |
void |
KdbPublisherManager.publish(List<KdbTable> tables)
Publishes the specified tables to all processes that are managed by this class.
|
List<Boolean> |
KdbPublisher.publish(List<KdbTable> tables)
Allows a list of tables to be published (in sequence) to the target KDB process
|
Copyright © 2017. All rights reserved.