Packages

package util

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class SpelHack extends Serializer[List[_]]
  2. class SpelMapHack extends Serializer[Map[_, _]]
  3. class TimeSerializers extends AnyRef

    Copied from com.esotericsoftware.kryo.serializers.TimeSerializers - newer Kryo version

    Copied from com.esotericsoftware.kryo.serializers.TimeSerializers - newer Kryo version

    Serializers for java.time.*, are added as default serializers if java version is >= 8.

    Serializers are all public because Flink's class-based serialization init instances of serializer by creating a new instance

    Implementation note: All serialization is inspired by oracles java.time.Ser.

Value Members

  1. object Serializers extends LazyLogging

    Watch out, serializers are also serialized.

    Watch out, serializers are also serialized. Incompatible SerializationUID on serializer class can lead process state loss (unable to continue from old snapshot). This is why we set SerialVersionUID explicit.

    See also

    org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil#writeSerializersAndConfigsWithResilience

    org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil#readSerializersAndConfigsWithResilience

  2. object SpelHack
  3. object SpelMapHack
  4. object StateConfiguration

Ungrouped