本文整理了Java中org.apache.hadoop.hbase.client.Table.setWriteBufferSize()
方法的一些代码示例,展示了Table.setWriteBufferSize()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.setWriteBufferSize()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Table
类名称: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
@Override
public void setWriteBufferSize( long bufferSize ) throws IOException {
//#if shim_name!="hdp30" && shim_name!="cdh601"
tab.setWriteBufferSize( bufferSize );
//#endif
//#if shim_name=="hdp30" || shim_name=="cdh601"
//$mutator = conn.getBufferedMutator( new BufferedMutatorParams( tab.getName() ).writeBufferSize( bufferSize ) );
//#endif
}
代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-1.1
@Override
public void setWriteBufferSize(long writeBufferSize) throws IOException {
hTable.setWriteBufferSize(writeBufferSize);
}
内容来源于网络,如有侵权,请联系作者删除!