com.google.cloud.dataflow.sdk.runners.worker

Class SideInputUtils

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.SideInputUtils

public class SideInputUtils
extends Object

Utilities for working with side inputs.

Constructor Summary

Constructors

Constructor and Description
SideInputUtils()

Method Summary

Modifier and Type	Method and Description
static com.google.api.services.dataflow.model.SideInputInfo	createCollectionSideInputInfo(com.google.api.services.dataflow.model.Source... sideInputSources) Builds a SideInputInfo for a "collection" side input.
static com.google.api.services.dataflow.model.SideInputInfo	createSingletonSideInputInfo(com.google.api.services.dataflow.model.Source sideInputSource) Builds a SideInputInfo for a "singleton" side input.
static Object	readSideInput(PipelineOptions options, com.google.api.services.dataflow.model.SideInputInfo sideInputInfo, ExecutionContext executionContext)
static Object	readSideInput(PipelineOptions options, com.google.api.services.dataflow.model.SideInputInfo sideInputInfo, Observer observer, ExecutionContext executionContext) Reads the given side input, producing the contents associated with a a PCollectionView.

Methods inherited from class java.lang.Object

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

Constructor Detail

SideInputUtils

public SideInputUtils()

Method Detail

readSideInput

public static Object readSideInput(PipelineOptions options,
                                   com.google.api.services.dataflow.model.SideInputInfo sideInputInfo,
                                   Observer observer,
                                   ExecutionContext executionContext)
                            throws Exception

Reads the given side input, producing the contents associated with a a PCollectionView.

Throws:

Exception - anything thrown by the delegate Reader

readSideInput

public static Object readSideInput(PipelineOptions options,
                                   com.google.api.services.dataflow.model.SideInputInfo sideInputInfo,
                                   ExecutionContext executionContext)
                            throws Exception

Throws:

Exception

createSingletonSideInputInfo

public static com.google.api.services.dataflow.model.SideInputInfo createSingletonSideInputInfo(com.google.api.services.dataflow.model.Source sideInputSource)

Builds a SideInputInfo for a "singleton" side input.

createCollectionSideInputInfo

public static com.google.api.services.dataflow.model.SideInputInfo createCollectionSideInputInfo(com.google.api.services.dataflow.model.Source... sideInputSources)

Builds a SideInputInfo for a "collection" side input.