public class TimeseriesWriterConfig extends Object
| Constructor and Description |
|---|
TimeseriesWriterConfig() |
| Modifier and Type | Method and Description |
|---|---|
int |
getBucketCount() |
int |
getBufferSize()
获取一个TableStoreWriter在内存中缓冲队列的大小,必须是2的指数。
|
int |
getCallbackThreadCount() |
int |
getCallbackThreadPoolQueueSize() |
int |
getClientMaxConnections() |
int |
getConcurrency()
获取一个TableStoreWriter的最大请求并发数。
|
TSDispatchMode |
getDispatchMode() |
int |
getFlushInterval()
设置writer自动flush的时间间隔,单位为毫秒。
|
int |
getLogInterval() |
int |
getMaxBatchRowsCount()
获取一次批量RPC请求导入的最大行数。
|
int |
getMaxBatchSize()
获取一次批量RPC请求导入的最大数据量,单位Byte。
|
TSWriteMode |
getWriteMode() |
WriterRetryStrategy |
getWriterRetryStrategy() |
boolean |
isAllowDuplicatedRowInBatchRequest() |
void |
setAllowDuplicatedRowInBatchRequest(boolean allowDuplicatedRowInBatchRequest) |
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(TSDispatchMode dispatchMode) |
void |
setFlushInterval(int flushInterval)
获取writer自动flush的时间间隔,单位为毫秒。
|
void |
setLogInterval(int logInterval) |
void |
setMaxBatchRowsCount(int maxBatchRowsCount)
设置一次批量RPC请求导入的最大行数。
|
void |
setMaxBatchSize(int maxBatchSize)
设置一次批量RPC请求导入的最大数据量,单位Byte。
|
void |
setWriteMode(TSWriteMode writeMode) |
void |
setWriterRetryStrategy(WriterRetryStrategy writerRetryStrategy) |
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 int getBucketCount()
public void setBucketCount(int bucketCount)
public TSDispatchMode getDispatchMode()
public void setDispatchMode(TSDispatchMode dispatchMode)
public TSWriteMode getWriteMode()
public void setWriteMode(TSWriteMode writeMode)
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 © 2024. All Rights Reserved.