Uses of Interface
org.apache.flink.statefun.sdk.java.types.Type

Packages that use Type

Package	Description
org.apache.flink.statefun.sdk.java
org.apache.flink.statefun.sdk.java.io
org.apache.flink.statefun.sdk.java.message
org.apache.flink.statefun.sdk.java.types

Uses of Type in org.apache.flink.statefun.sdk.java

Methods in org.apache.flink.statefun.sdk.java that return Type

Modifier and Type	Method and Description
Type<T>	ValueSpec.type()

Methods in org.apache.flink.statefun.sdk.java with parameters of type Type

Modifier and Type	Method and Description
<T> ValueSpec<T>	ValueSpec.Untyped.withCustomType(Type<T> type)

Uses of Type in org.apache.flink.statefun.sdk.java.io

Methods in org.apache.flink.statefun.sdk.java.io with parameters of type Type

Modifier and Type	Method and Description
<T> KafkaEgressMessage.Builder	KafkaEgressMessage.Builder.withKey(Type<T> type, T value)
<T> KinesisEgressMessage.Builder	KinesisEgressMessage.Builder.withValue(Type<T> type, T value)
<T> KafkaEgressMessage.Builder	KafkaEgressMessage.Builder.withValue(Type<T> type, T value)

Uses of Type in org.apache.flink.statefun.sdk.java.message

Methods in org.apache.flink.statefun.sdk.java.message with parameters of type Type

Modifier and Type	Method and Description
<T> T	Message.as(Type<T> type)
<T> T	MessageWrapper.as(Type<T> type)
<T> boolean	Message.is(Type<T> type)
<T> boolean	MessageWrapper.is(Type<T> type)
<T> MessageBuilder	MessageBuilder.withCustomType(Type<T> customType, T element)
<T> EgressMessageBuilder	EgressMessageBuilder.withCustomType(Type<T> customType, T element)

Uses of Type in org.apache.flink.statefun.sdk.java.types

Classes in org.apache.flink.statefun.sdk.java.types that implement Type

Modifier and Type	Class and Description
class	SimpleType<T> A utility to create simple Type implementations.
class	SliceType

Methods in org.apache.flink.statefun.sdk.java.types that return Type

Modifier and Type	Method and Description
static Type<java.lang.Boolean>	Types.booleanType()
static Type<java.lang.Double>	Types.doubleType()
static Type<java.lang.Float>	Types.floatType()
static Type<java.lang.Integer>	Types.integerType()
static Type<java.lang.Long>	Types.longType()
static <T> Type<T>	SimpleType.simpleImmutableTypeFrom(TypeName typeName, SimpleType.Fn<T,byte[]> serialize, SimpleType.Fn<byte[],T> deserialize)
static <T> Type<T>	SimpleType.simpleTypeFrom(TypeName typeName, SimpleType.Fn<T,byte[]> serialize, SimpleType.Fn<byte[],T> deserialize)
static Type<java.lang.String>	Types.stringType()