Serialized Form

  • Package io.confluent.flink.plugin

  • Package org.apache.flink.api.common.typeinfo

    • Class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo

      class BasicArrayTypeInfo extends TypeInformation<T extends Object> implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.api.common.typeinfo.BasicTypeInfo

      class BasicTypeInfo extends TypeInformation<T extends Object> implements Serializable
      serialVersionUID:
      -430955220409131770L

      • Serialized Fields

        • clazz
          Class<T extends Object> clazz
        • comparatorClass
          Class<? extends org.apache.flink.api.common.typeutils.TypeComparator<T extends Object>> comparatorClass
        • possibleCastTargetTypes
          Class<?>[] possibleCastTargetTypes
        • serializer
          org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> serializer

    • Class org.apache.flink.api.common.typeinfo.BitmapTypeInfo

      class BitmapTypeInfo extends TypeInformation<org.apache.flink.types.bitmap.Bitmap> implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.api.common.typeinfo.FractionalTypeInfo

      class FractionalTypeInfo extends org.apache.flink.api.common.typeinfo.NumericTypeInfo<T extends Object> implements Serializable
      serialVersionUID:
      554334260950199994L

    • Class org.apache.flink.api.common.typeinfo.IntegerTypeInfo

      class IntegerTypeInfo extends org.apache.flink.api.common.typeinfo.NumericTypeInfo<T extends Object> implements Serializable
      serialVersionUID:
      -8068827354966766955L

    • Class org.apache.flink.api.common.typeinfo.LocalTimeTypeInfo

      class LocalTimeTypeInfo extends TypeInformation<T extends Temporal> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • clazz
          Class<T extends Temporal> clazz
        • comparatorClass
          Class<? extends org.apache.flink.api.common.typeutils.TypeComparator<T extends Temporal>> comparatorClass
        • serializer
          org.apache.flink.api.common.typeutils.TypeSerializer<T extends Temporal> serializer

    • Class org.apache.flink.api.common.typeinfo.NothingTypeInfo

      class NothingTypeInfo extends TypeInformation<org.apache.flink.types.Nothing> implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.api.common.typeinfo.NumericTypeInfo

      class NumericTypeInfo extends org.apache.flink.api.common.typeinfo.BasicTypeInfo<T extends Object> implements Serializable
      serialVersionUID:
      -5937777910658986986L

    • Class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo

      class PrimitiveArrayTypeInfo extends TypeInformation<T extends Object> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • arrayClass
          Class<T extends Object> arrayClass
        • comparatorClass
          Class<? extends org.apache.flink.api.common.typeutils.base.array.PrimitiveArrayComparator<T extends Object,?>> comparatorClass
        • serializer
          org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> serializer

    • Class org.apache.flink.api.common.typeinfo.SqlTimeTypeInfo

      class SqlTimeTypeInfo extends TypeInformation<T> implements Serializable
      serialVersionUID:
      -132955295409131880L

      • Serialized Fields

        • clazz
          Class<T> clazz
        • comparatorClass
          Class<? extends org.apache.flink.api.common.typeutils.TypeComparator<T>> comparatorClass
        • serializer
          org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer

    • Class org.apache.flink.api.common.typeinfo.TypeDescriptors

      class TypeDescriptors extends Object implements Serializable

    • Class org.apache.flink.api.common.typeinfo.TypeInformation

      class TypeInformation extends Object implements Serializable
      serialVersionUID:
      -7742311969684489493L

    • Class org.apache.flink.api.common.typeinfo.VariantTypeInfo

      class VariantTypeInfo extends TypeInformation<org.apache.flink.types.variant.Variant> implements Serializable

  • Package org.apache.flink.configuration

    • Class org.apache.flink.configuration.Configuration

      class Configuration extends org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • confData
          HashMap<String,Object> confData
          Stores the concrete key/value pairs of this configuration object.

          NOTE: This map stores the values that are actually used, and does not include any escaping that is required by the standard YAML syntax.

    • Class org.apache.flink.configuration.DelegatingConfiguration

      class DelegatingConfiguration extends Configuration implements Serializable
      serialVersionUID:
      1L

    • Exception org.apache.flink.configuration.IllegalConfigurationException

      class IllegalConfigurationException extends RuntimeException implements Serializable
      serialVersionUID:
      695506964810499989L

    • Class org.apache.flink.configuration.MemorySize

      class MemorySize extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • bytes
          long bytes
          The memory size, in bytes.

    • Class org.apache.flink.configuration.UnmodifiableConfiguration

      class UnmodifiableConfiguration extends Configuration implements Serializable
      serialVersionUID:
      -8151292629158972280L

  • Package org.apache.flink.core.execution

  • Package org.apache.flink.table.api

    • Exception org.apache.flink.table.api.AmbiguousTableFactoryException

      class AmbiguousTableFactoryException extends RuntimeException implements Serializable

      • Serialized Fields

        • factories
          List<org.apache.flink.table.legacy.factories.TableFactory> factories
          Deprecated.
        • factoryClass
          Class<? extends org.apache.flink.table.legacy.factories.TableFactory> factoryClass
          Deprecated.
        • matchingFactories
          List<? extends org.apache.flink.table.legacy.factories.TableFactory> matchingFactories
          Deprecated.
        • properties
          Map<String,String> properties
          Deprecated.

    • Exception org.apache.flink.table.api.CatalogNotExistException

      class CatalogNotExistException extends RuntimeException implements Serializable

    • Exception org.apache.flink.table.api.ExpressionParserException

      class ExpressionParserException extends RuntimeException implements Serializable

    • Class org.apache.flink.table.api.InsertConflictStrategy

      class InsertConflictStrategy extends Object implements Serializable
      serialVersionUID:
      1L

    • Exception org.apache.flink.table.api.NoMatchingTableFactoryException

      class NoMatchingTableFactoryException extends RuntimeException implements Serializable

      • Serialized Fields

        • factories
          List<org.apache.flink.table.legacy.factories.TableFactory> factories
          Deprecated.
        • factoryClass
          Class<?> factoryClass
          Deprecated.
        • matchCandidatesMessage
          String matchCandidatesMessage
          Deprecated.
        • message
          String message
          Deprecated.
        • properties
          Map<String,String> properties
          Deprecated.

    • Exception org.apache.flink.table.api.SqlParserEOFException

      class SqlParserEOFException extends org.apache.flink.table.api.SqlParserException implements Serializable

    • Exception org.apache.flink.table.api.SqlParserException

      class SqlParserException extends RuntimeException implements Serializable

    • Exception org.apache.flink.table.api.TableException

      class TableException extends RuntimeException implements Serializable

    • Exception org.apache.flink.table.api.TableNotExistException

      class TableNotExistException extends RuntimeException implements Serializable

    • Exception org.apache.flink.table.api.TableRuntimeException

      class TableRuntimeException extends RuntimeException implements Serializable

    • Exception org.apache.flink.table.api.ValidationException

      class ValidationException extends RuntimeException implements Serializable

  • Package org.apache.flink.table.catalog

  • Package org.apache.flink.table.connector

  • Package org.apache.flink.table.connector.sink

  • Package org.apache.flink.table.connector.source

    • Class org.apache.flink.table.connector.source.DynamicFilteringData

      class DynamicFilteringData extends Object implements Serializable

    • Class org.apache.flink.table.connector.source.DynamicFilteringEvent

      class DynamicFilteringEvent extends Object implements Serializable

      • Serialized Fields

        • data
          org.apache.flink.table.connector.source.DynamicFilteringData data

  • Package org.apache.flink.table.connector.source.abilities

  • Package org.apache.flink.table.data

  • Package org.apache.flink.table.expressions

    • Exception org.apache.flink.table.expressions.ExpressionParserException

      class ExpressionParserException extends org.apache.flink.table.api.ExpressionParserException implements Serializable

    • Class org.apache.flink.table.expressions.UnresolvedReferenceExpression

      class UnresolvedReferenceExpression extends Object implements Serializable

      • Serialized Fields

  • Package org.apache.flink.table.factories

    • Exception org.apache.flink.table.factories.AmbiguousTableFactoryException

      class AmbiguousTableFactoryException extends org.apache.flink.table.api.AmbiguousTableFactoryException implements Serializable

    • Exception org.apache.flink.table.factories.NoMatchingTableFactoryException

      class NoMatchingTableFactoryException extends org.apache.flink.table.api.NoMatchingTableFactoryException implements Serializable

  • Package org.apache.flink.table.functions

  • Package org.apache.flink.table.module

  • Package org.apache.flink.table.runtime.functions

    • Class org.apache.flink.table.runtime.functions.DefaultExpressionEvaluator

      class DefaultExpressionEvaluator extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • expressionSummary
          String expressionSummary
        • generatedClass
          org.apache.flink.table.runtime.generated.GeneratedFunction<org.apache.flink.api.common.functions.RichFunction> generatedClass
        • methodType
          MethodType methodType

  • Package org.apache.flink.table.types

  • Package org.apache.flink.table.types.logical

    • Class org.apache.flink.table.types.logical.ArrayType

      class ArrayType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

    • Class org.apache.flink.table.types.logical.BigIntType

      class BigIntType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.BinaryType

      class BinaryType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • length
          int length

    • Class org.apache.flink.table.types.logical.BitmapType

      class BitmapType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.BooleanType

      class BooleanType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.CharType

      class CharType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • length
          int length

    • Class org.apache.flink.table.types.logical.DateType

      class DateType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.DayTimeIntervalType

      class DayTimeIntervalType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • dayPrecision
          int dayPrecision
        • fractionalPrecision
          int fractionalPrecision
        • resolution
          org.apache.flink.table.types.logical.DayTimeIntervalType.DayTimeResolution resolution

    • Class org.apache.flink.table.types.logical.DecimalType

      class DecimalType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • precision
          int precision
        • scale
          int scale

    • Class org.apache.flink.table.types.logical.DescriptorType

      class DescriptorType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.DistinctType

      class DistinctType extends org.apache.flink.table.types.logical.UserDefinedType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.DoubleType

      class DoubleType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.FloatType

      class FloatType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.IntType

      class IntType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.LegacyTypeInformationType

      class LegacyTypeInformationType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.LocalZonedTimestampType

      class LocalZonedTimestampType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • kind
          org.apache.flink.table.types.logical.TimestampKind kind
        • precision
          int precision

    • Class org.apache.flink.table.types.logical.LogicalType

      class LogicalType extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • isNullable
          boolean isNullable
        • typeRoot
          org.apache.flink.table.types.logical.LogicalTypeRoot typeRoot

    • Class org.apache.flink.table.types.logical.MapType

      class MapType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.MultisetType

      class MultisetType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

    • Class org.apache.flink.table.types.logical.NullType

      class NullType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.RawType

      class RawType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • clazz
          Class<T extends Object> clazz
        • serializer
          org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> serializer

    • Class org.apache.flink.table.types.logical.RowType

      class RowType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.RowType.RowField

      class RowField extends Object implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.SmallIntType

      class SmallIntType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.StructuredType

      class StructuredType extends org.apache.flink.table.types.logical.UserDefinedType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.StructuredType.StructuredAttribute

      class StructuredAttribute extends Object implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.SymbolType

      class SymbolType extends LogicalType implements Serializable
      serialVersionUID:
      2L

    • Class org.apache.flink.table.types.logical.TimestampType

      class TimestampType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • kind
          org.apache.flink.table.types.logical.TimestampKind kind
        • precision
          int precision

    • Class org.apache.flink.table.types.logical.TimeType

      class TimeType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • precision
          int precision

    • Class org.apache.flink.table.types.logical.TinyIntType

      class TinyIntType extends LogicalType implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.table.types.logical.UnresolvedUserDefinedType

      class UnresolvedUserDefinedType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • unresolvedIdentifier
          org.apache.flink.table.catalog.UnresolvedIdentifier unresolvedIdentifier

    • Class org.apache.flink.table.types.logical.UserDefinedType

      class UserDefinedType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

    • Class org.apache.flink.table.types.logical.VarBinaryType

      class VarBinaryType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • length
          int length

    • Class org.apache.flink.table.types.logical.VarCharType

      class VarCharType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • length
          int length

    • Class org.apache.flink.table.types.logical.VariantType

      class VariantType extends LogicalType implements Serializable

    • Class org.apache.flink.table.types.logical.YearMonthIntervalType

      class YearMonthIntervalType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • resolution
          org.apache.flink.table.types.logical.YearMonthIntervalType.YearMonthResolution resolution
        • yearPrecision
          int yearPrecision

    • Class org.apache.flink.table.types.logical.ZonedTimestampType

      class ZonedTimestampType extends LogicalType implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • kind
          org.apache.flink.table.types.logical.TimestampKind kind
        • precision
          int precision

  • Package org.apache.flink.types

    • Class org.apache.flink.types.BooleanValue

      class BooleanValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          boolean value

    • Class org.apache.flink.types.ByteValue

      class ByteValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          byte value

    • Class org.apache.flink.types.CharValue

      class CharValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          char value

    • Class org.apache.flink.types.ColumnList

      class ColumnList extends Object implements Serializable
      serialVersionUID:
      1L

    • Exception org.apache.flink.types.DeserializationException

      class DeserializationException extends RuntimeException implements Serializable
      serialVersionUID:
      -8725950711347033148L

    • Class org.apache.flink.types.DoubleValue

      class DoubleValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          double value

    • Class org.apache.flink.types.FloatValue

      class FloatValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          float value

    • Class org.apache.flink.types.IntValue

      class IntValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          int value

    • Exception org.apache.flink.types.KeyFieldOutOfBoundsException

      class KeyFieldOutOfBoundsException extends RuntimeException implements Serializable
      serialVersionUID:
      1538404143052384932L

      • Serialized Fields

        • fieldNumber
          int fieldNumber

    • Class org.apache.flink.types.ListValue

      class ListValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • list
          List<V extends org.apache.flink.types.Value> list
        • valueClass
          Class<V extends org.apache.flink.types.Value> valueClass

    • Class org.apache.flink.types.LongValue

      class LongValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          long value

    • Class org.apache.flink.types.MapValue

      class MapValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • keyClass
          Class<K extends org.apache.flink.types.Value> keyClass
        • map
          Map<K extends org.apache.flink.types.Value,V extends org.apache.flink.types.Value> map
        • valueClass
          Class<V extends org.apache.flink.types.Value> valueClass

    • Exception org.apache.flink.types.NullFieldException

      class NullFieldException extends RuntimeException implements Serializable
      serialVersionUID:
      -8820467525772321173L

      • Serialized Fields

        • fieldPos
          int fieldPos

    • Exception org.apache.flink.types.NullKeyFieldException

      class NullKeyFieldException extends RuntimeException implements Serializable
      serialVersionUID:
      -3254501285363420762L

      • Serialized Fields

        • fieldNumber
          int fieldNumber

    • Class org.apache.flink.types.NullValue

      class NullValue extends Object implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.types.Record

      class Record extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • binaryData
          byte[] binaryData
        • binaryLen
          int binaryLen
        • firstModifiedPos
          int firstModifiedPos
        • lengths
          int[] lengths
        • numFields
          int numFields
        • offsets
          int[] offsets
        • readFields
          org.apache.flink.types.Value[] readFields
        • serializer
          org.apache.flink.types.Record.InternalDeSerializer serializer
        • switchBuffer
          byte[] switchBuffer
        • writeFields
          org.apache.flink.types.Value[] writeFields

    • Class org.apache.flink.types.Row

      class Row extends Object implements Serializable
      serialVersionUID:
      3L

      • Serialized Fields

        • fieldByName
          Map<String,Object> fieldByName
          Fields organized by name. Either this or Row.fieldByPosition is set.
        • fieldByPosition
          Object[] fieldByPosition
          Fields organized by position. Either this or Row.fieldByName is set.
        • kind
          RowKind kind
          The kind of change a row describes in a changelog.
        • positionByName
          LinkedHashMap<String,Integer> positionByName
          Mapping from field names to positions. Requires Row.fieldByPosition semantics.

    • Class org.apache.flink.types.SerializableOptional

      class SerializableOptional extends Object implements Serializable
      serialVersionUID:
      -3312769593551775940L

    • Class org.apache.flink.types.ShortValue

      class ShortValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • value
          short value

    • Class org.apache.flink.types.StringValue

      class StringValue extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • hashCode
          int hashCode
        • len
          int len
        • value
          char[] value

  • Package org.apache.flink.util

    • Class org.apache.flink.util.AbstractID

      class AbstractID extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • lowerPart
          long lowerPart
        • upperPart
          long upperPart

    • Class org.apache.flink.util.AbstractParameterTool

      class AbstractParameterTool extends org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.util.CompressedSerializedValue

      class CompressedSerializedValue extends org.apache.flink.util.SerializedValue<T extends Object> implements Serializable
      serialVersionUID:
      -4358765382738374654L

    • Exception org.apache.flink.util.ConfigurationException

      class ConfigurationException extends org.apache.flink.util.FlinkException implements Serializable
      serialVersionUID:
      3971647332059381556L

    • Exception org.apache.flink.util.DynamicCodeLoadingException

      class DynamicCodeLoadingException extends org.apache.flink.util.FlinkException implements Serializable
      serialVersionUID:
      -25138443817255490L

    • Exception org.apache.flink.util.FlinkException

      class FlinkException extends Exception implements Serializable
      serialVersionUID:
      450688772469004724L

    • Exception org.apache.flink.util.FlinkExpectedException

      class FlinkExpectedException extends Exception implements Serializable
      serialVersionUID:
      1L

    • Exception org.apache.flink.util.FlinkRuntimeException

      class FlinkRuntimeException extends RuntimeException implements Serializable
      serialVersionUID:
      193141189399279147L

    • Class org.apache.flink.util.LongValueSequenceIterator

      class LongValueSequenceIterator extends org.apache.flink.util.SplittableIterator<org.apache.flink.types.LongValue> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • current
          long current
        • currentValue
          org.apache.flink.types.LongValue currentValue
        • to
          long to

    • Class org.apache.flink.util.MultipleParameterTool

      class MultipleParameterTool extends org.apache.flink.util.AbstractParameterTool implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.util.NumberSequenceIterator

      class NumberSequenceIterator extends org.apache.flink.util.SplittableIterator<Long> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • current
          long current
        • to
          long to

    • Class org.apache.flink.util.OptionalFailure

      class OptionalFailure extends Object implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.util.OutputTag

      class OutputTag extends Object implements Serializable
      serialVersionUID:
      2L

    • Class org.apache.flink.util.ParameterTool

      class ParameterTool extends org.apache.flink.util.AbstractParameterTool implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.util.ResourceGuard

      class ResourceGuard extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • closed
          boolean closed
        • leaseCount
          int leaseCount
        • lock
          org.apache.flink.util.SerializableObject lock

    • Class org.apache.flink.util.SerializableObject

      class SerializableObject extends Object implements Serializable
      serialVersionUID:
      -7322636177391854669L

    • Exception org.apache.flink.util.SerializedThrowable

      class SerializedThrowable extends Exception implements Serializable
      serialVersionUID:
      7284183123441947635L

      • Serialized Fields

        • fullStringifiedStackTrace
          String fullStringifiedStackTrace
        • originalErrorClassName
          String originalErrorClassName
        • serializedException
          byte[] serializedException

    • Class org.apache.flink.util.SerializedValue

      class SerializedValue extends Object implements Serializable
      serialVersionUID:
      -3564011643393683761L

      • Serialized Fields

        • serializedData
          byte[] serializedData

    • Class org.apache.flink.util.SplittableIterator

      class SplittableIterator extends Object implements Serializable
      serialVersionUID:
      200377674313072307L

    • Exception org.apache.flink.util.StateMigrationException

      class StateMigrationException extends org.apache.flink.util.FlinkException implements Serializable
      serialVersionUID:
      8268516412747670839L

    • Class org.apache.flink.util.StringBasedID

      class StringBasedID extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

    • Class org.apache.flink.util.StringValueUtils.WhitespaceTokenizer

      class WhitespaceTokenizer extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • limit
          int limit
        • pos
          int pos
        • toTokenize
          org.apache.flink.types.StringValue toTokenize

    • Exception org.apache.flink.util.TraversableOnceException

      class TraversableOnceException extends RuntimeException implements Serializable
      serialVersionUID:
      7636881584773577290L

    • Class org.apache.flink.util.Utils.ChecksumHashCode

      class ChecksumHashCode extends Object implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • checksum
          long checksum
        • count
          long count

    • Class org.apache.flink.util.Utils.ChecksumHashCodeHelper

      class ChecksumHashCodeHelper extends org.apache.flink.api.common.io.RichOutputFormat<T extends Object> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • checksum
          long checksum
        • counter
          long counter
        • id
          String id

    • Class org.apache.flink.util.Utils.CollectHelper

      class CollectHelper extends org.apache.flink.api.common.io.RichOutputFormat<T extends Object> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • accumulator
          org.apache.flink.api.common.accumulators.SerializedListAccumulator<T extends Object> accumulator
        • id
          String id
        • serializer
          org.apache.flink.api.common.typeutils.TypeSerializer<T extends Object> serializer

    • Class org.apache.flink.util.Utils.CountHelper

      class CountHelper extends org.apache.flink.api.common.io.RichOutputFormat<T extends Object> implements Serializable
      serialVersionUID:
      1L

      • Serialized Fields

        • counter
          long counter
        • id
          String id

    • Exception org.apache.flink.util.WrappingRuntimeException

      class WrappingRuntimeException extends org.apache.flink.util.FlinkRuntimeException implements Serializable
      serialVersionUID:
      1L

    • Class org.apache.flink.util.XORShiftRandom

      class XORShiftRandom extends Random implements Serializable
      serialVersionUID:
      -825722456120842841L

      • Serialized Fields

        • seed
          long seed