org.apache.flink.connector.hbase1.source

Class HBaseDynamicTableSource

java.lang.Object

org.apache.flink.connector.hbase.source.AbstractHBaseDynamicTableSource

org.apache.flink.connector.hbase1.source.HBaseDynamicTableSource

All Implemented Interfaces:

SupportsProjectionPushDown, DynamicTableSource, LookupTableSource, ScanTableSource

@Internal
public class HBaseDynamicTableSource
extends AbstractHBaseDynamicTableSource

HBase table source implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.ScanTableSource

ScanTableSource.ScanContext, ScanTableSource.ScanRuntimeProvider

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.LookupTableSource

LookupTableSource.LookupContext, LookupTableSource.LookupRuntimeProvider

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

DynamicTableSource.Context, DynamicTableSource.DataStructureConverter

Field Summary

Fields inherited from class org.apache.flink.connector.hbase.source.AbstractHBaseDynamicTableSource

cache, conf, hbaseSchema, maxRetryTimes, nullStringLiteral, tableName

Constructor Summary

Constructors

Constructor and Description
HBaseDynamicTableSource(org.apache.hadoop.conf.Configuration conf, String tableName, HBaseTableSchema hbaseSchema, String nullStringLiteral, int maxRetryTimes, LookupCache cache)

Method Summary

Modifier and Type	Method and Description
DynamicTableSource	copy() Creates a copy of this instance during planning.
boolean	equals(Object o)
InputFormat<RowData,?>	getInputFormat()
int	hashCode()

Methods inherited from class org.apache.flink.connector.hbase.source.AbstractHBaseDynamicTableSource

applyProjection, asSummaryString, getCache, getChangelogMode, getHBaseTableSchema, getLookupRuntimeProvider, getMaxRetryTimes, getScanRuntimeProvider, supportsNestedProjection

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown

applyProjection

Constructor Detail

HBaseDynamicTableSource

public HBaseDynamicTableSource(org.apache.hadoop.conf.Configuration conf,
                               String tableName,
                               HBaseTableSchema hbaseSchema,
                               String nullStringLiteral,
                               int maxRetryTimes,
                               @Nullable
                               LookupCache cache)

Method Detail

copy

public DynamicTableSource copy()

Description copied from interface: DynamicTableSource

Creates a copy of this instance during planning. The copy should be a deep copy of all mutable members.

getInputFormat

public InputFormat<RowData,?> getInputFormat()

Specified by:

getInputFormat in class AbstractHBaseDynamicTableSource

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object