Package cz.o2.proxima.beam.core.io

Class StreamElementCoder

java.lang.Object

org.apache.beam.sdk.coders.Coder<T>

org.apache.beam.sdk.coders.CustomCoder<StreamElement>

cz.o2.proxima.beam.core.io.StreamElementCoder

All Implemented Interfaces:

java.io.Serializable

public class StreamElementCoder
extends org.apache.beam.sdk.coders.CustomCoder<StreamElement>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.coders.Coder

org.apache.beam.sdk.coders.Coder.Context, org.apache.beam.sdk.coders.Coder.NonDeterministicException

Method Summary

Modifier and Type	Method	Description
StreamElement	decode(java.io.InputStream inStream)
void	encode(StreamElement value, java.io.OutputStream outStream)
boolean	equals(java.lang.Object obj)
org.apache.beam.sdk.values.TypeDescriptor<StreamElement>	getEncodedTypeDescriptor()
int	hashCode()
static StreamElementCoder	of(Repository repository)	Create coder for StreamElements originating in given Repository.
static StreamElementCoder	of(RepositoryFactory factory)	Create coder for StreamElements originating in given Repository.
void	verifyDeterministic()

Methods inherited from class org.apache.beam.sdk.coders.CustomCoder

getCoderArguments

Methods inherited from class org.apache.beam.sdk.coders.Coder

consistentWithEquals, decode, encode, getEncodedElementByteSize, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

Methods inherited from class java.lang.Object

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

Method Detail

of

public static StreamElementCoder of(RepositoryFactory factory)

Create coder for StreamElements originating in given Repository.

Parameters:

factory - the repository factory to create coder for

Returns:

the coder

of

public static StreamElementCoder of(Repository repository)

Create coder for StreamElements originating in given Repository.

Parameters:

repository - the repository to create coder for

Returns:

the coder

encode

public void encode(StreamElement value,
                   java.io.OutputStream outStream)
            throws java.io.IOException

Specified by:

encode in class org.apache.beam.sdk.coders.Coder<StreamElement>

Throws:

java.io.IOException

decode

public StreamElement decode(java.io.InputStream inStream)
                     throws java.io.IOException

Specified by:

decode in class org.apache.beam.sdk.coders.Coder<StreamElement>

Throws:

java.io.IOException

getEncodedTypeDescriptor

public org.apache.beam.sdk.values.TypeDescriptor<StreamElement> getEncodedTypeDescriptor()

Overrides:

getEncodedTypeDescriptor in class org.apache.beam.sdk.coders.Coder<StreamElement>

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

verifyDeterministic

public void verifyDeterministic()

Overrides:

verifyDeterministic in class org.apache.beam.sdk.coders.CustomCoder<StreamElement>