Package org.apache.drill.common.logical.data

Class SinkOperator

java.lang.Object

org.apache.drill.common.logical.data.LogicalOperatorBase

org.apache.drill.common.logical.data.SingleInputOperator

org.apache.drill.common.logical.data.SinkOperator

All Implemented Interfaces:

Iterable<LogicalOperator>, GraphValue<LogicalOperator>, LogicalOperator

Direct Known Subclasses:

Store

public abstract class SinkOperator
extends SingleInputOperator

An operator that cannot be subscribed to.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.common.logical.data.LogicalOperator

LogicalOperator.NodeBuilder<T extends LogicalOperator>

Constructor Summary

Constructors

Constructor	Description
SinkOperator()

Method Summary

Modifier and Type	Method	Description
void	registerAsSubscriber(LogicalOperator operator)

Methods inherited from class org.apache.drill.common.logical.data.SingleInputOperator

getInput, iterator, setInput

Methods inherited from class org.apache.drill.common.logical.data.LogicalOperatorBase

accept, equals, getMemo, hashCode, nodeBuilder, setMemo, setupAndValidate, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.apache.drill.common.logical.data.LogicalOperator

accept

Constructor Details

SinkOperator

public SinkOperator()

Method Details

registerAsSubscriber

public void registerAsSubscriber(LogicalOperator operator)

Specified by:

registerAsSubscriber in interface LogicalOperator

Overrides:

registerAsSubscriber in class LogicalOperatorBase