Class | Description |
---|---|
CaseClassComparator<T extends scala.Product> |
Comparator for Case Classes.
|
CaseClassSerializer<T extends scala.Product> |
Serializer for Case Classes.
|
CaseClassTypeInfo<T extends scala.Product> |
TypeInformation for Case Classes.
|
EitherSerializer<A,B,T extends scala.util.Either<A,B>> |
Serializer for
Either . |
EitherTypeInfo<A,B,T extends scala.util.Either<A,B>> |
TypeInformation
Either . |
EnumValueComparator<E extends scala.Enumeration> |
Comparator for
Enumeration values. |
EnumValueSerializer<E extends scala.Enumeration> |
Serializer for
Enumeration values. |
EnumValueSerializer.ScalaEnumSerializerConfigSnapshot<E extends scala.Enumeration> | |
EnumValueSerializer.ScalaEnumSerializerConfigSnapshot$ | |
EnumValueSerializer$ | |
EnumValueTypeInfo<E extends scala.Enumeration> |
TypeInformation for
Enumeration values. |
NothingSerializer |
Serializer for cases where no serializer is required but the system still expects one.
|
OptionSerializer<A> |
Serializer for
Option . |
OptionSerializer.OptionSerializerConfigSnapshot<A> |
We need to keep this to be compatible with snapshots taken in Flink 1.3.0.
|
OptionSerializer.OptionSerializerConfigSnapshot$ | |
OptionSerializer$ | |
OptionTypeComparator<A> |
Comparator for
Option values. |
OptionTypeComparator$ | |
OptionTypeInfo<A,T extends scala.Option<A>> |
TypeInformation for
Option . |
ScalaNothingTypeInfo | |
ScalaOptionSerializerConfigSnapshot<E> |
A
TypeSerializerConfigSnapshot for the Scala OptionSerializer . |
ScalaTrySerializerConfigSnapshot<E> |
A
TypeSerializerConfigSnapshot for the Scala TrySerializer . |
TraversableSerializer<T extends scala.collection.TraversableOnce<E>,E> |
Serializer for Scala Collections.
|
TraversableSerializerConfigSnapshot<E> |
A
TypeSerializerConfigSnapshot for the Scala TraversableSerializer . |
TraversableTypeInfo<T extends scala.collection.TraversableOnce<E>,E> |
TypeInformation for Scala Collections.
|
TrySerializer<A> |
Serializer for
Try . |
TrySerializer.TrySerializerConfigSnapshot<A> |
We need to keep this to be compatible with snapshots taken in Flink 1.3.0.
|
TrySerializer.TrySerializerConfigSnapshot$ | |
TrySerializer$ | |
TryTypeInfo<A,T extends scala.util.Try<A>> |
TypeInformation for
Try . |
TypeUtils | |
TypeUtils$ | |
UnitSerializer | |
UnitTypeInfo |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.