org.apache.beam.runners.core.construction

Class UnconsumedReads

java.lang.Object

org.apache.beam.runners.core.construction.UnconsumedReads

public class UnconsumedReads
extends Object

Utilities for ensuring that all Read PTransforms are consumed by some PTransform.

Constructor Summary

Constructors

Constructor and Description
UnconsumedReads()

Method Summary

Modifier and Type	Method and Description
static void	ensureAllReadsConsumed(Pipeline pipeline)

Methods inherited from class java.lang.Object

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

Constructor Detail

UnconsumedReads

public UnconsumedReads()

Method Detail

ensureAllReadsConsumed

public static void ensureAllReadsConsumed(Pipeline pipeline)