Package | Description |
---|---|
com.buabook.kdb | |
com.buabook.kdb.consumer | |
com.buabook.kdb.data | |
com.buabook.kdb.query |
Modifier and Type | Method and Description |
---|---|
static boolean |
Dicts.isNullOrEmpty(KdbDict dict) |
Modifier and Type | Field and Description |
---|---|
private KdbDict |
KdbConsumer.subscriptionConfiguration
An optional dictionary of subscription information if the upstream kdb process supports subscription configuration
|
Constructor and Description |
---|
KdbConsumer(KdbProcess server,
KdbDict subscriptionConfiguration,
IKdbRawDataConsumer rawDataConsumer,
IKdbTableConsumer tableConsumer) |
KdbConsumer(KdbProcess server,
List<String> tables,
KdbDict subscriptionConfiguration,
IKdbRawDataConsumer rawDataConsumer,
IKdbTableConsumer tableConsumer) |
KdbConsumerThread(KdbProcess server,
KdbDict subscriptionConfig,
IKdbRawDataConsumer rawDataConsumer,
IKdbTableConsumer tableConsumer,
IKdbConsumerFailedListener failureListener) |
Modifier and Type | Method and Description |
---|---|
KdbDict |
KdbDict.add(Object key,
Object value)
Adds a new key / value pair to the dictionary
|
KdbDict |
KdbDict.add(Object key,
Object value,
Class<?> elementType)
Adds a new key / value pair to the dictionary with
null detection |
static KdbDict |
KdbDict.fromObject(Object object)
Generates a new
KdbDict object from an object. |
KdbDict |
KdbTable.getRow(int rowNumber)
Provides the ability to return a specified row of the table.
|
KdbDict |
KdbTableIterator.next() |
KdbDict |
KdbDict.union(KdbDict that)
Allows the joining of 2 dictionaries of distinct elements together
|
Modifier and Type | Method and Description |
---|---|
Iterator<KdbDict> |
KdbTable.iterator() |
Stream<KdbDict> |
KdbTable.stream()
TODO: Implement
Collection interface so this is an override |
Modifier and Type | Method and Description |
---|---|
void |
KdbTable.addRow(KdbDict row) |
KdbDict |
KdbDict.union(KdbDict that)
Allows the joining of 2 dictionaries of distinct elements together
|
Modifier and Type | Method and Description |
---|---|
static KdbTable |
KdbTable.buildFromRowList(String name,
List<KdbDict> rows)
|
Modifier and Type | Method and Description |
---|---|
Object |
KdbSyncQuery.query(String query,
KdbDict arguments)
NOTE: This function does not perform any re-send of the query in case the connection
fails (due to
IOException ). |
abstract Object |
KdbQuery.query(String query,
KdbDict arguments)
Method to query a kdb process with a function name and a dictionary argument.
|
Object |
KdbAsyncQuery.query(String query,
KdbDict arguments)
NOTE: This function does not perform any re-send of the query in case the connection
fails (due to
IOException ). |
Copyright © 2017. All rights reserved.