Package org.apache.beam.sdk.schemas.logicaltypes

Class UnknownLogicalType<T>

java.lang.Object

org.apache.beam.sdk.schemas.logicaltypes.PassThroughLogicalType<T>

org.apache.beam.sdk.schemas.logicaltypes.UnknownLogicalType<T>

All Implemented Interfaces:

java.io.Serializable, Schema.LogicalType<T,T>

public class UnknownLogicalType<T>
extends PassThroughLogicalType<T>

A base class for logical types that are not understood by the Java SDK.

Unknown logical types are passed through and treated like their Base type in the Java SDK.

Java transforms and JVM runners should take care when processing these types as they may have a particular semantic meaning in the context that created them. For example, consider an enumerated type backed by a primitive . A Java transform can clearly pass through this value and pass it back to a context that understands it, but that transform should not blindly perform arithmetic on this type.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
UnknownLogicalType(java.lang.String identifier, byte[] payload, Schema.FieldType argumentType, java.lang.Object argument, Schema.FieldType fieldType)

Method Summary

Modifier and Type	Method	Description
byte[]	getPayload()

Methods inherited from class org.apache.beam.sdk.schemas.logicaltypes.PassThroughLogicalType

getArgument, getArgumentType, getBaseType, getIdentifier, toBaseType, toInputType

Methods inherited from class java.lang.Object

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

Constructor Detail

UnknownLogicalType

public UnknownLogicalType(java.lang.String identifier,
                          byte[] payload,
                          Schema.FieldType argumentType,
                          java.lang.Object argument,
                          Schema.FieldType fieldType)

Method Detail

getPayload

public byte[] getPayload()