public class WriterConfig extends Object
构造器和说明 |
---|
WriterConfig() |
限定符和类型 | 方法和说明 |
---|---|
int |
getBufferSize()
获取一个TableStoreWriter在内存中缓冲队列的大小,必须是2的指数。
|
int |
getConcurrency()
获取一个TableStoreWriter的最大请求并发数。
|
int |
getFlushInterval()
设置writer自动flush的时间间隔,单位为毫秒。
|
int |
getMaxAttrColumnSize()
获取属性列的值的最大大小限制,单位Byte。
|
int |
getMaxBatchRowsCount()
获取一次批量RPC请求导入的最大行数。
|
int |
getMaxBatchSize()
获取一次批量RPC请求导入的最大数据量,单位Byte。
|
int |
getMaxColumnsCount()
获取一行的最大列数限制。
|
int |
getMaxPKColumnSize()
获取主键列的值的最大大小限制,单位Byte。
|
boolean |
isEnableSchemaCheck()
获取是否开启在SDK层开启写入数据时的schema检查
|
void |
setBufferSize(int bufferSize)
设置一个TableStoreWriter在内存中缓冲队列的大小。
|
void |
setConcurrency(int concurrency)
设置一个TableStoreWriter的最大请求并发数。
|
void |
setEnableSchemaCheck(boolean enableSchemaCheck)
设置是否开启在SDK层写入数据时的schema检查
|
void |
setFlushInterval(int flushInterval)
获取writer自动flush的时间间隔,单位为毫秒。
|
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。
|
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检查Copyright © 2019. All Rights Reserved.