org.apache.flink.table.operations

Class CollectModifyOperation

java.lang.Object

org.apache.flink.table.operations.CollectModifyOperation

All Implemented Interfaces:

ModifyOperation, Operation

@Internal
public final class CollectModifyOperation
extends Object
implements ModifyOperation

Special, internal kind of ModifyOperation that collects the content of QueryOperation to local.

Constructor Summary

Constructors

Constructor and Description
CollectModifyOperation(QueryOperation child)

Method Summary

Modifier and Type	Method and Description
<T> T	accept(ModifyOperationVisitor<T> visitor)
String	asSummaryString() Returns a string that summarizes this operation for printing to a console.
QueryOperation	getChild()
DataType	getConsumedDataType()
ResultProvider	getSelectResultProvider()
void	setConsumedDataType(DataType consumedDataType)
void	setSelectResultProvider(ResultProvider resultProvider)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectModifyOperation

public CollectModifyOperation(QueryOperation child)

Method Detail

setSelectResultProvider

public void setSelectResultProvider(ResultProvider resultProvider)

getSelectResultProvider

public ResultProvider getSelectResultProvider()

setConsumedDataType

public void setConsumedDataType(DataType consumedDataType)

getConsumedDataType

public DataType getConsumedDataType()

getChild

public QueryOperation getChild()

Specified by:

getChild in interface ModifyOperation

accept

public <T> T accept(ModifyOperationVisitor<T> visitor)

Specified by:

accept in interface ModifyOperation

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 interface Operation

Returns:

summary string of this operation for debugging purposes