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

Class EntityDescriptorCoder

java.lang.Object

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

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

cz.o2.proxima.beam.core.io.EntityDescriptorCoder

All Implemented Interfaces:

java.io.Serializable

public class EntityDescriptorCoder
extends org.apache.beam.sdk.coders.CustomCoder<T>

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
EntityDescriptor	decode(java.io.InputStream inStream)
void	encode(EntityDescriptor value, java.io.OutputStream outStream)
org.apache.beam.sdk.values.TypeDescriptor<EntityDescriptor>	getEncodedTypeDescriptor()
static EntityDescriptorCoder	of(Repository repo)	Construct the coder from repository
static EntityDescriptorCoder	of(RepositoryFactory factory)	Construct the coder from repository factory
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, getEncodedElementByteSizeUsingCoder, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

Methods inherited from class java.lang.Object

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

Method Detail

of

public static EntityDescriptorCoder of(Repository repo)

Construct the coder from repository

Parameters:

repo - the repository

Returns:

the coder

of

public static EntityDescriptorCoder of(RepositoryFactory factory)

Construct the coder from repository factory

Parameters:

factory - the factory

Returns:

the coder

encode

public void encode(EntityDescriptor value,
                   java.io.OutputStream outStream)
            throws org.apache.beam.sdk.coders.CoderException,
                   java.io.IOException

Specified by:

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

Throws:

org.apache.beam.sdk.coders.CoderException

java.io.IOException

decode

public EntityDescriptor decode(java.io.InputStream inStream)
                        throws org.apache.beam.sdk.coders.CoderException,
                               java.io.IOException

Specified by:

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

Throws:

org.apache.beam.sdk.coders.CoderException

java.io.IOException

getEncodedTypeDescriptor

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

Overrides:

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

verifyDeterministic

public void verifyDeterministic()

Overrides:

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