@PublicEvolving public abstract class ConnectTableDescriptor extends TableDescriptor<ConnectTableDescriptor>
TableEnvironment.connect(ConnectorDescriptor)
.
It can access TableEnvironment
for fluently registering the table.
Constructor and Description |
---|
ConnectTableDescriptor(Registration registration,
ConnectorDescriptor connectorDescriptor) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,String> |
additionalProperties()
Enables adding more specific properties to
TableDescriptor.toProperties() . |
void |
createTemporaryTable(String path)
Registers the table described by underlying properties in a given path.
|
void |
registerTableSink(String name)
Deprecated.
|
void |
registerTableSource(String name)
Deprecated.
|
void |
registerTableSourceAndSink(String name)
Deprecated.
|
ConnectTableDescriptor |
withSchema(Schema schema)
Specifies the resulting table schema.
|
inAppendMode, inRetractMode, inUpsertMode, toProperties, withFormat
toString
public ConnectTableDescriptor(Registration registration, ConnectorDescriptor connectorDescriptor)
public ConnectTableDescriptor withSchema(Schema schema)
@Deprecated public void registerTableSource(String name)
createTemporaryTable(String)
Temporary objects can shadow permanent ones. If a permanent object in a given path exists, it will be inaccessible in the current session. To make the permanent object available again you can drop the corresponding temporary object.
name
- table name to be registered in the table environment@Deprecated public void registerTableSink(String name)
createTemporaryTable(String)
Temporary objects can shadow permanent ones. If a permanent object in a given path exists, it will be inaccessible in the current session. To make the permanent object available again you can drop the corresponding temporary object.
name
- table name to be registered in the table environment@Deprecated public void registerTableSourceAndSink(String name)
createTemporaryTable(String)
Temporary objects can shadow permanent ones. If a permanent object in a given path exists, it will be inaccessible in the current session. To make the permanent object available again you can drop the corresponding temporary object.
name
- table name to be registered in the table environmentpublic void createTemporaryTable(String path)
There is no distinction between source and sink at the descriptor level anymore as this method does not perform actual class lookup. It only stores the underlying properties. The actual source/sink lookup is performed when the table is used.
Temporary objects can shadow permanent ones. If a permanent object in a given path exists, it will be inaccessible in the current session. To make the permanent object available again you can drop the corresponding temporary object.
NOTE: The schema must be explicitly defined.
path
- path where to register the temporary tableprotected Map<String,String> additionalProperties()
TableDescriptor
TableDescriptor.toProperties()
.additionalProperties
in class TableDescriptor<ConnectTableDescriptor>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.