SchemaStreamElementCoder

java.lang.Object
- org.apache.beam.sdk.coders.Coder<T>
- - org.apache.beam.sdk.coders.CustomCoder<T>
  - - org.apache.beam.sdk.schemas.SchemaCoder<StreamElement>
    - - cz.o2.proxima.beam.core.io.SchemaStreamElementCoder

All Implemented Interfaces:: java.io.Serializable

public class SchemaStreamElementCoder
extends org.apache.beam.sdk.schemas.SchemaCoder<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
- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  static java.util.Map<AttributeValueType,org.apache.beam.sdk.schemas.Schema.FieldType> FIELD_TYPES
  - Fields inherited from class org.apache.beam.sdk.schemas.SchemaCoder
    schema
- Method Summary
  
  All Methods Static Methods Concrete Methods
  Modifier and Type Method Description
  
  static SchemaStreamElementCoder of(Repository repo)
  - Methods inherited from class org.apache.beam.sdk.schemas.SchemaCoder
    coderForFieldType, consistentWithEquals, decode, encode, equals, getEncodedTypeDescriptor, getFromRowFunction, getSchema, getToRowFunction, hashCode, of, of, overrideEncodingPositions, toString, verifyDeterministic
  - Methods inherited from class org.apache.beam.sdk.coders.CustomCoder
    getCoderArguments
  - Methods inherited from class org.apache.beam.sdk.coders.Coder
    decode, encode, getEncodedElementByteSize, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic
  - Methods inherited from class java.lang.Object
    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

FIELD_TYPES

public static final java.util.Map<AttributeValueType,org.apache.beam.sdk.schemas.Schema.FieldType> FIELD_TYPES

Method Detail

of

public static SchemaStreamElementCoder of(Repository repo)