We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9cd4464 commit 0a87f24Copy full SHA for 0a87f24
src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java
@@ -238,16 +238,6 @@ public void setWriteBufferSize(long writeBufferSize) throws IOException {
238
}
239
240
241
- private ObTableBatchOperation buildObTableBatchOperation(List<? extends Mutation> execBuffer) {
242
- List<KeyValue> keyValueList = new LinkedList<>();
243
- for (Mutation mutation : execBuffer) {
244
- for (Map.Entry<byte[], List<KeyValue>> entry : mutation.getFamilyMap().entrySet()) {
245
- keyValueList.addAll(entry.getValue());
246
- }
247
248
- return OHTable.buildObTableBatchOperation(keyValueList, false, null);
249
250
-
251
/**
252
* Only 4_2_5 BP1 - 4_3_0 and after 4_3_4 support multi-cf
253
* */
0 commit comments