Package org.apache.beam.sdk.fn.stream

Class DataStreams.ElementDelimitedOutputStream

java.lang.Object

java.io.OutputStream

org.apache.beam.sdk.fn.stream.DataStreams.ElementDelimitedOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Enclosing class:

DataStreams

public static final class DataStreams.ElementDelimitedOutputStream
extends OutputStream

An adapter which wraps an DataStreams.OutputChunkConsumer as an OutputStream.

Note that this adapter follows the Beam Fn API specification for forcing values that encode producing zero bytes to produce exactly one byte.

Note that users must invoke delimitElement() at each element boundary.

Constructor Summary

Constructors

Constructor	Description
ElementDelimitedOutputStream(DataStreams.OutputChunkConsumer<org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString> consumer, int maximumChunkSize)

Method Summary

Modifier and Type	Method	Description
void	close()
void	delimitElement()
void	write(byte[] b, int offset, int length)
void	write(int i)

Methods inherited from class java.io.OutputStream

flush, nullOutputStream, write

Methods inherited from class java.lang.Object

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

Constructor Details

ElementDelimitedOutputStream

public ElementDelimitedOutputStream(DataStreams.OutputChunkConsumer<org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString> consumer,
 int maximumChunkSize)

Method Details

delimitElement

public void delimitElement()
                    throws IOException

Throws:

IOException

write

public void write(int i)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b,
 int offset,
 int length)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException