| Package | Description |
|---|---|
| com.xxdb.compression | |
| com.xxdb.data | |
| com.xxdb.route | |
| com.xxdb.streaming.client |
| Modifier and Type | Method and Description |
|---|---|
Vector |
VectorDecompressor.decompress(EntityFactory factory,
ExtendedDataInput in,
boolean extended,
boolean isLittleEndian) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractVector |
class |
BasicAnyVector
Corresponds to DolphinDB tuple(any vector)
|
class |
BasicArrayVector |
class |
BasicBooleanVector
Corresponds to DolphinDB bool vector
|
class |
BasicByteVector
Corresponds to DolphinDB char vector
|
class |
BasicComplexVector |
class |
BasicDateHourVector
Corresponds to DolphinDB datehour vector
|
class |
BasicDateTimeVector
Corresponds to DolphinDB datetime vector
|
class |
BasicDateVector
Corresponds to DolphinDB date vector
|
class |
BasicDecimal128Vector |
class |
BasicDecimal32Vector |
class |
BasicDecimal64Vector |
class |
BasicDoubleVector
Corresponds to DolphinDB double vector
|
class |
BasicDurationVector |
class |
BasicFloatVector
Corresponds to DolphinDB float vector
|
class |
BasicInt128Vector |
class |
BasicIntVector
Corresponds to DolphinDB int vector
|
class |
BasicIotAnyVector |
class |
BasicIPAddrVector |
class |
BasicLongVector
Corresponds to DolphinDB long vector
|
class |
BasicMinuteVector
Corresponds to DolphinDB minute vector
|
class |
BasicMonthVector
Corresponds to DolphinDB month vector
|
class |
BasicNanoTimestampVector
Corresponds to DolphinDB nanotimestamp vector
|
class |
BasicNanoTimeVector
Corresponds to DolphinDB nanotime vector
|
class |
BasicPointVector |
class |
BasicSecondVector
Corresponds to DolphinDB second vector
|
class |
BasicShortVector
Corresponds to DolphinDB short vector
|
class |
BasicStringVector
Corresponds to DolphinDB string vector
|
class |
BasicSymbolVector
Corresponds to DolphinDB symbol vector
|
class |
BasicTimestampVector
Corresponds to DolphinDB timestamp vector
|
class |
BasicTimeVector
Corresponds to DolphinDB time vector
|
class |
BasicUuidVector |
class |
BasicVoidVector |
| Modifier and Type | Method and Description |
|---|---|
Vector |
BasicArrayVector.combine(Vector vector) |
Vector |
BasicNanoTimeVector.combine(Vector vector) |
Vector |
BasicComplexVector.combine(Vector vector) |
Vector |
BasicIotAnyVector.combine(Vector vector) |
Vector |
BasicNanoTimestampVector.combine(Vector vector) |
Vector |
BasicDateHourVector.combine(Vector vector) |
Vector |
BasicAnyVector.combine(Vector vector) |
Vector |
BasicFloatVector.combine(Vector vector) |
Vector |
BasicDateVector.combine(Vector vector) |
Vector |
BasicDateTimeVector.combine(Vector vector) |
Vector |
Vector.combine(Vector vector) |
Vector |
BasicDecimal128Vector.combine(Vector vector) |
Vector |
BasicIPAddrVector.combine(Vector vector) |
Vector |
BasicVoidVector.combine(Vector vector) |
Vector |
BasicPointVector.combine(Vector vector) |
Vector |
BasicIntVector.combine(Vector vector) |
Vector |
BasicSecondVector.combine(Vector vector) |
Vector |
BasicMinuteVector.combine(Vector vector) |
Vector |
BasicDoubleVector.combine(Vector vector) |
Vector |
BasicInt128Vector.combine(Vector vector) |
Vector |
BasicTimeVector.combine(Vector vector) |
Vector |
BasicMonthVector.combine(Vector vector) |
Vector |
BasicDurationVector.combine(Vector vector) |
Vector |
BasicLongVector.combine(Vector vector) |
Vector |
BasicBooleanVector.combine(Vector vector) |
Vector |
BasicUuidVector.combine(Vector vector) |
Vector |
BasicSymbolVector.combine(Vector vector) |
Vector |
BasicTimestampVector.combine(Vector vector) |
Vector |
BasicDecimal64Vector.combine(Vector vector) |
Vector |
BasicByteVector.combine(Vector vector) |
Vector |
BasicDecimal32Vector.combine(Vector vector) |
Vector |
BasicShortVector.combine(Vector vector) |
Vector |
BasicStringVector.combine(Vector vector) |
Vector |
EntityFactory.createPairWithDefaultValue(Entity.DATA_TYPE type) |
Vector |
BasicEntityFactory.createPairWithDefaultValue(Entity.DATA_TYPE type) |
Vector |
EntityFactory.createVectorWithDefaultValue(Entity.DATA_TYPE type,
int size,
int extra) |
Vector |
BasicEntityFactory.createVectorWithDefaultValue(Entity.DATA_TYPE type,
int size,
int extra) |
Vector |
BasicTable.getColumn(int index) |
Vector |
Table.getColumn(int index) |
Vector |
BasicTable.getColumn(String name) |
Vector |
Table.getColumn(String name) |
Vector |
Matrix.getColumnLabels() |
Vector |
AbstractMatrix.getColumnLabels() |
Vector |
BasicTensor.getData() |
Vector |
Matrix.getRowLabels() |
Vector |
AbstractMatrix.getRowLabels() |
Vector |
BasicArrayVector.getSubVector(int[] indices) |
Vector |
BasicNanoTimeVector.getSubVector(int[] indices) |
Vector |
BasicComplexVector.getSubVector(int[] indices) |
Vector |
BasicIotAnyVector.getSubVector(int[] indices) |
Vector |
BasicNanoTimestampVector.getSubVector(int[] indices) |
Vector |
BasicDateHourVector.getSubVector(int[] indices) |
Vector |
BasicAnyVector.getSubVector(int[] indices) |
Vector |
BasicFloatVector.getSubVector(int[] indices) |
Vector |
BasicDateVector.getSubVector(int[] indices) |
Vector |
BasicDateTimeVector.getSubVector(int[] indices) |
Vector |
Vector.getSubVector(int[] indices) |
Vector |
BasicDecimal128Vector.getSubVector(int[] indices) |
Vector |
BasicIPAddrVector.getSubVector(int[] indices) |
Vector |
BasicVoidVector.getSubVector(int[] indices) |
Vector |
BasicPointVector.getSubVector(int[] indices) |
Vector |
BasicIntVector.getSubVector(int[] indices) |
Vector |
BasicSecondVector.getSubVector(int[] indices) |
Vector |
BasicMinuteVector.getSubVector(int[] indices) |
Vector |
BasicDoubleVector.getSubVector(int[] indices) |
Vector |
BasicInt128Vector.getSubVector(int[] indices) |
Vector |
BasicTimeVector.getSubVector(int[] indices) |
Vector |
BasicMonthVector.getSubVector(int[] indices) |
Vector |
BasicDurationVector.getSubVector(int[] indices) |
Vector |
BasicLongVector.getSubVector(int[] indices) |
Vector |
BasicBooleanVector.getSubVector(int[] indices) |
Vector |
BasicUuidVector.getSubVector(int[] indices) |
Vector |
BasicSymbolVector.getSubVector(int[] indices) |
Vector |
BasicTimestampVector.getSubVector(int[] indices) |
Vector |
BasicDecimal64Vector.getSubVector(int[] indices) |
Vector |
BasicByteVector.getSubVector(int[] indices) |
Vector |
BasicDecimal32Vector.getSubVector(int[] indices) |
Vector |
BasicShortVector.getSubVector(int[] indices) |
Vector |
BasicStringVector.getSubVector(int[] indices) |
Vector |
BasicArrayVector.getVectorValue(int index) |
Vector |
BasicSet.keys() |
| Modifier and Type | Method and Description |
|---|---|
void |
BasicTable.addColumn(String colName,
Vector col) |
void |
Table.addColumn(String colName,
Vector col) |
void |
BasicArrayVector.Append(Vector value) |
void |
BasicNanoTimeVector.Append(Vector value) |
void |
BasicComplexVector.Append(Vector value) |
void |
BasicIotAnyVector.Append(Vector value) |
void |
BasicNanoTimestampVector.Append(Vector value) |
void |
BasicDateHourVector.Append(Vector value) |
void |
BasicAnyVector.Append(Vector value) |
void |
BasicFloatVector.Append(Vector value) |
void |
BasicDateVector.Append(Vector value) |
void |
BasicDateTimeVector.Append(Vector value) |
void |
Vector.Append(Vector value) |
void |
BasicDecimal128Vector.Append(Vector value) |
void |
BasicIPAddrVector.Append(Vector value) |
void |
BasicVoidVector.Append(Vector value) |
void |
BasicPointVector.Append(Vector value) |
void |
BasicIntVector.Append(Vector value) |
void |
BasicSecondVector.Append(Vector value) |
void |
BasicMinuteVector.Append(Vector value) |
abstract void |
AbstractVector.Append(Vector value) |
void |
BasicDoubleVector.Append(Vector value) |
void |
BasicInt128Vector.Append(Vector value) |
void |
BasicTimeVector.Append(Vector value) |
void |
BasicMonthVector.Append(Vector value) |
void |
BasicDurationVector.Append(Vector value) |
void |
BasicLongVector.Append(Vector value) |
void |
BasicBooleanVector.Append(Vector value) |
void |
BasicUuidVector.Append(Vector value) |
void |
BasicSymbolVector.Append(Vector value) |
void |
BasicTimestampVector.Append(Vector value) |
void |
BasicDecimal64Vector.Append(Vector value) |
void |
BasicByteVector.Append(Vector value) |
void |
BasicDecimal32Vector.Append(Vector value) |
void |
BasicShortVector.Append(Vector value) |
void |
BasicStringVector.Append(Vector value) |
Vector |
BasicArrayVector.combine(Vector vector) |
Vector |
BasicNanoTimeVector.combine(Vector vector) |
Vector |
BasicComplexVector.combine(Vector vector) |
Vector |
BasicIotAnyVector.combine(Vector vector) |
Vector |
BasicNanoTimestampVector.combine(Vector vector) |
Vector |
BasicDateHourVector.combine(Vector vector) |
Vector |
BasicAnyVector.combine(Vector vector) |
Vector |
BasicFloatVector.combine(Vector vector) |
Vector |
BasicDateVector.combine(Vector vector) |
Vector |
BasicDateTimeVector.combine(Vector vector) |
Vector |
Vector.combine(Vector vector) |
Vector |
BasicDecimal128Vector.combine(Vector vector) |
Vector |
BasicIPAddrVector.combine(Vector vector) |
Vector |
BasicVoidVector.combine(Vector vector) |
Vector |
BasicPointVector.combine(Vector vector) |
Vector |
BasicIntVector.combine(Vector vector) |
Vector |
BasicSecondVector.combine(Vector vector) |
Vector |
BasicMinuteVector.combine(Vector vector) |
Vector |
BasicDoubleVector.combine(Vector vector) |
Vector |
BasicInt128Vector.combine(Vector vector) |
Vector |
BasicTimeVector.combine(Vector vector) |
Vector |
BasicMonthVector.combine(Vector vector) |
Vector |
BasicDurationVector.combine(Vector vector) |
Vector |
BasicLongVector.combine(Vector vector) |
Vector |
BasicBooleanVector.combine(Vector vector) |
Vector |
BasicUuidVector.combine(Vector vector) |
Vector |
BasicSymbolVector.combine(Vector vector) |
Vector |
BasicTimestampVector.combine(Vector vector) |
Vector |
BasicDecimal64Vector.combine(Vector vector) |
Vector |
BasicByteVector.combine(Vector vector) |
Vector |
BasicDecimal32Vector.combine(Vector vector) |
Vector |
BasicShortVector.combine(Vector vector) |
Vector |
BasicStringVector.combine(Vector vector) |
void |
BasicTable.replaceColumn(String colName,
Vector col)
Replace modifies the specified column.
|
void |
Table.replaceColumn(String colName,
Vector col) |
void |
AbstractMatrix.setColumnLabels(Vector vector) |
void |
AbstractMatrix.setRowLabels(Vector vector) |
| Modifier and Type | Method and Description |
|---|---|
void |
BasicTable.setColumns(List<Vector> cols) |
| Constructor and Description |
|---|
BasicArrayVector(int[] index,
Vector value) |
| Constructor and Description |
|---|
BasicArrayVector(List<Vector> value) |
BasicTable(List<String> colNames,
List<Vector> cols) |
| Modifier and Type | Method and Description |
|---|---|
List<Integer> |
RangeDomain.getPartitionKeys(Vector partitionCol) |
List<Integer> |
Domain.getPartitionKeys(Vector partitionCol)
Given the values of a partition column, get the keys of partitions those values belong to.
|
List<Integer> |
ListDomain.getPartitionKeys(Vector partitionCol) |
List<Integer> |
ValueDomain.getPartitionKeys(Vector partitionCol) |
List<Integer> |
HashDomain.getPartitionKeys(Vector partitionCol) |
| Constructor and Description |
|---|
ListDomain(Vector list,
Entity.DATA_TYPE type,
Entity.DATA_CATEGORY cat) |
RangeDomain(Vector range,
Entity.DATA_TYPE type,
Entity.DATA_CATEGORY cat) |
ValueDomain(Vector partitionScheme,
Entity.DATA_TYPE type,
Entity.DATA_CATEGORY cat) |
| Modifier and Type | Method and Description |
|---|---|
Vector |
Site.getFilter() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ThreadPooledClient.backupSitesSubscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String password,
boolean createSubInfo) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler batchMessageHandler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
float throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler batchMessageHandler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
float throttle,
String userName,
String passWord) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler batchMessageHandler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
int throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler batchMessageHandler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
int throttle,
String userName,
String passWord) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler batchMessageHandler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
float throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
float throttle,
String userName,
String password) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
float throttle,
String userName,
String password,
boolean msgAsTable) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler batchMessageHandler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
int throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
BatchMessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
int throttle,
String userName,
String password) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
String userName,
String passWord) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
String userName,
String passWord,
boolean msgAsTable) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites,
int resubTimeout,
boolean subOnce) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect,
Vector filter,
String userName,
String passWord) |
TopicPoller |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
long offset,
Vector filter) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
float throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
float throttle,
String userName,
String passWord) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
int throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
int batchSize,
int throttle,
String userName,
String passWord) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
String userName,
String passWord) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
boolean allowExistTopic,
String userName,
String password) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
float throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
float throttle,
String userName,
String password) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
int throttle) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
int throttle,
String userName,
String password) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
int throttle,
String userName,
String password,
List<String> backupSites) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
int batchSize,
int throttle,
String userName,
String password,
List<String> backupSites,
int resubTimeout,
boolean subOnce) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String password) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable) |
protected void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String password,
boolean createSubInfo)
This internal subscribe method only use for when enable backupSite, try to switch site and subscribe.
|
protected void |
PollingClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String password,
boolean msgAsTable,
boolean createSubInfo) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites,
int resubTimeout,
boolean subOnce) |
void |
ThreadPooledClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
Vector filter) |
void |
ThreadedClient.subscribe(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
Vector filter) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
boolean createSubInfo) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites,
int resubTimeout,
boolean subOnce) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites,
int resubTimeout,
boolean subOnce,
boolean createSubInfo) |
Copyright © 2024 DolphinDB. All rights reserved.