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

Interface ParDoFn

All Known Implementing Classes:

ParDoFnBase

public interface ParDoFn

Interface for functions invocable by ParDoOperation instances.

To easily create a ParDoFn implementation with default setup, processing, and teardown, extend ParDoFnBase.

Method Summary

Modifier and Type	Method and Description
void	finishBundle()
void	processElement(Object elem)
void	startBundle(Receiver... receivers)

Method Detail

startBundle

void startBundle(Receiver... receivers)
          throws Exception

Throws:

Exception

processElement

void processElement(Object elem)
             throws Exception

Throws:

Exception

finishBundle

void finishBundle()
           throws Exception

Throws:

Exception