Package | Description |
---|---|
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
HBase |
HBase.properties(Properties properties)
Sets the configuration properties for HBase Configuration.
|
HBase |
HBase.property(String key,
String value)
Adds a configuration property for HBase Configuration.
|
HBase |
HBase.tableName(String tableName)
Set the HBase table name, Required.
|
HBase |
HBase.version(String version)
Set the Apache HBase version to be used.
|
HBase |
HBase.writeBufferFlushInterval(String interval)
Set an interval when to flushing buffered requesting if the interval passes, in milliseconds.
|
HBase |
HBase.writeBufferFlushMaxRows(int writeBufferFlushMaxRows)
Set threshold when to flush buffered request based on the number of rows currently added.
|
HBase |
HBase.writeBufferFlushMaxSize(String maxSize)
Set threshold when to flush buffered request based on the memory byte size of rows currently
added.
|
HBase |
HBase.zookeeperNodeParent(String zookeeperNodeParent)
Set the zookeeper node parent path of HBase cluster.
|
HBase |
HBase.zookeeperQuorum(String zookeeperQuorum)
Set the zookeeper quorum address to connect the HBase cluster.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.