Modifier and Type | Method and Description |
---|---|
ConnectTableDescriptor |
TableEnvironment.connect(ConnectorDescriptor connectorDescriptor)
Creates a table source and/or table sink from a descriptor.
|
Modifier and Type | Method and Description |
---|---|
ConnectTableDescriptor |
TableEnvironmentImpl.connect(ConnectorDescriptor connectorDescriptor) |
Modifier and Type | Method and Description |
---|---|
BatchTableDescriptor |
BatchTableEnvironment.connect(ConnectorDescriptor connectorDescriptor)
Creates a table source and/or table sink from a descriptor.
|
StreamTableDescriptor |
StreamTableEnvironment.connect(ConnectorDescriptor connectorDescriptor)
Creates a table source and/or table sink from a descriptor.
|
Modifier and Type | Method and Description |
---|---|
StreamTableDescriptor |
StreamTableEnvironmentImpl.connect(ConnectorDescriptor connectorDescriptor) |
Constructor and Description |
---|
CatalogTableBuilder(ConnectorDescriptor connectorDescriptor,
TableSchema tableSchema) |
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch
Connector descriptor for the Elasticsearch search engine.
|
class |
FileSystem
Connector descriptor for a file system.
|
class |
Kafka
Connector descriptor for the Apache Kafka message queue.
|
Constructor and Description |
---|
BatchTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
ConnectTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
StreamTableDescriptor(TableEnvironment tableEnv,
ConnectorDescriptor connectorDescriptor) |
TableDescriptor(ConnectorDescriptor connectorDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
CustomConnectorDescriptor
Describes a custom connector to an other system.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.