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

conf, hbaseSchema, lookupOptions, nullStringLiteral, tableName

Constructor Summary

Constructors

Constructor and Description
HBaseDynamicTableSource(Configuration conf, String tableName, HBaseTableSchema hbaseSchema, String nullStringLiteral, HBaseLookupOptions lookupOptions)

Method Summary

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

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

applyProjection, asSummaryString, getChangelogMode, getHBaseTableSchema, getScanRuntimeProvider, supportsNestedProjection

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseDynamicTableSource

public HBaseDynamicTableSource(Configuration conf,
                               String tableName,
                               HBaseTableSchema hbaseSchema,
                               String nullStringLiteral,
                               HBaseLookupOptions lookupOptions)

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:

TableFunctionProvider, AsyncTableFunctionProvider

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

getLookupOptions

@VisibleForTesting
public HBaseLookupOptions getLookupOptions()