Package 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<org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString>) OutputStream becomes full.

DataStreams.outbound(OutputChunkConsumer).

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    read(T chunk)