@Internal public interface Registration
TableEnvironment
that this descriptor originates from.Modifier and Type | Method and Description |
---|---|
void |
createTableSink(String name,
TableSink<?> tableSink)
Registers an external
TableSink with already configured field names and field types in
this TableEnvironment 's catalog. |
void |
createTableSource(String name,
TableSource<?> tableSource)
Registers an external
TableSource in this TableEnvironment 's catalog. |
void |
createTemporaryTable(String path,
CatalogBaseTable table)
Creates a temporary table in a given path.
|
void createTableSource(String name, TableSource<?> tableSource)
TableSource
in this TableEnvironment
's catalog.
Registered tables can be referenced in SQL queries.name
- The name under which the TableSource
is registered.tableSource
- The TableSource
to register.TableEnvironment.registerTableSource(String, TableSource)
void createTableSink(String name, TableSink<?> tableSink)
TableSink
with already configured field names and field types in
this TableEnvironment
's catalog.
Registered sink tables can be referenced in SQL DML statements.name
- The name under which the TableSink
is registered.tableSink
- The configured TableSink
to register.TableEnvironment.registerTableSink(String, TableSink)
void createTemporaryTable(String path, CatalogBaseTable table)
path
- Path where to register the given tabletable
- table to registerCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.