com.google.protobuf.Message cachedUnpackValue
Object typeUrl_
com.google.protobuf.ByteString value_
byte memoizedIsInitialized
boolean value_
byte memoizedIsInitialized
int hash
com.google.protobuf.ByteString value_
byte memoizedIsInitialized
int bitField0_
Object name_
List<E> field_
List<E> extension_
List<E> nestedType_
List<E> enumType_
List<E> extensionRange_
List<E> oneofDecl_
com.google.protobuf.DescriptorProtos.MessageOptions options_
List<E> reservedRange_
com.google.protobuf.LazyStringArrayList reservedName_
byte memoizedIsInitialized
int bitField0_
int start_
int end_
com.google.protobuf.DescriptorProtos.ExtensionRangeOptions options_
byte memoizedIsInitialized
int bitField0_
int start_
int end_
byte memoizedIsInitialized
int bitField0_
int start_
int end_
byte memoizedIsInitialized
int bitField0_
boolean allowAlias_
boolean deprecated_
boolean deprecatedLegacyJsonFieldConflicts_
com.google.protobuf.DescriptorProtos.FeatureSet features_
List<E> uninterpretedOption_
byte memoizedIsInitialized
int bitField0_
Object name_
int number_
com.google.protobuf.DescriptorProtos.EnumValueOptions options_
byte memoizedIsInitialized
int bitField0_
int fieldPresence_
int enumType_
int repeatedFieldEncoding_
int stringFieldValidation_
int messageEncoding_
int jsonFormat_
com.google.protobuf.DescriptorProtos.FeatureSet rawFeatures_
byte memoizedIsInitialized
int bitField0_
Object name_
int number_
int label_
int type_
Object typeName_
Object extendee_
Object defaultValue_
int oneofIndex_
Object jsonName_
com.google.protobuf.DescriptorProtos.FieldOptions options_
boolean proto3Optional_
byte memoizedIsInitialized
int bitField0_
int ctype_
boolean packed_
int jstype_
boolean lazy_
boolean unverifiedLazy_
boolean deprecated_
boolean weak_
boolean debugRedact_
int retention_
List<E> targets_
List<E> editionDefaults_
com.google.protobuf.DescriptorProtos.FeatureSet features_
List<E> uninterpretedOption_
byte memoizedIsInitialized
int bitField0_
Object name_
Object package_
com.google.protobuf.LazyStringArrayList dependency_
com.google.protobuf.Internal.IntList publicDependency_
com.google.protobuf.Internal.IntList weakDependency_
List<E> messageType_
List<E> enumType_
List<E> service_
List<E> extension_
com.google.protobuf.DescriptorProtos.FileOptions options_
com.google.protobuf.DescriptorProtos.SourceCodeInfo sourceCodeInfo_
Object syntax_
Object edition_
byte memoizedIsInitialized
int bitField0_
Object javaPackage_
Object javaOuterClassname_
boolean javaMultipleFiles_
boolean javaGenerateEqualsAndHash_
boolean javaStringCheckUtf8_
int optimizeFor_
Object goPackage_
boolean ccGenericServices_
boolean javaGenericServices_
boolean pyGenericServices_
boolean phpGenericServices_
boolean deprecated_
boolean ccEnableArenas_
Object objcClassPrefix_
Object csharpNamespace_
Object swiftPrefix_
Object phpClassPrefix_
Object phpNamespace_
Object phpMetadataNamespace_
Object rubyPackage_
com.google.protobuf.DescriptorProtos.FeatureSet features_
List<E> uninterpretedOption_
byte memoizedIsInitialized
int bitField0_
com.google.protobuf.Internal.IntList path_
int pathMemoizedSerializedSize
Object sourceFile_
int begin_
int end_
int semantic_
byte memoizedIsInitialized
int bitField0_
boolean messageSetWireFormat_
boolean noStandardDescriptorAccessor_
boolean deprecated_
boolean mapEntry_
boolean deprecatedLegacyJsonFieldConflicts_
com.google.protobuf.DescriptorProtos.FeatureSet features_
List<E> uninterpretedOption_
byte memoizedIsInitialized
int bitField0_
Object name_
Object inputType_
Object outputType_
com.google.protobuf.DescriptorProtos.MethodOptions options_
boolean clientStreaming_
boolean serverStreaming_
byte memoizedIsInitialized
int bitField0_
Object name_
com.google.protobuf.DescriptorProtos.OneofOptions options_
byte memoizedIsInitialized
int bitField0_
com.google.protobuf.Internal.IntList path_
int pathMemoizedSerializedSize
com.google.protobuf.Internal.IntList span_
int spanMemoizedSerializedSize
Object leadingComments_
Object trailingComments_
com.google.protobuf.LazyStringArrayList leadingDetachedComments_
byte memoizedIsInitialized
int bitField0_
List<E> name_
Object identifierValue_
long positiveIntValue_
long negativeIntValue_
double doubleValue_
com.google.protobuf.ByteString stringValue_
Object aggregateValue_
byte memoizedIsInitialized
int bitField0_
Object namePart_
boolean isExtension_
byte memoizedIsInitialized
double value_
byte memoizedIsInitialized
long seconds_
int nanos_
byte memoizedIsInitialized
byte memoizedIsInitialized
com.google.protobuf.LazyStringArrayList paths_
byte memoizedIsInitialized
float value_
byte memoizedIsInitialized
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
com.google.protobuf.FieldSet<T extends com.google.protobuf.FieldSet.FieldDescriptorLite<T>> extensions
protected Object readResolve() throws ObjectStreamException
ObjectStreamException
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
com.google.protobuf.FieldSet<T extends com.google.protobuf.FieldSet.FieldDescriptorLite<T>> extensions
int value_
byte memoizedIsInitialized
long value_
byte memoizedIsInitialized
com.google.protobuf.MessageLite unfinishedMessage
boolean wasThrownFromInputStream
boolean isMutable
int bitField0_
Object name_
com.google.protobuf.Any value_
byte memoizedIsInitialized
Object fileName_
byte memoizedIsInitialized
Object value_
byte memoizedIsInitialized
com.google.protobuf.MapField<K,V> fields_
byte memoizedIsInitialized
int line
int column
String unknownField
long seconds_
int nanos_
byte memoizedIsInitialized
int bitField0_
Object name_
List<E> fields_
com.google.protobuf.LazyStringArrayList oneofs_
List<E> options_
com.google.protobuf.SourceContext sourceContext_
int syntax_
Object edition_
byte memoizedIsInitialized
int value_
byte memoizedIsInitialized
long value_
byte memoizedIsInitialized
int kindCase_
Object kind_
byte memoizedIsInitialized
public void readExternal(ObjectInput in) throws IOException
IOException
public void writeExternal(ObjectOutput out) throws IOException
IOException
org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory.Creator creator
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> isReleaseSynchronous
Collator collator
org.apache.calcite.sql.type.SqlTypeName typeName
boolean isNullable
org.apache.calcite.rel.type.RelDataType elementType
int precision
int scale
org.apache.calcite.rel.type.RelDataTypeSystem typeSystem
org.apache.calcite.sql.SqlCollation collation
org.apache.calcite.util.SerializableCharset wrappedCharset
org.apache.calcite.rel.type.RelDataTypeSystem typeSystem
org.apache.calcite.sql.SqlIntervalQualifier intervalQualifier
org.apache.calcite.rel.type.RelDataType keyType
org.apache.calcite.rel.type.RelDataType valueType
org.apache.calcite.rel.type.RelDataType elementType
org.apache.calcite.sql.SqlIdentifier sqlIdentifier
org.apache.calcite.rel.type.RelDataTypeComparability comparability
org.apache.calcite.rel.type.RelDataTypeFamily family
String executionMode
String restartStrategyDescription
int parallelism
int maxParallelism
boolean objectReuseEnabled
long periodicMaterializeIntervalMillis
Map<K,V> globalJobParameters
Configuration configuration
Configuration
from
StreamExecutionEnvironment.SerializerConfig serializerConfig
long executionRetryDelay
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
RestartStrategyOptions
for configuring
restart strategies.com.esotericsoftware.kryo.Serializer<T> serializer
long count
double sum
double localValue
double max
double min
int localValue
int max
int min
long localValue
long max
long min
DoubleValue wrapper
double sum
long sum
TypeComparator<T> typeComparator
Object[][] boundaries
TypeComparator<T>[] flatComparators
Object[] keys
SerializableTimestampAssigner<T> assigner
long timestamp
long maxAllowedWatermarkDrift
long updateInterval
String watermarkGroup
boolean target
String sinkIdentifier
long blockSize
long readRecords
long blockSize
Path filePath
FileInputFormat.supportsMultiPaths()
and use FileInputFormat.getFilePaths()
and FileInputFormat.setFilePaths(Path...)
.Path[] filePaths
long minSplitSize
int numSplits
long openTimeout
boolean unsplittable
boolean enumerateNestedFiles
FilePathFilter filesFilter
Path outputFilePath
FileSystem.WriteMode writeMode
FileOutputFormat.OutputDirectoryMode outputDirectoryMode
boolean lineDelimiterIsLinebreak
Class<T>[] fieldTypes
boolean[] fieldIncluded
byte[] fieldDelim
String fieldDelimString
boolean lenient
boolean skipFirstLineAsHeader
boolean quotedStringParsing
byte quoteCharacter
byte[] commentPrefix
String commentPrefixString
int partitionNumber
Semaphore semaphore
Duration maxConcurrentRequestsTimeout
int maxConcurrentRequests
AtomicReference<V> throwable
InputFormat<OT,T extends InputSplit> replicatedIF
long globalRateBytesPerSecond
long localRateBytesPerSecond
RuntimeContext runtimeContext
org.apache.flink.shaded.guava31.com.google.common.util.concurrent.RateLimiter rateLimiter
Map<K,V> fieldMapping1
Map<K,V> fieldMapping2
FieldSet readFields1
FieldSet readFields2
private Object readResolve()
CPUResource cpuCores
MemorySize taskHeapMemory
MemorySize taskOffHeapMemory
MemorySize managedMemory
Map<K,V> extendedResources
String name
CPUResource cpuCores
MemorySize taskHeapMemory
MemorySize taskOffHeapMemory
MemorySize managedMemory
Map<K,V> externalResources
SlotSharingGroup
.long count
BulkIterationBase.TerminationCriterionAggregator aggregator
Object userCodeObject
String name
BigDecimal value
int restartAttempts
Duration delayBetweenAttemptsInterval
TypeInformation<T> type
DeserializationSchema
.Configuration configuration
ExecutionConfig executionConfig
TypeInformation.createSerializer(ExecutionConfig)
is
deprecated; If it is removed, this field will also be removed.LinkedHashMap<K,V> registeredTypesWithKryoSerializers
LinkedHashMap<K,V> registeredTypesWithKryoSerializerClasses
LinkedHashMap<K,V> defaultKryoSerializers
LinkedHashMap<K,V> defaultKryoSerializerClasses
LinkedHashSet<E> registeredKryoTypes
LinkedHashSet<E> registeredPojoTypes
Map<K,V> registeredTypeInfoFactories
String charsetName
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
TypeInformation<T> typeInfo
TypeInformationSerializationSchema.getProducedType()
.TypeSerializer<T> serializer
AggregateFunction<IN,ACC,OUT> aggFunction
ReduceFunction<T> reduceFunction
String name
TypeDescriptor<T> stateTypeDescriptor
AggregateFunction<IN,ACC,OUT> aggregateFunction
String name
TypeDescriptor<T> elementTypeInformation
ListStateDeclaration.RedistributionStrategy redistributionStrategy
StateDeclaration.RedistributionMode redistributionMode
String name
TypeDescriptor<T> keyTypeInformation
TypeDescriptor<T> valueTypeInformation
StateDeclaration.RedistributionMode redistributionMode
String name
TypeDescriptor<T> typeInformation
ReduceFunction<T> reduceFunction
String name
TypeDescriptor<T> valueType
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
String name
AtomicReference<V> serializerAtomicReference
StateDescriptor.initializeSerializerUnlessSet(ExecutionConfig)
method is called.TypeInformation<T> typeInfo
String queryableStateName
StateTtlConfig ttlConfig
StateTtlConfig.UpdateType updateType
StateTtlConfig.StateVisibility stateVisibility
StateTtlConfig.TtlTimeCharacteristic ttlTimeCharacteristic
Duration ttl
StateTtlConfig.CleanupStrategies cleanupStrategies
int cleanupSize
boolean runCleanupForEveryRecord
long queryTimeAfterNumEntries
Duration periodicCompactionTime
TimeUnit unit
long size
Class<T> arrayClass
TypeInformation<T> componentInfo
BasicTypeInfo<T> basicTypeInfo
ListTypeInfo<T> listTypeInfo
MapTypeInfo<K,V> mapTypeInfo
ValueTypeInfo<T extends Value> valueTypeInfo
TypeSerializer<T>[] fieldSerializers
CompositeSerializer.PrecomputedParameters precomputed
boolean immutableTargetType
boolean immutable
int length
boolean stateful
TypeComparator<T> comparator1
TypeComparator<T> comparator2
TypeComparator<T>[] comparators1
TypeComparator<T>[] comparators2
Object[] referenceKeyFields
Object[] candidateKeyFields
private void writeObject(ObjectOutputStream outputStream) throws IOException
IOException
org.apache.flink.api.common.typeutils.SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessChecker singleThreadAccessChecker
TypeSerializer<T> originalSerializer
byte[] actualBytes
Throwable originalError
boolean ascendingComparison
TypeComparator<T>[] comparators
boolean ascendingComparison
BooleanValue reference
BooleanValue tempReference
TypeComparator<T>[] comparators
boolean ascendingComparison
ByteValue reference
ByteValue tempReference
TypeComparator<T>[] comparators
boolean ascendingComparison
CharValue reference
CharValue tempReference
TypeComparator<T>[] comparators
boolean ascendingComparison
DoubleValue reference
DoubleValue tempReference
TypeComparator<T>[] comparators
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> enumClass
Map<K,V> valueToOrdinal
Enum.ordinal()
. This allows us to maintain backwards compatibility for previous serialized
data in the case that the order of enum constants was changed or new constants were added.
On a fresh start with no reconfiguration, the ordinals would simply be identical to the enum constants actual ordinals. Ordinals may change after reconfiguration.
Enum<E extends Enum<E>>[] values
EnumSerializer.valueToOrdinal
map. Serves as a bidirectional map to have fast access from ordinal to
value. May be reordered after reconfiguration.boolean ascendingComparison
FloatValue reference
FloatValue tempReference
TypeComparator<T>[] comparators
Class<T> componentClass
TypeSerializer<T> componentSerializer
boolean ascendingComparison
IntValue reference
IntValue tempReference
TypeComparator<T>[] comparators
TypeSerializer<T> elementSerializer
boolean ascendingComparison
LocalDateComparator[] comparators
boolean ascendingComparison
LocalDateComparator dateComparator
LocalTimeComparator timeComparator
LocalDateTimeComparator[] comparators
boolean ascendingComparison
LongValue reference
LongValue tempReference
TypeComparator<T>[] comparators
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
TypeComparator<T>[] comparators
boolean ascendingComparison
ShortValue reference
ShortValue tempReference
TypeComparator<T>[] comparators
boolean ascendingComparison
StringValue reference
StringValue tempReference
TypeComparator<T>[] comparators
TypeComparator<T>[] comparators
boolean ascending
BasicTypeComparator<T extends Comparable<T>> comparator
int subtaskId
String location
long from
long to
long count
long checksum
String id
long counter
long checksum
String id
TypeSerializer<T> serializer
SerializedListAccumulator<T> accumulator
String id
long counter
int count
TextOutputFormat.TextFormatter<IN> formatter
boolean withReplacement
int numSample
long seed
boolean withReplacement
int numSample
long seed
boolean withReplacement
double fraction
long seed
int[] fields
int[] fields
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hadoop.mapred.JobConf jobConf
org.apache.hadoop.mapred.OutputFormat<K,V> mapredOutputFormat
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hadoop.conf.Configuration configuration
org.apache.hadoop.mapreduce.OutputFormat<K,V> mapreduceOutputFormat
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
AbstractID intermediateDataSetId
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
TypeSerializer<T> serializer
TypeSerializer<T> typeSerializer
int id
SplittableIterator<T> source
PrintSinkOutputWriter<IN> writer
int arity
TypeInformation<T>[] fieldTypeInfos
int[] fieldPosMap
boolean emptyColumnAsNull
String partitionMarker
String charsetName
String charsetName
String charsetName
boolean skipInvalidLines
TupleSerializerBase<T> tupleSerializer
TypeSerializer<T> serializer
TypeSerializer<T> serializer
int[] fields
boolean[] isFromFirst
Tuple outTuple
CombineFunction<IN,OUT> wrappedFunction
RichGroupReduceFunction<IN,OUT> wrappedFunction
KeySelector<IN,KEY> keySelector1
KeySelector<IN,KEY> keySelector2
Tuple3<T0,T1,T2> tuple
Function wrappedFunction
long nonMissingCount
long nullCount
long nanCount
long infinityCount
Object min
Object max
Object sum
Double mean
Double variance
Double standardDeviation
long trueCount
long falseCount
long nullCount
double value
double delta
double max
double min
CompensatedSum sum
float max
float min
CompensatedSum sum
int max
int min
int sum
long max
long min
long nonMissingCount
long nullCount
long nanCount
long infinityCount
Aggregator<T,R> min
Aggregator<T,R> max
Aggregator<T,R> sum
CompensatedSum mean
CompensatedSum m2
The algorithm is described in: "Scalable and Numerically Stable Descriptive Statistics in SystemML", Tian et al, International Conference on Data Engineering 2012
long nonNullCount
long nullCount
short max
short min
short sum
long nonNullCount
long nullCount
long emptyCount
int minStringLength
int maxStringLength
CompensatedSum meanLength
Aggregator<T,R>[] columnAggregators
Aggregator<T,R> aggregator
private Object readResolve() throws ObjectStreamException
ObjectStreamException
Object f0
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f22
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f22
Object f23
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f22
Object f23
Object f24
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
TypeInformation<T> leftType
TypeInformation<T> rightType
TypeInformation<T> elementTypeInfo
TypeInformation<T> keyTypeInfo
TypeInformation<T> valueTypeInfo
String functionName
InvalidTypesException typeException
Class<T> arrayType
TypeInformation<T> componentInfo
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeInformation<T> type
PojoField[] fields
int totalFields
String[] fieldNames
boolean[] comparatorOrders
String[] fieldNames
TypeInformation<T>[] types
int totalFields
private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> type
boolean ascendingComparison
TypeComparator<T>[] comparators
TypeSerializer<T> leftSerializer
TypeSerializer<T> rightSerializer
boolean ascending
Class<T> type
TypeSerializer<T> serializer
TypeComparator<T>[] comparators
Class<T> registeredClass
Class<T> serializerClass
KryoRegistration.SerializerDefinitionType.CLASS
.ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> serializableSerializerInstance
KryoRegistration.SerializerDefinitionType.INSTANCE
.KryoRegistration.SerializerDefinitionType serializerDefinitionType
TypeSerializer<T> originalSerializer
byte[] padding
TypeComparator<T> wrappedComparator
boolean order
int flatFields
boolean nullReference
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeComparator<T>[] comparators
int[] normalizedKeyLengths
int numLeadingNormalizableKeys
int normalizableKeyPrefixLen
boolean invertNormKey
TypeSerializer<T> serializer
Class<T> type
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> clazz
TypeSerializer<T>[] fieldSerializers
int numFields
LinkedHashMap<K,V> registeredClasses
TypeSerializer<T>[] registeredSerializers
SerializerConfig serializerConfig
int arity
int[] keyPositions
NullAwareComparator<T>[] comparators
TypeSerializer<T>[] serializers
int[] normalizedKeyLengths
int numLeadingNormalizableKeys
int normalizableKeyPrefixLen
boolean invertNormKey
boolean[] mask1
boolean[] mask2
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
boolean supportsRowKind
int rowKindOffset
TypeSerializer<T>[] fieldSerializers
int arity
LinkedHashMap<K,V> positionByName
TypeComparator<T> comparator
TypeSerializer<T> serializer
Class<T> clazz
int[] keyPositions
TypeComparator<T>[] comparators
int[] normalizedKeyLengths
int numLeadingNormalizableKeys
int normalizableKeyPrefixLen
boolean invertNormKey
TypeSerializer<T>[] serializers
Class<T> tupleClass
TypeSerializer<T>[] fieldSerializers
int arity
int length
Class<T> type
boolean ascendingComparison
TypeComparator<T>[] comparators
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> type
LinkedHashMap<K,V> kryoRegistrations
This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
Currently, we only have one single registration for the value type. Nevertheless, we keep this information here for future compatibility.
Class<T> type
boolean ascendingComparison
TypeComparator<T>[] comparators
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
LinkedHashMap<K,V> defaultSerializers
LinkedHashMap<K,V> defaultSerializerClasses
LinkedHashMap<K,V> kryoRegistrations
This map serves as a preview of the final registration result of the Kryo instance, taking into account registration overwrites.
Class<T> type
LinkedHashMap<K,V> registeredTypesWithSerializers
LinkedHashMap<K,V> registeredTypesWithSerializerClasses
LinkedHashSet<E> registeredTypes
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Object[] extractedKeys
Class<T> clazz
TypeInformation<T>[] typeParamTypeInfos
scala.collection.Seq<A> fieldTypes
scala.collection.Seq<A> fieldNames
String REGEX_INT_FIELD
String REGEX_STR_FIELD
String REGEX_FIELD
String REGEX_NESTED_FIELDS
String REGEX_NESTED_FIELDS_WILDCARD
Pattern PATTERN_NESTED_FIELDS
Pattern PATTERN_NESTED_FIELDS_WILDCARD
Pattern PATTERN_INT_FIELD
TypeSerializer<T> leftSerializer
TypeSerializer<T> rightSerializer
Class<T> clazz
TypeInformation<T> leftTypeInfo
TypeInformation<T> rightTypeInfo
TypeComparator<T>[] getFlatComparators
boolean ascComp
IntComparator intComparator
boolean bitmap$0
scala.Enumeration enum
TypeSerializer<T> elemSerializer
TypeComparator<T>[] getFlatComparators
boolean ascending
TypeComparator<T> typeComparator
scala.Option<A> reference
boolean bitmap$0
private Object readResolve()
byte ZeroInByte
byte OneInByte
TypeInformation<T> elemTypeInfo
private void readObject(ObjectInputStream arg0)
private Object readResolve()
private void readObject(ObjectInputStream arg0)
TypeSerializer<T> elementSerializer
String cbfCode
int classLoaderHash
scala.ref.WeakReference<T> classLoaderRef
String cbfCode
private Object readResolve()
ClassLoader classLoader
String code
private Object readResolve()
private Object readResolve()
org.apache.flink.shaded.guava31.com.google.common.cache.Cache<K,V> CACHE
Class<T> clazz
TypeInformation<T> elementTypeInfo
TypeSerializer<T> elemSerializer
TypeSerializer<T> throwableSerializer
TypeInformation<T> elemTypeInfo
private Object readResolve()
public void readExternal(ObjectInput in) throws IOException
IOException
public void writeExternal(ObjectOutput out) throws IOException
IOException
String latchFilePath
long numRecords
long numKeys
long recordsPerPartition
long keysPerPartition
long recordCnt
int partitionId
boolean infinite
int eventsBufferCacheSlots
int entryCacheSlots
Duration cacheStatisticsInterval
PatternFlatSelectFunction<IN,OUT> flatSelectFunction
PatternSelectFunction<IN,OUT> selectFunction
PatternFlatTimeoutFunction<IN,OUT> flatTimeoutFunction
OutputTag<T> timedOutPartialMatchesTag
PatternTimeoutFunction<IN,OUT> timeoutFunction
OutputTag<T> timedOutPartialMatchesTag
int[] deweyNumber
TypeSerializer<T> sharedBufferSerializer
TypeSerializer<T> eventSerializer
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeSerializer<T> versionSerializer
NFAStateSerializer.readObject(ObjectInputStream)
.TypeSerializer<T> nodeIdSerializer
TypeSerializer<T> eventIdSerializer
boolean supportsPreviousTimestamp
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
TypeSerializer<T> versionSerializer
String name
State.StateType stateType
Collection<E> stateTransitions
StateTransitionAction action
State<T> sourceState
State<T> targetState
IterativeCondition<T> condition
TypeSerializer<T> elementSerializer
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeSerializer<T> eventIdSerializer
NodeId.NodeIdSerializer.readObject(ObjectInputStream)
.private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeSerializer<T> nodeIdSerializer
SharedBufferEdge.SharedBufferEdgeSerializer.readObject(ObjectInputStream)
.TypeSerializer<T> deweyNumberSerializer
ListSerializer<T> edgesSerializer
TypeSerializer<T> edgeSerializer
boolean isProcessingTime
TypeSerializer<T> inputSerializer
NFACompiler.NFAFactory<T> nfaFactory
EventComparator<T> comparator
OutputTag<T> lateDataOutputTag
OutputTag
to use for late arriving events. Elements with timestamp smaller than the
current watermark will be emitted to this.AfterMatchSkipStrategy afterMatchSkipStrategy
IterativeCondition<T> left
IterativeCondition<T> right
IterativeCondition<T> original
IterativeCondition<T> left
IterativeCondition<T> right
IterativeCondition<T>[] nestedConditions
ApplicationStatus status
Configuration backingConfig
String prefix
long bytes
ElementConverter<InputT,RequestEntryT> elementConverter
int maxBatchSize
int maxInFlightRequests
int maxBufferedRequests
long maxBatchSizeInBytes
long maxTimeInBufferMS
long maxRecordSizeInBytes
long requestTimeoutMS
boolean failOnTimeout
int sourceIndex
int sourceIndex
Source<T,SplitT extends SourceSplit,EnumChkT> source
boolean finalSource
TypeSerializer<T> serializer
byte[] elementsSerialized
int numElementsEmitted
TypeSerializer<T> serializer
byte[] elementsSerialized
int numElements
SourceReaderFactory<T,SplitT extends SourceSplit> sourceReaderFactory
TypeInformation<T> typeInfo
NumberSequenceSource numberSource
GeneratorFunction<T,O> generatorFunction
DataGenerator<T> generator
SerializableFunction<T,R> mapper
float nullRate
int precision
int scale
double min
double max
float nullRate
DataGenerator<T>[] fieldGenerators
List<E> fieldNames
float nullRate
org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T>> bucketsBuilder
Path basePath
long bucketCheckInterval
BulkWriter.Factory<T> writerFactory
FileWriterBucketFactory<IN> bucketFactory
BucketAssigner<IN,BucketID> bucketAssigner
CheckpointRollingPolicy<IN,BucketID> rollingPolicy
OutputFileConfig outputFileConfig
boolean isCompactDisabledExplicitly
FileCompactStrategy compactStrategy
FileCompactor fileCompactor
Path basePath
long bucketCheckInterval
Encoder<IN> encoder
FileWriterBucketFactory<IN> bucketFactory
BucketAssigner<IN,BucketID> bucketAssigner
RollingPolicy<IN,BucketID> rollingPolicy
OutputFileConfig outputFileConfig
boolean isCompactDisabledExplicitly
FileCompactStrategy compactStrategy
FileCompactor fileCompactor
String bucketId
InProgressFileWriter.PendingFileRecoverable pendingFile
InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup
Path compactedFileToCleanup
byte[] fileDelimiter
DecoderBasedReader.Decoder.Factory<T> decoderFactory
long sizeThreshold
int numCheckpointsBeforeCompaction
int numCompactThreads
SerializableSupplierWithException<T,E extends Throwable> inputFormatFactory
RecordWiseFileCompactor.Reader.Factory<T> readerFactory
BufferedReader reader
FileCompactStrategy strategy
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
SimpleVersionedSerializer<E> committableSerializer
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
FileCompactStrategy strategy
SimpleVersionedSerializer<E> committableSerializer
FileCompactor fileCompactor
BucketWriter<IN,BucketID> bucketWriter
List<E> collectingRequests
TreeMap<K,V> checkpointRequests
List<E> compactingRequests
ListState<T> remainingRequestsState
FileCompactStrategy strategy
FileCompactor fileCompactor
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
SerializableSupplierWithException<T,E extends Throwable> bucketWriterProvider
SimpleVersionedSerializer<E> committableSerializer
BucketWriter<IN,BucketID> bucketWriter
List<E> compactingRequests
SimpleVersionedListState<T> remainingRequestsState
Iterable<T> stateRemaining
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
SerializableSupplierWithException<T,E extends Throwable> bucketWriterProvider
SerializableSupplierWithException<T,E extends Throwable> committableSerializerSupplier
Path[] inputPaths
FileEnumerator.Provider enumeratorFactory
FileSplitAssigner.Provider assignerFactory
BulkFormat<T,SplitT extends FileSourceSplit> readerFormat
ContinuousEnumerationSettings continuousEnumerationSettings
Duration discoveryInterval
String id
Path filePath
long offset
long length
long fileModificationTime
FileStatus.getModificationTime()
.long fileSize
FileStatus.getLen()
.String[] hostnames
CheckpointedPosition readerPosition
FileRecordFormat<T> fileFormat
StreamFormat<T> streamFormat
String charsetName
long offset
long recordsAfterOffset
DeserializationSchema<T> deserializationSchema
Path path
FileSystemFactory fsFactory
TableMetaStoreFactory msFactory
boolean overwrite
boolean isToLocal
Path stagingPath
String[] partitionColumns
boolean dynamicGrouped
LinkedHashMap<K,V> staticPartitions
PartitionComputer<T> computer
OutputFormatFactory<T> formatFactory
OutputFileConfig outputFileConfig
ObjectIdentifier identifier
PartitionCommitPolicyFactory partitionCommitPolicyFactory
BulkWriter.Factory<T> factory
RowDataPartitionComputer computer
PartitionComputer<T> computer
boolean rollOnCheckpoint
long rollingFileSize
long rollingTimeInterval
long inactivityInterval
BulkFormat<T,SplitT extends FileSourceSplit> format
long limit
String defaultPartValue
String[] partitionColumns
int[] partitionIndexes
LogicalType[] partitionTypes
RowData.FieldGetter[] partitionFieldGetters
int[] nonPartitionIndexes
LogicalType[] nonPartitionTypes
RowData.FieldGetter[] nonPartitionFieldGetters
SerializationSchema<T> serializationSchema
SupplierWithException<R,E extends Throwable> fsFactory
long compactAverageSize
long compactTargetSize
SupplierWithException<R,E extends Throwable> fsFactory
CompactReader.Factory<T> readerFactory
CompactWriter.Factory<T> writerFactory
FileSystemFactory fsFactory
Path tmpPath
String[] partitionColumns
boolean dynamicGrouped
LinkedHashMap<K,V> staticPartitions
PartitionComputer<T> computer
OutputFormatFactory<T> formatFactory
OutputFileConfig outputFileConfig
FileSystemFactory fsFactory
TableMetaStoreFactory msFactory
PartitionCommitPolicyFactory partitionCommitPolicyFactory
Path tmpPath
boolean overwrite
boolean isToLocal
String[] partitionColumns
LinkedHashMap<K,V> staticPartitions
ObjectIdentifier identifier
long bucketCheckInterval
StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>> bucketsBuilder
boolean endOfInput
ListState<T> endOfInputState
long checkpointId
int taskId
int numberOfTasks
String[] partitions
Configuration conf
Path locationPath
ObjectIdentifier tableIdentifier
List<E> partitionKeys
TableMetaStoreFactory metaStoreFactory
FileSystemFactory fsFactory
List<E> partitionKeys
Configuration conf
SupplierWithException<R,E extends Throwable> fsFactory
long targetFileSize
long checkpointId
int taskId
int numberOfTasks
long checkpointId
SupplierWithException<R,E extends Throwable> fsFactory
CompactReader.Factory<T> readerFactory
CompactWriter.Factory<T> writerFactory
Boundedness boundedness
List<E> elements
Integer emittedElementsNum
File outputFile
SerializationSchema<T> keySerializationSchema
SerializationSchema<T> valueSerializationSchema
PartitionFetcher<P> partitionFetcher
PartitionFetcher.Context<P> fetcherContext
PartitionReader<P,OUT> partitionReader
RowData.FieldGetter[] lookupFieldGetters
Duration reloadInterval
TypeSerializer<T> serializer
RowType rowType
JobConfWrapper jobConfWrapper
DataFormatConverters.DataFormatConverter<Internal,External>[] partitionConverters
HiveObjectConversion[] hiveObjectConversions
HiveObjectConversion[] partColConversions
JobConfWrapper jobConfWrapper
List<E> partitionKeys
String hiveVersion
List<E> dynamicFilterPartitionKeys
List<E> partitionBytes
ContinuousPartitionFetcher<P,T extends Comparable<T>> fetcher
HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>> fetcherContext
ObjectPath tablePath
Long limit
List<E> partitionBytes
JobConfWrapper jobConfWrapper
JobConfWrapper conf
FileSystemFactory fileSystemFactory
String hiveVersion
String database
String tableName
boolean autoGatherStatistic
String successFileName
int gatherStatsThreadNum
ExecutorService executorService
CachedSerializedValue<T> storageDescriptor
Map<K,V> partitionSpec
Properties tableProps
TypeSerializer<T> typeSerializer
Comparable<T> consumeStartOffset
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
CachedSerializedValue<T> sd
Properties properties
JobConfWrapper jobConfWrapper
List<E> partitionKeys
String[] fieldNames
DataType[] fieldTypes
String hiveVersion
HiveShim shim
RowType producedRowType
boolean useMapRedReader
JobConfWrapper jobConfWrapper
List<E> partitionKeys
String[] fieldNames
DataType[] fieldTypes
String hiveVersion
HiveShim hiveShim
RowType producedRowType
boolean useMapRedReader
PartitionFieldExtractor<T extends FileSourceSplit> partitionFieldExtractor
int threadNum
JobConfWrapper jobConfWrapper
String hiveVersion
ObjectPath tablePath
DataType[] fieldTypes
String[] fieldNames
List<E> partitionKeys
int[] selectedFields
boolean useMapRedReader
ObjectPath tablePath
HiveShim hiveShim
JobConfWrapper confWrapper
List<E> partitionKeys
Configuration configuration
String defaultPartitionName
HiveOptions.PartitionOrder partitionOrder
HiveTablePartition hiveTablePartition
int threadNum
JobConfWrapper jobConf
String hiveVersion
List<E> partitionKeys
DataType[] fieldTypes
String[] fieldNames
List<E> partitions
int[] selectedFields
Long limit
boolean useMapRedReader
HiveTablePartition hiveTablePartition
HiveWriterFactory factory
HiveWriterFactory factory
Class<T> hiveOutputFormatClz
CachedSerializedValue<T> serDeInfo
String[] allColumns
DataType[] allTypes
String[] partitionColumns
Properties tableProperties
JobConfWrapper confWrapper
HiveShim hiveShim
boolean isCompressed
File[] localRocksDbDirectories
PredefinedOptions predefinedOptions
ReadableConfig configurableOptions
RocksDBOptionsFactory rocksDbOptionsFactory
TernaryBoolean enableIncrementalCheckpointing
int numberOfTransferThreads
RocksDBMemoryConfiguration memoryConfiguration
RocksDBPriorityQueueConfig priorityQueueConfig
RocksDBNativeMetricOptions nativeMetricOptions
long writeBatchSize
RocksDBWriteBatchWrapper
, default value
2mb.double overlapFractionThreshold
TernaryBoolean useIngestDbRestoreMode
TernaryBoolean incrementalRestoreAsyncCompactAfterRescale
TernaryBoolean rescalingUseDeleteFilesInRange
RocksDBMemoryControllerUtils.RocksDBMemoryFactory rocksDBMemoryFactory
RocksDBManualCompactionConfig manualCompactionConfig
Boolean useManagedMemory
MemorySize fixedMemoryPerSlot
Double writeBufferRatio
Double highPriorityPoolRatio
Boolean usePartitionedIndexFilters
EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType
int rocksDBPriorityQueueSetCacheSize
EmbeddedRocksDBStateBackend rocksDBStateBackend
StateBackend checkpointStreamBackend
long minInterval
int maxManualCompactions
MemorySize maxFileSizeToCompact
int minFilesToCompact
int maxFilesToCompact
MemorySize maxOutputFileSize
int maxAutoCompactions
Path file
long start
long length
URI uri
int partitionNumber
int totalNumberOfPartitions
int splitNumber
String[] hostnames
TypeSerializer<T> serializer
SerializableSupplier<T> serializerSupplier
byte[] buffer
int end
int position
KeySelector<IN,KEY> outKeySelector
KeySelector<IN,KEY> outKeySelector
KeySelector<IN,KEY> outKeySelector
KeySelector<IN,KEY> mainOutKeySelector
KeySelector<IN,KEY> sideOutKeySelector
int id
double x
double y
Collection<E> centroids
List<E> tasks
FileCopyTaskInputSplit curInputSplit
FileCopyTask task
int splitNumber
EnumTrianglesDataTypes.Edge outEdge
double dampening
double randomJump
EmptyFieldsCountAccumulator.VectorAccumulator emptyFieldCounter
int dataTypeCase_
Object dataType_
int mode_
boolean separatedWithEndMessage_
byte memoizedIsInitialized
FlinkFnApi.Schema schema_
byte memoizedIsInitialized
FlinkFnApi.Schema schema_
byte memoizedIsInitialized
FlinkFnApi.Schema schema_
byte memoizedIsInitialized
FlinkFnApi.TypeInfo typeInfo_
byte memoizedIsInitialized
FlinkFnApi.Schema schema_
byte memoizedIsInitialized
int windowType_
boolean isTimeWindow_
long windowSlide_
long windowSize_
long windowGap_
boolean isRowTime_
int timeFieldIndex_
long allowedLateness_
List<E> namedProperties_
int namedPropertiesMemoizedSerializedSize
Object shiftTimezone_
byte memoizedIsInitialized
int inputCase_
Object input_
byte memoizedIsInitialized
int windowType_
long lowerBoundary_
long upperBoundary_
byte memoizedIsInitialized
int length_
byte memoizedIsInitialized
int length_
byte memoizedIsInitialized
int precision_
int scale_
byte memoizedIsInitialized
Object name_
Object description_
FlinkFnApi.Schema.FieldType type_
byte memoizedIsInitialized
int typeInfoCase_
Object typeInfo_
int typeName_
boolean nullable_
byte memoizedIsInitialized
int precision_
byte memoizedIsInitialized
FlinkFnApi.Schema.FieldType keyType_
FlinkFnApi.Schema.FieldType valueType_
byte memoizedIsInitialized
int precision_
byte memoizedIsInitialized
int precision_
byte memoizedIsInitialized
int length_
byte memoizedIsInitialized
int length_
byte memoizedIsInitialized
int precision_
byte memoizedIsInitialized
Object stateName_
FlinkFnApi.StateDescriptor.StateTTLConfig stateTtlConfig_
byte memoizedIsInitialized
int updateType_
int stateVisibility_
int ttlTimeCharacteristic_
long ttl_
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies cleanupStrategies_
byte memoizedIsInitialized
int cleanupSize_
boolean runCleanupForEveryRecord_
byte memoizedIsInitialized
int cleanupStrategyCase_
Object cleanupStrategy_
int strategy_
byte memoizedIsInitialized
long queryTimeAfterNumEntries_
byte memoizedIsInitialized
int typeInfoCase_
Object typeInfo_
int typeName_
byte memoizedIsInitialized
Object schema_
byte memoizedIsInitialized
FlinkFnApi.TypeInfo keyType_
FlinkFnApi.TypeInfo valueType_
byte memoizedIsInitialized
Object fieldName_
FlinkFnApi.TypeInfo fieldType_
byte memoizedIsInitialized
FlinkFnApi.Schema.FieldType elementType_
byte memoizedIsInitialized
FlinkFnApi.Schema.FieldType keyType_
FlinkFnApi.Schema.FieldType valueType_
byte memoizedIsInitialized
List<E> udfs_
boolean metricEnabled_
com.google.protobuf.Internal.IntList grouping_
int groupingMemoizedSerializedSize
boolean generateUpdateBefore_
FlinkFnApi.Schema.FieldType keyType_
int indexOfCountStar_
boolean stateCleaningEnabled_
int stateCacheSize_
int mapStateReadCacheSize_
int mapStateWriteCacheSize_
boolean countStarInserted_
FlinkFnApi.GroupWindow groupWindow_
boolean profileEnabled_
List<E> jobParameters_
byte memoizedIsInitialized
int functionType_
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext runtimeContext_
com.google.protobuf.ByteString payload_
boolean metricEnabled_
FlinkFnApi.TypeInfo keyTypeInfo_
boolean profileEnabled_
boolean hasSideOutput_
int stateCacheSize_
int mapStateReadCacheSize_
int mapStateWriteCacheSize_
byte memoizedIsInitialized
Object taskName_
Object taskNameWithSubtasks_
int numberOfParallelSubtasks_
int maxNumberOfParallelSubtasks_
int indexOfThisSubtask_
int attemptNumber_
List<E> jobParameters_
boolean inBatchExecutionMode_
byte memoizedIsInitialized
org.apache.avro.Schema readerSchema
Class<T> recordClazz
String schemaString
AvroFormatOptions.AvroEncoding encoding
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
DeserializationSchema<T> nestedSchema
GenericRecord
. *TypeInformation<T> typeInfo
AvroToRowDataConverters.AvroToRowDataConverter runtimeConverter
SerializationSchema<T> nestedSchema
GenericRecord
into bytes. *RowType rowType
RowDataToAvroConverters.RowDataToAvroConverter runtimeConverter
private void readObject(ObjectInputStream inputStream) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
private void writeObject(ObjectOutputStream outputStream) throws IOException
IOException
private void readObject(ObjectInputStream inputStream) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
private void writeObject(ObjectOutputStream outputStream) throws IOException
IOException
Class<T> recordClazz
String schemaString
AvroFormatOptions.AvroEncoding encoding
AvroBuilder<T> avroBuilder
DataFileWriter
.SchemaCoder.SchemaCoderProvider schemaCoderProvider
SchemaCoder.SchemaCoderProvider schemaCoderProvider
SchemaCoder schemaCoder
AvroRowDataDeserializationSchema avroDeserializer
TypeInformation<T> producedTypeInfo
RowData
.AvroRowDataSerializationSchema avroSerializer
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void readObject(ObjectInputStream ois) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
private void writeObject(ObjectOutputStream oos) throws IOException
IOException
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
SerializableSupplier<T> mapperFactory
SerializableFunction<T,R> schemaGenerator
Class<T> rootType
Converter<From,To,C> converter
TypeInformation<T> typeInformation
boolean ignoreParseErrors
TypeInformation<T> resultTypeInfo
org.apache.flink.formats.csv.CsvToRowDataConverters.CsvToRowDataConverter runtimeConverter
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
boolean ignoreParseErrors
RowType rowType
org.apache.flink.formats.csv.RowDataToCsvConverters.RowDataToCsvConverter runtimeConverter
SerializableSupplier<T> csvMapperSuppler
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
TypeInformation<T> typeInfo
org.apache.flink.formats.csv.CsvRowDeserializationSchema.RuntimeConverter runtimeConverter
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
boolean ignoreParseErrors
RowTypeInfo typeInfo
org.apache.flink.formats.csv.CsvRowSerializationSchema.RuntimeConverter runtimeConverter
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
boolean ignoreParseErrors
TypeInformation<T>[] fieldTypes
String[] selectedFieldNames
boolean ignoreParseErrors
Path[] filePaths
TypeInformation<T>[] fieldTypes
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema
boolean ignoreParseErrors
int[] selectedFields
boolean failOnMissingField
boolean ignoreParseErrors
TypeInformation<T> resultTypeInfo
RowData
.TimestampFormat timestampFormat
boolean hasDecimalType
Class<T> clazz
SerializableSupplier<T> mapperFactory
JsonParserToRowDataConverters.JsonParserToRowDataConverter runtimeConverter
JsonParser
s into objects of Flink SQL internal data
structures.boolean failOnMissingField
boolean ignoreParseErrors
TimestampFormat timestampFormat
JsonToRowDataConverters.JsonToRowDataConverter runtimeConverter
JsonNode
s into objects of Flink SQL internal data
structures.RowType rowType
RowDataToJsonConverters.RowDataToJsonConverter runtimeConverter
TimestampFormat timestampFormat
JsonFormatOptions.MapNullKeyMode mapNullKeyMode
String mapNullKeyLiteral
boolean encodeDecimalAsPlainNumber
boolean ignoreNullFields
RowTypeInfo typeInfo
boolean failOnMissingField
boolean hasDecimalType
org.apache.flink.formats.json.JsonRowDeserializationSchema.DeserializationRuntimeConverter runtimeConverter
boolean ignoreParseErrors
RowTypeInfo typeInfo
org.apache.flink.formats.json.JsonRowSerializationSchema.SerializationRuntimeConverter runtimeConverter
SerializableSupplier<T> mapperFactory
boolean failOnMissingField
boolean ignoreParseErrors
TimestampFormat timestampFormat
TimestampFormat timestampFormat
JsonFormatOptions.MapNullKeyMode mapNullKeyMode
String mapNullKeyLiteral
boolean ignoreNullFields
JsonRowDataDeserializationSchema jsonDeserializer
boolean hasMetadata
org.apache.flink.formats.json.canal.CanalJsonDeserializationSchema.MetadataConverter[] metadataConverters
TypeInformation<T> producedTypeInfo
TypeInformation
of the produced RowData
(physical + meta data).String database
String table
boolean ignoreParseErrors
List<E> fieldNames
int fieldCount
Pattern databasePattern
Pattern tablePattern
JsonRowDataSerializationSchema jsonSerializer
JsonRowDataDeserializationSchema jsonDeserializer
boolean hasMetadata
org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema.MetadataConverter[] metadataConverters
TypeInformation<T> producedTypeInfo
TypeInformation
of the produced RowData
(physical + meta data).boolean schemaInclude
boolean ignoreParseErrors
JsonRowDataSerializationSchema jsonSerializer
JsonRowDataDeserializationSchema jsonDeserializer
boolean hasMetadata
org.apache.flink.formats.json.maxwell.MaxwellJsonDeserializationSchema.MetadataConverter[] metadataConverters
TypeInformation<T> producedTypeInfo
TypeInformation
of the produced RowData
(physical + meta data).boolean ignoreParseErrors
List<E> fieldNames
int fieldCount
JsonRowDataSerializationSchema jsonSerializer
TimestampFormat timestampFormat
JsonRowDataDeserializationSchema jsonDeserializer
boolean hasMetadata
org.apache.flink.formats.json.ogg.OggJsonDeserializationSchema.MetadataConverter[] metadataConverters
TypeInformation<T> producedTypeInfo
TypeInformation
of the produced RowData
(physical + metadata).boolean ignoreParseErrors
JsonRowDataSerializationSchema jsonSerializer
TypeInformation<T> producedTypeInfo
SerializableConfiguration hadoopConfig
String[] projectedFields
LogicalType[] projectedTypes
ColumnBatchFactory<SplitT extends FileSourceSplit> batchFactory
int batchSize
boolean isUtcTimestamp
boolean isCaseSensitive
ParquetBuilder<T> writerBuilder
RowType rowType
SerializableConfiguration configuration
boolean utcTimestamp
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
RowType rowType
TypeInformation<T> resultTypeInfo
PbFormatConfig formatConfig
RowType rowType
PbFormatConfig pbFormatConfig
LogicalType deserializedType
TypeInformation<T> producedTypeInfo
String charsetName
boolean isBigEndian
org.apache.flink.formats.raw.RawFormatDeserializationSchema.DeserializationRuntimeConverter converter
org.apache.flink.formats.raw.RawFormatDeserializationSchema.DataLengthValidator validator
LogicalType serializedType
org.apache.flink.formats.raw.RawFormatSerializationSchema.SerializationRuntimeConverter converter
String charsetName
boolean isBigEndian
org.apache.flink.formats.sequencefile.SerializableHadoopConfiguration serializableHadoopConfig
Class<T> keyClass
Class<T> valueClass
String compressionCodecName
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
TypeSerializer<T> keySerializer
int fieldNumber
OrcShim<BATCH> shim
SerializableHadoopConfigWrapper hadoopConfigWrapper
org.apache.orc.TypeDescription schema
int[] selectedFields
List<E> conjunctPredicates
int batchSize
ColumnBatchFactory<BatchT,SplitT extends FileSourceSplit> batchFactory
TypeInformation<T> producedTypeInfo
OrcFilters.Predicate[] preds
Serializable lowerBound
Serializable upperBound
Serializable[] literals
OrcFilters.Predicate pred
OrcFilters.Predicate[] preds
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hadoop.conf.Configuration conf
String schema
LogicalType[] fieldTypes
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
LogicalType[] fieldTypes
org.apache.orc.TypeDescription schema
Vectorizer<T> vectorizer
Properties writerProperties
Map<K,V> confMap
org.apache.orc.OrcFile.WriterOptions writerOptions
DataType dataType
SerializationSchema<T> wrappedSchema
OperatorID generatedOperatorID
OperatorID userDefinedOperatorID
JobID jobID
ExecutionAttemptID executionAttemptID
SerializedValue<T> userAccumulators
State state
StateRequestType.SYNC_POINT
.StateRequestType type
Object payload
InternalStateFuture<T> stateFuture
RecordContext<K> context
byte[] key
org.apache.flink.runtime.blob.BlobKey.BlobType type
AbstractID random
long checkpointId
long triggerTimestamp
Map<K,V> taskStats
TaskStateStats
accessible by their ID.int numberOfSubtasks
CheckpointProperties props
CheckpointFailureReason checkpointFailureReason
long checkpointId
long timestamp
long receiveTimestamp
long bytesProcessedDuringAlignment
long bytesPersistedDuringAlignment
long alignmentDurationNanos
long syncDurationMillis
long asyncDurationMillis
long checkpointStartDelayNanos
boolean unalignedCheckpoint
long bytesPersistedOfThisCheckpoint
long totalBytesPersisted
SnapshotType checkpointType
CheckpointStorageLocationReference targetLocation
CheckpointOptions.AlignmentType alignmentType
long alignedCheckpointTimeout
SnapshotType checkpointType
boolean forced
boolean discardSubsumed
boolean discardFinished
boolean discardCancelled
boolean discardFailed
boolean discardSuspended
boolean unclaimed
boolean parallelMode
Object lock
int numberOfCheckpointsToClean
CompletableFuture<T> cleanUpFuture
List<E> subsumedCheckpoints
long numRestoredCheckpoints
long numTotalCheckpoints
int numInProgressCheckpoints
long numCompletedCheckpoints
long numFailedCheckpoints
List<E> checkpointsHistory
CheckpointStatsHistory.createSnapshot()
.LinkedHashMap<K,V> recentCheckpoints
int maxSize
boolean readOnly
CompletedCheckpointStats latestCompletedCheckpoint
FailedCheckpointStats latestFailedCheckpoint
CompletedCheckpointStats latestSavepoint
CheckpointStatsCounts counts
CompletedCheckpointStatsSummarySnapshot summary
CheckpointStatsHistory history
RestoredCheckpointStats latestRestoredCheckpoint
String name
SnapshotType.SharingFilesStrategy sharingFilesStrategy
JobID job
long checkpointID
long timestamp
long completionTimestamp
Map<K,V> operatorStates
CheckpointProperties props
CheckpointProperties restoredProps
Collection<E> masterHookStates
CompletedCheckpointStorageLocation storageLocation
StreamStateHandle metadataHandle
String externalPointer
long checkpointedSize
long stateSize
long processedData
long persistedData
boolean unalignedCheckpoint
SubtaskStateStats latestAcknowledgedSubtask
String externalPointer
boolean discarded
StatsSummary stateSize
StatsSummary checkpointedSize
StatsSummary duration
StatsSummary processedData
StatsSummary persistedData
StatsSummarySnapshot duration
StatsSummarySnapshot persistedData
StatsSummarySnapshot processedData
StatsSummarySnapshot stateSize
StatsSummarySnapshot checkpointedSize
long failureTimestamp
String failureMsg
InflightDataRescalingDescriptor.InflightDataGateOrPartitionRescalingDescriptor[] gateOrPartitionDescriptors
int[] oldSubtaskIndexes
RescaleMappings rescaledChannelsMappings
Set<E> ambiguousSubtaskIndexes
InflightDataRescalingDescriptor.InflightDataGateOrPartitionRescalingDescriptor.MappingType mappingType
long restoreCheckpointId
TaskStateSnapshot taskStateSnapshot
String name
byte[] bytes
int version
OperatorID operatorID
Map<K,V> operatorSubtaskStates
ByteStreamStateHandle coordinatorState
int parallelism
int maxParallelism
StateObjectCollection<T extends StateObject> managedOperatorState
OperatorStateBackend
.StateObjectCollection<T extends StateObject> rawOperatorState
OperatorStateCheckpointOutputStream
.StateObjectCollection<T extends StateObject> managedKeyedState
KeyedStateBackend
.StateObjectCollection<T extends StateObject> rawKeyedState
KeyedStateCheckpointOutputStream
.StateObjectCollection<T extends StateObject> inputChannelState
StateObjectCollection<T extends StateObject> resultSubpartitionState
InflightDataRescalingDescriptor inputRescalingDescriptor
StateAssignmentOperation
and will not be persisted in the checkpoint itself as it can only
be calculated if the post-recovery scale factor is known.InflightDataRescalingDescriptor outputRescalingDescriptor
StateAssignmentOperation
and will not
be persisted in the checkpoint itself as it can only be calculated if the post-recovery scale
factor is known.long stateSize
long checkpointedSize
int currentNumAcknowledgedSubtasks
long currentStateSize
long currentCheckpointedSize
long currentProcessedData
long currentPersistedData
boolean unalignedCheckpoint
SubtaskStateStats latestAcknowledgedSubtask
int numberOfSources
int[][] mappings
int numberOfTargets
long checkpointId
CheckpointProperties props
long restoreTimestamp
String externalPath
long stateSize
String name
SavepointType.PostCheckpointAction postCheckpointAction
SavepointFormatType formatType
Collection<E> stateObjects
long min
long max
long sum
long count
Histogram histogram
long min
long max
long sum
long count
HistogramStatistics histogram
long startTs
long endTs
Map<K,V> durationMetrics
InitializationStatus status
ChainedStateHandle<T extends StateObject> managedOperatorState
OperatorStateBackend
.ChainedStateHandle<T extends StateObject> rawOperatorState
OperatorStateCheckpointOutputStream
.KeyedStateHandle managedKeyedState
KeyedStateBackend
.KeyedStateHandle rawKeyedState
KeyedStateCheckpointOutputStream
.long stateSize
int subtaskIndex
long ackTimestamp
long stateSize
long checkpointedSize
long syncCheckpointDuration
long asyncCheckpointDuration
long processedData
long persistedData
long alignmentDuration
long checkpointStartDelay
boolean unalignedCheckpoint
boolean completed
JobVertexID jobVertexID
Map<K,V> subtaskStates
int parallelism
int maxParallelism
int chainLength
JobVertexID jobVertexId
SubtaskStateStats[] subtaskStats
TaskStateStats.TaskStateStatsSummary summaryStats
int numAcknowledgedSubtasks
SubtaskStateStats latestAckedSubtaskStats
StatsSummary stateSize
StatsSummary checkpointedSize
StatsSummary ackTimestamp
StatsSummary syncCheckpointDuration
StatsSummary asyncCheckpointDuration
StatsSummary processedData
StatsSummary persistedData
StatsSummary alignmentDuration
StatsSummary checkpointStartDelay
int gateIdx
int inputChannelIdx
int partitionIdx
int subPartitionIdx
boolean globallyTerminated
JobID jobID
HashMap<K,V> taskManagerEnv
TaskExecutorProcessSpec taskExecutorProcessSpec
CPUResource cpuCores
int numSlots
Map<K,V> extendedResources
private Object readResolve()
CPUResource cpuCores
MemorySize taskHeapMemory
MemorySize taskOffHeapMemory
MemorySize managedMemory
MemorySize networkMemory
Map<K,V> extendedResources
ResourceSpec
.ResourceID resourceId
int slotNumber
IntermediateDataSetID consumedResultId
ResultPartitionType consumedPartitionType
IndexRange consumedSubpartitionIndexRange
DistributionPattern
and the subtask indices of the producing and
consuming task. The range is inclusive.List<E> serializedInputChannels
int numberOfInputChannels
PartitionDescriptor partitionDescriptor
ShuffleDescriptor shuffleDescriptor
int maxParallelism
TaskDeploymentDescriptor.MaybeOffloaded<T> serializedJobInformation
TaskDeploymentDescriptor.MaybeOffloaded<T> serializedTaskInformation
JobID jobId
NOTE: this is redundant to the information stored in TaskDeploymentDescriptor.serializedJobInformation
but
needed in order to restore offloaded data.
ExecutionAttemptID executionId
AllocationID allocationId
List<E> producedPartitions
List<E> inputGates
JobManagerTaskRestore taskRestore
SerializedValue<T> serializedValue
PermanentBlobKey serializedValueKey
ShuffleDescriptor shuffleDescriptor
int index
TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex[] shuffleDescriptors
String blobServerHostname
int blobServerPort
ExecutionAttemptID attemptId
long[] stateTimestamps
long[] stateEndTimestamps
ExecutionState state
ErrorInfo failureInfo
TaskManagerLocation assignedResourceLocation
AllocationID assignedAllocationID
StringifiedAccumulatorResult[] userAccumulators
IOMetrics ioMetrics
JobID jobID
String jobName
Map<K,V> tasks
List<E> verticesInCreationOrder
long[] stateTimestamps
System.currentTimeMillis()
when the
execution graph transitioned into a certain state. The index into this array is the ordinal
of the enum value, i.e. the timestamp when the graph went into state "RUNNING" is at stateTimestamps[RUNNING.ordinal()]
.JobStatus state
JobType jobType
ErrorInfo failureCause
String jsonPlan
StringifiedAccumulatorResult[] archivedUserAccumulators
ArchivedExecutionConfig archivedExecutionConfig
boolean isStoppable
Map<K,V> serializedUserAccumulators
CheckpointCoordinatorConfiguration jobCheckpointingConfiguration
CheckpointStatsSnapshot checkpointStatsSnapshot
String stateBackendName
String checkpointStorageName
TernaryBoolean stateChangelogEnabled
String changelogStorageName
ArchivedExecutionVertex[] taskVertices
JobVertexID id
String name
int parallelism
int maxParallelism
SlotSharingGroup slotSharingGroup
ResourceProfile resourceProfile
StringifiedAccumulatorResult[] archivedUserAccumulators
int subTaskIndex
ExecutionHistory executionHistory
String taskNameWithSubtask
ArchivedExecution currentExecution
Collection<E> currentExecutions
SerializedThrowable exception
long timestamp
ExecutionGraphID executionGraphId
ExecutionVertexID executionVertexId
int attemptNumber
org.apache.flink.runtime.executiongraph.ExecutionHistory.BoundedLinkedHashMap<K,V> historicalExecutions
int maxAttemptNumber
int subtaskIndex
IndexRange partitionIndexRange
IndexRange subpartitionIndexRange
int startIndex
int endIndex
long numRecordsIn
long numRecordsOut
long numBytesIn
long numBytesOut
long accumulateBackPressuredTime
double accumulateBusyTime
long accumulateIdleTime
Map<K,V> resultPartitionBytes
JobID jobId
JobType jobType
String jobName
SerializedValue<T> serializedExecutionConfig
UnmodifiableConfiguration jobConfiguration
org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableCollection<E> requiredJarFileBlobKeys
org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableCollection<E> requiredClasspathURLs
IntermediateDataSetID intermediateDataSetID
ShuffleDescriptor shuffleDescriptor
long[] subpartitionBytes
JobVertexID jobVertexId
String taskName
int numberOfSubtasks
int maxNumberOfSubtasks
String invokableClassName
Configuration taskConfiguration
int numberOfCPUCores
long sizeOfPhysicalMemory
long sizeOfJvmHeap
long sizeOfManagedMemory
boolean closed
InetSocketAddress address
int connectionIndex
ResourceID resourceID
SocketAddress address
ResultPartitionID partitionId
IntermediateResultPartitionID partitionId
ExecutionAttemptID producerId
IntermediateDataSetID consumedResultID
ExecutionAttemptID consumerID
byte[] bytes
int hashCode
int inputChannelId
ResultPartitionID partitionID
int subpartitionId
TieredStoragePartitionId partitionId
IntermediateDataSetID id
JobVertex producer
List<E> consumers
ResultPartitionType resultType
DistributionPattern distributionPattern
boolean isBroadcast
IntermediateDataSetID intermediateDataSetID
int partitionNum
JobVertex target
DistributionPattern distributionPattern
SubtaskStateMapper downstreamSubtaskStateMapper
SubtaskStateMapper upstreamSubtaskStateMapper
IntermediateDataSet source
String shipStrategyName
boolean isBroadcast
boolean isForward
String preProcessingOperationName
String operatorLevelCachingDescription
Map<K,V> taskVertices
Configuration jobConfiguration
JobID jobID
String jobName
JobType jobType
boolean dynamic
boolean approximateLocalRecovery
SerializedValue<T> serializedExecutionConfig
JobCheckpointingSettings snapshotSettings
SavepointRestoreSettings savepointRestoreSettings
List<E> userJars
Map<K,V> userArtifacts
List<E> userJarBlobKeys
List<E> classpaths
List<E> jobStatusHooks
JobVertexID id
List<E> operatorIDs
The ID pairs are stored depth-first post-order; for the forking chain below the ID's would be stored as [D, E, B, C, A].
A - B - D \ \ C E
This is the same order that operators are stored in the StreamTask
.
Map<K,V> results
List<E> inputs
List<E> operatorCoordinators
int parallelism
int maxParallelism
ResourceSpec minResources
ResourceSpec preferredResources
Configuration configuration
String invokableClassName
boolean isStoppable
InputSplitSource<T extends InputSplit> inputSplitSource
String name
SlotSharingGroup slotSharingGroup
CoLocationGroupImpl coLocationGroup
String operatorName
String operatorDescription
String operatorPrettyName
String resultOptimizerProperties
List<E> intermediateDataSetIdsToConsume
boolean supportsConcurrentExecutionAttempts
boolean anyOutputBlocking
boolean parallelismConfigured
boolean dynamicParallelism
JobVertexResourceRequirements.Parallelism parallelism
int lowerBound
int upperBound
String restorePath
boolean allowNonRestoredState
RestoreMode restoreMode
long checkpointInterval
long checkpointIntervalDuringBacklog
long checkpointTimeout
long minPauseBetweenCheckpoints
int maxConcurrentCheckpoints
int tolerableCheckpointFailureNumber
CheckpointRetentionPolicy checkpointRetentionPolicy
boolean isExactlyOnce
false
, at least once mode has been configured. This is not a necessary attribute, because
the checkpointing mode is only relevant for the stream tasks, but we expose it here to
forward it to the web runtime UI.boolean isUnalignedCheckpointsEnabled
long alignedCheckpointTimeout
long checkpointIdOfIgnoredInFlightData
boolean enableCheckpointsAfterTasksFinish
CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration
SerializedValue<T> defaultStateBackend
TernaryBoolean changelogStateBackendEnabled
SerializedValue<T> defaultCheckpointStorage
SerializedValue<T> masterHooks
AbstractID id
List<E> vertices
Set<E> ids
SlotSharingGroupId slotSharingGroupId
ResourceProfile resourceProfile
int slotIndex
AllocationID allocationId
JobID jobId
Collection<E> allocatedSlotInfos
String reason
ResourceID resourceID
ResourceManagerId resourceManagerId
ResourceID resourceManagerResourceId
JobID jobId
ApplicationStatus applicationStatus
Map<K,V> accumulatorResults
long netRuntime
SerializedThrowable serializedThrowable
null
if the job finished successfully.byte[] inputSplitData
String taskManagerRpcAddress
UnresolvedTaskManagerLocation unresolvedTaskManagerLocation
UUID taskManagerSession
JobVertexID jobVertexId
int parallelism
Map<K,V> jobVertexInputInfos
ExecutionAttemptID executionAttemptId
TaskManagerLocation taskManagerLocation
IOMetrics ioMetrics
Map<K,V> userAccumulators
protected Object readResolve() throws ObjectStreamException
ObjectStreamException
JobStatus jobStatus
int requestId
ExecutionAttemptID executionAttemptID
double backPressureRatio
Thread.State threadState
StackTraceElement[] stackTrace
JobID job
ExecutionAttemptID taskExecutionId
long checkpointId
TaskStateSnapshot subtaskState
CheckpointMetrics checkpointMetrics
SerializedCheckpointException serializedCheckpointException
CheckpointFailureReason checkpointFailureReason
SerializedThrowable serializedThrowable
int numTaskManagersConnected
int numSlotsTotal
int numSlotsAvailable
int numTaskManagersBlocked
int numSlotsFreeAndBlocked
JobID jobId
String jobName
long startTime
long endTime
long duration
JobStatus status
long lastUpdateTime
int[] tasksPerState
int numTasks
Map<K,V> currentExecutionAttempts
The field is excluded from the json. Any usage from the web UI and the history server is not allowed.
Collection<E> jobsWithStatus
int numJobsRunningOrPending
int numJobsFinished
int numJobsCancelled
int numJobsFailed
JobStatus jobStatus
Collection<E> jobs
boolean includeRunning
boolean includeFinished
private Object readResolve()
private Object readResolve()
private Object readResolve()
org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogram.CircularDoubleArray descriptiveStatistics
org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogramStatistics.CommonMetricsSnapshot statisticsSummary
byte[] serializedCounters
byte[] serializedGauges
byte[] serializedMeters
byte[] serializedHistograms
int numCounters
int numGauges
int numMeters
int numHistograms
long checkpointId
OperatorID operatorID
TypeComparatorFactory<T> typeComparator
int parallelism
TypeComparatorFactory<T> comparatorFactory
Configuration config
int value
String value
JobID jobId
JobVertexID jobVertexId
int numKeyGroups
String registrationName
KvStateID[] kvStateIds
InetSocketAddress[] kvStateAddresses
int numRegisteredKeyGroups
SerializedThrowable reason
int numberTaskManagers
int numberRegisteredSlots
int numberFreeSlots
int numberBlockedTaskManagers
int numberBlockedFreeSlots
ResourceProfile totalResource
ResourceProfile freeResource
String taskExecutorAddress
ResourceID resourceId
int dataPort
int jmxPort
HardwareDescription hardwareDescription
TaskExecutorMemoryConfiguration memoryConfiguration
ResourceProfile defaultSlotResourceProfile
ResourceProfile totalResourceProfile
String nodeId
TaskManagerOptionsInternal.TASK_MANAGER_NODE_ID
). In other modes, this value will be
the external address of the TaskManager.TaskManagerInfo taskManagerInfo
Collection<E> allocatedSlots
CPUResource cpuCores
MemorySize taskHeapSize
MemorySize taskOffHeapSize
MemorySize networkMemSize
MemorySize managedMemSize
int numSlots
Map<K,V> extendedResources
int responseCode
RestHandlerException.LoggingBehavior loggingBehavior
TriggerId triggerId
OperationResultStatus status
Object result
Throwable throwable
JobID jobId
boolean numBytesInComplete
boolean numBytesOutComplete
boolean numRecordsInComplete
boolean numRecordsOutComplete
String name
long size
long mtime
Collection<E> logInfos
ProfilingInfo.ProfilingStatus status
ProfilingInfo.ProfilingMode mode
Long triggerTime
Long finishedTime
Long duration
String message
String outputFile
Collection<E> profilingInfos
Collection<E> threadInfos
JobIDDeserializer jobIdDeserializer
SerializedThrowableDeserializer serializedThrowableDeserializer
SerializedValueDeserializer serializedValueDeserializer
JobIDSerializer jobIdSerializer
SerializedValueSerializer serializedValueSerializer
SerializedThrowableSerializer serializedThrowableSerializer
ResourceProfileInfo resource
JobID jobId
TaskManagerMetricsInfo taskManagerMetrics
Collection<E> allocatedSlots
ResourceID resourceId
String address
int dataPort
int jmxPort
long lastHeartbeat
int numberSlots
int numberAvailableSlots
ResourceProfileInfo totalResource
ResourceProfileInfo freeResource
HardwareDescription hardwareDescription
TaskExecutorMemoryConfiguration memoryConfiguration
boolean blocked
int responseCode
Serializable fencingToken
Serializable payload
private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream oos) throws IOException
IOException
org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation.MethodInvocation methodInvocation
ArchivedExecutionGraph executionGraph
Iterable<T> exceptionHistory
String failingTaskName
ExceptionHistoryEntry.ArchivedTaskManagerLocation taskManagerLocation
Map<K,V> failureLabels
ResourceID resourceID
String addressStr
int port
String hostname
String fqdnHostname
Collection<E> concurrentExceptions
String savepointPath
JobVertexID jobVertexId
int subtaskIndex
ShuffleDescriptor shuffleDescriptor
ShuffleMetrics partitionMetrics
ResultPartitionBytes partitionBytes
ResourceID producerLocation
NettyShuffleDescriptor.PartitionConnectionInfo partitionConnectionInfo
ResultPartitionID resultPartitionID
List<E> tierShuffleDescriptors
InetSocketAddress address
int connectionIndex
IntermediateDataSetID resultId
int totalNumberOfPartitions
IntermediateResultPartitionID partitionId
ResultPartitionType partitionType
int numberOfSubpartitions
int connectionIndex
boolean isBroadcast
boolean isAllToAllDistribution
DistributionPattern.ALL_TO_ALL
.boolean isNumberOfPartitionConsumerUndefined
ResultPartitionID resultPartitionID
ResourceProfile resourceProfile
int numberOfRequiredSlots
JobID jobId
String targetAddress
Collection<E> resourceRequirements
String operatorName
Source<T,SplitT extends SourceSplit,EnumChkT> source
int numWorkerThreads
WatermarkAlignmentParams alignmentParams
String coordinatorListeningID
boolean isProcessingBacklog
int subtaskId
String location
long watermark
String hostName
SourceEvent sourceEvent
long maxWatermark
Object info
StreamStateHandle delegate
List<E> offsets
long size
int subtaskIndex
long checkpointId
UUID backendIdentifier
SharedStateRegistry
.KeyGroupRange keyGroupRange
List<E> sharedState
StreamStateHandle metaStateHandle
StateHandleID stateHandleId
LatencyTrackingStateConfig.Builder latencyTrackingConfigBuilder
TypeSerializer<T> elementSerializer
protected final Object readResolve() throws ObjectStreamException
ObjectStreamException
byte[] encodedReference
String directoryString
long directorySize
StreamStateHandle handle
String localPath
DirectoryStateHandle directoryStateHandle
int startKeyGroup
int endKeyGroup
KeyGroupRange keyGroupRange
long[] offsets
KeyGroupRangeOffsets groupRangeOffsets
StreamStateHandle stateHandle
StateHandleID stateHandleId
File[] allocationBaseDirs
JobID jobID
JobVertexID jobVertexID
int subtaskIndex
long[] offsets
OperatorStateHandle.Mode distributionMode
Map<K,V> stateNameToPartitionOffsets
StreamStateHandle delegateStateHandle
PhysicalStateHandleID physicalID
long stateSize
boolean fileMerged
StreamStateHandle wrappedStreamStateHandle
StateHandleID stateHandleID
StateObject jobManagerOwnedSnapshot
StateObject taskLocalSnapshot
List<E> materialized
List<E> nonMaterialized
KeyGroupRange keyGroupRange
long materializationID
long checkpointId
long persistedSizeOfThisCheckpoint
StateHandleID stateHandleID
List<E> localMaterialized
List<E> localNonMaterialized
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl remoteHandle
KeyGroupRange keyGroupRange
List<E> handlesAndOffsets
long size
long incrementalSize
StateHandleID stateHandleID
String storageIdentifier
long number
int keyGroup
byte[] change
List<E> changes
SequenceNumber from
SequenceNumber to
KeyGroupRange keyGroupRange
StateHandleID stateHandleID
Path directory
DirectoryStreamStateHandle taskOwnedDirHandle
DirectoryStreamStateHandle sharedDirHandle
Path filePath
long stateSize
long startPos
CheckpointedStateScope scope
LogicalFile.LogicalFileId logicalFileId
Path filePath
long stateSize
Path exclusiveCheckpointDir
FileStateHandle metadataFileHandle
String externalPointer
int fileStateThreshold
int writeBufferSize
boolean createCheckpointSubDirs
String relativePath
byte[] data
String handleName
ByteStreamStateHandle
with the exact same name must also have the exact same content
in data.int maxStateSize
TernaryBoolean createCheckpointSubDirs
boolean enabled
int sampleInterval
int historySize
boolean stateNameAsVariable
MetricGroup metricGroup
org.apache.flink.runtime.state.storage.ExternalizedSnapshotLocation location
int fileStateThreshold
int writeBufferSize
TernaryBoolean createCheckpointSubDirs
int maxStateSize
org.apache.flink.runtime.state.storage.ExternalizedSnapshotLocation location
TernaryBoolean createCheckpointSubDirs
Object userValue
long lastAccessTimestamp
AggregateFunction<IN,ACC,OUT> aggregateFunction
TypeSerializer<T> userKeySerializer
ReduceFunction<T> reduceFunction
String stateId
TypeSerializer<T> typeSerializer
StateTtlConfig ttlConfig
Collection<E> accumulatorSnapshots
Collection<E> slotsStatus
SlotID slotID
ResourceProfile resourceProfile
AllocationID allocationID
JobID jobID
SlotReport slotReport
ClusterPartitionReport clusterPartitionReport
Long frameworkHeap
Long taskHeap
Long frameworkOffHeap
Long taskOffHeap
Long networkMemory
Long managedMemoryTotal
Long jvmMetaspace
Long jvmOverhead
Long totalFlinkMemory
Long totalProcessMemory
String reason
InstanceID registrationId
ResourceID resourceManagerResourceId
ClusterInformation clusterInformation
byte[] initialTokens
AccumulatorReport accumulatorReport
ExecutionDeploymentReport executionDeploymentReport
AllocationID allocationId
JobID jobId
Collection<E> entries
IntermediateDataSetID dataSetId
Map<K,V> shuffleDescriptors
int numTotalPartitions
SlotID slotID
JobID jobId
String jobTargetAddress
AllocationID allocationId
ResourceProfile resourceProfile
AllocationID allocationId
int slotIndex
ResourceProfile resourceProfile
ExecutionAttemptID executionId
ExecutionState executionState
SerializedThrowable throwable
AccumulatorSnapshot accumulators
IOMetrics ioMetrics
ResourceID resourceID
InetAddress inetAddress
TaskManagerLocation.HostNameSupplier hostNameSupplier
int dataPort
String stringRepresentation
String nodeId
TaskManagerOptionsInternal.TASK_MANAGER_NODE_ID
). In other modes, this value will be
the external address of the TaskManager.InetAddress inetAddress
String hostName
String fqdnHostName
InetAddress inetAddress
ResourceID resourceID
String externalAddress
int dataPort
String nodeId
FlinkMemory flinkMemory
JvmMetaspaceAndOverhead jvmMetaspaceAndOverhead
MemorySize metaspace
MemorySize overhead
MemorySize jvmHeap
MemorySize offHeapMemory
MemorySize frameworkHeap
MemorySize frameworkOffHeap
MemorySize taskHeap
MemorySize taskOffHeap
MemorySize network
MemorySize managed
int requestId
int numSubSamples
Duration delayBetweenSamples
int maxStackTraceDepth
org.apache.calcite.sql.parser.SqlParserPos errorPosition
String message
boolean specialConstructor
Token currentToken
int[][] expectedTokenSequences
String[] tokenImage
String eol
int errorCode
int numKeys
int keyIndex
long durationMs
long stepMs
long offsetMs
long ms
String uid
OperatorID operatorId
MapStateDescriptor<UK,UV> descriptor
OperatorState operatorState
StateBackend stateBackend
Configuration configuration
StateReaderOperator<F extends Function,KEY,N,OUT> operator
SerializedValue<T> serializedExecutionConfig
ListStateDescriptor<T> descriptor
ListStateDescriptor<T> descriptor
Function function
TypeInformation<T> keyType
TypeSerializer<T> namespaceSerializer
WindowContents<S extends State,IN> contents
StateDescriptor<S extends State,T> descriptor
AggregateFunction<IN,ACC,OUT> aggFunction
ReduceFunction<T> reduceFunction
StateObjectCollection<T extends StateObject> managedOperatorState
int splitNum
StreamConfig streamConfig
int maxParallelism
StreamConfig streamConfig
int maxParallelism
Timestamper<T> timestamper
String path
Collection<E> masterStates
OperatorID operatorID
int maxParallelism
Path savepointPath
TimestampAssigner<T> assigner
long timestamp
Path savepointPath
long timestamp
Path savepointPath
long timestamp
Path savepointPath
long timestamp
Path savepointPath
Output<T> output
AbstractStreamOperator<OUT> operator
KeySelector<IN,KEY> keySelector
int maxParallelism
StateBackend delegatedStateBackend
Boolean useManagedMemory
MemorySize fixedMemoryPerSlot
Double writeBufferRatio
Double highPriorityPoolRatio
Boolean usePartitionedIndexFilters
Path remoteForStDirectory
File[] localForStDirectories
ReadableConfig configurableOptions
ForStOptionsFactory forStOptionsFactory
ForStMemoryConfiguration memoryConfiguration
ForStNativeMetricOptions nativeMetricOptions
ForStMemoryControllerUtils.ForStMemoryFactory forStMemoryFactory
SerializableSupplier<T> committableSerializerFactory
TypeSerializer<T> oneSerializer
TypeSerializer<T> twoSerializer
Configuration configuration
Configuration
from
StreamExecutionEnvironment
.long maxTimestamp
Comparator comparator
boolean byAggregate
boolean first
FieldAccessor<T,F> fieldAccessor
FieldAccessor<T,F> fieldAccessor
SumFunction adder
TypeSerializer<T> serializer
boolean isTuple
byte[] serializedPythonFunction
PythonEnv pythonEnv
int functionType
OutputFormat<IT> format
boolean cleanupCalled
String sinkIdentifier
boolean stdErr
PrintSinkOutputWriter<IN> writer
SerializableObject lock
SerializationSchema<T> schema
String hostName
int port
int maxNumRetries
boolean autoFlush
int retries
boolean isRunning
LinkedHashMap<K,V> pendingCommitTransactions
Clock clock
ListStateDescriptor<T> stateDescriptor
TwoPhaseCommitSinkFunction.TransactionHolder<TXN> currentTransactionHolder
long transactionTimeout
boolean ignoreFailuresAfterTransactionTimeout
TwoPhaseCommitSinkFunction.recoverAndCommit(Object)
will be caught instead of
propagated.double transactionTimeoutWarningRatio
boolean finished
TypeSerializer<T> transactionSerializer
TypeSerializer<T> contextSerializer
boolean supportNullPendingTransaction
String path
ArrayList<E> tupleList
WriteFormat<IN> format
long millis
long lastTime
Path basePath
HadoopPathBasedBulkWriter.Factory<T> writerFactory
HadoopFileCommitterFactory fileCommitterFactory
SerializableConfiguration serializableConfiguration
BucketAssigner<IN,BucketID> bucketAssigner
CheckpointRollingPolicy<IN,BucketID> rollingPolicy
BucketFactory<IN,BucketID> bucketFactory
OutputFileConfig outputFileConfig
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
long bucketCheckInterval
StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>> bucketsBuilder
long bucketCheckInterval
Path basePath
BulkWriter.Factory<T> writerFactory
BucketAssigner<IN,BucketID> bucketAssigner
CheckpointRollingPolicy<IN,BucketID> rollingPolicy
BucketFactory<IN,BucketID> bucketFactory
OutputFileConfig outputFileConfig
long bucketCheckInterval
Path basePath
Encoder<IN> encoder
BucketAssigner<IN,BucketID> bucketAssigner
RollingPolicy<IN,BucketID> rollingPolicy
BucketFactory<IN,BucketID> bucketFactory
OutputFileConfig outputFileConfig
long partSize
long rolloverInterval
long inactivityInterval
String path
int readerParallelism
FileInputFormat<OT> format
FileInputFormat
to be read.long interval
FileProcessingMode watchType
FileProcessingMode
.long globalModificationTime
boolean isRunning
TypeSerializer<T> serializer
InputFormat<OT,T extends InputSplit> inputFormat
TypeInformation<T> type
ExecutionConfig executionConfig
TypeSerializer<T> serializer
byte[] elementsSerialized
int numElements
int numElementsEmitted
int numElementsToSkip
boolean isRunning
SplittableIterator<T> fullIterator
boolean isRunning
TypeInformation<T> typeInfo
InputFormat<OT,T extends InputSplit> format
boolean isRunning
TypeSerializer<T> idSerializer
long start
long end
boolean isRunning
long modificationTime
Serializable splitState
DataGenerator<T> generator
long rowsPerSecond
Long numberOfRows
float nullRate
boolean varLen
long start
long end
long currentTimestamp
AscendingTimestampExtractor.MonotonyViolationHandler violationHandler
long currentMaxTimestamp
long lastEmittedWatermark
long maxOutOfOrderness
AggregateFunction<IN,ACC,OUT> aggFunction
AggregateFunction<IN,ACC,OUT> aggFunction
Window window
ProcessWindowFunction.Context context
ReduceFunction<T> reduceFunction
ReduceFunction<T> reduceFunction
ProcessAllWindowFunction<IN,OUT,W extends Window> windowFunction
ReduceFunction<T> reduceFunction
ProcessWindowFunction<IN,OUT,KEY,W extends Window> windowFunction
ReduceFunction<T> reduceFunction
int[] order
int fieldId
int fieldId
int[] indexes
boolean supportsUnalignedCheckpoints
int sourceNodeId
StreamNode
.int consumerParallelism
int consumerMaxParallelism
long bufferTimeout
IntermediateDataSetID dataSetId
boolean isPersistentDataSet
OutputTag<T> outputTag
StreamPartitioner<T> partitioner
ResultPartitionType partitionType
ResultPartitionType
.Configuration config
Set<E> removedKeys
StreamConfig.clearInitialConfigs()
. Recording these keys here to prevent they are accessed after
removing.TypeSerializer<T> typeSerializer
StreamConfig.InputRequirement inputRequirement
int inputGateIndex
StreamEdge inputEdge
String edgeId
int sourceId
int targetId
int uniqueId
StreamEdge
s. It's enough if
this field ensures that all logical instances of StreamEdge
are unique, and StreamEdge.hashCode()
are different and StreamEdge.equals(Object)
returns false, for every possible pair
of StreamEdge
. Especially among two different StreamEdge
s that are connecting
the same pair of nodes.int typeNumber
OutputTag<T> outputTag
StreamEdge
.StreamPartitioner<T> outputPartitioner
StreamPartitioner
on this StreamEdge
.String sourceOperatorName
String targetOperatorName
StreamExchangeMode exchangeMode
long bufferTimeout
boolean supportsUnalignedCheckpoints
IntermediateDataSetID intermediateDatasetIdToProduce
ChainingStrategy chainingStrategy
ChainingStrategy chainingStrategy
StreamConfig config
Output<T> output
StreamingRuntimeContext runtimeContext
MailboxExecutor mailboxExecutor
ExecutionConfig executionConfig
ClassLoader userCodeClassLoader
CloseableRegistry cancelables
IndexedCombinedWatermarkStatus combinedWatermark
InternalOperatorMetricGroup metrics
LatencyStats latencyStats
ProcessingTimeService processingTimeService
RecordAttributes[] lastRecordAttributes
StreamOperatorStateHandler stateHandler
InternalTimeServiceManager<K> timeServiceManager
MailboxWatermarkProcessor<OUT> watermarkProcessor
Function userFunction
TypeSerializer<T> serializer
InternalTimerService<N> timerService
long inputMask
TypeSerializer<T> keySerializer
TypeSerializer<T> namespaceSerializer
MapPartitionFunction<T,O> function
boolean outputOnlyAfterEndOfStream
boolean internalSorterSupported
AggregateFunction<IN,ACC,OUT> aggregateFunction
Object currentAccumulator
ReduceFunction<T> reduceFunction
Object currentRecord
long currentWatermark
InternalTimerService
.StreamSource<OUT,SRC extends SourceFunction<OUT>> operator
StreamOperator<OUT> operator
OutputFormat<IT> outputFormat
AbstractUdfStreamOperator<OUT,F extends Function> operator
FunctionWithException<T,R,E extends Throwable> readerFactory
SimpleVersionedSerializer<E> splitSerializer
OperatorEventGateway operatorEventGateway
WatermarkStrategy<T> watermarkStrategy
WatermarkAlignmentParams watermarkAlignmentParams
Configuration configuration
String localHostname
boolean emitProgressiveWatermarks
SourceReader<T,SplitT extends SourceSplit> sourceReader
ReaderOutput<T> currentMainOutput
PushingAsyncDataInput.DataOutput<T> lastInvokedOutput
long latestWatermark
boolean idle
ListState<T> readerState
TimestampsAndWatermarks<T> eventTimeLogic
org.apache.flink.streaming.api.operators.SourceOperator.OperatingMode operatingMode
PushingAsyncDataInput.emitNext(DataOutput)
method.CompletableFuture<T> finished
org.apache.flink.streaming.api.operators.SourceOperator.SourceOperatorAvailabilityHelper availabilityHelper
List<E> splitsToInitializeOutput
Map<K,V> splitCurrentWatermarks
Set<E> currentlyPausedSplits
InternalSourceReaderMetricGroup sourceMetricGroup
long currentMaxDesiredWatermark
CompletableFuture<T> waitingForAlignmentFuture
OperatingMode#WAITING_FOR_ALIGNMENT
mode.org.apache.flink.streaming.api.operators.LatencyMarkerEmitter<OUT> latencyMarkerEmitter
boolean allowUnalignedSourceSplits
StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords
Source<T,SplitT extends SourceSplit,EnumChkT> source
Source
to create the SourceOperator
.WatermarkStrategy<T> watermarkStrategy
boolean emitProgressiveWatermarks
int numCoordinatorWorkerThread
String coordinatorListeningID
TypeSerializer<T> serializer
TypeSerializer<T> outSerializer
int[] fields
int numFields
long currentWatermark
InternalTimerService
.boolean emitProgressiveWatermarks
TypeSerializer<T> keySerializer
TypeSerializer<T> namespaceSerializer
int length
boolean immutableType
int capacity
AsyncDataStream.OutputMode outputMode
long timeout
AsyncRetryStrategy<OUT> asyncRetryStrategy
boolean retryEnabled
AsyncFunction<IN,OUT> asyncFunction
long timeout
int capacity
AsyncDataStream.OutputMode outputMode
AsyncRetryStrategy<OUT> asyncRetryStrategy
long currentWatermark
InternalTimerService
.List<E> broadcastStateDescriptors
long currentWatermark
InternalTimerService
.long lowerBound
long upperBound
OutputTag<T> leftLateDataOutputTag
OutputTag<T> rightLateDataOutputTag
TypeSerializer<T> leftTypeSerializer
TypeSerializer<T> rightTypeSerializer
TypeSerializer<T> elementSerializer
String version
long offset
InetSocketAddress address
TypeSerializer<T> serializer
long maxBytesPerBatch
long bufferSizeLimitBytes
String accumulatorName
CollectSinkFunction<IN> sinkFunction
OperatorID operatorId
int socketTimeout
CollectSinkOperator<IN> operator
int socketTimeoutMillis
Configuration config
DataStreamPythonFunctionInfo pythonFunctionInfo
Map<K,V> sideOutputTags
TypeInformation<T> outputTypeInfo
Integer numPartitions
TypeInformation<T> inputTypeInfo
TypeInformation<T> inputTypeInfo1
TypeInformation<T> inputTypeInfo2
PythonTypeUtils.DataConverter<IN,OUT> inputDataConverter1
PythonTypeUtils.DataConverter<IN,OUT> inputDataConverter2
TypeSerializer<T> windowSerializer
Integer numPartitions
DataStreamPythonFunctionInfo pythonFunctionInfo
TypeInformation<T> outputTypeInfo
Map<K,V> sideOutputTags
TypeInformation<T> inputTypeInfo
TypeInformation<T> inputTypeInfo1
TypeInformation<T> inputTypeInfo2
TypeSerializer<T> namespaceSerializer
int serializedKeyLength
TypeComparator<T> valueComparator
byte[] keyReference
Object valueReference
TypeInformation<T> inputType
KeySelector<IN,KEY> sortFieldSelector
Order sortOrder
String stringSortField
int positionSortField
PushSorter<E> recordSorter
KeySelector
.PushSorter<E> recordSorterForSelector
KeySelector
.TypeSerializer<T> recordKeySerializer
DataOutputSerializer dataOutputSerializer
TypeInformation<T> inputType
KeySelector<IN,KEY> sortFieldSelector
Order sortOrder
String stringSortField
int positionSortField
PushSorter<E> recordSorter
KeySelector
.PushSorter<E> recordSorterForKeySelector
KeySelector
.TypeComparator<T> valueComparator
byte[] keyReference
Object valueReference
Sink<InputT,CommT,WriterStateT,GlobalCommT> sink
byte[] data
int offset
int limit
PythonTypeUtils.DataConverter<IN,OUT> elementConverter
Class<T> componentClass
PythonTypeUtils.DataConverter<IN,OUT> elementConverter
PythonTypeUtils.DataConverter<IN,OUT> keyConverter
PythonTypeUtils.DataConverter<IN,OUT> valueConverter
PythonTypeUtils.RowDataConverter dataConverter
DataFormatConverters.DataFormatConverter<Internal,External> dataFormatConverter
PythonTypeUtils.DataConverter<IN,OUT>[] fieldDataConverters
Tuple reuseTuple
Object[] reuseExternalTuple
SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor
SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor
long sessionTimeout
long sessionTimeout
long size
long slide
long offset
long size
long offset
long slide
long size
long globalOffset
Long staggerOffset
WindowStagger windowStagger
long size
long globalOffset
Long staggerOffset
WindowStagger windowStagger
long maxCount
boolean doEvictAfter
DeltaFunction<DATA> deltaFunction
double threshold
boolean doEvictAfter
long windowSize
boolean doEvictAfter
long interval
ReducingStateDescriptor<T> stateDesc
long interval
ReducingStateDescriptor<T> stateDesc
long maxCount
ReducingStateDescriptor<T> stateDesc
DeltaFunction<DATA> deltaFunction
double threshold
ValueStateDescriptor<T> stateDesc
double errorProbability
int min
int max
int[] speeds
double[] distances
long[] lastUpdate
int nextCar
Random rand
Path[] inputs
Path output
Duration discoveryInterval
RuntimeExecutionMode executionMode
MultipleParameterTool params
InetAddress hostIp
int port
TypeSerializer<T> serializer
String id
CheckpointCommitter committer
TypeSerializer<T> serializer
Set<E> pendingCheckpoints
WatermarkStrategy<T> watermarkStrategy
boolean emitProgressiveWatermarks
AsyncExecutionController<K> asyncExecutionController
RecordContext<K> currentProcessingContext
Environment environment
Environment environment
AsyncExecutionController<K> asyncExecutionController
RecordContext<K> currentProcessingContext
Function userFunction
SupportsCommitter<CommittableT> sink
boolean isBatchMode
boolean isCheckpointingEnabled
AssignerWithPeriodicWatermarks<T> wms
AssignerWithPunctuatedWatermarks<T> wms
WindowAssigner<T,W extends Window> windowAssigner
KeySelector<IN,KEY> keySelector
Trigger<T,W extends Window> trigger
StateDescriptor<S extends State,T> windowStateDescriptor
TypeSerializer<T> keySerializer
TypeSerializer<T> windowSerializer
long allowedLateness
window.maxTimestamp
+ allowedLateness
landmark.
OutputTag<T> lateDataOutputTag
OutputTag
to use for late arriving events. Elements for which window.maxTimestamp + allowedLateness
is smaller than the current watermark will be emitted
to this.Window window
WindowOperator.AbstractPerWindowStateStore windowState
AggregateFunction<IN,ACC,OUT> aggFunction
AggregateFunction<IN,ACC,OUT> aggFunction
InternalProcessWindowContext<IN,OUT,KEY,W extends Window> ctx
Window window
InternalWindowFunction.InternalWindowContext internalContext
Partitioner<K> partitioner
KeySelector<IN,KEY> keySelector
StreamPartitioner<T> hashPartitioner
KeySelector<IN,KEY> keySelector
int maxParallelism
int nextChannelToSendTo
int nextChannelToSendTo
Random random
int numberOfChannels
boolean supportsUnalignedCheckpoint
StreamPartitioner.isBroadcast()
or StreamPartitioner.isPointwise()
support
unaligned checkpoints. However, transformations may disable unaligned checkpoints for
specific cases.TypeSerializer<T> typeSerializer
long numProcessedRecordsFailureThreshold
long numCompleteCheckpointsFailureThreshold
int maxNumFailures
long numProcessedRecords
long numCompleteCheckpoints
org.apache.flink.streaming.tests.SemanticsCheckMapper.ValidatorFunction validator
int payloadLength
int totalKeySpaceSize
long eventTimeClockProgressPerEvent
long maxOutOfOrder
long sleepTime
long sleepAfterElements
long monotonousEventTime
boolean running
TypeInformation<T> originalTypeInformation
int slideFactor
boolean failingTask
boolean killedJvm
int jvmPid
String taskNameWithSubtask
String allocationId
MapFunction<T,O> mapFunction
MapFunction<T,O> mapFunction
List<E> artificialStateBuilders
long eventTime
List<E> stringList
String strPayload
ComplexPayload.InnerPayLoad innerPayLoad
long sequenceNumber
AtomicReference<V> currentOwnerThread
ListStateDescriptor<T> listStateDescriptor
JoinFunction<IN1,IN2,OUT> keyedStateGenerator
JoinFunction<IN1,IN2,OUT> operatorStateGenerator
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
JoinFunction<IN1,IN2,OUT> stateValueGenerator
String stateName
ValueStateDescriptor<T> valueStateDescriptor
JoinFunction<IN1,IN2,OUT> stateValueGenerator
public void readExternal(ObjectInput in) throws IOException
IOException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException
IOException
public void writeExternal(ObjectOutput out) throws IOException
IOException
String emailId
Object value
long timestamp
Iterable<T> elements
boolean running
BooleanSupplier couldExit
long waitTimeOut
int[] fields
TypeComparator<T> comparator
int keyLength
Object[] keyArray
TypeComparator<T> comparator
Object[] keyArray
boolean includeMetadata
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper mapper
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
DataInputDeserializer inputDeserializer
TypeInformation<T> fieldType
boolean holdDDLTime
boolean isAcid
boolean inheritTableSpecs
boolean isSkewedStoreAsSubdir
boolean hasFollowingStatsTask
long writeIdInLoadTableOrPartition
int stmtIdInLoadTableOrPartition
TypeInformation<T> typeInfo
RowType rowType
List<E> serializedData
boolean isFiltering
DynamicFilteringData data
Duration reloadInterval
PeriodicCacheReloadTrigger.ScheduleMode scheduleMode
Temporal reloadTime
int reloadIntervalInDays
int numRows
ColumnVector[] columns
boolean[] isNull
HeapIntVector dictionaryIds
int len
long[] offsets
long[] lengths
int size
ColumnVector child
boolean[] vector
int[] start
int[] length
byte[] buffer
int elementsAppended
int capacity
byte[] vector
double[] vector
float[] vector
int[] vector
long[] vector
long[] offsets
long[] lengths
int size
ColumnVector keys
ColumnVector values
WritableColumnVector[] fields
short[] vector
long[] milliseconds
int[] nanoOfMilliseconds
boolean noNulls
Dictionary dictionary
Object[] arrayKind
ArrayObjectArrayConverter<E> elementsConverter
Class<T> elementClass
int elementSize
BinaryArrayWriter.NullSetter writerNullSetter
BinaryWriter.ValueSetter writerValueSetter
org.apache.flink.table.data.conversion.ArrayObjectArrayConverter.GenericToJavaArrayConverter<E> genericToJavaArrayConverter
boolean hasInternalElements
ArrayData.ElementGetter elementGetter
DataStructureConverter<I,E> elementConverter
int precision
int scale
ArrayObjectArrayConverter<E> keyConverter
ArrayObjectArrayConverter<E> valueConverter
boolean hasInternalEntries
TypeSerializer<T> serializer
TypeSerializer<T> serializer
DataStructureConverter<I,E>[] fieldConverters
RowData.FieldGetter[] fieldGetters
LinkedHashMap<K,V> positionByName
DataStructureConverter<I,E>[] fieldConverters
RowData.FieldGetter[] fieldGetters
String generatedName
String generatedCode
org.apache.flink.table.data.conversion.YearMonthIntervalPeriodConverter.PeriodConstructor periodConstructor
DataFormatConverters.DataFormatConverter<Internal,External>[] converters
int precision
int scale
TupleTypeInfoBase<T> t
TupleSerializerBase<T> serializer
int precision
int scale
TypeSerializer<T> serializer
int precision
int precision
int precision
LogicalType keyType
LogicalType valueType
DataFormatConverters.DataFormatConverter<Internal,External> keyConverter
DataFormatConverters.DataFormatConverter<Internal,External> valueConverter
ArrayData.ElementGetter keyGetter
ArrayData.ElementGetter valueGetter
int keyElementSize
int valueElementSize
Class<T> keyComponentClass
Class<T> valueComponentClass
TypeSerializer<T> keySer
TypeSerializer<T> valueSer
boolean isKeyValueIndentity
Class<T> componentClass
LogicalType elementType
ArrayData.ElementGetter elementGetter
DataFormatConverters.DataFormatConverter<Internal,External> elementConverter
int elementSize
TypeSerializer<T> eleSer
boolean isEleIndentity
PojoTypeInfo<T> t
PojoField[] fields
int arity
int precision
int precision
int precision
TypeSerializer<T> listSerializer
TypeInformation<T> elementType
boolean nullSerializer
TypeSerializer<T> mapSerializer
TypeInformation<T> keyType
TypeInformation<T> valueType
boolean nullAware
boolean nullSerializer
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
List<E> parsingTypes
DynamicTableSource.DataStructureConverter converter
TypeInformation<T> producedTypeInfo
String columnDelimiter
String hostname
int port
byte byteDelimiter
DeserializationSchema<T> deserializer
StagedTable stagedTable
String name
ObjectIdentifier objectIdentifier
String functionName
RowTypeInfo resultType
UnresolvedReferenceExpression sum
UnresolvedReferenceExpression count
DataType resultType
DataType bufferedSumType
UnresolvedReferenceExpression count
Integer arguments
boolean countLiteral
HiveFunctionWrapper<UDFType> hiveFunctionWrapper
boolean isUDAFBridgeRequired
boolean isUDAFResolve2
HiveShim hiveShim
HiveFunctionArguments arguments
HiveShim hiveShim
HiveFunctionWrapper<UDFType> hiveFunctionWrapper
HiveShim hiveShim
HiveFunctionArguments arguments
UnresolvedReferenceExpression max
DataType resultType
UnresolvedReferenceExpression min
DataType resultType
HiveFunctionWrapper<UDFType> hiveFunctionWrapper
HiveFunctionArguments arguments
HiveShim hiveShim
UnresolvedReferenceExpression sum
UnresolvedReferenceExpression isEmpty
DataType resultType
ValueLiteralExpression zero
HiveObjectConversion flinkToJavaConversion
HiveShim hiveShim
String name
byte[] serializedAggregateFunction
PythonFunctionKind pythonFunctionKind
boolean deterministic
PythonEnv pythonEnv
boolean takesRowAsInput
DataType[] inputTypes
String[] inputTypesString
DataType resultType
String resultTypeString
DataType accumulatorType
String accumulatorTypeString
int filterArg
boolean distinct
PythonEnv.ExecType execType
PythonFunction pythonFunction
Object[] inputs
String name
byte[] serializedScalarFunction
PythonFunctionKind pythonFunctionKind
boolean deterministic
PythonEnv pythonEnv
boolean takesRowAsInput
DataType[] inputTypes
String[] inputTypesString
DataType resultType
String resultTypeString
String name
byte[] serializedTableAggregateFunction
PythonFunctionKind pythonFunctionKind
boolean deterministic
PythonEnv pythonEnv
boolean takesRowAsInput
DataType[] inputTypes
String[] inputTypesString
DataType resultType
String resultTypeString
DataType accumulatorType
String accumulatorTypeString
String name
byte[] serializedTableFunction
PythonFunctionKind pythonFunctionKind
boolean deterministic
PythonEnv pythonEnv
boolean takesRowAsInput
DataType[] inputTypes
String[] inputTypesString
DataType resultType
String resultTypeString
String keyTerm
org.apache.calcite.rel.type.RelDataType dataType
LogicalType internalType
private Object readResolve()
String fieldTerm
org.apache.calcite.rel.type.RelDataType dataType
private Object readResolve()
private Object readResolve()
String resultTerm
String nullTerm
String code
LogicalType resultType
scala.Option<A> literalValue
GeneratedFunction<F extends Function> tableFunc
DataType dataType
private Object readResolve()
scala.collection.Seq<A> aggregations
scala.collection.Seq<A> inputExprs
org.apache.calcite.sql.SqlAggFunction sqlAggFunction
org.apache.calcite.rel.type.RelDataType resultType
scala.collection.Seq<A> exprIndices
org.apache.calcite.rel.RelNode rexSubQuery
org.apache.hadoop.hive.ql.plan.ExprNodeDesc subQueryLhs
HiveParserExprNodeSubQueryDesc.SubqueryType type
org.apache.hadoop.hive.ql.exec.RowSchema rowSchema
LinkedHashMap<K,V> rslvMap
HashMap<K,V> invRslvMap
Map<K,V> altInvRslvMap
Map<K,V> expressionMap
LinkedHashMap<K,V> ambiguousColumns
boolean checkForAmbiguity
boolean isExprResolver
HiveParserNamedJoinInfo namedJoinInfo
UnresolvedReferenceExpression sum
UnresolvedReferenceExpression count
UnresolvedReferenceExpression count1
UnresolvedReferenceExpression count
UnresolvedReferenceExpression sequence
int operandCount
boolean existDefaultValue
UnresolvedReferenceExpression value
CharType type
DecimalType decimalType
TimestampType type
int operandCount
UnresolvedReferenceExpression acc
UnresolvedReferenceExpression accDelimiter
Expression delimiter
Expression operand
UnresolvedReferenceExpression max
DataType resultType
LocalZonedTimestampType type
TimestampType type
UnresolvedReferenceExpression min
DataType resultType
LocalZonedTimestampType type
TimestampType type
Expression bucketSize
Expression bucketsWithPadding
UnresolvedReferenceExpression rowNumber
UnresolvedReferenceExpression bucket
UnresolvedReferenceExpression bucketThreshold
ValueLiteralExpression one
UnresolvedReferenceExpression currNumber
UnresolvedReferenceExpression sequence
UnresolvedReferenceExpression[] lastValues
LogicalType[] orderKeyTypes
UnresolvedReferenceExpression sequence
UnresolvedReferenceExpression value
UnresolvedReferenceExpression count
CharType type
DecimalType type
LocalZonedTimestampType type
TimestampType type
UnresolvedReferenceExpression sum0
DataType returnType
UnresolvedReferenceExpression sum
DataType returnType
UnresolvedReferenceExpression sum
UnresolvedReferenceExpression count
DataType resultType
org.apache.calcite.rex.RexNode pattern
com.google.common.collect.ImmutableMap<K,V> patternDefinitions
com.google.common.collect.ImmutableMap<K,V> measures
org.apache.calcite.rex.RexNode after
com.google.common.collect.ImmutableMap<K,V> subsets
boolean allRows
org.apache.calcite.util.ImmutableBitSet partitionKeys
org.apache.calcite.rel.RelCollation orderKeys
org.apache.calcite.rex.RexNode interval
private Object readResolve()
ValueLiteralExpression gap
private Object readResolve()
ValueLiteralExpression size
ValueLiteralExpression slide
private Object readResolve()
ValueLiteralExpression size
private Object readResolve()
TemporalTableFunction temporalTableFunction
org.apache.calcite.rex.RexNode timeAttribute
private Object readResolve()
TypeInformationRawType<T> genericType
boolean nullable
StructuredType structuredType
org.apache.calcite.rel.type.RelDataTypeSystem typeSystemField
org.apache.calcite.sql.type.BasicSqlType originalType
boolean nullable
boolean isEventTime
org.apache.calcite.rel.core.AggregateCall agg
UserDefinedFunction function
int aggIndex
int[] argIndexes
DataType[] externalArgTypes
DataType[] externalAccTypes
DataViewSpec[] viewSpecs
DataType externalResultType
boolean consumeRetraction
private Object readResolve()
org.apache.flink.table.planner.plan.utils.AggregateInfo[] aggInfos
scala.Option<A> indexOfCountStar
boolean countStarInserted
org.apache.flink.table.planner.plan.utils.DistinctInfo[] distinctInfos
private Object readResolve()
int[] argIndexes
DataType keyType
DataType accType
boolean excludeAcc
scala.Option<A> dataViewSpec
boolean consumeRetraction
scala.collection.mutable.ArrayBuffer<A> filterArgs
scala.collection.mutable.ArrayBuffer<A> aggIndexes
private Object readResolve()
scala.Enumeration.Value Explain
scala.Enumeration.Value Digest
scala.Enumeration.Value Infix
scala.Enumeration.Value PostFix
scala.Enumeration.Value Prefix
boolean isEventTime
boolean isLeftInput
int idx
private Object readResolve()
boolean isEventTime
boolean leftInputOnLeftSide
int leftTimeIdx
int rightTimeIdx
org.apache.calcite.rex.RexCall pred
private Object readResolve()
long bound
boolean isLeftLower
private Object readResolve()
long lower
long upper
private Object readResolve()
int inputFieldIndex
private Object readResolve()
boolean rankOnLeftSide
org.apache.calcite.rex.RexCall pred
private Object readResolve()
long lower
private Object readResolve()
long upper
private Object readResolve()
DataType dataType
byte[][] arrowData
ListenableCollector.CollectListener<T> collectListener
Object input
ResultFuture<OUT> resultFuture
TypeSerializer<T> elementSerializer
boolean containsNullKey
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
GeneratedFunction<F extends Function> generatedClass
MethodType methodType
String expressionSummary
long minRetentionTime
long maxRetentionTime
boolean stateCleaningEnabled
ValueState<T> cleanupTimeState
boolean ignoreNulls
int precision
boolean skipNulls
boolean skipNulls
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator equalityEvaluator
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator equalityEvaluator
ArrayData.ElementGetter elementGetter
EqualityAndHashcodeProvider equalityAndHashcodeProvider
ArrayData.ElementGetter elementGetter
EqualityAndHashcodeProvider equalityAndHashcodeProvider
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator compareEvaluator
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator compareEvaluator
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator equalityEvaluator
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator equalityEvaluator
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator greaterEvaluator
ArrayData.ElementGetter elementGetter
SpecializedFunction.ExpressionEvaluator equalityEvaluator
ArrayData.ElementGetter keyElementGetter
ArrayData.ElementGetter valueElementGetter
ArrayData.ElementGetter keyElementGetter
ArrayData.ElementGetter valueElementGetter
SpecializedFunction.ExpressionEvaluator keyEqualityEvaluator
String typeString
ArrayData.ElementGetter elementGetter
ArrayData.ElementGetter keyGetter
ArrayData.ElementGetter valueGetter
AsyncLookupFunction delegate
LookupCache cache
long latestLoadTime
LookupFunction delegate
LookupCache cache
long latestLoadTime
ReentrantLock reloadLock
long latestLoadTimeMs
boolean isStopped
CacheLoader cacheLoader
CacheReloadTrigger reloadTrigger
InputFormat<OT,T extends InputSplit> initialInputFormat
GenericRowDataKeySelector keySelector
RowDataSerializer cacheEntriesSerializer
GeneratedWatermarkGenerator generatedWatermarkGenerator
WatermarkParams watermarkParams
InternalTypeInfo<T> keyRowType
GeneratedProjection generatedProjection
InternalTypeInfo<T> returnType
InternalTypeInfo<T> keyRowType
RowDataSerializer keySerializer
GeneratedProjection generatedProjection
GeneratedClass<T> generatedClass
long currentWatermark
InternalTimerService
.GeneratedAggsHandleFunction genAggsHandler
GeneratedRecordEqualiser genRecordEqualiser
LogicalType[] accTypes
RecordCounter recordCounter
boolean generateUpdateBefore
long stateRetentionTime
GeneratedTableAggsHandleFunction genAggsHandler
LogicalType[] accTypes
RecordCounter recordCounter
boolean generateUpdateBefore
boolean incrementalUpdate
long stateRetentionTime
GeneratedAggsHandleFunction genLocalAggsHandler
GeneratedAggsHandleFunction genGlobalAggsHandler
GeneratedRecordEqualiser genRecordEqualiser
LogicalType[] accTypes
RecordCounter recordCounter
boolean generateUpdateBefore
long stateRetentionTime
GeneratedAggsHandleFunction genAggsHandler
GeneratedRecordEqualiser genRecordEqualiser
LogicalType[] accTypes
RowType inputType
RecordCounter recordCounter
boolean generateUpdateBefore
long stateRetentionTime
GeneratedAggsHandleFunction genPartialAggsHandler
GeneratedAggsHandleFunction genFinalAggsHandler
KeySelector<IN,KEY> finalKeySelector
long stateRetentionTime
GeneratedAggsHandleFunction genAggsHandler
RowDataKeySelector keySelector
SliceAssigner sliceAssigner
long windowInterval
WindowBuffer.LocalFactory windowBufferFactory
ZoneId shiftTimezone
boolean useDayLightSaving
PagedTypeSerializer<T> keySer
AbstractRowDataSerializer<T extends RowData> inputSer
RecordsCombiner.Factory factory
PagedTypeSerializer<T> keySer
AbstractRowDataSerializer<T extends RowData> inputSer
RecordsCombiner.LocalFactory localFactory
GeneratedNamespaceAggsHandleFunction<N> genAggsHandler
GeneratedNamespaceAggsHandleFunction<N> genLocalAggsHandler
GeneratedNamespaceAggsHandleFunction<N> genGlobalAggsHandler
GeneratedNamespaceAggsHandleFunction<N> genAggsHandler
WindowBuffer.Factory windowBufferFactory
SliceAssigner sliceAssigner
long windowInterval
GeneratedNamespaceAggsHandleFunction<N> genAggsHandler
TypeSerializer<T> accSerializer
boolean isEventTime
ZoneId shiftTimeZone
boolean useDayLightSaving
AbstractWindowAggProcessor.WindowIsEmptySupplier emptySupplier
int indexOfCountStar
SliceSharedAssigner sliceSharedAssigner
org.apache.flink.table.runtime.operators.aggregate.window.processors.SliceSharedWindowAggProcessor.SliceMergeTargetHelper mergeTargetHelper
BundleTrigger<T> bundleTrigger
MapBundleFunction<K,V,IN,OUT> function
KeySelector<IN,KEY> keySelector
long maxCount
long maxCount
GeneratedFunction<F extends Function> generatedFetcher
boolean generateUpdateBefore
boolean generateInsert
boolean inputIsInsertOnly
boolean isStateTtlEnabled
GeneratedRecordEqualiser genRecordEqualiser
TypeSerializer<T> serializer
TypeSerializer<T> serializer
boolean generateUpdateBefore
boolean generateInsert
boolean inputInsertOnly
boolean isStateTtlEnabled
GeneratedRecordEqualiser genRecordEqualiser
boolean generateUpdateBefore
boolean generateInsert
int rowtimeIndex
boolean keepLastRow
TypeSerializer<T> serializer
boolean generateUpdateBefore
boolean generateInsert
int rowtimeIndex
boolean keepLastRow
TypeSerializer<T> serializer
boolean generateUpdateBefore
boolean generateInsert
int rowtimeIndex
boolean keepLastRow
TypeSerializer<T> recordSerializer
int rowtimeIndex
boolean keepLastRow
WindowBuffer.Factory bufferFactory
TypeSerializer<T> inputSerializer
int windowEndIndex
ZoneId shiftTimeZone
RowType dynamicFilteringFieldType
List<E> dynamicFilteringFieldIndices
long threshold
OperatorEventGateway operatorEventGateway
StreamOperatorParameters<OUT> parameters
GeneratedClass<T> generatedClass
int[] inputIndices
String script
ScriptTransformIOInfo scriptTransformIOInfo
LogicalType inputType
LogicalType outputType
RowData.FieldGetter[] fieldGetters
JobConfWrapper jobConfWrapper
org.apache.flink.table.runtime.operators.join.HashJoinOperator.HashJoinParameter parameter
boolean reverseJoinFunction
HashJoinType type
boolean leftIsBuild
SortMergeJoinFunction sortMergeJoinFunction
int[] nullFilterKeys
boolean nullSafe
boolean filterAllNulls
KeyContext keyContext
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
int leftArity
int rightArity
double externalBufferMemRatio
FlinkJoinType type
boolean leftIsSmaller
boolean[] filterNulls
int maxNumFileHandles
boolean compressionEnabled
int compressionBlockSize
boolean asyncMergeEnabled
GeneratedJoinCondition condFuncCode
GeneratedProjection projectionCode1
GeneratedProjection projectionCode2
GeneratedNormalizedKeyComputer computer1
GeneratedRecordComparator comparator1
GeneratedNormalizedKeyComputer computer2
GeneratedRecordComparator comparator2
GeneratedRecordComparator genKeyComparator
SortMergeJoinFunction sortMergeJoinFunction
InternalTypeInfo<T> outputTypeInfo
InternalTypeInfo<T> returnTypeInfo
int[] nullFilterKeys
boolean nullSafe
boolean filterAllNulls
GeneratedJoinCondition joinConditionCode
OuterJoinPaddingUtil paddingUtil
InternalTypeInfo<T> outputTypeInfo
OuterJoinPaddingUtil paddingUtil
InternalTypeInfo<T> outputTypeInfo
int leftTimeIdx
int rightTimeIdx
GeneratedFunction<F extends Function> generatedFetcher
DataStructureConverter<I,E> fetcherConverter
GeneratedResultFuture<T extends ResultFuture<?>> generatedResultFuture
GeneratedFunction<F extends Function> generatedPreFilterCondition
boolean isLeftOuterJoin
int asyncBufferCapacity
RowDataSerializer rightRowSerializer
GeneratedFunction<F extends Function> generatedCalc
LookupJoinRunner lookupJoinRunner
StateTtlConfig ttlConfig
TypeSerializer<T> serializer
boolean lookupKeyContainsPrimaryKey
boolean lenient
GeneratedFunction<F extends Function> generatedFetcher
GeneratedCollector<C extends Collector<?>> generatedCollector
GeneratedFunction<F extends Function> generatedPreFilterCondition
boolean isLeftOuterJoin
int tableFieldsCount
GeneratedFunction<F extends Function> generatedCalc
AsyncRetryStrategy<OUT> retryStrategy
AsyncLookupFunction userLookupFunction
ResultRetryStrategy retryStrategy
boolean retryEnabled
LookupFunction userLookupFunction
ResultRetryStrategy retryStrategy
boolean retryEnabled
GeneratedJoinCondition generatedJoinCondition
InternalTypeInfo<T> leftType
InternalTypeInfo<T> rightType
JoinInputSideSpec leftInputSideSpec
JoinInputSideSpec rightInputSideSpec
boolean[] filterNullKeys
long leftStateRetentionTime
long rightStateRetentionTime
CoBundleTrigger<IN1,IN2> coBundleTrigger
boolean leftIsOuter
boolean rightIsOuter
boolean isAntiJoin
boolean inputSideHasUniqueKey
boolean joinKeyContainsUniqueKey
InternalTypeInfo<T> uniqueKeyType
KeySelector<IN,KEY> uniqueKeySelector
long minRetentionTime
long maxRetentionTime
boolean stateCleaningEnabled
boolean isLeftOuterJoin
InternalTypeInfo<T> rightType
GeneratedJoinCondition generatedJoinCondition
boolean isLeftOuterJoin
InternalTypeInfo<T> leftType
InternalTypeInfo<T> rightType
GeneratedJoinCondition generatedJoinCondition
int leftTimeAttribute
int rightTimeAttribute
org.apache.flink.table.runtime.operators.join.temporal.TemporalRowTimeJoinOperator.RowtimeComparator rightRowtimeComparator
RowDataSerializer leftSerializer
RowDataSerializer rightSerializer
GeneratedJoinCondition generatedJoinCondition
int leftWindowEndIndex
int rightWindowEndIndex
boolean[] filterNullKeys
ZoneId shiftTimeZone
GeneratedFunction<F extends Function> generatedFunction
GeneratedFunction<F extends Function> generatedFunction
GeneratedRecordComparator generatedComparator
InputSelectionHandler inputSelectionHandler
List<E> inputSpecs
List<E> headWrappers
TableOperatorWrapper<OP extends StreamOperator<RowData>> tailWrapper
List<E> inputSpecs
Map<K,V> inputSpecMap
List<E> headWrappers
TableOperatorWrapper<OP extends StreamOperator<RowData>> tailWrapper
Deque<E> topologicalOrderingOperators
StreamOperatorFactory<OUT> factory
String operatorName
List<E> allInputTypes
NOTE:The inputs of an operator may not all be in the multiple-input operator, e.g. The multiple-input operator contains A and J, and A is one of the input of J, and another input of J is not in the multiple-input operator.
------- \ J -- / -- A --
For this example, `allInputTypes` contains two input types.
TypeInformation<T> outputType
double managedMemoryFraction
List<E> inputEdges
List<E> outputEdges
boolean closed
int endedInputCount
TableOperatorWrapper<OP extends StreamOperator<RowData>> source
TableOperatorWrapper<OP extends StreamOperator<RowData>> target
int inputId
int multipleInputId
Input
in MultipleInputStreamOperator.getInputs()
.int readOrder
InputSelectionSpec inputSelectionSpec
TableOperatorWrapper<OP extends StreamOperator<RowData>> output
Input
.int outputOpInputId
GeneratedAggsHandleFunction genAggsHandler
LogicalType[] accTypes
LogicalType[] inputFieldTypes
int rowTimeIdx
OverWindowFrame[] overWindowFrames
GeneratedRecordComparator genComparator
boolean isRowAllInFixedPart
RecordComparator partitionComparator
RowData lastInput
JoinedRowData[] joinedRows
StreamRecordCollector<T> collector
AbstractRowDataSerializer<T extends RowData> serializer
ResettableExternalBuffer currentData
GeneratedAggsHandleFunction[] aggsHandlers
GeneratedRecordComparator genComparator
boolean[] resetAccumulators
RecordComparator partitionComparator
RowData lastInput
AggsHandleFunction[] processors
JoinedRowData[] joinedRows
StreamRecordCollector<T> collector
AbstractRowDataSerializer<T extends RowData> serializer
GeneratedAggsHandleFunction genAggsHandler
LogicalType[] accTypes
LogicalType[] inputFieldTypes
long precedingTimeBoundary
GeneratedAggsHandleFunction genAggsHandler
LogicalType[] accTypes
LogicalType[] inputFieldTypes
long precedingOffset
StateTtlConfig ttlConfig
GeneratedAggsHandleFunction genAggsHandler
LogicalType[] accTypes
GeneratedAggsHandleFunction genAggsHandler
LogicalType[] accTypes
LogicalType[] inputFieldTypes
long precedingOffset
int rowTimeIdx
GeneratedAggsHandleFunction genAggsHandler
LogicalType[] accTypes
LogicalType[] inputFieldTypes
long precedingOffset
int rowTimeIdx
GeneratedAggsHandleFunction aggsHandleFunction
AggsHandleFunction processor
GeneratedAggsHandleFunction aggsHandleFunction
Long offset
OffsetOverFrame.CalcOffsetFunc calcOffsetFunc
AggsHandleFunction processor
ResettableExternalBuffer.BufferIterator inputIterator
long inputIndex
ResettableExternalBuffer externalBuffer
long currentBufferLength
GeneratedRecordComparator lboundComparator
GeneratedRecordComparator rboundComparator
RecordComparator lbound
RecordComparator rbound
GeneratedRecordComparator boundComparator
RecordComparator lbound
GeneratedRecordComparator boundComparator
RecordComparator rbound
long leftBound
long rightBound
int inputRightIndex
int inputLeftIndex
long leftBound
long rightBound
long inputRightIndex
RowType inputType
RowType valueType
GeneratedAggsHandleFunction aggsHandleFunction
GeneratedAggsHandleFunction aggsHandleFunction
RowType valueType
AggsHandleFunction processor
RowData accValue
ResettableExternalBuffer input
RowDataSerializer valueSer
int inputIndex
GeneratedAggsHandleFunction aggsHandleFunction
RowType valueType
AggsHandleFunction processor
RowData accValue
RowDataSerializer valueSer
GeneratedAggsHandleFunction aggsHandleFunction
AggsHandleFunction processor
RowData accValue
ResettableExternalBuffer.BufferIterator inputIterator
BinaryRowData nextRow
PythonAggregateFunctionInfo[] aggregateFunctions
DataViewSpec[][] dataViewSpecs
RowType inputType
RowType outputType
int[] grouping
int indexOfCountStar
boolean generateUpdateBefore
int stateCacheSize
int mapStateReadCacheSize
int mapStateWriteCacheSize
long minRetentionTime
long maxRetentionTime
boolean stateCleaningEnabled
boolean countStarInserted
boolean countStarInserted
int inputTimeFieldIndex
long allowedLateness
window.maxTimestamp
+ allowedLateness
landmark.
ZoneId shiftTimeZone
FlinkFnApi.GroupWindow.WindowProperty[] namedProperties
GroupWindowAssigner<W extends Window> windowAssigner
GroupWindowAssigner
assigns zero or more Windows
to an element.FlinkFnApi.GroupWindow.WindowType windowType
boolean isRowTime
boolean isTimeWindow
long size
long slide
long gap
PythonFunctionInfo[] pandasAggFunctions
AggregateFunction
s to be executed.GeneratedProjection udafInputGeneratedProjection
int[] namedProperties
int inputTimeFieldIndex
int maxLimitSize
long windowSize
long slideSize
long[] lowerBoundary
long[] upperBoundary
boolean[] isRangeWindows
int[] aggWindowIndex
int inputTimeFieldIndex
boolean asc
long minRetentionTime
long maxRetentionTime
boolean stateCleaningEnabled
int inputTimeFieldIndex
long lowerBoundary
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream.StreamArrowPythonGroupWindowAggregateFunctionOperator.WindowProperty[] namedProperties
int inputTimeFieldIndex
GroupWindowAssigner<W extends Window> windowAssigner
GroupWindowAssigner
assigns zero or more Windows
to an element.Trigger<W extends Window> trigger
Trigger
determines when a pane of a window should be evaluated to emit the results
for that part of the window.long allowedLateness
window.maxTimestamp
+ allowedLateness
landmark.
ZoneId shiftTimeZone
PythonFunctionInfo[] scalarFunctions
ScalarFunction
s to be executed.GeneratedProjection udfInputGeneratedProjection
GeneratedProjection forwardedFieldGeneratedProjection
PythonFunctionInfo[] scalarFunctions
ScalarFunction
s to be executed.GeneratedProjection forwardedFieldGeneratedProjection
PythonFunctionInfo tableFunction
TableFunction
to be executed.FlinkJoinType joinType
GenericRowData reuseNullResultRowData
PythonFunctionInfo tableFunction
TableFunction
to be executed.FlinkJoinType joinType
GeneratedProjection udtfInputGeneratedProjection
StateTtlConfig ttlConfig
GeneratedRecordComparator generatedSortKeyComparator
Comparator<T> sortKeyComparator
boolean generateUpdateBefore
boolean outputRankNumber
InternalTypeInfo<T> inputRowType
KeySelector<IN,KEY> sortKeySelector
KeyContext keyContext
boolean isConstantRankEnd
long rankStart
int rankEndIndex
long rankEnd
ValueState<T> rankEndState
Counter invalidCounter
JoinedRowData outputRow
long hitCount
long requestCount
ValueState<T> state
InternalTypeInfo<T> sortKeyType
TypeSerializer<T> inputRowSer
long cacheSize
GeneratedRecordComparator generatedRecordComparator
int[] compareKeyPositions
LogicalType[] compareKeyTypes
boolean[] compareOrders
boolean[] nullsIsLast
long rankStart
long rankEnd
long rankStart
TypeSerializer<T> inputRowSer
long cacheSize
InternalTypeInfo<T> sortKeyType
boolean lenient
GeneratedRecordEqualiser generatedEqualiser
RecordEqualiser equaliser
ComparableRecordComparator serializableComparator
TypeSerializer<T> inputRowSer
InternalTypeInfo<T> rowKeyType
long cacheSize
boolean lenient
TypeSerializer<T> inputRowSer
KeySelector<IN,KEY> rowKeySelector
int rankEndIndex
GeneratedRecordComparator generatedSortKeyComparator
KeySelector<IN,KEY> sortKeySelector
TypeSerializer<T> recordSerializer
long topN
GeneratedRecordComparator generatedSortKeyComparator
Comparator<T> sortKeyComparator
TypeSerializer<T> sortKeySerializer
WindowBuffer.Factory bufferFactory
TypeSerializer<T> inputSerializer
long rankStart
long rankEnd
boolean outputRankNumber
int windowEndIndex
ZoneId shiftTimeZone
int maxRowCount
GeneratedProjection buildProjectionCode
int estimatedRowCount
int maxRowCount
ExecutionConfigOptions.NotNullEnforcer notNullEnforcer
int[] notNullFieldIndices
String[] allFieldNames
ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer
int[] charFieldIndices
int[] charFieldLengths
BitSet charFieldCouldPad
int[] binaryFieldIndices
int[] binaryFieldLengths
BitSet binaryFieldCouldPad
String operatorName
RowData.FieldGetter atomicFieldGetter
DynamicTableSink.DataStructureConverter converter
int rowtimeIndex
boolean consumeRowtimeMetadata
RowKind targetRowKind
int rowtimeFieldIndex
long currentWatermark
InternalTimerService
.StateTtlConfig ttlConfig
GeneratedRecordEqualiser generatedRecordEqualiser
GeneratedRecordEqualiser generatedUpsertKeyEqualiser
TypeSerializer<T> serializer
int[] inputUpsertKey
boolean hasUpsertKey
int rowtimeIndex
int precision
boolean isGlobal
long limitStart
long limitEnd
InternalTypeInfo<T> inputRowType
GeneratedRecordComparator gComparator
GeneratedRecordComparator partitionByGenComp
GeneratedRecordComparator orderByGenComp
long rankStart
long rankEnd
boolean outputRankFunColumn
InternalTypeInfo<T> inputRowType
int rowTimeIdx
GeneratedRecordComparator gComparator
boolean isGlobal
long limitStart
long limitEnd
GeneratedRecordComparator genComparator
GeneratedNormalizedKeyComputer gComputer
GeneratedRecordComparator gComparator
int maxNumFileHandles
boolean compressionEnabled
int compressionBlockSize
boolean asyncMergeEnabled
InternalTypeInfo<T> inputRowType
GeneratedRecordComparator gComparator
DynamicTableSource.DataStructureConverter converter
boolean requiresWrapping
boolean produceRowtimeMetadata
boolean propagateWatermark
boolean isInsertOnly
GeneratedInput<F extends InputFormat<?,?>> generatedInput
InternalTypeInfo<T> returnType
GenericInputFormat<OT> format
long windowSize
long windowSlide
long size
long maxSize
long step
long offset
boolean isEventTime
long sessionGap
boolean isEventTime
long size
long slide
long offset
long paneSize
int numPanesPerWindow
boolean isEventTime
long size
long offset
boolean isEventTime
GroupWindowAssigner<W extends Window> windowAssigner
NamespaceAggsHandleFunctionBase<N> windowAggregator
long allowedLateness
InternalWindowProcessFunction.Context<K,W extends Window> ctx
MergingWindowAssigner<W extends Window> windowAssigner
TypeSerializer<T> windowSerializer
List<E> reuseActualWindows
PanedWindowAssigner<W extends Window> windowAssigner
NamespaceAggsHandleFunction<N> aggWindowAggregator
GeneratedNamespaceAggsHandleFunction<N> generatedAggWindowAggregator
RecordEqualiser equaliser
GeneratedRecordEqualiser generatedEqualiser
NamespaceTableAggsHandleFunction<N> tableAggWindowAggregator
GeneratedNamespaceTableAggsHandleFunction<N> generatedTableAggWindowAggregator
GroupWindowAssigner<W extends Window> windowAssigner
Trigger<W extends Window> trigger
TypeSerializer<T> windowSerializer
LogicalType[] inputFieldTypes
LogicalType[] accumulatorTypes
LogicalType[] aggResultTypes
LogicalType[] windowPropertyTypes
boolean produceUpdates
ZoneId shiftTimeZone
int rowtimeIndex
long allowedLateness
window.maxTimestamp
+ allowedLateness
landmark.
RecordCounter recordCounter
NamespaceAggsHandleFunctionBase<N> windowAggregator
long countElems
ReducingStateDescriptor<T> countStateDesc
long interval
ReducingStateDescriptor<T> nextFiringStateDesc
WindowProcessor<W> windowProcessor
boolean isEventTime
Trigger<W extends Window> trigger
TypeSerializer<T> inputSerializer
TypeSerializer<T> windowSerializer
ZoneId shiftTimeZone
int rowtimeIndex
GroupWindowAssigner<W extends Window> windowAssigner
long maxSize
long step
long offset
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceAssigners.ReusableListIterable reuseToBeMergedList
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceAssigners.ReusableListIterable reuseExpiredList
long size
long slide
long offset
long sliceSize
int numSlicesPerWindow
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceAssigners.ReusableListIterable reuseExpiredList
SliceSharedAssigner innerSharedAssigner
long size
long offset
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceAssigners.ReusableListIterable reuseExpiredList
int windowEndIndex
SliceAssigner innerAssigner
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceAssigners.ReusableListIterable reuseExpiredList
int rowtimeIndex
long sessionGap
boolean isEventTime
ZoneId shiftTimeZone
SessionWindowAssigner innerSessionWindowAssigner
int windowStartIndex
int windowEndIndex
UnsliceAssigner<W extends Window> innerAssigner
long delay
int rowtimeIndex
PeriodicWatermarkAssigner assigner
int timeFieldIdx
long intervalMs
PunctuatedWatermarkAssigner assigner
int timeFieldIdx
DataFormatConverters.DataFormatConverter<Internal,External> converter
long minibatchInterval
int rowtimeFieldIndex
long idleTimeout
WatermarkGenerator watermarkGenerator
int rowtimeFieldIndex
long idleTimeout
GeneratedWatermarkGenerator generatedWatermarkGenerator
GeneratedHashFunction genHashFunc
String[] hashFieldNames
LogicalType eleType
TypeSerializer<T> eleSer
ArrayData.ElementGetter elementGetter
int precision
int scale
int numFields
int fixedLengthPartSize
int precision
int scale
int precision
int scale
private void readObject(ObjectInputStream serialized) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
DataType dataType
TypeSerializer<T> internalSerializer
boolean isInternalInput
boolean isReuseEnabled
DataType dataType
TypeSerializer<T> typeSerializer
LogicalType type
Class<T> typeClass
TypeSerializer<T> typeSerializer
int precision
int precision
int precision
TypeSerializer<T> elementSerializer
boolean hasNullMask
LogicalType keyType
LogicalType valueType
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
ArrayData.ElementGetter keyGetter
ArrayData.ElementGetter valueGetter
DataFormatConverters.DataFormatConverter<Internal,External> dataFormatConverter
PythonTypeUtils.DataConverter<IN,INTER,OUT> keyConverter
PythonTypeUtils.DataConverter<IN,INTER,OUT> valueConverter
TypeSerializer<T> serializer
BinaryRowDataSerializer binarySerializer
LogicalType[] types
TypeSerializer<T>[] fieldSerializers
RowData.FieldGetter[] fieldGetters
Comparator<T> comparator
Comparator<T> comparator
int precision
int precision
PagedTypeSerializer<T> keySerializer
LogicalType elementType
TypeSerializer<T> elementTypeSerializer
ArrayData.ElementGetter elementGetter
int elementSize
BinaryArrayWriter.NullSetter nullSetter
int precision
int scale
LogicalType keyType
LogicalType valueType
TypeSerializer<T> keyTypeSerializer
TypeSerializer<T> valueTypeSerializer
BinaryWriter.ValueSetter keySetter
BinaryWriter.ValueSetter valueSetter
ArrayData.ElementGetter keyGetter
ArrayData.ElementGetter valueGetter
BinaryArrayWriter.NullSetter nullValueSetter
int keySize
int valueSize
LogicalType[] fieldTypes
TypeSerializer<T>[] fieldSerializers
RowData.FieldGetter[] fieldGetters
int precision
SpecializedFunction.ExpressionEvaluator hashcodeEvaluator
SpecializedFunction.ExpressionEvaluator equalityEvaluator
int cacheSize
LRUMap.RemovalListener<K,V> removalListener
String fieldDelim
String field
long maxTimestamp
long delay
long maxTimestamp
WatermarkStrategy<T> watermarkStrategy
boolean isRunning
DataType elementDataType
LogicalType logicalType
Class<T> conversionClass
LogicalType elementType
int length
int length
DayTimeIntervalType.DayTimeResolution resolution
int dayPrecision
int fractionalPrecision
int precision
int scale
LogicalType sourceType
TypeInformation<T> typeInfo
TimestampKind kind
int precision
boolean isNullable
LogicalTypeRoot typeRoot
LogicalType keyType
LogicalType valueType
LogicalType elementType
Class<T> clazz
TypeSerializer<T> serializer
String name
LogicalType type
String description
List<E> attributes
boolean isInstantiable
StructuredType.StructuredComparison comparison
StructuredType superType
Class<T> implementationClass
String name
LogicalType type
String description
TimestampKind kind
int precision
int precision
TypeInformation<T> typeInfo
UnresolvedIdentifier unresolvedIdentifier
ObjectIdentifier objectIdentifier
boolean isFinal
String description
int length
int length
YearMonthIntervalType.YearMonthResolution resolution
int yearPrecision
TimestampKind kind
int precision
boolean isEventTime
WatermarkEmitStrategy emitStrategy
String alignGroupName
Duration alignMaxDrift
Duration alignUpdateInterval
long sourceIdleTimeout
boolean cancel
int resultListId
boolean value
byte value
char value
double value
float value
int value
int fieldNumber
long value
int fieldPos
int fieldNumber
org.apache.flink.types.Record.InternalDeSerializer serializer
byte[] binaryData
byte[] switchBuffer
int[] offsets
int[] lengths
Value[] readFields
Value[] writeFields
int binaryLen
int numFields
int firstModifiedPos
RowKind kind
Object[] fieldByPosition
Row.fieldByName
is set.Map<K,V> fieldByName
Row.fieldByPosition
is set.LinkedHashMap<K,V> positionByName
Row.fieldByPosition
semantics.Serializable value
short value
char[] value
int len
int hashCode
long upperPart
long lowerPart
long to
long current
LongValue currentValue
long to
long current
private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream stream) throws IOException
IOException
Throwable failureCause
String id
TypeInformation<T> typeInfo
SerializableObject lock
int leaseCount
boolean closed
byte[] serializedData
String keyString
StringValue toTokenize
int pos
int limit
long seed
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
long offset_
long length_
int index_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
int objectTypePtr
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
boolean value
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
byte value
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
String delegationToken
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCancelOperationReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCancelOperationResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCloseOperationReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCloseOperationResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCloseSessionReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TCloseSessionResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TExecuteStatementReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TExecuteStatementResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TFetchResultsReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TFetchResultsResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetCatalogsReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetCatalogsResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetColumnsReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetColumnsResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetFunctionsReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetFunctionsResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetInfoReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetInfoResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetOperationStatusReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetOperationStatusResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
TGetQueryIdReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
TGetQueryIdResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetSchemasReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetSchemasResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetTablesReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetTablesResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetTableTypesReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetTableTypesResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetTypeInfoReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TGetTypeInfoResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOpenSessionReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOpenSessionResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
TSetClientInfoReq req
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
TSetClientInfoResp success
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
double value
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
org.apache.hive.service.rpc.thrift.TFetchOrientation orientation
long maxRows
short fetchType
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
boolean hasMoreRows
org.apache.hive.service.rpc.thrift.TRowSet results
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
String parentCatalogName
String parentSchemaName
String parentTableName
String foreignCatalogName
String foreignSchemaName
String foreignTableName
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
String delegationToken
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
org.apache.hive.service.rpc.thrift.TGetInfoType infoType
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TGetInfoValue infoValue
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
boolean getProgressUpdate
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationState operationState
String sqlState
int errorCode
String errorMessage
String taskStatus
long operationStarted
long operationCompleted
boolean hasResultSet
org.apache.hive.service.rpc.thrift.TProgressUpdateResp progressUpdateResponse
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
String queryId
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TTableSchema schema
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
org.apache.hive.service.rpc.thrift.TOperationHandle operationHandle
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
ByteBuffer guid
ByteBuffer secret
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
short value
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
int value
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
long value
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
int keyTypePtr
int valueTypePtr
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.THandleIdentifier operationId
org.apache.hive.service.rpc.thrift.TOperationType operationType
boolean hasResultSet
double modifiedRowCount
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TTypeId type
org.apache.hive.service.rpc.thrift.TTypeQualifiers typeQualifiers
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TSessionHandle sessionHandle
String delegationToken
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
long startRowOffset
List<E> rows
List<E> columns
ByteBuffer binaryColumns
int columnCount
byte __isset_bitfield
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
org.apache.hive.service.rpc.thrift.THandleIdentifier sessionId
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hive.service.rpc.thrift.TStatus status
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
List<E> values
ByteBuffer nulls
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
String value
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
String typeClassName
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.