org.apache.beam.sdk.fn.stream

Interface DataStreams.OutputChunkConsumer<T>

Enclosing class:

DataStreams

Deprecated.

Used as a temporary placeholder until implementation of DataStreams.outbound(OutputChunkConsumer).

@Deprecated
public static interface DataStreams.OutputChunkConsumer<T>

Reads chunks of output.

Method Summary

Modifier and Type	Method and Description
void	read(T chunk) Deprecated.

Method Detail

read

void read(T chunk)
   throws java.lang.Exception

Deprecated.

Throws:

java.lang.Exception