Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.table.factories | |
org.apache.flink.table.filesystem |
Modifier and Type | Method and Description |
---|---|
TableSource<RowData> |
HiveTableFactory.createTableSource(TableSourceFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
TableSourceFactoryContextImpl
Implementation of
TableSourceFactory.Context . |
Modifier and Type | Method and Description |
---|---|
default TableSource<T> |
TableSourceFactory.createTableSource(TableSourceFactory.Context context)
Creates and configures a
TableSource based on the given TableSourceFactory.Context . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(TableSourceFactory.Context context)
Returns a table source matching the descriptor.
|
Modifier and Type | Method and Description |
---|---|
TableSource<RowData> |
FileSystemTableFactory.createTableSource(TableSourceFactory.Context context) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.