com.google.cloud.dataflow.sdk.util.common.worker

Class ReceivingOperation

java.lang.Object

com.google.cloud.dataflow.sdk.util.common.worker.Operation

com.google.cloud.dataflow.sdk.util.common.worker.ReceivingOperation

All Implemented Interfaces:

Receiver

Direct Known Subclasses:

FlattenOperation, ParDoOperation, PartialGroupByKeyOperation, WriteOperation

public abstract class ReceivingOperation
extends Operation
implements Receiver

The abstract base class for Operations that have inputs and implement process().

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.util.common.worker.Operation

Operation.InitializationState

Field Summary

Fields inherited from class com.google.cloud.dataflow.sdk.util.common.worker.Operation

finishState, initializationState, initializationStateLock, operationName, processState, receivers, startState, stateSampler

Constructor Summary

Constructors

Constructor and Description
ReceivingOperation(String operationName, OutputReceiver[] receivers, String counterPrefix, CounterSet.AddCounterMutator addCounterMutator, StateSampler stateSampler)

Method Summary

Modifier and Type	Method and Description
void	attachInput(Operation source, int outputNum) Adds an input to this Operation, coming from the given output of the given source Operation.

Methods inherited from class com.google.cloud.dataflow.sdk.util.common.worker.Operation

finish, start, supportsRestart

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.cloud.dataflow.sdk.util.common.worker.Receiver

process

Constructor Detail

ReceivingOperation

public ReceivingOperation(String operationName,
                          OutputReceiver[] receivers,
                          String counterPrefix,
                          CounterSet.AddCounterMutator addCounterMutator,
                          StateSampler stateSampler)

Method Detail

attachInput

public void attachInput(Operation source,
                        int outputNum)

Adds an input to this Operation, coming from the given output of the given source Operation.