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

Class FlattenOperation

java.lang.Object

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

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

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

All Implemented Interfaces:

Receiver

public class FlattenOperation
extends ReceivingOperation

A flatten operation.

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
FlattenOperation(OutputReceiver outputReceiver, String counterPrefix, CounterSet.AddCounterMutator addCounterMutator, StateSampler stateSampler) Invoked by tests.
FlattenOperation(String operationName, OutputReceiver[] receivers, String counterPrefix, CounterSet.AddCounterMutator addCounterMutator, StateSampler stateSampler)

Method Summary

Modifier and Type	Method and Description
void	process(Object elem) Processes the element.
boolean	supportsRestart() Returns true if this Operation can be started again after it is finished.

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

attachInput

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

finish, start

Methods inherited from class java.lang.Object

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

Constructor Detail

FlattenOperation

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

FlattenOperation

public FlattenOperation(OutputReceiver outputReceiver,
                        String counterPrefix,
                        CounterSet.AddCounterMutator addCounterMutator,
                        StateSampler stateSampler)

Invoked by tests.

Method Detail

process

public void process(Object elem)
             throws Exception

Description copied from interface: Receiver

Processes the element.

Throws:

Exception

supportsRestart

public boolean supportsRestart()

Description copied from class: Operation

Returns true if this Operation can be started again after it is finished.

Overrides:

supportsRestart in class Operation