Package org.apache.flink.table.api
Interface TablePipeline
-
- All Superinterfaces:
Compilable
,Executable
,Explainable<TablePipeline>
@PublicEvolving public interface TablePipeline extends Explainable<TablePipeline>, Executable, Compilable
Describes a complete pipeline from one or more source tables to a sink table.- See Also:
Table.insertInto(String)
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Optional<ObjectIdentifier>
getSinkIdentifier()
-
Methods inherited from interface org.apache.flink.table.api.Compilable
compilePlan
-
Methods inherited from interface org.apache.flink.table.api.Executable
execute
-
Methods inherited from interface org.apache.flink.table.api.Explainable
explain, explain, printExplain
-
-
-
-
Method Detail
-
getSinkIdentifier
Optional<ObjectIdentifier> getSinkIdentifier()
- Returns:
- The sink table's
ObjectIdentifier
, if any. The result is empty for anonymous sink tables that haven't been registered before.
-
-