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

Interface Receiver

All Known Implementing Classes:

FlattenOperation, OutputReceiver, ParDoOperation, PartialGroupByKeyOperation, ReceivingOperation, WriteOperation

public interface Receiver

Abstract interface of things that accept inputs one at a time via process().

Method Summary

Modifier and Type	Method and Description
void	process(Object outputElem) Processes the element.

Method Detail

process

void process(Object outputElem)
      throws Exception

Processes the element.

Throws:

Exception