public class WriterConfig extends Object
构造器和说明 |
---|
WriterConfig() |
限定符和类型 | 方法和说明 |
---|---|
BatchRequestType |
getBatchRequestType() |
int |
getBucketCount() |
int |
getBufferSize()
获取一个TableStoreWriter在内存中缓冲队列的大小,必须是2的指数。
|
int |
getCallbackThreadCount() |
int |
getCallbackThreadPoolQueueSize() |
int |
getClientMaxConnections() |
int |
getConcurrency()
获取一个TableStoreWriter的最大请求并发数。
|
DispatchMode |
getDispatchMode() |
int |
getFlushInterval()
设置writer自动flush的时间间隔,单位为毫秒。
|
int |
getLogInterval() |
int |
getMaxAttrColumnSize()
获取属性列的值的最大大小限制,单位Byte。
|
int |
getMaxBatchRowsCount()
获取一次批量RPC请求导入的最大行数。
|
int |
getMaxBatchSize()
获取一次批量RPC请求导入的最大数据量,单位Byte。
|
int |
getMaxColumnsCount()
获取一行的最大列数限制。
|
int |
getMaxPKColumnSize()
获取主键列的值的最大大小限制,单位Byte。
|
WriteMode |
getWriteMode() |
WriterRetryStrategy |
getWriterRetryStrategy() |
boolean |
isAllowDuplicatedRowInBatchRequest() |
boolean |
isEnableSchemaCheck()
获取是否开启在SDK层开启写入数据时的schema检查
|
void |
setAllowDuplicatedRowInBatchRequest(boolean allowDuplicatedRowInBatchRequest) |
void |
setBatchRequestType(BatchRequestType batchRequestType) |
void |
setBucketCount(int bucketCount) |
void |
setBufferSize(int bufferSize)
设置一个TableStoreWriter在内存中缓冲队列的大小。
|
void |
setCallbackThreadCount(int callbackThreadCount) |
void |
setCallbackThreadPoolQueueSize(int callbackThreadPoolQueueSize) |
void |
setClientMaxConnections(int clientMaxConnections) |
void |
setConcurrency(int concurrency)
设置一个TableStoreWriter的最大请求并发数。
|
void |
setDispatchMode(DispatchMode dispatchMode) |
void |
setEnableSchemaCheck(boolean enableSchemaCheck)
设置是否开启在SDK层写入数据时的schema检查
|
void |
setFlushInterval(int flushInterval)
获取writer自动flush的时间间隔,单位为毫秒。
|
void |
setLogInterval(int logInterval) |
void |
setMaxAttrColumnSize(int maxAttrColumnSize)
设置属性列的值的最大大小限制,单位Byte。
|
void |
setMaxBatchRowsCount(int maxBatchRowsCount)
设置一次批量RPC请求导入的最大行数。
|
void |
setMaxBatchSize(int maxBatchSize)
设置一次批量RPC请求导入的最大数据量,单位Byte。
|
void |
setMaxColumnsCount(int maxColumnsCount)
设置一行的最大列数限制。
|
void |
setMaxPKColumnSize(int maxPKColumnSize)
设置主键列的值的最大大小限制,单位Byte。
|
void |
setWriteMode(WriteMode writeMode) |
void |
setWriterRetryStrategy(WriterRetryStrategy writerRetryStrategy) |
public int getMaxPKColumnSize()
public void setMaxPKColumnSize(int maxPKColumnSize)
maxPKColumnSize
- 主键列的值的最大大小限制。public int getMaxAttrColumnSize()
public void setMaxAttrColumnSize(int maxAttrColumnSize)
maxAttrColumnSize
- 属性列的值的最大大小限制。public int getMaxColumnsCount()
public void setMaxColumnsCount(int maxColumnsCount)
maxColumnsCount
- 一行的最大列数限制。public int getMaxBatchRowsCount()
public void setMaxBatchRowsCount(int maxBatchRowsCount)
maxBatchRowsCount
- 一次批量RPC请求导入的最大行数。public int getMaxBatchSize()
public void setMaxBatchSize(int maxBatchSize)
maxBatchSize
- 一次批量RPC请求导入的最大数据量。public int getConcurrency()
public void setConcurrency(int concurrency)
concurrency
- 一个TableStoreWriter的最大请求并发数。public int getBufferSize()
public void setBufferSize(int bufferSize)
bufferSize
- 一个TableStoreWriter在内存中缓冲队列的大小。public int getFlushInterval()
public void setFlushInterval(int flushInterval)
flushInterval
- writer自动flush的时间间隔。public boolean isEnableSchemaCheck()
public void setEnableSchemaCheck(boolean enableSchemaCheck)
enableSchemaCheck
- 是否开启在SDK层写入数据时的schema检查public int getBucketCount()
public void setBucketCount(int bucketCount)
public DispatchMode getDispatchMode()
public void setDispatchMode(DispatchMode dispatchMode)
public WriteMode getWriteMode()
public void setWriteMode(WriteMode writeMode)
public BatchRequestType getBatchRequestType()
public void setBatchRequestType(BatchRequestType batchRequestType)
public int getLogInterval()
public void setLogInterval(int logInterval)
public int getCallbackThreadCount()
public void setCallbackThreadCount(int callbackThreadCount)
public int getCallbackThreadPoolQueueSize()
public void setCallbackThreadPoolQueueSize(int callbackThreadPoolQueueSize)
public WriterRetryStrategy getWriterRetryStrategy()
public void setWriterRetryStrategy(WriterRetryStrategy writerRetryStrategy)
public int getClientMaxConnections()
public void setClientMaxConnections(int clientMaxConnections)
public boolean isAllowDuplicatedRowInBatchRequest()
public void setAllowDuplicatedRowInBatchRequest(boolean allowDuplicatedRowInBatchRequest)
Copyright © 2021. All Rights Reserved.