org.apache.flink.statefun.sdk.java.types

Class SimpleType<T>

java.lang.Object

org.apache.flink.statefun.sdk.java.types.SimpleType<T>

Type Parameters:

T - the Java type handled by this Type.

All Implemented Interfaces:

Type<T>

public final class SimpleType<T>
extends java.lang.Object
implements Type<T>

A utility to create simple Type implementations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SimpleType.Fn<I,O>

Method Summary

Modifier and Type	Method and Description
static <T> Type<T>	simpleImmutableTypeFrom(TypeName typeName, SimpleType.Fn<T,byte[]> serialize, SimpleType.Fn<byte[],T> deserialize)
static <T> Type<T>	simpleTypeFrom(TypeName typeName, SimpleType.Fn<T,byte[]> serialize, SimpleType.Fn<byte[],T> deserialize)
java.util.Set<TypeCharacteristics>	typeCharacteristics()
TypeName	typeName()
TypeSerializer<T>	typeSerializer()

Methods inherited from class java.lang.Object

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

Method Detail

simpleTypeFrom

public static <T> Type<T> simpleTypeFrom(TypeName typeName,
                                         SimpleType.Fn<T,byte[]> serialize,
                                         SimpleType.Fn<byte[],T> deserialize)

simpleImmutableTypeFrom

public static <T> Type<T> simpleImmutableTypeFrom(TypeName typeName,
                                                  SimpleType.Fn<T,byte[]> serialize,
                                                  SimpleType.Fn<byte[],T> deserialize)

typeName

public TypeName typeName()

Specified by:

typeName in interface Type<T>

Returns:

The unique TypeName of this type.

typeSerializer

public TypeSerializer<T> typeSerializer()

Specified by:

typeSerializer in interface Type<T>

Returns:

A TypeSerializer that can serialize and deserialize this type.

typeCharacteristics

public java.util.Set<TypeCharacteristics> typeCharacteristics()

Specified by:

typeCharacteristics in interface Type<T>