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

Class ParDoOperation

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.ParDoOperation

All Implemented Interfaces:

Receiver

public class ParDoOperation
extends ReceivingOperation

A ParDo mapping function.

Nested Class Summary

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

Operation.InitializationState

Field Summary

Fields

Modifier and Type	Field and Description
ParDoFn	fn

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
ParDoOperation(String operationName, ParDoFn fn, OutputReceiver[] outputReceivers, String counterPrefix, CounterSet.AddCounterMutator addCounterMutator, StateSampler stateSampler)

Method Summary

Modifier and Type	Method and Description
void	finish() Finishes this Operation's execution.
void	process(Object elem) Processes the element.
void	start() Starts this Operation's execution.
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 java.lang.Object

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

Field Detail

fn

public final ParDoFn fn

Constructor Detail

ParDoOperation

public ParDoOperation(String operationName,
                      ParDoFn fn,
                      OutputReceiver[] outputReceivers,
                      String counterPrefix,
                      CounterSet.AddCounterMutator addCounterMutator,
                      StateSampler stateSampler)

Method Detail

start

public void start()
           throws Exception

Description copied from class: Operation

Starts this Operation's execution. Called after all successsor consuming operations have been started.

Overrides:

start in class Operation

Throws:

Exception

process

public void process(Object elem)
             throws Exception

Description copied from interface: Receiver

Processes the element.

Throws:

Exception

finish

public void finish()
            throws Exception

Description copied from class: Operation

Finishes this Operation's execution. Called after all predecessor producing operations have been finished.

Overrides:

finish in class Operation

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