org.apache.flink.table.operations

Class SetQueryOperation

java.lang.Object

org.apache.flink.table.operations.SetQueryOperation

All Implemented Interfaces:

Operation, QueryOperation

@Internal
public class SetQueryOperation
extends Object
implements QueryOperation

A set operation on two relations. It provides a way to union, intersect or subtract underlying data sets/streams. Both relations must have equal schemas.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SetQueryOperation.SetQueryOperationType Represent kind of this set operation.

Constructor Summary

Constructors

Constructor and Description
SetQueryOperation(QueryOperation leftOperation, QueryOperation rightOperation, SetQueryOperation.SetQueryOperationType type, boolean all, ResolvedSchema resolvedSchema)

Method Summary

Modifier and Type	Method and Description
<T> T	accept(QueryOperationVisitor<T> visitor)
String	asSerializableString() Returns a string that fully serializes this instance.
String	asSummaryString() Returns a string that summarizes this operation for printing to a console.
List<QueryOperation>	getChildren()
ResolvedSchema	getResolvedSchema() Resolved schema of this operation.
SetQueryOperation.SetQueryOperationType	getType()
boolean	isAll()

Methods inherited from class java.lang.Object

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

Constructor Detail

SetQueryOperation

public SetQueryOperation(QueryOperation leftOperation,
                         QueryOperation rightOperation,
                         SetQueryOperation.SetQueryOperationType type,
                         boolean all,
                         ResolvedSchema resolvedSchema)

Method Detail

getResolvedSchema

public ResolvedSchema getResolvedSchema()

Description copied from interface: QueryOperation

Resolved schema of this operation.

Specified by:

getResolvedSchema in interface QueryOperation

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

asSerializableString

public String asSerializableString()

Description copied from interface: QueryOperation

Returns a string that fully serializes this instance. The serialized string can be used for storing the query in e.g. a Catalog as a view.

Specified by:

asSerializableString in interface QueryOperation

Returns:

detailed string for persisting in a catalog

See Also:

Operation.asSummaryString()

accept

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

Specified by:

accept in interface QueryOperation

getChildren

public List<QueryOperation> getChildren()

Specified by:

getChildren in interface QueryOperation

getType

public SetQueryOperation.SetQueryOperationType getType()

isAll

public boolean isAll()