org.apache.flink.connector.hbase2.source

Class HBaseDynamicTableSource

java.lang.Object

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

org.apache.flink.connector.hbase2.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, boolean lookupAsync, LookupCache cache)

Method Summary

Modifier and Type	Method and Description
DynamicTableSource	copy() Creates a copy of this instance during planning.
boolean	equals(Object o)
protected InputFormat<RowData,?>	getInputFormat()
LookupTableSource.LookupRuntimeProvider	getLookupRuntimeProvider(LookupTableSource.LookupContext context) Returns a provider of runtime implementation for reading the data.
int	hashCode()

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

applyProjection, asSummaryString, getCache, getChangelogMode, getHBaseTableSchema, 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,
                               boolean lookupAsync,
                               @Nullable
                               LookupCache cache)

Method Detail

getLookupRuntimeProvider

public LookupTableSource.LookupRuntimeProvider getLookupRuntimeProvider(LookupTableSource.LookupContext context)

Description copied from interface: LookupTableSource

Returns a provider of runtime implementation for reading the data.

There exist different interfaces for runtime implementation which is why LookupTableSource.LookupRuntimeProvider serves as the base interface.

Independent of the provider interface, a source implementation can work on either arbitrary objects or internal data structures (see org.apache.flink.table.data for more information).

The given LookupTableSource.LookupContext offers utilities by the planner for creating runtime implementation with minimal dependencies to internal data structures.

Specified by:

getLookupRuntimeProvider in interface LookupTableSource

Overrides:

getLookupRuntimeProvider in class AbstractHBaseDynamicTableSource

See Also:

LookupFunctionProvider, AsyncLookupFunctionProvider

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

protected 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