@PublicEvolving public abstract class ConnectTableDescriptor extends TableDescriptor<ConnectTableDescriptor> implements SchematicDescriptor<ConnectTableDescriptor>
TableEnvironment.connect(ConnectorDescriptor)
.
It can access TableEnvironment
for fluently registering the table.
Constructor and Description |
---|
ConnectTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,String> |
additionalProperties()
Enables adding more specific properties to
TableDescriptor.toProperties() . |
void |
registerTableSink(String name)
Searches for the specified table sink, configures it accordingly, and registers it as
a table under the given name.
|
void |
registerTableSource(String name)
Searches for the specified table source, configures it accordingly, and registers it as
a table under the given name.
|
void |
registerTableSourceAndSink(String name)
Searches for the specified table source and sink, configures them accordingly, and registers
them as a table under the given name.
|
ConnectTableDescriptor |
withSchema(Schema schema)
Specifies the resulting table schema.
|
inAppendMode, inRetractMode, inUpsertMode, toProperties, withFormat
toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
toProperties
public ConnectTableDescriptor(TableEnvironment tableEnv, ConnectorDescriptor connectorDescriptor)
public ConnectTableDescriptor withSchema(Schema schema)
withSchema
in interface SchematicDescriptor<ConnectTableDescriptor>
public void registerTableSource(String name)
name
- table name to be registered in the table environmentpublic void registerTableSink(String name)
name
- table name to be registered in the table environmentpublic void registerTableSourceAndSink(String name)
name
- table name to be registered in the table environmentprotected Map<String,String> additionalProperties()
TableDescriptor
TableDescriptor.toProperties()
.additionalProperties
in class TableDescriptor<ConnectTableDescriptor>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.