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

Modifier and Type	Method and Description
Optional<ObjectIdentifier>	getSinkIdentifier()

Methods inherited from interface org.apache.flink.table.api.Explainable

explain, explain, printExplain

Methods inherited from interface org.apache.flink.table.api.Executable

execute

Methods inherited from interface org.apache.flink.table.api.Compilable

compilePlan

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.