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:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

Enclosing class:

DataStreams

public static final class DataStreams.ElementDelimitedOutputStream
extends java.io.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 and Description
ElementDelimitedOutputStream(DataStreams.OutputChunkConsumer<com.google.protobuf.ByteString> consumer, int maximumChunkSize)

Method Summary

Modifier and Type	Method and 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, write

Methods inherited from class java.lang.Object

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

Constructor Detail

ElementDelimitedOutputStream

public ElementDelimitedOutputStream(DataStreams.OutputChunkConsumer<com.google.protobuf.ByteString> consumer,
                                    int maximumChunkSize)

Method Detail

delimitElement

public void delimitElement()
                    throws java.io.IOException

Throws:

java.io.IOException

write

public void write(int i)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

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

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.OutputStream

Throws:

java.io.IOException