@Internal public class HBaseDynamicTableSource extends AbstractHBaseDynamicTableSource
ScanTableSource.ScanContext, ScanTableSource.ScanRuntimeProvider
LookupTableSource.LookupContext, LookupTableSource.LookupRuntimeProvider
DynamicTableSource.Context, DynamicTableSource.DataStructureConverter
conf, hbaseSchema, lookupOptions, nullStringLiteral, tableName
Constructor and Description |
---|
HBaseDynamicTableSource(Configuration conf,
String tableName,
HBaseTableSchema hbaseSchema,
String nullStringLiteral,
HBaseLookupOptions lookupOptions) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
copy()
Creates a copy of this instance during planning.
|
InputFormat<RowData,?> |
getInputFormat() |
HBaseLookupOptions |
getLookupOptions() |
applyProjection, asSummaryString, getChangelogMode, getHBaseTableSchema, getLookupRuntimeProvider, getScanRuntimeProvider, supportsNestedProjection
public HBaseDynamicTableSource(Configuration conf, String tableName, HBaseTableSchema hbaseSchema, String nullStringLiteral, HBaseLookupOptions lookupOptions)
public DynamicTableSource copy()
DynamicTableSource
public InputFormat<RowData,?> getInputFormat()
getInputFormat
in class AbstractHBaseDynamicTableSource
@VisibleForTesting public HBaseLookupOptions getLookupOptions()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.