Class UnregisteredSinkModifyOperation<T>
- java.lang.Object
-
- org.apache.flink.table.operations.UnregisteredSinkModifyOperation<T>
-
- All Implemented Interfaces:
ModifyOperation
,Operation
@Internal public class UnregisteredSinkModifyOperation<T> extends Object implements ModifyOperation
DML operation that tells to write to the given sink.
-
-
Constructor Summary
Constructors Constructor Description UnregisteredSinkModifyOperation(TableSink<T> sink, QueryOperation child)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <R> R
accept(ModifyOperationVisitor<R> visitor)
String
asSummaryString()
Returns a string that summarizes this operation for printing to a console.QueryOperation
getChild()
TableSink<T>
getSink()
-
-
-
Constructor Detail
-
UnregisteredSinkModifyOperation
public UnregisteredSinkModifyOperation(TableSink<T> sink, QueryOperation child)
-
-
Method Detail
-
getChild
public QueryOperation getChild()
- Specified by:
getChild
in interfaceModifyOperation
-
asSummaryString
public String asSummaryString()
Description copied from interface:Operation
Returns a string that summarizes this operation for printing to a console. An implementation might skip very specific properties.- Specified by:
asSummaryString
in interfaceOperation
- Returns:
- summary string of this operation for debugging purposes
-
accept
public <R> R accept(ModifyOperationVisitor<R> visitor)
- Specified by:
accept
in interfaceModifyOperation
-
-