org.apache.flink.connector.hbase.options

Class HBaseOptions

java.lang.Object

org.apache.flink.connector.hbase.options.HBaseOptions

@Internal
public class HBaseOptions
extends Object

Common Options for HBase.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Boolean>	LOOKUP_ASYNC
static ConfigOption<Long>	LOOKUP_CACHE_MAX_ROWS
static ConfigOption<java.time.Duration>	LOOKUP_CACHE_TTL
static ConfigOption<Integer>	LOOKUP_MAX_RETRIES
static ConfigOption<String>	NULL_STRING_LITERAL
static String	PROPERTIES_PREFIX
static ConfigOption<java.time.Duration>	SINK_BUFFER_FLUSH_INTERVAL
static ConfigOption<Integer>	SINK_BUFFER_FLUSH_MAX_ROWS
static ConfigOption<MemorySize>	SINK_BUFFER_FLUSH_MAX_SIZE
static ConfigOption<String>	TABLE_NAME
static ConfigOption<String>	ZOOKEEPER_QUORUM
static ConfigOption<String>	ZOOKEEPER_ZNODE_PARENT

Constructor Summary

Constructors

Constructor and Description
HBaseOptions()

Method Summary

Modifier and Type	Method and Description
static Configuration	getHBaseConfiguration(Map<String,String> options) config HBase Configuration.
static HBaseLookupOptions	getHBaseLookupOptions(ReadableConfig tableOptions)
static HBaseWriteOptions	getHBaseWriteOptions(ReadableConfig tableOptions)
static void	validatePrimaryKey(TableSchema schema) Checks that the HBase table have row key defined.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TABLE_NAME

public static final ConfigOption<String> TABLE_NAME

ZOOKEEPER_QUORUM

public static final ConfigOption<String> ZOOKEEPER_QUORUM

ZOOKEEPER_ZNODE_PARENT

public static final ConfigOption<String> ZOOKEEPER_ZNODE_PARENT

NULL_STRING_LITERAL

public static final ConfigOption<String> NULL_STRING_LITERAL

SINK_BUFFER_FLUSH_MAX_SIZE

public static final ConfigOption<MemorySize> SINK_BUFFER_FLUSH_MAX_SIZE

SINK_BUFFER_FLUSH_MAX_ROWS

public static final ConfigOption<Integer> SINK_BUFFER_FLUSH_MAX_ROWS

SINK_BUFFER_FLUSH_INTERVAL

public static final ConfigOption<java.time.Duration> SINK_BUFFER_FLUSH_INTERVAL

LOOKUP_ASYNC

public static final ConfigOption<Boolean> LOOKUP_ASYNC

LOOKUP_CACHE_MAX_ROWS

public static final ConfigOption<Long> LOOKUP_CACHE_MAX_ROWS

LOOKUP_CACHE_TTL

public static final ConfigOption<java.time.Duration> LOOKUP_CACHE_TTL

LOOKUP_MAX_RETRIES

public static final ConfigOption<Integer> LOOKUP_MAX_RETRIES

PROPERTIES_PREFIX

public static final String PROPERTIES_PREFIX

See Also:

Constant Field Values

Constructor Detail

HBaseOptions

public HBaseOptions()

Method Detail

validatePrimaryKey

public static void validatePrimaryKey(TableSchema schema)

Checks that the HBase table have row key defined. A row key is defined as an atomic type, and column families and qualifiers are defined as ROW type. There shouldn't be multiple atomic type columns in the schema. The PRIMARY KEY constraint is optional, if exist, the primary key constraint must be defined on the single row key field.

getHBaseWriteOptions

public static HBaseWriteOptions getHBaseWriteOptions(ReadableConfig tableOptions)

getHBaseLookupOptions

public static HBaseLookupOptions getHBaseLookupOptions(ReadableConfig tableOptions)

getHBaseConfiguration

public static Configuration getHBaseConfiguration(Map<String,String> options)

config HBase Configuration.

Parameters:

options - properties option