Package org.apache.beam.sdk.transforms

Class Requirements

java.lang.Object

org.apache.beam.sdk.transforms.Requirements

All Implemented Interfaces:

java.io.Serializable

@Experimental(CONTEXTFUL)
public final class Requirements
extends java.lang.Object
implements java.io.Serializable

Describes the run-time requirements of a Contextful, such as access to side inputs.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
static Requirements	empty()	Describes an empty set of requirements.
java.util.Collection<PCollectionView<?>>	getSideInputs()	The side inputs that this Contextful needs access to.
boolean	isEmpty()	Whether this is an empty set of requirements.
static Requirements	requiresSideInputs(java.util.Collection<PCollectionView<?>> sideInputs)	Describes the need for access to the given side inputs.
static Requirements	requiresSideInputs(PCollectionView<?>... sideInputs)	Like requiresSideInputs(Collection).
static Requirements	union(Contextful... contextfuls)

Methods inherited from class java.lang.Object

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

Method Detail

getSideInputs

public java.util.Collection<PCollectionView<?>> getSideInputs()

The side inputs that this Contextful needs access to.

requiresSideInputs

public static Requirements requiresSideInputs(java.util.Collection<PCollectionView<?>> sideInputs)

Describes the need for access to the given side inputs.

requiresSideInputs

public static Requirements requiresSideInputs(PCollectionView<?>... sideInputs)

Like requiresSideInputs(Collection).

empty

public static Requirements empty()

Describes an empty set of requirements.

isEmpty

public boolean isEmpty()

Whether this is an empty set of requirements.

union

public static Requirements union(Contextful... contextfuls)