public class WriteRPCBuffer extends Object
限定符和类型 | 字段和说明 |
---|---|
BatchWriteRowRequest |
batchWriteRowRequest |
WriterConfig |
config |
int |
totalRowsCount |
int |
totalSize |
构造器和说明 |
---|
WriteRPCBuffer(WriterConfig config) |
限定符和类型 | 方法和说明 |
---|---|
boolean |
appendRowChange(RowChange rowChange)
向RPC缓冲中添加一个RowChange,若添加成功,返回true,否则返回false。
|
void |
clear() |
int |
getTotalRowsCount() |
BatchWriteRowRequest |
makeRequest() |
public WriterConfig config
public BatchWriteRowRequest batchWriteRowRequest
public int totalSize
public int totalRowsCount
public WriteRPCBuffer(WriterConfig config)
public boolean appendRowChange(RowChange rowChange)
WriterConfig.maxBatchRowsCount
限制rowChange
- 行数据public BatchWriteRowRequest makeRequest()
public int getTotalRowsCount()
public void clear()
Copyright © 2017. All Rights Reserved.