| Package | Description |
|---|---|
| com.xxdb | |
| com.xxdb.data | |
| com.xxdb.multithreadedtablewriter | |
| com.xxdb.route | |
| com.xxdb.streaming.client | |
| com.xxdb.streaming.client.cep |
| Modifier and Type | Method and Description |
|---|---|
Entity |
BasicDBTask.call() |
Entity |
DBTask.getResult() |
Entity |
BasicDBTask.getResult() |
Entity |
DBConnection.run(String script) |
Entity |
DBConnection.run(String script,
boolean clearSessionMemory) |
Entity |
DBConnection.run(String script,
int priority) |
Entity |
DBConnection.run(String script,
int priority,
boolean clearSessionMemory) |
Entity |
DBConnection.run(String script,
int priority,
int parallelism) |
Entity |
DBConnection.run(String script,
int priority,
int parallelism,
boolean clearSessionMemory) |
Entity |
DBConnection.run(String function,
List<Entity> arguments) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize,
boolean enableSeqNo) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize,
boolean enableSeqNo,
ProgressListener listener) |
Entity |
DBConnection.run(String script,
ProgressListener listener) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
boolean clearSessionMemory) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
int priority,
int parallelism) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
int priority,
int parallelism,
boolean clearSessionMemory) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
int priority,
int parallelism,
int fetchSize) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
int priority,
int parallelism,
int fetchSize,
boolean clearSessionMemory) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
int priority,
int parallelism,
int fetchSize,
boolean clearSessionMemory,
String tableName) |
Entity |
DBConnection.run(String script,
ProgressListener listener,
int priority,
int parallelism,
int fetchSize,
boolean clearSessionMemory,
String tableName,
boolean enableSeqNo) |
Entity |
DBConnection.run(String script,
String tableName) |
Entity |
DBConnection.tryRun(String script) |
Entity |
DBConnection.tryRun(String script,
boolean clearSessionMemory) |
Entity |
DBConnection.tryRun(String script,
int priority,
int parallelism) |
Entity |
DBConnection.tryRun(String script,
int priority,
int parallelism,
boolean clearSessionMemory) |
Entity |
DBConnection.tryRun(String script,
int priority,
int parallelism,
int fetchSize,
boolean clearSessionMemory) |
Entity |
DBConnection.tryRun(String function,
List<Entity> arguments) |
Entity |
DBConnection.tryRun(String function,
List<Entity> arguments,
int priority,
int parallelism) |
Entity |
DBConnection.tryRun(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize) |
| Modifier and Type | Method and Description |
|---|---|
Entity |
DBConnection.run(String function,
List<Entity> arguments) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize,
boolean enableSeqNo) |
Entity |
DBConnection.run(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize,
boolean enableSeqNo,
ProgressListener listener) |
Entity |
DBConnection.tryRun(String function,
List<Entity> arguments) |
Entity |
DBConnection.tryRun(String function,
List<Entity> arguments,
int priority,
int parallelism) |
Entity |
DBConnection.tryRun(String function,
List<Entity> arguments,
int priority,
int parallelism,
int fetchSize) |
void |
DBConnection.tryUpload(Map<String,Entity> variableObjectMap) |
void |
DBConnection.upload(Map<String,Entity> variableObjectMap) |
| Constructor and Description |
|---|
BasicDBTask(String script,
List<Entity> args) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
Chart
Interface for chart object
|
interface |
Dictionary |
interface |
ExtendObj |
interface |
Matrix
Interface for matrix object
|
interface |
Scalar
Interface for scalar object
|
interface |
Set |
interface |
Table
Interface for table object
|
interface |
Tensor |
interface |
Vector
Interface for DolphinDB data form: ARRAY, BIGARRAY
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractExtendObj |
class |
AbstractMatrix |
class |
AbstractScalar |
class |
AbstractTensor |
class |
AbstractVector |
class |
BasicAnyVector
Corresponds to DolphinDB tuple(any vector)
|
class |
BasicArrayVector |
class |
BasicBoolean
Corresponds to DolphinDB bool scalar
|
class |
BasicBooleanMatrix
Corresponds to DolphinDB bool matrix
|
class |
BasicBooleanVector
Corresponds to DolphinDB bool vector
|
class |
BasicByte
Corresponds to DolphinDB char scalar
|
class |
BasicByteMatrix
Corresponds to DolphinDB char matrix
|
class |
BasicByteVector
Corresponds to DolphinDB char vector
|
class |
BasicChart
Corresponds to DolphinDB chart object
|
class |
BasicChunkMeta |
class |
BasicComplex |
class |
BasicComplexMatrix |
class |
BasicComplexVector |
class |
BasicDate
Corresponds to DolphinDB date scalar
|
class |
BasicDateHour
Corresponds to DolphinDB datehour scalar
|
class |
BasicDateHourMatrix
Corresponds to DolphinDB datehour matrix
|
class |
BasicDateHourVector
Corresponds to DolphinDB datehour vector
|
class |
BasicDateMatrix
Corresponds to DolphinDB date matrix
|
class |
BasicDateTime
Corresponds to DolphinDB datetime scalar
|
class |
BasicDateTimeMatrix
Corresponds to DolphinDB datetime matrix
|
class |
BasicDateTimeVector
Corresponds to DolphinDB datetime vector
|
class |
BasicDateVector
Corresponds to DolphinDB date vector
|
class |
BasicDecimal128 |
class |
BasicDecimal128Matrix |
class |
BasicDecimal128Vector |
class |
BasicDecimal32 |
class |
BasicDecimal32Matrix |
class |
BasicDecimal32Vector |
class |
BasicDecimal64 |
class |
BasicDecimal64Matrix |
class |
BasicDecimal64Vector |
class |
BasicDictionary
Corresponds to DolphinDB dictionary object
|
class |
BasicDouble
Corresponds to DolphinDB double scalar
|
class |
BasicDoubleMatrix
Corresponds to DolphinDB double matrix
|
class |
BasicDoubleVector
Corresponds to DolphinDB double vector
|
class |
BasicDuration |
class |
BasicDurationVector |
class |
BasicFloat
Corresponds to DolphinDB float scalar
|
class |
BasicFloatMatrix
Corresponds to DolphinDB float matrix
|
class |
BasicFloatVector
Corresponds to DolphinDB float vector
|
class |
BasicInstrument |
class |
BasicInt
Corresponds to DolphinDB int scalar
|
class |
BasicInt128 |
class |
BasicInt128Vector |
class |
BasicIntMatrix
Corresponds to DolphinDB int matrix
|
class |
BasicIntVector
Corresponds to DolphinDB int vector
|
class |
BasicIotAnyVector |
class |
BasicIPAddr |
class |
BasicIPAddrVector |
class |
BasicLong
Corresponds to DolphindB long scalar
|
class |
BasicLongMatrix
Corresponds to DolphinDB long matrix
|
class |
BasicLongVector
Corresponds to DolphinDB long vector
|
class |
BasicMinute
Corresponds to DolphinDB minute scalar
|
class |
BasicMinuteMatrix
Corresponds to DolphinDB minute matrix
|
class |
BasicMinuteVector
Corresponds to DolphinDB minute vector
|
class |
BasicMktData |
class |
BasicMonth
Corresponds to DolphinDB month scalar
|
class |
BasicMonthMatrix
Corresponds to DolphinDB month matrix
|
class |
BasicMonthVector
Corresponds to DolphinDB month vector
|
class |
BasicNanoTime
Corresponds to DolphinDB nanotime scalar.
|
class |
BasicNanoTimeMatrix
Corresponds to DolphinDB nanotime matrix.
|
class |
BasicNanoTimestamp
Corresponds to DolphinDB nanotimestamp scalar
|
class |
BasicNanoTimestampMatrix
Corresponds to DolphinDB nanotimestamp matrix
|
class |
BasicNanoTimestampVector
Corresponds to DolphinDB nanotimestamp vector
|
class |
BasicNanoTimeVector
Corresponds to DolphinDB nanotime vector
|
class |
BasicPoint |
class |
BasicPointVector |
class |
BasicSecond
Corresponds to DolphinDB second scalar
|
class |
BasicSecondMatrix
Corresponds to DolphinDB second matrix
|
class |
BasicSecondVector
Corresponds to DolphinDB second vector
|
class |
BasicSet
Corresponds to DolphinDB set object
|
class |
BasicShort
Corresponds to DolphinDB short scalar
|
class |
BasicShortMatrix
Corresponds to DolphinDB short matrix
|
class |
BasicShortVector
Corresponds to DolphinDB short vector
|
class |
BasicString
Corresponds to DolphinDB string scalar
|
class |
BasicStringMatrix
Corresponds to DolphinDB string matrix
|
class |
BasicStringVector
Corresponds to DolphinDB string vector
|
class |
BasicSymbolVector
Corresponds to DolphinDB symbol vector
|
class |
BasicSystemEntity |
class |
BasicTable
Corresponds to DolphinDB table object
|
class |
BasicTableSchema |
class |
BasicTensor |
class |
BasicTime
Corresponds to DolphinDB time scalar.
|
class |
BasicTimeMatrix
Corresponds to DolphinDB time matrix.
|
class |
BasicTimestamp
Corresponds to DolphinDB timestamp scalar
|
class |
BasicTimestampMatrix
Corresponds to DolphinDB timestamp matrix
|
class |
BasicTimestampVector
Corresponds to DolphinDB timestamp vector
|
class |
BasicTimeVector
Corresponds to DolphinDB time vector
|
class |
BasicUuid |
class |
BasicUuidVector |
class |
BasicVoidVector |
class |
EntityBlockReader |
class |
Void |
| Modifier and Type | Method and Description |
|---|---|
static Entity |
Utils.castDateTime(Entity source,
Entity.DATA_TYPE newDateTimeType) |
Entity |
EntityFactory.createEntity(Entity.DATA_FORM form,
Entity.DATA_TYPE type,
ExtendedDataInput in,
boolean exteneded) |
Entity |
BasicEntityFactory.createEntity(Entity.DATA_FORM form,
Entity.DATA_TYPE type,
ExtendedDataInput in,
boolean extended) |
static Entity |
BasicEntityFactory.createScalar(Entity.DATA_TYPE dataType,
Object object,
int extraParam) |
Entity |
BasicArrayVector.get(int index) |
Entity |
BasicNanoTimeVector.get(int index) |
Entity |
BasicComplexVector.get(int index) |
Entity |
BasicIotAnyVector.get(int index) |
Entity |
BasicNanoTimestampVector.get(int index) |
Entity |
BasicDateHourVector.get(int index) |
Entity |
BasicAnyVector.get(int index) |
Entity |
BasicFloatVector.get(int index) |
Entity |
BasicDateVector.get(int index) |
Entity |
BasicDateTimeVector.get(int index) |
Entity |
Vector.get(int index) |
Entity |
BasicDecimal128Vector.get(int index) |
Entity |
BasicVoidVector.get(int index) |
Entity |
BasicPointVector.get(int index) |
Entity |
BasicIntVector.get(int index) |
Entity |
BasicSecondVector.get(int index) |
Entity |
BasicMinuteVector.get(int index) |
Entity |
BasicDoubleVector.get(int index) |
Entity |
BasicInt128Vector.get(int index) |
Entity |
BasicTimeVector.get(int index) |
Entity |
BasicMonthVector.get(int index) |
Entity |
BasicDurationVector.get(int index) |
Entity |
BasicLongVector.get(int index) |
Entity |
BasicBooleanVector.get(int index) |
Entity |
BasicSymbolVector.get(int index) |
Entity |
BasicTimestampVector.get(int index) |
Entity |
BasicDecimal64Vector.get(int index) |
Entity |
BasicByteVector.get(int index) |
Entity |
BasicDecimal32Vector.get(int index) |
Entity |
BasicShortVector.get(int index) |
Entity |
BasicStringVector.get(int index) |
Entity |
BasicDictionary.get(Scalar key) |
Entity |
Dictionary.get(Scalar key) |
Entity |
BasicDictionary.get(String key) |
Entity |
Matrix.getColumnLabel(int column) |
Entity |
AbstractMatrix.getColumnLabel(int index) |
Entity |
BasicAnyVector.getEntity(int index) |
Entity |
Chart.getExtraParameter(CHART_PARAMETER_TYPE key) |
Entity |
BasicChart.getExtraParameter(CHART_PARAMETER_TYPE key) |
Entity |
Matrix.getRowLabel(int row) |
Entity |
AbstractMatrix.getRowLabel(int index) |
Entity |
EntityBlockReader.read() |
static Entity |
Utils.toDate(Entity source) |
static Entity |
Utils.toDateHour(Entity source) |
static Entity |
Utils.toMonth(Entity source) |
| Modifier and Type | Method and Description |
|---|---|
Set<Map.Entry<Entity,Entity>> |
BasicDictionary.entrySet() |
Set<Map.Entry<Entity,Entity>> |
BasicDictionary.entrySet() |
Set<Entity> |
BasicDictionary.keys() |
Collection<Entity> |
BasicDictionary.values() |
| Modifier and Type | Method and Description |
|---|---|
static Entity |
Utils.castDateTime(Entity source,
Entity.DATA_TYPE newDateTimeType) |
boolean |
BasicDictionary.put(Scalar key,
Entity value) |
boolean |
Dictionary.put(Scalar key,
Entity value) |
void |
BasicArrayVector.set(int index,
Entity value) |
void |
BasicComplexVector.set(int index,
Entity value) |
void |
BasicIotAnyVector.set(int index,
Entity value) |
void |
BasicAnyVector.set(int index,
Entity value) |
void |
BasicFloatVector.set(int index,
Entity value) |
void |
Vector.set(int index,
Entity value) |
void |
BasicDecimal128Vector.set(int index,
Entity value) |
void |
BasicVoidVector.set(int index,
Entity value) |
void |
BasicPointVector.set(int index,
Entity value) |
void |
BasicIntVector.set(int index,
Entity value) |
void |
BasicDoubleVector.set(int index,
Entity value) |
void |
BasicInt128Vector.set(int index,
Entity value) |
void |
BasicDurationVector.set(int index,
Entity value) |
void |
BasicLongVector.set(int index,
Entity value) |
void |
BasicBooleanVector.set(int index,
Entity value) |
void |
BasicSymbolVector.set(int index,
Entity value) |
void |
BasicDecimal64Vector.set(int index,
Entity value) |
void |
BasicByteVector.set(int index,
Entity value) |
void |
BasicDecimal32Vector.set(int index,
Entity value) |
void |
BasicShortVector.set(int index,
Entity value) |
void |
BasicStringVector.set(int index,
Entity value) |
void |
BasicDecimal64Matrix.set(int row,
int column,
Entity value) |
void |
BasicDecimal128Matrix.set(int row,
int column,
Entity value) |
void |
BasicDecimal32Matrix.set(int row,
int column,
Entity value) |
void |
BasicAnyVector.setEntity(int index,
Entity value) |
static Entity |
Utils.toDate(Entity source) |
static Entity |
Utils.toDateHour(Entity source) |
static Entity |
Utils.toMonth(Entity source) |
| Constructor and Description |
|---|
BasicAnyVector(Entity[] array,
boolean copy) |
| Modifier and Type | Method and Description |
|---|---|
List<List<Entity>> |
MultithreadedTableWriter.getFailedData() |
List<List<Entity>> |
MultithreadedTableWriter.getUnwrittenData() |
| Modifier and Type | Method and Description |
|---|---|
ErrorCodeInfo |
MultithreadedTableWriter.insertUnwrittenData(List<List<Entity>> records) |
| Modifier and Type | Method and Description |
|---|---|
Entity |
AutoFitTableAppender.append(BasicTable table) |
| Modifier and Type | Method and Description |
|---|---|
static Domain |
DomainFactory.createDomain(Entity.PARTITION_TYPE type,
Entity.DATA_TYPE partitionColType,
Entity partitionSchema) |
| Modifier and Type | Method and Description |
|---|---|
Entity |
BasicMessage.getEntity(int colIndex) |
Entity |
IMessage.getEntity(int colIndex) |
Entity |
BasicMessage.getMsg() |
| Modifier and Type | Method and Description |
|---|---|
void |
ScalarAttributeSerializer.serialize(Entity attribute,
ExtendedDataOutput out) |
void |
FastArrayAttributeSerializer.serialize(Entity attribute,
ExtendedDataOutput out) |
void |
StringScalarAttributeSerializer.serialize(Entity attribute,
ExtendedDataOutput outStream) |
void |
AttributeSerializer.serialize(Entity attribute,
ExtendedDataOutput out) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
EventHandler.deserializeEvent(List<IMessage> msgs,
List<String> eventTypes,
List<List<Entity>> attributes,
ErrorCodeInfo errorInfo) |
void |
EventMessageHandler.doEvent(String eventType,
List<Entity> attribute) |
void |
EventSender.sendEvent(String eventType,
List<Entity> attributes) |
boolean |
EventHandler.serializeEvent(String eventType,
List<Entity> attributes,
List<Entity> serializedEvent,
StringBuilder errMsg) |
boolean |
EventHandler.serializeEvent(String eventType,
List<Entity> attributes,
List<Entity> serializedEvent,
StringBuilder errMsg) |
Copyright © 2025 DolphinDB. All rights reserved.