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

Class AttributeDescriptorCoder

java.lang.Object

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

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

cz.o2.proxima.beam.core.io.AttributeDescriptorCoder

All Implemented Interfaces:

java.io.Serializable

public class AttributeDescriptorCoder
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
AttributeDescriptor<?>	decode(java.io.InputStream inStream)
void	encode(AttributeDescriptor<?> value, java.io.OutputStream outStream)
org.apache.beam.sdk.values.TypeDescriptor<AttributeDescriptor<?>>	getEncodedTypeDescriptor()
static AttributeDescriptorCoder	of(Repository repo)	Create AttributeDescriptorCoder from Repository.
static AttributeDescriptorCoder	of(RepositoryFactory factory)	Create AttributeDescriptorCoder from RepositoryFactory.
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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

of

public static AttributeDescriptorCoder of(Repository repo)

Create AttributeDescriptorCoder from Repository.

Parameters:

repo - the repository for the coder

Returns:

the coder

of

public static AttributeDescriptorCoder of(RepositoryFactory factory)

Create AttributeDescriptorCoder from RepositoryFactory.

Parameters:

factory - the repository factory for the coder

Returns:

the coder

encode

public void encode(AttributeDescriptor<?> 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<AttributeDescriptor<?>>

Throws:

org.apache.beam.sdk.coders.CoderException

java.io.IOException

decode

public AttributeDescriptor<?> decode(java.io.InputStream inStream)
                              throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

getEncodedTypeDescriptor

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

Overrides:

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

verifyDeterministic

public void verifyDeterministic()

Overrides:

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