org.apache.beam.sdk.fn.stream

Interface DataStreams.OutputChunkConsumer<T>

Enclosing class:

DataStreams

public static interface DataStreams.OutputChunkConsumer<T>

A callback which is invoked whenever the DataStreams.outbound(org.apache.beam.sdk.fn.stream.DataStreams.OutputChunkConsumer<com.google.protobuf.ByteString>) OutputStream becomes full. DataStreams.outbound(OutputChunkConsumer).

Method Summary

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

Method Detail

read

void read(T chunk)
   throws java.io.IOException

Throws:

java.io.IOException