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

Class WriteOperation

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

All Implemented Interfaces:

Receiver

public class WriteOperation
extends ReceivingOperation

A write operation.

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
Sink<?>	sink The Sink this operation writes to.

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

Method Summary

Modifier and Type	Method and Description
protected String	bytesCounterName(String counterPrefix, String operationName)
void	finish() Finishes this Operation's execution.
Counter<Long>	getByteCount()
Sink<?>	getSink()
void	process(Object outputElem) 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

sink

public final Sink<?> sink

The Sink this operation writes to.

Constructor Detail

WriteOperation

public WriteOperation(String operationName,
                      Sink<?> sink,
                      OutputReceiver[] receivers,
                      String counterPrefix,
                      CounterSet.AddCounterMutator addCounterMutator,
                      StateSampler stateSampler)

WriteOperation

public WriteOperation(Sink<?> sink,
                      String counterPrefix,
                      CounterSet.AddCounterMutator addCounterMutator,
                      StateSampler stateSampler)

Invoked by tests.

Method Detail

bytesCounterName

protected String bytesCounterName(String counterPrefix,
                                  String operationName)

getSink

public Sink<?> getSink()

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 outputElem)
             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

getByteCount

public Counter<Long> getByteCount()