Uses of Package
org.apache.flink.table.connector
-
Classes in org.apache.flink.table.connector used by org.apache.flink.connector.datagen.table Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.connector.file.table Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.connector.file.table.stream Class Description ProviderContext Context provided by someScanTableSource.ScanRuntimeProviderandDynamicTableSink.SinkRuntimeProviderwith utilities for generating the runtime implementation. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.csv Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.json.canal Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.json.debezium Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.json.maxwell Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.json.ogg Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.parquet Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.formats.protobuf Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.legacy.table.connector.source Class Description ParallelismProvider Parallelism provider for other connector providers. -
Classes in org.apache.flink.table.connector used by org.apache.flink.orc Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.api.bridge.internal Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.api.bridge.java Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.api.bridge.java.internal Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector Class Description ChangelogMode The set of changes contained in a changelog.ChangelogMode.Builder Builder for configuring and creating instances ofChangelogMode.Projection Projectionrepresents a list of (possibly nested) indexes that can be used to project data types.RuntimeConverter.Context Context for conversions during runtime. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector.format Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector.sink Class Description ChangelogMode The set of changes contained in a changelog.ParallelismProvider Parallelism provider for other connector providers.ProviderContext Context provided by someScanTableSource.ScanRuntimeProviderandDynamicTableSink.SinkRuntimeProviderwith utilities for generating the runtime implementation.RuntimeConverter Base interface for converting data during runtime. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector.sink.abilities Class Description RowLevelModificationScanContext The context is intended to provide the relevant table scan information needed by the sink to perform row-level update/delete. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector.sink.legacy Class Description ParallelismProvider Parallelism provider for other connector providers. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector.source Class Description ChangelogMode The set of changes contained in a changelog.ParallelismProvider Parallelism provider for other connector providers.ProviderContext Context provided by someScanTableSource.ScanRuntimeProviderandDynamicTableSink.SinkRuntimeProviderwith utilities for generating the runtime implementation.RuntimeConverter Base interface for converting data during runtime. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.connector.source.abilities Class Description RowLevelModificationScanContext The context is intended to provide the relevant table scan information needed by the sink to perform row-level update/delete. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.data.utils Class Description Projection Projectionrepresents a list of (possibly nested) indexes that can be used to project data types. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.examples.java.connectors Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.operations Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.connectors Class Description ChangelogMode The set of changes contained in a changelog.ParallelismProvider Parallelism provider for other connector providers.ProviderContext Context provided by someScanTableSource.ScanRuntimeProviderandDynamicTableSink.SinkRuntimeProviderwith utilities for generating the runtime implementation. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.lineage Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.plan.abilities.sink Class Description RowLevelModificationScanContext The context is intended to provide the relevant table scan information needed by the sink to perform row-level update/delete. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.plan.nodes.exec.common Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.plan.nodes.exec.stream Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.plan.trait Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.plan.utils Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.planner.utils Class Description RowLevelModificationScanContext The context is intended to provide the relevant table scan information needed by the sink to perform row-level update/delete. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.toolbox Class Description ChangelogMode The set of changes contained in a changelog. -
Classes in org.apache.flink.table.connector used by org.apache.flink.table.utils.python Class Description ChangelogMode The set of changes contained in a changelog.