org.apache.hadoop.hbase.client.Table.setWriteBufferSize()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(1.1k)|赞(0)|评价(0)|浏览(237)

本文整理了Java中org.apache.hadoop.hbase.client.Table.setWriteBufferSize()方法的一些代码示例,展示了Table.setWriteBufferSize()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.setWriteBufferSize()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Table
类名称:Table
方法名:setWriteBufferSize

Table.setWriteBufferSize介绍

[英]Sets the size of the buffer in bytes.

If the new size is less than the current amount of data in the write buffer, the buffer gets flushed.
[中]以字节为单位设置缓冲区的大小。
如果新大小小于写入缓冲区中的当前数据量,则会刷新缓冲区。

代码示例

代码示例来源:origin: pentaho/pentaho-hadoop-shims

  1. @Override
  2. public void setWriteBufferSize( long bufferSize ) throws IOException {
  3. //#if shim_name!="hdp30" && shim_name!="cdh601"
  4. tab.setWriteBufferSize( bufferSize );
  5. //#endif
  6. //#if shim_name=="hdp30" || shim_name=="cdh601"
  7. //$mutator = conn.getBufferedMutator( new BufferedMutatorParams( tab.getName() ).writeBufferSize( bufferSize ) );
  8. //#endif
  9. }

代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-1.1

  1. @Override
  2. public void setWriteBufferSize(long writeBufferSize) throws IOException {
  3. hTable.setWriteBufferSize(writeBufferSize);
  4. }

相关文章