public abstract class TableActionBase extends ActionBase
Action
for table.Modifier and Type | Field and Description |
---|---|
protected Identifier |
identifier |
protected Table |
table |
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.api.TableResult |
batchSink(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream)
Sink
DataStream dataStream to table with Flink Table API in batch environment. |
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
protected Table table
protected final Identifier identifier
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.