| 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 |
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 |
BasicComplexVector.combine(Vector vector) |
Vector |
BasicMinuteVector.combine(Vector vector) |
Vector |
BasicInt128Vector.combine(Vector vector) |
Vector |
BasicNanoTimestampVector.combine(Vector vector) |
Vector |
BasicTimestampVector.combine(Vector vector) |
Vector |
BasicDecimal128Vector.combine(Vector vector) |
Vector |
BasicSecondVector.combine(Vector vector) |
Vector |
BasicDecimal32Vector.combine(Vector vector) |
Vector |
BasicMonthVector.combine(Vector vector) |
Vector |
BasicStringVector.combine(Vector vector) |
Vector |
BasicDoubleVector.combine(Vector vector) |
Vector |
BasicDateTimeVector.combine(Vector vector) |
Vector |
BasicVoidVector.combine(Vector vector) |
Vector |
BasicByteVector.combine(Vector vector) |
Vector |
BasicIntVector.combine(Vector vector) |
Vector |
BasicDurationVector.combine(Vector vector) |
Vector |
BasicFloatVector.combine(Vector vector) |
Vector |
BasicLongVector.combine(Vector vector) |
Vector |
BasicTimeVector.combine(Vector vector) |
Vector |
BasicDateHourVector.combine(Vector vector) |
Vector |
BasicDecimal64Vector.combine(Vector vector) |
Vector |
BasicSymbolVector.combine(Vector vector) |
Vector |
BasicAnyVector.combine(Vector vector) |
Vector |
BasicIPAddrVector.combine(Vector vector) |
Vector |
BasicShortVector.combine(Vector vector) |
Vector |
BasicArrayVector.combine(Vector vector) |
Vector |
BasicDateVector.combine(Vector vector) |
Vector |
BasicUuidVector.combine(Vector vector) |
Vector |
BasicPointVector.combine(Vector vector) |
Vector |
BasicNanoTimeVector.combine(Vector vector) |
Vector |
BasicBooleanVector.combine(Vector vector) |
Vector |
Vector.combine(Vector vector) |
Vector |
BasicEntityFactory.createPairWithDefaultValue(Entity.DATA_TYPE type) |
Vector |
EntityFactory.createPairWithDefaultValue(Entity.DATA_TYPE type) |
Vector |
BasicEntityFactory.createVectorWithDefaultValue(Entity.DATA_TYPE type,
int size,
int extra) |
Vector |
EntityFactory.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 |
Matrix.getRowLabels() |
Vector |
AbstractMatrix.getRowLabels() |
Vector |
BasicComplexVector.getSubVector(int[] indices) |
Vector |
BasicMinuteVector.getSubVector(int[] indices) |
Vector |
BasicInt128Vector.getSubVector(int[] indices) |
Vector |
BasicNanoTimestampVector.getSubVector(int[] indices) |
Vector |
BasicTimestampVector.getSubVector(int[] indices) |
Vector |
BasicDecimal128Vector.getSubVector(int[] indices) |
Vector |
BasicSecondVector.getSubVector(int[] indices) |
Vector |
BasicDecimal32Vector.getSubVector(int[] indices) |
Vector |
BasicMonthVector.getSubVector(int[] indices) |
Vector |
BasicStringVector.getSubVector(int[] indices) |
Vector |
BasicDoubleVector.getSubVector(int[] indices) |
Vector |
BasicDateTimeVector.getSubVector(int[] indices) |
Vector |
BasicVoidVector.getSubVector(int[] indices) |
Vector |
BasicByteVector.getSubVector(int[] indices) |
Vector |
BasicIntVector.getSubVector(int[] indices) |
Vector |
BasicDurationVector.getSubVector(int[] indices) |
Vector |
BasicFloatVector.getSubVector(int[] indices) |
Vector |
BasicLongVector.getSubVector(int[] indices) |
Vector |
BasicTimeVector.getSubVector(int[] indices) |
Vector |
BasicDateHourVector.getSubVector(int[] indices) |
Vector |
BasicDecimal64Vector.getSubVector(int[] indices) |
Vector |
BasicSymbolVector.getSubVector(int[] indices) |
Vector |
BasicAnyVector.getSubVector(int[] indices) |
Vector |
BasicIPAddrVector.getSubVector(int[] indices) |
Vector |
BasicShortVector.getSubVector(int[] indices) |
Vector |
BasicArrayVector.getSubVector(int[] indices) |
Vector |
BasicDateVector.getSubVector(int[] indices) |
Vector |
BasicUuidVector.getSubVector(int[] indices) |
Vector |
BasicPointVector.getSubVector(int[] indices) |
Vector |
BasicNanoTimeVector.getSubVector(int[] indices) |
Vector |
BasicBooleanVector.getSubVector(int[] indices) |
Vector |
Vector.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 |
BasicComplexVector.Append(Vector value) |
void |
BasicMinuteVector.Append(Vector value) |
void |
BasicInt128Vector.Append(Vector value) |
void |
BasicNanoTimestampVector.Append(Vector value) |
void |
BasicTimestampVector.Append(Vector value) |
void |
BasicDecimal128Vector.Append(Vector value) |
void |
BasicSecondVector.Append(Vector value) |
void |
BasicDecimal32Vector.Append(Vector value) |
void |
BasicMonthVector.Append(Vector value) |
void |
BasicStringVector.Append(Vector value) |
void |
BasicDoubleVector.Append(Vector value) |
void |
BasicDateTimeVector.Append(Vector value) |
void |
BasicVoidVector.Append(Vector value) |
abstract void |
AbstractVector.Append(Vector value) |
void |
BasicByteVector.Append(Vector value) |
void |
BasicIntVector.Append(Vector value) |
void |
BasicDurationVector.Append(Vector value) |
void |
BasicFloatVector.Append(Vector value) |
void |
BasicLongVector.Append(Vector value) |
void |
BasicTimeVector.Append(Vector value) |
void |
BasicDateHourVector.Append(Vector value) |
void |
BasicDecimal64Vector.Append(Vector value) |
void |
BasicSymbolVector.Append(Vector value) |
void |
BasicAnyVector.Append(Vector value) |
void |
BasicIPAddrVector.Append(Vector value) |
void |
BasicShortVector.Append(Vector value) |
void |
BasicArrayVector.Append(Vector value) |
void |
BasicDateVector.Append(Vector value) |
void |
BasicUuidVector.Append(Vector value) |
void |
BasicPointVector.Append(Vector value) |
void |
BasicNanoTimeVector.Append(Vector value) |
void |
BasicBooleanVector.Append(Vector value) |
void |
Vector.Append(Vector value) |
Vector |
BasicComplexVector.combine(Vector vector) |
Vector |
BasicMinuteVector.combine(Vector vector) |
Vector |
BasicInt128Vector.combine(Vector vector) |
Vector |
BasicNanoTimestampVector.combine(Vector vector) |
Vector |
BasicTimestampVector.combine(Vector vector) |
Vector |
BasicDecimal128Vector.combine(Vector vector) |
Vector |
BasicSecondVector.combine(Vector vector) |
Vector |
BasicDecimal32Vector.combine(Vector vector) |
Vector |
BasicMonthVector.combine(Vector vector) |
Vector |
BasicStringVector.combine(Vector vector) |
Vector |
BasicDoubleVector.combine(Vector vector) |
Vector |
BasicDateTimeVector.combine(Vector vector) |
Vector |
BasicVoidVector.combine(Vector vector) |
Vector |
BasicByteVector.combine(Vector vector) |
Vector |
BasicIntVector.combine(Vector vector) |
Vector |
BasicDurationVector.combine(Vector vector) |
Vector |
BasicFloatVector.combine(Vector vector) |
Vector |
BasicLongVector.combine(Vector vector) |
Vector |
BasicTimeVector.combine(Vector vector) |
Vector |
BasicDateHourVector.combine(Vector vector) |
Vector |
BasicDecimal64Vector.combine(Vector vector) |
Vector |
BasicSymbolVector.combine(Vector vector) |
Vector |
BasicAnyVector.combine(Vector vector) |
Vector |
BasicIPAddrVector.combine(Vector vector) |
Vector |
BasicShortVector.combine(Vector vector) |
Vector |
BasicArrayVector.combine(Vector vector) |
Vector |
BasicDateVector.combine(Vector vector) |
Vector |
BasicUuidVector.combine(Vector vector) |
Vector |
BasicPointVector.combine(Vector vector) |
Vector |
BasicNanoTimeVector.combine(Vector vector) |
Vector |
BasicBooleanVector.combine(Vector vector) |
Vector |
Vector.combine(Vector vector) |
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> |
ValueDomain.getPartitionKeys(Vector partitionCol) |
List<Integer> |
HashDomain.getPartitionKeys(Vector partitionCol) |
List<Integer> |
RangeDomain.getPartitionKeys(Vector partitionCol) |
List<Integer> |
ListDomain.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.
|
| 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 |
|---|---|
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,
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 |
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) |
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) |
Copyright © 2023 DolphinDB. All rights reserved.