限定符和类型 | 方法和说明 |
---|---|
WriterConfig |
DefaultTableStoreWriter.getWriterConfig() |
WriterConfig |
TableStoreWriter.getWriterConfig()
获取限制项配置。
|
构造器和说明 |
---|
DefaultTableStoreWriter(AsyncClientInterface ots,
String tableName,
WriterConfig config,
TableStoreCallback<RowChange,ConsumedCapacity> callback,
Executor executor) |
DefaultTableStoreWriter(String endpoint,
ServiceCredentials credentials,
String instanceName,
String tableName,
WriterConfig config,
ClientConfiguration cc,
TableStoreCallback<RowChange,RowWriteResult> resultCallback) |
DefaultTableStoreWriter(String endpoint,
ServiceCredentials credentials,
String instanceName,
String tableName,
WriterConfig config,
TableStoreCallback<RowChange,RowWriteResult> resultCallback) |
限定符和类型 | 方法和说明 |
---|---|
static void |
ParamChecker.checkColumn(Map<String,PrimaryKeySchema> pkDefinedInMeta,
Column column,
WriterConfig config) |
static void |
ParamChecker.checkRowChange(TableMeta tableMeta,
RowChange rowChange,
WriterConfig config)
It does following checkings:
- primary key schema is matched with which defined in table meta
|
限定符和类型 | 方法和说明 |
---|---|
WriterConfig |
TimelineSchema.getWriterConfig() |
限定符和类型 | 方法和说明 |
---|---|
TimelineSchema |
TimelineSchema.withWriterConfig(WriterConfig writerConfig) |
构造器和说明 |
---|
TimestreamDBClient(AsyncClient asyncClient,
TimestreamDBConfiguration config,
WriterConfig writerConfig,
TableStoreCallback<RowChange,ConsumedCapacity> callback)
TimestreamDBClient的构造函数
|
构造器和说明 |
---|
Bucket(BucketConfig bucketConfig,
AsyncClientInterface ots,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> resultCallback,
Executor executor,
WriterHandleStatistics writerStatistics,
Semaphore semaphore) |
限定符和类型 | 字段和说明 |
---|---|
protected WriterConfig |
FlushCallbackFactory.writerConfig |
protected WriterConfig |
BaseRequestManager.writerConfig |
Copyright © 2021. All Rights Reserved.