Uses of Class
org.apache.flink.annotation.Internal
-
-
Uses of Internal in org.apache.calcite.sql.validate
Classes in org.apache.calcite.sql.validate with annotations of type Internal Modifier and Type Class Description classProcedureNamespaceNamespace whose contents are defined by the result of a call to a user-defined procedure. -
Uses of Internal in org.apache.flink.annotation
Classes in org.apache.flink.annotation with annotations of type Internal Modifier and Type Class Description interfaceVisibleForTestingThis annotations declares that a function, field, constructor, or entire type, is only visible for testing purposes. -
Uses of Internal in org.apache.flink.annotation.docs
Classes in org.apache.flink.annotation.docs with annotations of type Internal Modifier and Type Class Description interfaceConfigGroupA class that specifies a group of config options.interfaceConfigGroupsAnnotation used on classes containing config options that enables the separation of options into different tables based on key prefixes.static interfaceDocumentation.ExcludeFromDocumentationAnnotation used on config option fields or REST API message headers to exclude it from documentation.static interfaceDocumentation.OverrideDefaultAnnotation used on config option fields to override the documented default.static interfaceDocumentation.SectionAnnotation used on config option fields to include them in specific sections.static interfaceDocumentation.SuffixOptionAnnotation used on config option fields or options class to mark them as a suffix-option; i.e., a config option where the key is only a suffix, with the prefix being dynamically provided at runtime.static interfaceDocumentation.TableOptionAnnotation used on table config options for adding meta data labels.classFlinkJsonSchemaAnnotations for auto-generating a documentation of json payloads.static interfaceFlinkJsonSchema.AdditionalFieldsThis allows documenting a class that supports setting dynamic properties of a certain type. -
Uses of Internal in org.apache.flink.api.common
Classes in org.apache.flink.api.common with annotations of type Internal Modifier and Type Interface Description interfaceArchiveable<T extends Serializable>classArchivedExecutionConfigSerializable class which is created when archiving the job.classJobInfoImplThe default implementation ofJobInfo.classPlanThis class represents Flink programs, in the form of dataflow plans.classRestartStrategyDescriptionUtilsUtility class for describing restart strategies.classSerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable>The wrapper to make serializer serializable.classTaskInfoImplThe default implementation ofTaskInfo.Methods in org.apache.flink.api.common with annotations of type Internal Modifier and Type Method Description ArchivedExecutionConfigExecutionConfig. archive()voidExecutionConfig. enablePeriodicMaterialize(boolean enabled)intExecutionConfig. getMaterializationMaxAllowedFailures()longExecutionConfig. getPeriodicMaterializeIntervalMillis()Optional<JobManagerOptions.SchedulerType>ExecutionConfig. getSchedulerType()SerializerConfigExecutionConfig. getSerializerConfig()booleanExecutionConfig. isLatencyTrackingConfigured()booleanExecutionConfig. isPeriodicMaterializeEnabled()voidExecutionConfig. resetParallelism()voidExecutionConfig. setMaterializationMaxAllowedFailures(int materializationMaxAllowedFailures)voidExecutionConfig. setPeriodicMaterializeIntervalMillis(Duration periodicMaterializeInterval)ConfigurationExecutionConfig. toConfiguration()Constructors in org.apache.flink.api.common with annotations of type Internal Constructor Description ExecutionConfig(Configuration configuration) -
Uses of Internal in org.apache.flink.api.common.accumulators
Classes in org.apache.flink.api.common.accumulators with annotations of type Internal Modifier and Type Class Description classAccumulatorHelperHelper functions for the interaction withAccumulator. -
Uses of Internal in org.apache.flink.api.common.aggregators
Classes in org.apache.flink.api.common.aggregators with annotations of type Internal Modifier and Type Class Description classAggregatorRegistryA registry for iterationAggregators. -
Uses of Internal in org.apache.flink.api.common.attribute
Classes in org.apache.flink.api.common.attribute with annotations of type Internal Modifier and Type Class Description classAttributeAttributecontains the information about the process logic of a process function.static classAttribute.Builder -
Uses of Internal in org.apache.flink.api.common.cache
Methods in org.apache.flink.api.common.cache with annotations of type Internal Modifier and Type Method Description static List<String>DistributedCache. parseStringFromCachedFiles(List<Tuple2<String,DistributedCache.DistributedCacheEntry>> files) -
Uses of Internal in org.apache.flink.api.common.distributions
Classes in org.apache.flink.api.common.distributions with annotations of type Internal Modifier and Type Class Description classCommonRangeBoundaries<T> -
Uses of Internal in org.apache.flink.api.common.eventtime
Classes in org.apache.flink.api.common.eventtime with annotations of type Internal Modifier and Type Class Description classIndexedCombinedWatermarkStatusRepresents combined value and status of a watermark for a set number of input partial watermarks.classWatermarkOutputMultiplexerAWatermarkOutputMultiplexercombines the watermark (and idleness) updates of multiple partitions/shards/splits into one combined watermark update and forwards it to an underlyingWatermarkOutput.static interfaceWatermarkOutputMultiplexer.WatermarkUpdateListenerA callback for propagating changes to split based watermarks. -
Uses of Internal in org.apache.flink.api.common.functions
Classes in org.apache.flink.api.common.functions with annotations of type Internal Modifier and Type Interface Description interfaceSerializerFactoryA factory forTypeSerializerimplementations.classWrappingFunction<T extends Function>Wrapper aroundFunction. -
Uses of Internal in org.apache.flink.api.common.functions.util
Classes in org.apache.flink.api.common.functions.util with annotations of type Internal Modifier and Type Class Description classAbstractRuntimeUDFContextA standalone implementation of theRuntimeContext, created by runtime UDF operators.classCopyingIterator<E>Wraps an iterator to return deep copies of the original iterator's elements.classCopyingListCollector<T>ACollectorthat collects deep copies of its elements in a list.classFunctionUtilsUtility class that contains helper methods to work with FlinkFunctionclass.classListCollector<T>ACollectorthat puts the collected elements into a given list.classNoOpFunctionAnAbstractRichFunctionthat does nothing.classPrintSinkOutputWriter<IN>Print sink output writer for DataStream and DataSet print API.classRuntimeUDFContextA standalone implementation of theRuntimeContext, created by runtime UDF operators.Methods in org.apache.flink.api.common.functions.util with annotations of type Internal Modifier and Type Method Description StringAbstractRuntimeUDFContext. getAllocationIDAsString() -
Uses of Internal in org.apache.flink.api.common.io
Classes in org.apache.flink.api.common.io with annotations of type Internal Modifier and Type Class Description classDefaultInputSplitAssignerThis is the default implementation of theInputSplitAssignerinterface.classGenericCsvInputFormat<OT>classGlobFilePathFilterClass for determining if a particular file should be included or excluded based on a set of include and exclude glob filters.classReplicatingInputSplitAssignerAssigns each InputSplit to each requesting parallel instance. -
Uses of Internal in org.apache.flink.api.common.io.compression
Classes in org.apache.flink.api.common.io.compression with annotations of type Internal Modifier and Type Class Description classBzip2InputStreamFactoryFactory for Bzip2 decompressors.classDeflateInflaterInputStreamFactoryFactory for input streams that decompress the "deflate" compression format.classGzipInflaterInputStreamFactoryFactory for input streams that decompress the GZIP compression format.interfaceInflaterInputStreamFactory<T extends InputStream>Creates a new instance of a certain subclass ofInflaterInputStream.classXZInputStreamFactoryFactory for XZ decompressors.classZStandardInputStreamFactoryFactory for ZStandard decompressors. -
Uses of Internal in org.apache.flink.api.common.operators
Classes in org.apache.flink.api.common.operators with annotations of type Internal Modifier and Type Class Description classAbstractUdfOperator<OUT,FT extends Function>Abstract superclass for all contracts that represent actual operators.classBinaryOperatorInformation<IN1,IN2,OUT>A class for holding information about a single input operator, such as input/output TypeInformation.classCollectionExecutorExecution utility for serial, local, collection-based executions of Flink programs.classCompilerHintsA class encapsulating compiler hints describing the behavior of the user function.classDualInputOperator<IN1,IN2,OUT,FT extends Function>Abstract operator superclass for all operators that have two inputs, like "Join", "CoGroup", or "Cross".classDualInputSemanticPropertiesContainer for the semantic properties associated to a dual input operator.classGenericDataSinkBase<IN>Operator for nodes that act as data sinks, storing the data they receive.classGenericDataSourceBase<OUT,T extends InputFormat<OUT,?>>Abstract superclass for data sources in a Pact plan.interfaceIterationOperatorclassKeys<T>classMailOptionsImplOptions to configure behaviour of executing mailbox mails.classOperator<OUT>Abstract base class for all operators.classOperatorInformation<OUT>A class for holding information about an operator, such as input/output TypeInformation.classOrderingThis class represents an ordering on a set of fields.classResourceSpecDescribe the different resource factors of the operator with UDF.interfaceSemanticPropertiesContainer for the semantic properties associated to an operator.classSingleInputOperator<IN,OUT,FT extends Function>Abstract superclass for all operators that have one input like "map" or "reduce".classSingleInputSemanticPropertiesContainer for the semantic properties associated to a single input operator.classUnaryOperatorInformation<IN,OUT>A class for holding information about a single input operator, such as input/output TypeInformation.classUnion<T>This operator represents a Union between two inputs. -
Uses of Internal in org.apache.flink.api.common.operators.base
Classes in org.apache.flink.api.common.operators.base with annotations of type Internal Modifier and Type Class Description classBulkIterationBase<T>classCoGroupOperatorBase<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>>classCoGroupRawOperatorBase<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>>classCrossOperatorBase<IN1,IN2,OUT,FT extends CrossFunction<IN1,IN2,OUT>>classDeltaIterationBase<ST,WT>A DeltaIteration is similar to aBulkIterationBase, but maintains state across the individual iteration steps.classFilterOperatorBase<T,FT extends FlatMapFunction<T,T>>classFlatMapOperatorBase<IN,OUT,FT extends FlatMapFunction<IN,OUT>>classGroupCombineOperatorBase<IN,OUT,FT extends GroupCombineFunction<IN,OUT>>Base operator for the combineGroup transformation.classGroupReduceOperatorBase<IN,OUT,FT extends GroupReduceFunction<IN,OUT>>classInnerJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>classJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>classMapOperatorBase<IN,OUT,FT extends MapFunction<IN,OUT>>classMapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>>classOuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>classPartitionOperatorBase<IN>classReduceOperatorBase<T,FT extends ReduceFunction<T>>Base data flow operator for Reduce user-defined functions.classSortPartitionOperatorBase<IN> -
Uses of Internal in org.apache.flink.api.common.operators.util
Classes in org.apache.flink.api.common.operators.util with annotations of type Internal Modifier and Type Class Description classFieldListImmutable ordered list of fields IDs.classFieldSetImmutable unordered collection of fields IDs.classJoinHashMap<BT>classListKeyGroupedIterator<E>The KeyValueIterator returns a key and all values that belong to the key (share the same key).classTupleUnwrappingIterator<T,K>An iterator that reads 2-tuples (key value pairs) and returns only the values (second field).classTypeComparable<T>Wrapper that is used to store elements for which we have a TypeComparator in a Hash Map.classUserCodeClassWrapper<T>This holds a class containing user defined code.classUserCodeObjectWrapper<T>This holds an actual object containing user defined code.interfaceUserCodeWrapper<T>UDf operators can have either a class or an object containing the user code, this is the common interface to access them. -
Uses of Internal in org.apache.flink.api.common.resources
Classes in org.apache.flink.api.common.resources with annotations of type Internal Modifier and Type Class Description classCPUResourceRepresents CPU resource.classExternalResourceAn external resource.classResource<T extends Resource<T>>Base class for resources one can specify. -
Uses of Internal in org.apache.flink.api.common.serialization
Classes in org.apache.flink.api.common.serialization with annotations of type Internal Modifier and Type Class Description classRuntimeContextInitializationContextAdaptersA set of adapters betweenRuntimeContextandDeserializationSchema.InitializationContextorSerializationSchema.InitializationContext.classSerializerConfigImplThe default implement ofSerializerConfig.Methods in org.apache.flink.api.common.serialization with annotations of type Internal Modifier and Type Method Description voidSerializerConfig. addDefaultKryoSerializer(Class<?> type, Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)Adds a new Kryo default serializer to the Runtime.<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable>
voidSerializerConfig. addDefaultKryoSerializer(Class<?> type, T serializer)Adds a new Kryo default serializer to the Runtime.voidSerializerConfig. registerKryoType(Class<?> type)Registers the given type with the serialization stack.voidSerializerConfig. registerPojoType(Class<?> type)Registers the given type with the serialization stack.voidSerializerConfig. registerTypeWithKryoSerializer(Class<?> type, Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)Registers the given Serializer via its class as a serializer for the given type at the KryoSerializer.<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable>
voidSerializerConfig. registerTypeWithKryoSerializer(Class<?> type, T serializer)Registers the given type with a Kryo Serializer.voidSerializerConfig. setForceAvro(boolean forceAvro)The method will be converted to private in the next Flink major version after removing its deprecated caller methods.voidSerializerConfig. setForceKryo(boolean forceKryo)The method will be converted to private in the next Flink major version after removing its deprecated caller methods.voidSerializerConfig. setForceKryoAvro(boolean forceKryoAvro)The method will be converted to private in the next Flink major version after removing its deprecated caller methods.voidSerializerConfig. setGenericTypes(boolean genericTypes)The method will be converted to private in the next Flink major version after removing its deprecated caller methods.Constructors in org.apache.flink.api.common.serialization with annotations of type Internal Constructor Description SerializerConfigImpl(Configuration configuration) -
Uses of Internal in org.apache.flink.api.common.state
Classes in org.apache.flink.api.common.state with annotations of type Internal Modifier and Type Interface Description interfaceInternalCheckpointListenerThe internal checkpoint listener add anotherInternalCheckpointListener.notifyCheckpointSubsumed(long)interface for internal usage.Methods in org.apache.flink.api.common.state with annotations of type Internal Modifier and Type Method Description StateTtlConfigStateDescriptor. getTtlConfig()voidStateDescriptor. initializeSerializerUnlessSet(SerializerFactory serializerFactory) -
Uses of Internal in org.apache.flink.api.common.time
Classes in org.apache.flink.api.common.time with annotations of type Internal Modifier and Type Class Description classDeadlineThis class stores a deadline, as obtained viaDeadline.now()or fromDeadline.plus(Duration). -
Uses of Internal in org.apache.flink.api.common.typeinfo.descriptor
Classes in org.apache.flink.api.common.typeinfo.descriptor with annotations of type Internal Modifier and Type Class Description classBasicTypeDescriptorImpl<T>Implementation ofTypeDescriptorto createBasicTypeInfo.classListTypeDescriptorImpl<T>Implementation ofTypeDescriptorto createListTypeInfo.classMapTypeDescriptorImpl<K,V>Implementation ofTypeDescriptorto createMapTypeInfo.classValueTypeDescriptorImpl<T extends Value>Implementation ofTypeDescriptorto createValueTypeInfo. -
Uses of Internal in org.apache.flink.api.common.typeutils
Classes in org.apache.flink.api.common.typeutils with annotations of type Internal Modifier and Type Class Description classCompositeTypeSerializerUtilUtilities for theCompositeTypeSerializerSnapshot.classGenericPairComparator<T1,T2>classGenericTypeSerializerSnapshot<T,S extends TypeSerializer>BaseTypeSerializerSnapshotfor serializers for generic types.interfaceLegacySerializerSnapshotTransformer<T>This interface provides a way forTypeSerializers to transform a legacyTypeSerializerSnapshotused in versions before Flink 1.7 during deserialization.classNestedSerializersSnapshotDelegateA NestedSerializersSnapshotDelegate represents the snapshots of multiple serializers that are used by an outer serializer.classSameTypePairComparator<T>classSingleThreadAccessCheckingTypeSerializer<T>interfaceTypeComparatorFactory<T>classTypePairComparator<T1,T2>This interface defines the method required by the runtime to use data types in join-like operations.interfaceTypePairComparatorFactory<T1,T2>interfaceTypeSerializerFactory<T> -
Uses of Internal in org.apache.flink.api.common.typeutils.base
Classes in org.apache.flink.api.common.typeutils.base with annotations of type Internal Modifier and Type Class Description classBasicTypeComparator<T extends Comparable<T>>classBigDecComparatorComparator for comparing BigDecimal values.classBigDecSerializerSerializer for serializing/deserializing BigDecimal values including null values.classBigIntComparatorComparator for comparing BigInteger values.classBigIntSerializerSerializer for serializing/deserializing BigInteger values including null values.classBooleanComparatorclassBooleanSerializerType serializer forBoolean.classBooleanValueComparatorSpecialized comparator for BooleanValue based on CopyableValueComparator.classBooleanValueSerializerclassByteComparatorclassByteSerializerType serializer forByte.classByteValueComparatorSpecialized comparator for ByteValue based on CopyableValueComparator.classByteValueSerializerclassCharComparatorclassCharSerializerType serializer forCharacter.classCharValueComparatorSpecialized comparator for CharValue based on CopyableValueComparator.classCharValueSerializerclassDateComparatorclassDateSerializerclassDoubleComparatorclassDoubleSerializerType serializer forDouble.classDoubleValueComparatorSpecialized comparator for DoubleValue based on CopyableValueComparator.classDoubleValueSerializerclassEnumComparator<T extends Enum<T>>classEnumSerializer<T extends Enum<T>>TypeSerializerfor Java enums.classFloatComparatorclassFloatSerializerType serializer forFloat.classFloatValueComparatorSpecialized comparator for FloatValue based on CopyableValueComparator.classFloatValueSerializerclassGenericArraySerializer<C>A serializer for arrays of objects.classInstantComparatorComparator for comparing Java Instant.classInstantSerializerSerializer for serializing/deserializing Instant values including null values.classIntComparatorclassIntSerializerType serializer forInteger(andint, via auto-boxing).classIntValueComparatorSpecialized comparator for IntValue based on CopyableValueComparator.classIntValueSerializerclassListSerializer<T>A serializer forLists.classLocalDateComparatorThis class can not extendBasicTypeComparator, because LocalDate is a Comparable of ChronoLocalDate instead of Comparable of LocalDate.classLocalDateSerializerclassLocalDateTimeComparatorThis class can not extendBasicTypeComparator, because LocalDateTime is a Comparable of ChronoLocalDateTime instead of Comparable of LocalDateTime.classLocalDateTimeSerializerclassLocalTimeComparatorclassLocalTimeSerializerclassLongComparatorclassLongSerializerType serializer forLong.classLongValueComparatorSpecialized comparator for LongValue based on CopyableValueComparator.classLongValueSerializerclassMapSerializer<K,V>A serializer forMap.classNormalizedKeyUtilUtilities related toTypeComparator.classNullValueComparatorSpecialized comparator for NullValue based on CopyableValueComparator.classNullValueSerializerclassShortComparatorclassShortSerializerType serializer forByte.classShortValueComparatorSpecialized comparator for ShortValue based on CopyableValueComparator.classShortValueSerializerclassSqlDateSerializerclassSqlTimeSerializerclassSqlTimestampComparatorComparator for comparing Java SQL Timestamps.classSqlTimestampSerializerclassStringComparatorclassStringSerializerType serializer forString.classStringValueComparatorSpecialized comparator for StringValue based on CopyableValueComparator.classStringValueSerializerclassTypeSerializerSingleton<T>classVoidSerializerSerializer forVoid. -
Uses of Internal in org.apache.flink.api.common.typeutils.base.array
-
Uses of Internal in org.apache.flink.api.connector.dsv2
Classes in org.apache.flink.api.connector.dsv2 with annotations of type Internal Modifier and Type Class Description classFromDataSource<T>DataStream v2 source that emit data from pre-provided data.classWrappedSink<T>A simpleSinkimplementation that wrap a sink-v2 based sink.classWrappedSource<T>A simpleSourceimplementation that wrap a FLIP-27 source. -
Uses of Internal in org.apache.flink.api.connector.sink2
Classes in org.apache.flink.api.connector.sink2 with annotations of type Internal Modifier and Type Interface Description interfaceInitContextCommon interface which exposes runtime info for creatingSinkWriterandCommitterobjects. -
Uses of Internal in org.apache.flink.api.connector.source
Classes in org.apache.flink.api.connector.source with annotations of type Internal Modifier and Type Interface Description interfaceSupportsIntermediateNoMoreSplitsA decorative interface ofSplitEnumeratorContextwhich allows to handle intermediate NoMoreSplits. -
Uses of Internal in org.apache.flink.api.connector.source.util.ratelimit
Classes in org.apache.flink.api.connector.source.util.ratelimit with annotations of type Internal Modifier and Type Class Description classGatedRateLimiterAn implementation ofRateLimiterthat completes defined number of futures in-between the external notification events.classGuavaRateLimiterAn implementation ofRateLimiterbased on Guava's RateLimiter.classNoOpRateLimiterA convenience implementation ofRateLimiterthat does not throttle requests. -
Uses of Internal in org.apache.flink.api.dag
Classes in org.apache.flink.api.dag with annotations of type Internal Modifier and Type Interface Description interfacePipelineCommon interface for Flink pipelines.classTransformation<T>ATransformationrepresents the operation that creates a DataStream. -
Uses of Internal in org.apache.flink.api.java
Classes in org.apache.flink.api.java with annotations of type Internal Modifier and Type Class Description classClosureCleanerThe closure cleaner is a utility that tries to truncate the closure (enclosing instance) of non-static inner classes (created for inline transformation functions). -
Uses of Internal in org.apache.flink.api.java.functions
Classes in org.apache.flink.api.java.functions with annotations of type Internal Modifier and Type Class Description classNullByteKeySelector<T>Used as a dummyKeySelectorto allow using keyed operators for non-keyed use cases. -
Uses of Internal in org.apache.flink.api.java.hadoop.common
Classes in org.apache.flink.api.java.hadoop.common with annotations of type Internal Modifier and Type Class Description classHadoopInputFormatCommonBase<T,SPITTYPE extends InputSplit>A common base for both "mapred" and "mapreduce" Hadoop input formats.classHadoopOutputFormatCommonBase<T>A common base for both "mapred" and "mapreduce" Hadoop output formats. -
Uses of Internal in org.apache.flink.api.java.hadoop.mapred
Classes in org.apache.flink.api.java.hadoop.mapred with annotations of type Internal Modifier and Type Class Description classHadoopInputFormatBase<K,V,T>Common base for Java and Scala API for using Hadoop input formats with Flink.classHadoopOutputFormatBase<K,V,T>Common base for the mapred HadoopOutputFormat wrappers. -
Uses of Internal in org.apache.flink.api.java.hadoop.mapred.utils
Classes in org.apache.flink.api.java.hadoop.mapred.utils with annotations of type Internal Modifier and Type Class Description classHadoopUtilsUtility class to work with Apache Hadoop MapRed classes. -
Uses of Internal in org.apache.flink.api.java.hadoop.mapred.wrapper
Classes in org.apache.flink.api.java.hadoop.mapred.wrapper with annotations of type Internal Modifier and Type Class Description classHadoopInputSplitA wrapper that represents an input split from the Hadoop mapred API as a FlinkInputSplit. -
Uses of Internal in org.apache.flink.api.java.hadoop.mapreduce
Classes in org.apache.flink.api.java.hadoop.mapreduce with annotations of type Internal Modifier and Type Class Description classHadoopInputFormatBase<K,V,T>Base class shared between the Java and Scala API of Flink.classHadoopOutputFormatBase<K,V,T>Base class shared between the Java and Scala API of Flink. -
Uses of Internal in org.apache.flink.api.java.hadoop.mapreduce.utils
Classes in org.apache.flink.api.java.hadoop.mapreduce.utils with annotations of type Internal Modifier and Type Class Description classHadoopUtilsUtility class to work with next generation of Apache Hadoop MapReduce classes. -
Uses of Internal in org.apache.flink.api.java.hadoop.mapreduce.wrapper
Classes in org.apache.flink.api.java.hadoop.mapreduce.wrapper with annotations of type Internal Modifier and Type Class Description classHadoopInputSplitA wrapper that represents an input split from the Hadoop mapreduce API as a FlinkInputSplit. -
Uses of Internal in org.apache.flink.api.java.typeutils
Classes in org.apache.flink.api.java.typeutils with annotations of type Internal Modifier and Type Class Description classPojoFieldRepresent a field definition forPojoTypeInfotype of objects.classTypeExtractionExceptionType extraction always contains some uncertainty due to unpredictable JVM differences between vendors or versions.classTypeExtractionUtilsMethods in org.apache.flink.api.java.typeutils with annotations of type Internal Modifier and Type Method Description static <OUT> TypeInfoFactory<OUT>TypeExtractor. getTypeInfoFactory(Field field)Returns the type information factory for an annotated field.static <OUT> TypeInfoFactory<OUT>TypeExtractor. getTypeInfoFactory(Type t)Returns the type information factory for a type using the factory registry or annotations.static voidTypeExtractor. registerFactory(Type t, Class<? extends TypeInfoFactory<?>> factory)Registers a type information factory globally for a certain type. -
Uses of Internal in org.apache.flink.api.java.typeutils.runtime
Classes in org.apache.flink.api.java.typeutils.runtime with annotations of type Internal Modifier and Type Class Description classCopyableValueComparator<T extends CopyableValue<T> & Comparable<T>>Comparator for all Value types that extend KeyclassCopyableValueSerializer<T extends CopyableValue<T>>classDataInputViewStreamAn input stream that draws its data from aDataInputView.classDataOutputViewStreamclassEitherSerializer<L,R>ATypeSerializerfor theEithertype of the Java class.classFieldSerializerThis class is for the serialization of java.lang.reflect.Field, which doesn't implement Serializable, therefore readObject/writeObject need to be implemented in classes where there is a field of type java.lang.reflect.Field.classGenericTypeComparator<T extends Comparable<T>>TypeComparator for all types that extend Comparable.classKryoRegistrationAKryoRegistrationresembles a registered class and its serializer in Kryo.classKryoUtilsConvenience methods for KryoclassMaskUtilsUtilities for reading and writing binary masks.classNoFetchingInputclassNullAwareComparator<T>Null-aware comparator that wraps a comparator which does not support null references.classPojoComparator<T>classPojoSerializer<T>classPojoSerializerSnapshot<T>Snapshot class for thePojoSerializer.classRowComparatorComparator forRow.classRowSerializerSerializer forRow.classRuntimeComparatorFactory<T>classRuntimePairComparatorFactory<T1,T2>classRuntimeSerializerFactory<T>classTuple0SerializerclassTupleComparator<T extends Tuple>classTupleComparatorBase<T>classTupleSerializer<T extends Tuple>classTupleSerializerBase<T>classTupleSerializerSnapshot<T extends Tuple>Snapshot of a tuple serializer's configuration.classValueComparator<T extends Value & Comparable<T>>Comparator for all Value types that extend KeyclassValueSerializer<T extends Value>Serializer forValuetypes.classWritableComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>ATypeComparatorforWritable.classWritableSerializer<T extends org.apache.hadoop.io.Writable>ATypeSerializerforWritable.static classWritableSerializer.WritableSerializerSnapshot<T extends org.apache.hadoop.io.Writable>WritableSerializersnapshot class. -
Uses of Internal in org.apache.flink.api.java.typeutils.runtime.kryo
Classes in org.apache.flink.api.java.typeutils.runtime.kryo with annotations of type Internal Modifier and Type Class Description classSerializersClass containing utilities for the serializers of the Flink Runtime. -
Uses of Internal in org.apache.flink.cep.functions.adaptors
Classes in org.apache.flink.cep.functions.adaptors with annotations of type Internal Modifier and Type Class Description classPatternFlatSelectAdapter<IN,OUT>Adapter that expressesPatternFlatSelectFunctionwithPatternProcessFunction.classPatternSelectAdapter<IN,OUT>Adapter that expressesPatternSelectFunctionwithPatternProcessFunction.classPatternTimeoutFlatSelectAdapter<IN,OUT,T>Adapter that expresses combination ofPatternFlatSelectFunctionandPatternTimeoutFlatSelectAdapterwithPatternProcessFunction.classPatternTimeoutSelectAdapter<IN,OUT,T>Adapter that expresses combination ofPatternSelectFunctionandPatternTimeoutFlatSelectAdapterwithPatternProcessFunction. -
Uses of Internal in org.apache.flink.cep.nfa.sharedbuffer
Classes in org.apache.flink.cep.nfa.sharedbuffer with annotations of type Internal Modifier and Type Class Description classLockableTypeSerializerSnapshot<E> -
Uses of Internal in org.apache.flink.cep.operator
Classes in org.apache.flink.cep.operator with annotations of type Internal Modifier and Type Class Description classCepOperator<IN,KEY,OUT>CEP pattern operator for a keyed input stream. -
Uses of Internal in org.apache.flink.cep.pattern.conditions
Classes in org.apache.flink.cep.pattern.conditions with annotations of type Internal Modifier and Type Class Description classBooleanConditionsUtility class containing anIterativeConditionthat always returnstrueand one that always returnsfalse.classRichAndCondition<T>classRichNotCondition<T>Aconditionwhich negates the condition it wraps and returnstrueif the original condition returnsfalse.classRichOrCondition<T>Aconditionwhich combines two conditions with a logicalORand returnstrueif at least one istrue.classSubtypeCondition<T>Aconditionwhich filters elements of the given type. -
Uses of Internal in org.apache.flink.cep.time
Classes in org.apache.flink.cep.time with annotations of type Internal Modifier and Type Interface Description interfaceTimerServiceEnables to provide time characteristic toNFAfor use inIterativeCondition. -
Uses of Internal in org.apache.flink.changelog.fs
Classes in org.apache.flink.changelog.fs with annotations of type Internal Modifier and Type Class Description classFsStateChangelogStorageFactoryFsStateChangelogStoragefactory.interfaceRetryPolicyRetry policy to use byRetryingExecutor.classStateChangeFormatSerialization format for state changes.classStateChangeSetA set of changes made to some state(s) by a single state backend during a single checkpoint.interfaceStateChangeUploaderThe purpose of this interface is to abstract the different implementations of uploading state changelog parts.interfaceStateChangeUploadSchedulerSchedulesupload taskson aStateChangeUploader.interfaceTaskChangelogRegistryTM-side registry ofStateObjects, each representing one or more changelog segments.classUploadResultResult of uploading state changes. -
Uses of Internal in org.apache.flink.client.cli
Classes in org.apache.flink.client.cli with annotations of type Internal Modifier and Type Interface Description interfaceApplicationDeployerAn interface to be used by theCliFrontendto submit user programs for execution.classExecutionConfigAccessorAccessor that exposes config settings that are relevant for execution from an underlyingConfiguration.classGenericCLIA generic implementation of theCustomCommandLinethat only expects the execution.target parameter to be explicitly specified and simply forwards the rest of the options specified with -D to the correspondingPipelineExecutorfor further parsing. -
Uses of Internal in org.apache.flink.client.deployment
Classes in org.apache.flink.client.deployment with annotations of type Internal Modifier and Type Class Description classAbstractContainerizedClusterClientFactory<ClusterID>An abstractClusterClientFactorycontaining some common implementations for different containerized deployment clusters.interfaceClusterClientFactory<ClusterID>A factory containing all the necessary information for creating clients to Flink clusters.classDefaultClusterClientServiceLoaderA service provider forcluster client factories.classStandaloneClientFactoryAClusterClientFactoryfor a standalone cluster, i.e. -
Uses of Internal in org.apache.flink.client.deployment.application
Classes in org.apache.flink.client.deployment.application with annotations of type Internal Modifier and Type Class Description classApplicationConfigurationApplication-specific configurations.classApplicationDispatcherBootstrapADispatcherBootstrapused for running the user'smain()in "Application Mode" (see FLIP-85).classApplicationDispatcherGatewayServiceFactoryADispatcherGatewayServiceFactoryused when executing a job in Application Mode, i.e. the user's main is executed on the same machine as theDispatcherand the lifecycle of the cluster is the same as the one of the application.classApplicationDispatcherLeaderProcessFactoryFactoryFactory for aDispatcherLeaderProcessFactoryFactorydesigned to be used when executing an application in Application Mode.interfaceApplicationRunnerAn interface to be implemented by the entities responsible for application submission for the different deployment environments.classDetachedApplicationRunnerAnApplicationRunnerwhich runs the user specified application using theEmbeddedExecutor.classEmbeddedJobClientAJobClientwith the ability to also submit jobs which uses directly theDispatcherGateway.classUnsuccessfulExecutionExceptionException that signals the failure of an application with a givenApplicationStatus. -
Uses of Internal in org.apache.flink.client.deployment.application.cli
Classes in org.apache.flink.client.deployment.application.cli with annotations of type Internal Modifier and Type Class Description classApplicationClusterDeployerAn entity responsible for submitting an application for execution in "Application Mode", i.e. on a dedicated cluster that is created on application submission and torn down upon application termination, and with itsmain()executed on the cluster, rather than the client. -
Uses of Internal in org.apache.flink.client.deployment.application.executors
Classes in org.apache.flink.client.deployment.application.executors with annotations of type Internal Modifier and Type Class Description classEmbeddedExecutorA base class forexecutorsthat invoke directly methods of theDispatcherand do not go through the REST API.classEmbeddedExecutorFactoryAnPipelineExecutorFactoryfor theEmbeddedExecutor.classEmbeddedExecutorServiceLoaderAPipelineExecutorServiceLoaderthat always returns anEmbeddedExecutorFactory.interfaceEmbeddedJobClientCreatorAn interface to be implemented byJobClientsuppliers.classWebSubmissionExecutorFactoryclassWebSubmissionExecutorServiceLoaderAPipelineExecutorServiceLoaderthat always returns anWebSubmissionExecutorFactory. -
Uses of Internal in org.apache.flink.client.deployment.executors
Classes in org.apache.flink.client.deployment.executors with annotations of type Internal Modifier and Type Class Description classAbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>Deprecated.classAbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>An abstractPipelineExecutorused to executepipelineson an existing (session) cluster.classLocalExecutorAnPipelineExecutorfor executing aPipelinelocally.classLocalExecutorFactoryclassRemoteExecutorThePipelineExecutorto be used when executing a job on an already running cluster.classRemoteExecutorFactory -
Uses of Internal in org.apache.flink.client.program
Classes in org.apache.flink.client.program with annotations of type Internal Modifier and Type Interface Description interfaceClusterClientProvider<T>Factory forClusterClients.classMutatedConfigurationExceptionIfDeploymentOptions.PROGRAM_CONFIG_ENABLEDis disabled, configurations in the user jar will throw this exception.interfacePackagedProgramRetrieverInterface which allows to retrieve thePackagedProgram.Constructors in org.apache.flink.client.program with annotations of type Internal Constructor Description StreamContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader, Configuration clusterConfiguration, Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout, boolean programConfigEnabled, Collection<String> programConfigWildcards) -
Uses of Internal in org.apache.flink.configuration
Classes in org.apache.flink.configuration with annotations of type Internal Modifier and Type Class Description classConfigUtilsGeneral utilities for parsing values to configuration options.classDeploymentOptionsInternalInternal options used during deployment.classGlobalConfigurationGlobal configuration object for Flink.classPipelineOptionsInternalPipeline options that are not meant to be used by the user.static classRestartStrategyOptions.RestartStrategyTypeThe restart strategy type.classTaskManagerOptionsInternalTaskManager options that are not meant to be used by the user.Fields in org.apache.flink.configuration with annotations of type Internal Modifier and Type Field Description static ConfigOption<Boolean>StateRecoveryOptions. APPROXIMATE_LOCAL_RECOVERYAccess to this option is officially only supported viaorg.apache.flink.runtime.jobgraph.CheckpointConfig#enableApproximateLocalRecovery(boolean), but there is no good reason behind this.static ConfigOption<Boolean>RpcOptions. FORCE_RPC_INVOCATION_SERIALIZATIONstatic String[]CoreOptions. PARENT_FIRST_LOGGING_PATTERNSstatic StringRestartStrategyOptions. RESTART_STRATEGY_CONFIG_PREFIXMethods in org.apache.flink.configuration with annotations of type Internal Modifier and Type Method Description byte[]Configuration. getBytes(String key, byte[] defaultValue)Returns the value associated with the given key as a byte array.InlineElementExternalizedCheckpointRetention. getDescription()InlineElementJobManagerOptions.SchedulerType. getDescription()static String[]CoreOptions. mergeListsToArray(List<String> base, List<String> append)voidConfiguration. setBytes(String key, byte[] bytes)Adds the given byte array to the configuration object.Map<String,String>Configuration. toFileWritableMap()Convert Config into aMap<String, String>representation.Map<String,String>ReadableConfig. toMap()Converts the configuration items into a map of string key-value pairs. -
Uses of Internal in org.apache.flink.connector.base.sink.throwable
Classes in org.apache.flink.connector.base.sink.throwable with annotations of type Internal Modifier and Type Class Description classFatalExceptionClassifierClassifier class for retryable exceptions on request submission failure. -
Uses of Internal in org.apache.flink.connector.base.sink.writer
Classes in org.apache.flink.connector.base.sink.writer with annotations of type Internal Modifier and Type Class Description classAsyncSinkFatalExceptionClassifiersCommon retry exception classifiers needed for common errors. -
Uses of Internal in org.apache.flink.connector.base.sink.writer.strategy
Classes in org.apache.flink.connector.base.sink.writer.strategy with annotations of type Internal Modifier and Type Class Description classBasicRequestInfoDataclass to encapsulate information about starting requests.classBasicResultInfoDataclass to encapsulate results from completed requests. -
Uses of Internal in org.apache.flink.connector.base.source.hybrid
Methods in org.apache.flink.connector.base.source.hybrid with annotations of type Internal Modifier and Type Method Description SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>HybridSource. createEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext)SourceReader<T,HybridSourceSplit>HybridSource. createReader(SourceReaderContext readerContext)SimpleVersionedSerializer<HybridSourceEnumeratorState>HybridSource. getEnumeratorCheckpointSerializer()SimpleVersionedSerializer<HybridSourceSplit>HybridSource. getSplitSerializer()SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>HybridSource. restoreEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint) -
Uses of Internal in org.apache.flink.connector.base.source.reader.fetcher
Classes in org.apache.flink.connector.base.source.reader.fetcher with annotations of type Internal Modifier and Type Class Description classRemoveSplitsTask<SplitT extends SourceSplit>The task to finish reading some splits.Methods in org.apache.flink.connector.base.source.reader.fetcher with annotations of type Internal Modifier and Type Method Description FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>SplitFetcherManager. getQueue()Return the queue contains data produced by split fetchers.This method is Internal and only used inSourceReaderBase. -
Uses of Internal in org.apache.flink.connector.base.source.reader.splitreader
Classes in org.apache.flink.connector.base.source.reader.splitreader with annotations of type Internal Modifier and Type Class Description classSplitsRemoval<SplitT>A change to remove splits. -
Uses of Internal in org.apache.flink.connector.base.source.reader.synchronization
Classes in org.apache.flink.connector.base.source.reader.synchronization with annotations of type Internal Modifier and Type Class Description classFutureCompletingBlockingQueue<T>A custom implementation of blocking queue in combination with aCompletableFuturethat is used in the hand-over of data from a producing thread to a consuming thread. -
Uses of Internal in org.apache.flink.connector.base.source.utils
Classes in org.apache.flink.connector.base.source.utils with annotations of type Internal Modifier and Type Class Description classSerdeUtilsA util class with some helper method for serde in the sources. -
Uses of Internal in org.apache.flink.connector.base.table
Classes in org.apache.flink.connector.base.table with annotations of type Internal Modifier and Type Class Description classAsyncDynamicTableSinkFactory.AsyncDynamicSinkContextClass providing common table data required byAsyncDynamicTableSinkFactoryto createAsyncDynamicTableSink. -
Uses of Internal in org.apache.flink.connector.blackhole.table
Classes in org.apache.flink.connector.blackhole.table with annotations of type Internal Modifier and Type Class Description classBlackHoleTableSinkFactoryBlack hole table sink factory swallowing all input records. -
Uses of Internal in org.apache.flink.connector.datagen.functions
Classes in org.apache.flink.connector.datagen.functions with annotations of type Internal Modifier and Type Class Description classFromElementsGeneratorFunction<OUT>A stream generator function that returns a sequence of elements.classIndexLookupGeneratorFunction<OUT>A stream generator function that returns elements from the collection based on their index. -
Uses of Internal in org.apache.flink.connector.datagen.table
Classes in org.apache.flink.connector.datagen.table with annotations of type Internal Modifier and Type Class Description classDataGenConnectorOptionsUtilUtilities forDataGenConnectorOptions.classDataGeneratorContainerContainer class for wrapping awith its configuration options.classDataGenTableSourceAStreamTableSourcethat emits generated data rows.classDataGenTableSourceFactoryFactory for creating configured instances ofDataGenTableSourcein a stream environment.classDataGenVisitorBaseBase class for translatingLogicalTypestoDataGeneratorContainer's.classRandomGeneratorVisitorCreates a randomDataGeneratorContainerfor a particular logical type.classSequenceGeneratorVisitorCreates a sequentialDataGeneratorContainerfor a particular logical type. -
Uses of Internal in org.apache.flink.connector.datagen.table.types
Classes in org.apache.flink.connector.datagen.table.types with annotations of type Internal Modifier and Type Class Description classDataGeneratorMapper<A,B>Utility for mapping the output of aDataGenerator.classDecimalDataRandomGeneratorGenerates randomDecimalDatavalues.classRowDataGeneratorData generator for Flink's internalRowDatatype. -
Uses of Internal in org.apache.flink.connector.file.sink
Classes in org.apache.flink.connector.file.sink with annotations of type Internal Modifier and Type Class Description classFileSinkCommittableWrapper class for both type of committables inFileSink.classFileSinkCommittableSerializerVersioned serializer forFileSinkCommittable. -
Uses of Internal in org.apache.flink.connector.file.sink.committer
Classes in org.apache.flink.connector.file.sink.committer with annotations of type Internal Modifier and Type Class Description classFileCommitterCommitter implementation forFileSink. -
Uses of Internal in org.apache.flink.connector.file.sink.compactor
Classes in org.apache.flink.connector.file.sink.compactor with annotations of type Internal Modifier and Type Class Description classIdenticalFileCompactorA simpleOutputStreamBasedFileCompactorimplementation that directly copy the content of the only input file to the output. -
Uses of Internal in org.apache.flink.connector.file.sink.compactor.operator
Classes in org.apache.flink.connector.file.sink.compactor.operator with annotations of type Internal Modifier and Type Class Description classCompactCoordinatorCoordinator that coordinates file compaction for theFileSink.classCompactCoordinatorFactoryFactory forCompactCoordinator.classCompactCoordinatorStateHandlerFactoryFactory forCompactCoordinatorStateHandler.classCompactorOperatorAn operator that perform compaction for theFileSink.classCompactorOperatorFactoryFactory forCompactorOperator.classCompactorOperatorStateHandlerHandler that processes the state ofCompactorOperatorwhen compaction is disabled.classCompactorOperatorStateHandlerFactoryFactory forCompactorOperatorStateHandler.classCompactorRequestRequest of file compacting forFileSink.classCompactorRequestSerializerVersioned serializer forCompactorRequest.classCompactorRequestTypeInfoType information ofCompactorRequest.classCompactServiceThe asynchronous file compaction service. -
Uses of Internal in org.apache.flink.connector.file.sink.writer
Classes in org.apache.flink.connector.file.sink.writer with annotations of type Internal Modifier and Type Class Description classDefaultFileWriterBucketFactory<IN>A factory returningwriter.classFileWriter<IN>ASinkWriterimplementation forFileSink.interfaceFileWriterBucketFactory<IN>A factory able to createFileWriterBucketfor theFileSink.classFileWriterBucketStateStates forFileWriterBucket.classFileWriterBucketStateSerializerASimpleVersionedSerializerused to serialize theBucketState. -
Uses of Internal in org.apache.flink.connector.file.src
Classes in org.apache.flink.connector.file.src with annotations of type Internal Modifier and Type Class Description classContinuousEnumerationSettingsSettings describing how to do continuous file discovery and enumeration for the file source's continuous discovery and streaming mode. -
Uses of Internal in org.apache.flink.connector.file.src.enumerate
Classes in org.apache.flink.connector.file.src.enumerate with annotations of type Internal Modifier and Type Class Description classBlockSplittingRecursiveAllDirEnumeratorThisFileEnumeratorenumerates all files under the given paths recursively except the hidden directories, and creates a separate split for each file block.classNonSplittingRecursiveAllDirEnumeratorThisFileEnumeratorenumerates all files under the given paths recursively except the hidden directories. -
Uses of Internal in org.apache.flink.connector.file.src.impl
Classes in org.apache.flink.connector.file.src.impl with annotations of type Internal Modifier and Type Class Description classContinuousFileSplitEnumeratorA continuously monitoring enumerator.classDynamicFileSplitEnumerator<SplitT extends FileSourceSplit>A SplitEnumerator implementation that supports dynamic filtering.classFileRecords<T>A collection of records for one file split.classFileSourceReader<T,SplitT extends FileSourceSplit>ASourceReaderthat read records fromFileSourceSplit.classStaticFileSplitEnumeratorA SplitEnumerator implementation for bounded / batchFileSourceinput.classStreamFormatAdapter<T>Adapter to turn aStreamFormatinto aBulkFormat. -
Uses of Internal in org.apache.flink.connector.file.src.util
Classes in org.apache.flink.connector.file.src.util with annotations of type Internal Modifier and Type Class Description classRecyclableIterator<E>Utility base class for iterators that accept a recycler. -
Uses of Internal in org.apache.flink.connector.file.table
Classes in org.apache.flink.connector.file.table with annotations of type Internal Modifier and Type Class Description classBinPackingA bin packing implementation.classColumnarRowIteratorABulkFormat.RecordIteratorthat returnsRowDatas.interfaceContinuousPartitionFetcher<P,T extends Comparable<T>>Partition fetcher for helping continuously fetch partitioned table.classDefaultPartTimeExtractorDefaultPartitionTimeExtractor.classDeserializationSchemaAdapterAdapter to turn aDeserializationSchemainto aBulkFormat.classDynamicPartitionWriter<T>Dynamic partition writer to writing multiple partitions at the same time, it maybe consumes more memory.classEmptyMetaStoreFactoryEmpty implementationTableMetaStoreFactory.classEnrichedRowDataclassFileSystemCommitterFile system file committer implementation.interfaceFileSystemFactoryA factory to create file systems.classFileSystemOutputFormat<T>File systemOutputFormatfor batch job.classFileSystemTableFactoryFile systemTableFactory.classFileSystemTableSinkFile systemDynamicTableSink.classFileSystemTableSourceFile system table source.classGroupedPartitionWriter<T>PartitionWriterfor grouped dynamic partition inserting.classLimitableBulkFormat<T,SplitT extends FileSourceSplit>ABulkFormatthat can limit output record number.classMetastoreCommitPolicyPartition commit policy to update metastore.interfaceOutputFormatFactory<T>A factory to create anOutputFormat.classPartitionCommitPolicyFactoryA factory to createPartitionCommitPolicychain.interfacePartitionComputer<T>Compute partition path from record and project non-partition columns for output writer.interfacePartitionFetcher<P>Fetcher to fetch the suitable partitions of a filesystem table.interfacePartitionFieldExtractor<T extends FileSourceSplit>Interface to extract partition field from split.classPartitionLoaderLoader to temporary files to final output path and meta store.interfacePartitionReader<P,OUT>Reader that reads record from given partitions.classPartitionTempFileManagerManage temporary files for writing files.interfacePartitionWriter<T>Partition writer to write records with partition.interfacePartitionWriterFactory<T>Factory ofPartitionWriterto avoid virtual function calls.classRowDataPartitionComputerPartitionComputerforRowData.classRowPartitionComputerPartitionComputerforRow.classSerializationSchemaAdapterAdapter to turn aSerializationSchemainto aEncoder.classSingleDirectoryWriter<T>PartitionWriterfor single directory writer.classSuccessFileCommitPolicyPartition commit policy to add success file to directory.interfaceTableMetaStoreFactoryMeta store factory to createTableMetaStoreFactory.TableMetaStore. -
Uses of Internal in org.apache.flink.connector.file.table.batch
Classes in org.apache.flink.connector.file.table.batch with annotations of type Internal Modifier and Type Class Description classBatchSinkHelper for creating batch file sink. -
Uses of Internal in org.apache.flink.connector.file.table.factories
Classes in org.apache.flink.connector.file.table.factories with annotations of type Internal Modifier and Type Interface Description interfaceBulkReaderFormatFactoryBase interface for configuring aBulkFormatfor file system connector.interfaceBulkWriterFormatFactoryBase interface for configuring aBulkWriter.Factoryfor file system connector. -
Uses of Internal in org.apache.flink.connector.file.table.format
Classes in org.apache.flink.connector.file.table.format with annotations of type Internal Modifier and Type Interface Description interfaceBulkDecodingFormat<T> -
Uses of Internal in org.apache.flink.connector.file.table.stream
Classes in org.apache.flink.connector.file.table.stream with annotations of type Internal Modifier and Type Class Description classPartitionCommitInfoThe message sent by upstream.interfacePartitionCommitPredicatePartition commit predicate.classPartitionCommitterCommitter operator for partitions.interfacePartitionCommitTriggerPartition commit trigger.classPartitionTimeCommitPredicatePartition commit predicate by partition time and watermark, if 'watermark' > 'partition-time' + 'delay', the partition is committable.classPartitionTimeCommitTriggerPartition commit trigger by partition time and watermark.classProcTimeCommitPredicatePartition commit trigger by creation time and processing time service, if 'current processing time' > 'partition creation time' + 'delay', the partition is committable.classProcTimeCommitTriggerPartition commit trigger by creation time and processing time service.classStreamingFileWriter<IN>Writer for emittingPartitionCommitInfoto downstream.classStreamingSinkHelper for creating streaming file sink.classTaskTrackerTrack the upstream tasks to determine whether all the upstream data of a checkpoint has been received. -
Uses of Internal in org.apache.flink.connector.file.table.stream.compact
Classes in org.apache.flink.connector.file.table.stream.compact with annotations of type Internal Modifier and Type Class Description classCompactBucketWriter<T>TheCompactWriterto delegateBucketWriter.classCompactBulkReader<T>TheCompactReaderto delegateCompactBulkReader.interfaceCompactContextContext forCompactReaderandCompactWriter.classCompactCoordinatorThis is the single (non-parallel) monitoring task which coordinate input files to compaction units. - Receives in-flight input files inside checkpoint. - Receives all upstream end input messages after the checkpoint completes successfully, starts coordination.classCompactFileWriter<T>Writer for emittingCompactMessages.InputFileandCompactMessages.EndCheckpointto downstream.classCompactMessagesUtil class for all compaction messages.classCompactOperator<T>Receives compaction units to do compaction.interfaceCompactReader<T>Reader for compaction.interfaceCompactWriter<T>Writer for compaction.classFileInputFormatCompactReader<T>TheCompactReaderto delegateFileInputFormat. -
Uses of Internal in org.apache.flink.connector.print.table
Classes in org.apache.flink.connector.print.table with annotations of type Internal Modifier and Type Class Description classPrintTableSinkFactoryPrint table sink factory writing every row to the standard output or standard error stream. -
Uses of Internal in org.apache.flink.connector.testframe.junit.extensions
Classes in org.apache.flink.connector.testframe.junit.extensions with annotations of type Internal Modifier and Type Class Description classConnectorTestingExtensionA JUnit 5Extensionfor supporting running of connector testing framework.classTestCaseInvocationContextProviderA helper class for injecting test resources into test case as parameters. -
Uses of Internal in org.apache.flink.connector.upserttest.sink
Classes in org.apache.flink.connector.upserttest.sink with annotations of type Internal Modifier and Type Class Description classUpsertTestFileUtilCollection uf utility methods for reading and writing files from theUpsertTestSink.Methods in org.apache.flink.connector.upserttest.sink with annotations of type Internal Modifier and Type Method Description SinkWriter<IN>UpsertTestSink. createWriter(WriterInitContext context) -
Uses of Internal in org.apache.flink.connector.upserttest.table
Classes in org.apache.flink.connector.upserttest.table with annotations of type Internal Modifier and Type Class Description classUpsertTestDynamicTableSinkFactoryADynamicTableSinkFactoryfor discoveringUpsertTestDynamicTableSink. -
Uses of Internal in org.apache.flink.container.entrypoint
Classes in org.apache.flink.container.entrypoint with annotations of type Internal Modifier and Type Class Description classStandaloneApplicationClusterEntryPointAnApplicationClusterEntryPointwhich is started with a job in a predefined location. -
Uses of Internal in org.apache.flink.core.execution
Classes in org.apache.flink.core.execution with annotations of type Internal Modifier and Type Interface Description interfaceCacheSupportedPipelineExecutorThe pipeline executor that support caching intermediate dataset.classDefaultExecutorServiceLoaderThe default implementation of thePipelineExecutorServiceLoader.classDefaultJobExecutionStatusEventDefault implementation forJobExecutionStatusEvent.classDetachedJobExecutionResultTheJobExecutionResultreturned by a context environment when executing a job in detached mode.classJobStatusChangedListenerUtilsUtil class forJobStatusChangedListener.interfaceJobStatusHookHooks on job status changing.interfacePipelineExecutorThe entity responsible for executing aPipeline, i.e. a user job.interfacePipelineExecutorFactoryA factory for selecting and instantiating the adequatePipelineExecutorbased on a providedConfiguration.interfacePipelineExecutorServiceLoaderAn interface to be implemented by the entity responsible for finding the correctPipelineExecutorto execute a givenPipeline.Methods in org.apache.flink.core.execution with annotations of type Internal Modifier and Type Method Description InlineElementRecoveryClaimMode. getDescription()InlineElementSavepointFormatType. getDescription() -
Uses of Internal in org.apache.flink.core.fs
Classes in org.apache.flink.core.fs with annotations of type Internal Modifier and Type Class Description classAutoCloseableRegistryThis class allows to register instances ofAutoCloseable, which are all closed if this registry is closed.classBackPressuringExecutorAn executor decorator that allows only a certain number of concurrent executions.classByteBufferReadableClosingFSDataInputStreamAClosingFSDataInputStreamwhich isByteBufferReadable.classCloseableRegistryICloseableRegistryimplementation.classClosingFSDataInputStreamThis class is aWrappingProxyforFSDataInputStreamthat is used to implement a safety net against unclosed streams.classClosingFSDataOutputStreamThis class is aWrappingProxyforFSDataOutputStreamthat is used to implement a safety net against unclosed streams.classConnectionLimitingFactoryA wrapping factory that adds aLimitedConnectionsFileSystemto a file system.static classFileSystem.FSKeyAn identifier of a file system, via its scheme and its authority.classFileSystemSafetyNetThe FileSystemSafetyNet can be used to guard a thread againstFileSystemstream resource leaks.classFSDataInputStreamWrapperSimple forwarding wrapper aroundFSDataInputStream.classFSDataOutputStreamWrapperSimple forwarding wrapper aroundFSDataInputStream.interfaceICloseableRegistryThis class allows to register instances ofCloseable, which are all closed if this registry is closed.classLimitedConnectionsFileSystemA file system that limits the number of concurrently open input streams, output streams, and total streams for a target file system.classOffsetAwareOutputStreamAnOutputStreamthat keeps track of its current length.classRefCountedBufferingFileStreamARefCountedFileWithStreamthat also uses an in-memory buffer for buffering small writes.classRefCountedFileA reference counted file which is deleted as soon as no caller holds a reference to the wrappedFile.classRefCountedFileWithStreamA reference counted file which is deleted as soon as no caller holds a reference to the wrappedFile.classRefCountedFSOutputStreamAFSDataOutputStreamwith theRefCountedfunctionality.classRefCountedTmpFileCreatorA utility class that creates localreference counted filesthat serve as temporary files.classSafetyNetCloseableRegistryThis implementation of anAbstractAutoCloseableRegistryregistersWrappingProxyCloseable.classSafetyNetWrapperFileSystemThis is aWrappingProxyaroundFileSystemwhich (i) wraps all opened streams asClosingFSDataInputStreamorClosingFSDataOutputStreamand (ii) registers them to aSafetyNetCloseableRegistry.interfaceWrappingProxyCloseable<T extends Closeable>WrappingProxyforCloseablethat is also closeable.Methods in org.apache.flink.core.fs with annotations of type Internal Modifier and Type Method Description static voidFileSystemSafetyNet. closeSafetyNetAndGuardedResourcesForThread()Closes the safety net for a thread.static FileSystemFileSystem. getUnguardedFileSystem(URI fsUri)static voidFileSystemSafetyNet. initializeSafetyNetForThread()Activates the safety net for a thread. -
Uses of Internal in org.apache.flink.core.fs.local
Classes in org.apache.flink.core.fs.local with annotations of type Internal Modifier and Type Class Description classLocalBlockLocationImplementation of theBlockLocationinterface for a local file system.classLocalDataInputStreamTheLocalDataInputStreamclass is a wrapper class for a data input stream to the local file system.classLocalDataOutputStreamTheLocalDataOutputStreamclass is a wrapper class for a data output stream to the local file system.classLocalFileStatusThe classLocalFileStatusprovides an implementation of theFileStatusinterface for the local file system.classLocalFileSystemThe classLocalFileSystemis an implementation of theFileSysteminterface for the local file system of the machine where the JVM runs.classLocalRecoverableFsDataOutputStreamARecoverableFsDataOutputStreamfor theLocalFileSystem.classLocalRecoverableWriterARecoverableWriterfor theLocalFileSystem. -
Uses of Internal in org.apache.flink.core.io
Classes in org.apache.flink.core.io with annotations of type Internal Modifier and Type Class Description classPostVersionedIOReadableWritableAVersionedIOReadableWritablewhich allows to differentiate whether the previous data was versioned with aVersionedIOReadableWritable.classSimpleVersionedSerializerAdapter<T>Adapter forTypeSerializertoSimpleVersionedSerializer.classSimpleVersionedSerializerTypeSerializerProxy<T>ATypeSerializerthat delegates to an underlyingSimpleVersionedSerializer.classVersionedIOReadableWritableThis is the abstract base class forIOReadableWritablewhich allows to differentiate between serialization versions. -
Uses of Internal in org.apache.flink.core.memory
Classes in org.apache.flink.core.memory with annotations of type Internal Modifier and Type Class Description classByteArrayInputStreamWithPosUn-synchronized stream similar to Java's ByteArrayInputStream that also exposes the current position.classByteArrayOutputStreamWithPosUn-synchronized stream similar to Java's ByteArrayOutputStream that also exposes the current position.classManagedMemoryUseCaseUse cases of managed memory.classMemorySegmentThis class represents a piece of memory managed by Flink.classMemorySegmentFactoryA factory for memory segments (MemorySegment).interfaceMemorySegmentSourceInterface describing entities that can provide memory segments.interfaceMemorySegmentWritableProvides the interface for write(Segment).classMemoryUtilsUtility class for memory operations. -
Uses of Internal in org.apache.flink.core.plugin
Classes in org.apache.flink.core.plugin with annotations of type Internal Modifier and Type Class Description classDefaultPluginManagerDefault implementation ofPluginManager. -
Uses of Internal in org.apache.flink.core.state
Classes in org.apache.flink.core.state with annotations of type Internal Modifier and Type Class Description classCompletedStateFuture<T>AStateFuturethat has already been completed when it is created.interfaceInternalStateFuture<T>The Internal definition ofStateFuture, add some method that will be used by framework.classStateFutureImpl<T>The default implementation ofStateFuture. -
Uses of Internal in org.apache.flink.formats.avro
Classes in org.apache.flink.formats.avro with annotations of type Internal Modifier and Type Class Description classAbstractAvroBulkFormat<A,T,SplitT extends FileSourceSplit>Provides aBulkFormatfor Avro records.classAvroFileFormatFactoryAvro format factory for file system.classAvroFormatFactoryTable format factory for providing configured instances of Avro to RowDataSerializationSchemaandDeserializationSchema.classAvroRowDeserializationSchemaDeserialization schema from Avro bytes toRow.classAvroRowSerializationSchemaSerialization schema that serializesRowinto Avro bytes.classAvroToRowDataConvertersTool class used to convert from AvroGenericRecordtoRowData.classRowDataToAvroConvertersTool class used to convert fromRowDatato AvroGenericRecord. -
Uses of Internal in org.apache.flink.formats.avro.registry.confluent
Classes in org.apache.flink.formats.avro.registry.confluent with annotations of type Internal Modifier and Type Class Description classRegistryAvroFormatFactoryTable format factory for providing configured instances of Schema Registry Avro to RowDataSerializationSchemaandDeserializationSchema. -
Uses of Internal in org.apache.flink.formats.avro.registry.confluent.debezium
Classes in org.apache.flink.formats.avro.registry.confluent.debezium with annotations of type Internal Modifier and Type Class Description classDebeziumAvroDeserializationSchemaDeserialization schema from Debezium Avro to Flink Table/SQL internal data structureRowData.classDebeziumAvroFormatFactoryFormat factory for providing configured instances of Debezium Avro to RowDataDeserializationSchema.classDebeziumAvroSerializationSchemaSerialization schema from Flink Table/SQL internal data structureRowDatato Debezium Avro. -
Uses of Internal in org.apache.flink.formats.avro.typeutils
Classes in org.apache.flink.formats.avro.typeutils with annotations of type Internal Modifier and Type Class Description classAvroFactory<T>Creates AvroDatumReaderandDatumWriter. -
Uses of Internal in org.apache.flink.formats.common
Classes in org.apache.flink.formats.common with annotations of type Internal Modifier and Type Class Description classTimeFormatsTime formats and timestamp formats respecting the RFC3339 specification, ISO-8601 specification and SQL specification.classTimestampFormatTimestamp format Enums. -
Uses of Internal in org.apache.flink.formats.csv
Classes in org.apache.flink.formats.csv with annotations of type Internal Modifier and Type Class Description classCsvFileFormatFactoryCSV format factory for file system.classCsvFormatFactoryFormat factory for providing configured instances of CSV to RowDataSerializationSchemaandDeserializationSchema.classCsvRowDataDeserializationSchemaDeserialization schema from CSV to Flink Table & SQL internal data structures.static classCsvRowDataDeserializationSchema.BuilderA builder for creating aCsvRowDataDeserializationSchema.classCsvRowDeserializationSchemaDeserialization schema from CSV to Flink types.classCsvRowSerializationSchemaSerialization schema that serializes an object of Flink types into a CSV bytes.classCsvToRowDataConvertersTool class used to convert from CSV-formatJsonNodetoRowData.classRowDataToCsvConvertersTool class used to convert fromRowDatato CSV-formatJsonNode. -
Uses of Internal in org.apache.flink.formats.hadoop.bulk
Classes in org.apache.flink.formats.hadoop.bulk with annotations of type Internal Modifier and Type Interface Description interfaceHadoopFileCommitterThe committer publishes an intermediate Hadoop file to the target path after it finishes writing.interfaceHadoopFileCommitterFactoryThe factory to create theHadoopFileCommitter.interfaceHadoopPathBasedBulkWriter<T>SpecializedBulkWriterwhich is expected to write to specifiedPath. -
Uses of Internal in org.apache.flink.formats.json
Classes in org.apache.flink.formats.json with annotations of type Internal Modifier and Type Class Description classJsonFormatFactoryTable format factory for providing configured instances of JSON to RowDataSerializationSchemaandDeserializationSchema.classJsonFormatOptionsUtilUtilities forJsonFormatOptions.classJsonParserRowDataDeserializationSchemaTool class used to convert fields fromJsonParsertoRowDatawhich has a higher parsing efficiency.classJsonParserToRowDataConvertersTool class used to convert fields fromJsonParsertoRowData.classJsonRowDataDeserializationSchemaDeserialization schema from JSON to Flink Table/SQL internal data structureRowData.classJsonRowDataSerializationSchemaSerialization schema that serializes an object of Flink internal data structure into a JSON bytes.classJsonRowDeserializationSchemaDeserialization schema from JSON to Flink types.classJsonRowSerializationSchemaSerialization schema that serializes an object of Flink types into a JSON bytes.classJsonToRowDataConvertersTool class used to convert fromJsonNodetoRowData.classRowDataToJsonConvertersTool class used to convert fromRowDatatoJsonNode. -
Uses of Internal in org.apache.flink.formats.json.canal
Classes in org.apache.flink.formats.json.canal with annotations of type Internal Modifier and Type Class Description static classCanalJsonDeserializationSchema.BuilderA builder for creating aCanalJsonDeserializationSchema.classCanalJsonFormatFactoryFormat factory for providing configured instances of Canal JSON to RowDataDeserializationSchema. -
Uses of Internal in org.apache.flink.formats.json.debezium
Classes in org.apache.flink.formats.json.debezium with annotations of type Internal Modifier and Type Class Description classDebeziumJsonDeserializationSchemaDeserialization schema from Debezium JSON to Flink Table/SQL internal data structureRowData.classDebeziumJsonFormatFactoryFormat factory for providing configured instances of Debezium JSON to RowDataDeserializationSchema. -
Uses of Internal in org.apache.flink.formats.json.maxwell
Classes in org.apache.flink.formats.json.maxwell with annotations of type Internal Modifier and Type Class Description classMaxwellJsonFormatFactoryFormat factory for providing configured instances of Maxwell JSON to RowDataDeserializationSchema. -
Uses of Internal in org.apache.flink.formats.json.ogg
Classes in org.apache.flink.formats.json.ogg with annotations of type Internal Modifier and Type Class Description classOggJsonDeserializationSchemaDeserialization schema from Ogg JSON to Flink Table/SQL internal data structureRowData.classOggJsonFormatFactoryFormat factory for providing configured instances of Ogg JSON to RowDataDeserializationSchema. -
Uses of Internal in org.apache.flink.formats.parquet.vector
Classes in org.apache.flink.formats.parquet.vector with annotations of type Internal Modifier and Type Class Description classParquetDecimalVectorParquet write decimal as int32 and int64 and binary, this class wrap the real vector to provideDecimalColumnVectorinterface. -
Uses of Internal in org.apache.flink.formats.protobuf
Classes in org.apache.flink.formats.protobuf with annotations of type Internal Modifier and Type Class Description classPbFileFormatFactoryThrow aValidationExceptionwhen using Protobuf format factory for file system. -
Uses of Internal in org.apache.flink.formats.raw
Classes in org.apache.flink.formats.raw with annotations of type Internal Modifier and Type Class Description classRawFormatDeserializationSchemaDeserialization schema from raw (byte based) value to Flink Table/SQL internal data structureRowData.classRawFormatFactoryFormat factory for raw format which allows to read and write raw (byte based) values as a single column.classRawFormatSerializationSchemaSerialization schema that serializes anRowDataobject into raw (byte based) value. -
Uses of Internal in org.apache.flink.fs.azurefs
Classes in org.apache.flink.fs.azurefs with annotations of type Internal Modifier and Type Class Description classAzureBlobFsRecoverableDataOutputStreamAn implementation of theRecoverableFsDataOutputStreamfor AzureBlob's file system abstraction. -
Uses of Internal in org.apache.flink.fs.osshadoop.writer
Classes in org.apache.flink.fs.osshadoop.writer with annotations of type Internal Modifier and Type Class Description classOSSRecoverableSerializerSerializer implementation for aOSSRecoverable. -
Uses of Internal in org.apache.flink.fs.s3.common.token
Classes in org.apache.flink.fs.s3.common.token with annotations of type Internal Modifier and Type Class Description classAbstractS3DelegationTokenProviderDelegation token provider for S3 filesystems.classAbstractS3DelegationTokenReceiverDelegation token receiver for S3 filesystems.classDynamicTemporaryAWSCredentialsProviderSupport dynamic session credentials for authenticating with AWS. -
Uses of Internal in org.apache.flink.fs.s3.common.writer
Classes in org.apache.flink.fs.s3.common.writer with annotations of type Internal Modifier and Type Interface Description interfaceS3AccessHelperAn interface that abstracts away the Multi-Part Upload (MPU) functionality offered by S3, from the specific implementation of the file system. -
Uses of Internal in org.apache.flink.fs.s3hadoop.token
Classes in org.apache.flink.fs.s3hadoop.token with annotations of type Internal Modifier and Type Class Description classS3HadoopDelegationTokenProviderDelegation token provider for S3 Hadoop filesystems.classS3HadoopDelegationTokenReceiverDelegation token receiver for S3 Hadoop filesystems. -
Uses of Internal in org.apache.flink.fs.s3presto.token
Classes in org.apache.flink.fs.s3presto.token with annotations of type Internal Modifier and Type Class Description classS3PrestoDelegationTokenProviderDelegation token provider for S3 Presto filesystems.classS3PrestoDelegationTokenReceiverDelegation token receiver for S3 Presto filesystems. -
Uses of Internal in org.apache.flink.kubernetes
Classes in org.apache.flink.kubernetes with annotations of type Internal Modifier and Type Class Description classKubernetesClusterClientFactoryAClusterClientFactoryfor a Kubernetes cluster. -
Uses of Internal in org.apache.flink.kubernetes.artifact
Classes in org.apache.flink.kubernetes.artifact with annotations of type Internal Modifier and Type Interface Description interfaceKubernetesArtifactUploaderLocal artifact uploader for Kubernetes programs. -
Uses of Internal in org.apache.flink.kubernetes.cli
Classes in org.apache.flink.kubernetes.cli with annotations of type Internal Modifier and Type Class Description classKubernetesSessionCliKubernetes customized commandline. -
Uses of Internal in org.apache.flink.kubernetes.configuration
Classes in org.apache.flink.kubernetes.configuration with annotations of type Internal Modifier and Type Class Description classKubernetesConfigOptionsInternalKubernetes configuration options that are not meant to be set by the user.classKubernetesDeploymentTargetA class containing all the supported deployment target names for Kubernetes. -
Uses of Internal in org.apache.flink.kubernetes.entrypoint
Classes in org.apache.flink.kubernetes.entrypoint with annotations of type Internal Modifier and Type Class Description classKubernetesApplicationClusterEntrypointAnApplicationClusterEntryPointfor Kubernetes. -
Uses of Internal in org.apache.flink.kubernetes.executors
Classes in org.apache.flink.kubernetes.executors with annotations of type Internal Modifier and Type Class Description classKubernetesSessionClusterExecutorThePipelineExecutorto be used when executing a job on an already running cluster.classKubernetesSessionClusterExecutorFactoryAnPipelineExecutorFactoryfor executing jobs on an existing (session) cluster. -
Uses of Internal in org.apache.flink.legacy.table.connector.source
Classes in org.apache.flink.legacy.table.connector.source with annotations of type Internal Modifier and Type Interface Description interfaceSourceFunctionProviderDeprecated.This interface is based on theSourceFunctionAPI, which is due to be removed. -
Uses of Internal in org.apache.flink.legacy.table.descriptors
Classes in org.apache.flink.legacy.table.descriptors with annotations of type Internal Modifier and Type Class Description classRowtimeValidatorDeprecated.SeeRowtimefor details.classSchemaValidatorDeprecated.SeeSchemafor details. -
Uses of Internal in org.apache.flink.legacy.table.factories
Classes in org.apache.flink.legacy.table.factories with annotations of type Internal Modifier and Type Interface Description interfaceStreamTableSinkFactory<T>Deprecated.This interface has been replaced byDynamicTableSinkFactory.interfaceStreamTableSourceFactory<T>Deprecated.This interface has been replaced byDynamicTableSourceFactory. -
Uses of Internal in org.apache.flink.legacy.table.sinks
Classes in org.apache.flink.legacy.table.sinks with annotations of type Internal Modifier and Type Interface Description interfaceAppendStreamTableSink<T>Deprecated.This interface has been replaced byDynamicTableSink.classOutputFormatTableSink<T>Deprecated.This interface has been replaced byDynamicTableSink.interfaceRetractStreamTableSink<T>Deprecated.This interface has been replaced byDynamicTableSink.interfaceStreamTableSink<T>Deprecated.This interface has been replaced byDynamicTableSink.interfaceUpsertStreamTableSink<T>Deprecated.This interface has been replaced byDynamicTableSink. -
Uses of Internal in org.apache.flink.legacy.table.sources
Classes in org.apache.flink.legacy.table.sources with annotations of type Internal Modifier and Type Class Description classInputFormatTableSource<T>Deprecated.This interface has been replaced byDynamicTableSource.interfaceStreamTableSource<T>Deprecated.This interface has been replaced byDynamicTableSource. -
Uses of Internal in org.apache.flink.metrics
Classes in org.apache.flink.metrics with annotations of type Internal Modifier and Type Class Description classMeterViewA MeterView provides an average rate of events per second over a given time period.classSimpleCounterA simple low-overheadCounterthat is not thread-safe.classThreadSafeSimpleCounterA simple low-overheadCounterthat is thread-safe. -
Uses of Internal in org.apache.flink.metrics.groups
Classes in org.apache.flink.metrics.groups with annotations of type Internal Modifier and Type Class Description classUnregisteredMetricsGroupA specialMetricGroupthat does not register any metrics at the metrics registry and any reporters. -
Uses of Internal in org.apache.flink.metrics.otel
Methods in org.apache.flink.metrics.otel with annotations of type Internal Modifier and Type Method Description static voidOpenTelemetryReporterOptions. tryConfigureEndpoint(MetricConfig metricConfig, Consumer<String> builder)static voidOpenTelemetryReporterOptions. tryConfigureTimeout(MetricConfig metricConfig, Consumer<Duration> builder) -
Uses of Internal in org.apache.flink.orc.writer
Classes in org.apache.flink.orc.writer with annotations of type Internal Modifier and Type Class Description classOrcBulkWriter<T>ABulkWriterimplementation that writes data in ORC format.classPhysicalWriterImplA slightly customised clone ofPhysicalFsWriter.classThreadLocalClassLoaderConfigurationWorkaround for https://issues.apache.org/jira/browse/ORC-653. -
Uses of Internal in org.apache.flink.python
Classes in org.apache.flink.python with annotations of type Internal Modifier and Type Class Description classPythonConfigConfigurations for the Python job which are used at run time.interfacePythonFunctionRunnerThe base interface of runner which is responsible for the execution of Python functions.Methods in org.apache.flink.python with annotations of type Internal Modifier and Type Method Description Map<String,String>PythonConfig. toMap() -
Uses of Internal in org.apache.flink.python.env
Classes in org.apache.flink.python.env with annotations of type Internal Modifier and Type Class Description classAbstractPythonEnvironmentManagerThe base class of python environment manager which is used to create the PythonEnvironment object used to execute Python functions.classPythonDependencyInfoPythonDependencyInfo contains the information of third-party dependencies.interfacePythonEnvironmentThe base interface of python environment for executing UDFs.interfacePythonEnvironmentManagerThe base interface of python environment manager which is used to create the PythonEnvironment object used to execute Python functions. -
Uses of Internal in org.apache.flink.python.env.embedded
Classes in org.apache.flink.python.env.embedded with annotations of type Internal Modifier and Type Class Description classEmbeddedPythonEnvironmentAPythonEnvironmentfor executing UDFs in embedded environment.classEmbeddedPythonEnvironmentManagerThe base class of python environment manager which is used to create the PythonEnvironment object. -
Uses of Internal in org.apache.flink.python.env.process
Classes in org.apache.flink.python.env.process with annotations of type Internal Modifier and Type Class Description classProcessPythonEnvironmentAPythonEnvironmentfor executing UDFs in Process.classProcessPythonEnvironmentManagerThe ProcessPythonEnvironmentManager is used to prepare the working dir of python UDF worker and create ProcessPythonEnvironment object of Beam Fn API. -
Uses of Internal in org.apache.flink.python.legacy
Classes in org.apache.flink.python.legacy with annotations of type Internal Modifier and Type Class Description classIdPartitionerPartitioner that partitions by id. -
Uses of Internal in org.apache.flink.python.metric.embedded
Classes in org.apache.flink.python.metric.embedded with annotations of type Internal Modifier and Type Class Description classMetricDistributionFlinkGaugefor Python Distribution.classMetricGaugeFlinkGaugefor Python Gauge. -
Uses of Internal in org.apache.flink.python.metric.process
Classes in org.apache.flink.python.metric.process with annotations of type Internal Modifier and Type Class Description classFlinkMetricContainerHelper class for forwarding Python metrics to Java accumulators and metrics. -
Uses of Internal in org.apache.flink.python.util
Classes in org.apache.flink.python.util with annotations of type Internal Modifier and Type Class Description classHashMapWrapperHelper class to create aHashMaptaking Numeric data as key or value from Python side.classProtoUtilsUtilities used to construct protobuf objects or construct objects from protobuf objects.classPythonDependencyUtilsUtility class for Python dependency management.classPythonEnvironmentManagerUtilsUtils used to prepare the python environment. -
Uses of Internal in org.apache.flink.queryablestate.client
Classes in org.apache.flink.queryablestate.client with annotations of type Internal Modifier and Type Class Description classVoidNamespaceSingleton placeholder class for state without a namespace.classVoidNamespaceSerializerSerializer forVoidNamespace.classVoidNamespaceTypeInfo -
Uses of Internal in org.apache.flink.queryablestate.client.proxy
Classes in org.apache.flink.queryablestate.client.proxy with annotations of type Internal Modifier and Type Class Description classKvStateClientProxyHandlerThis handler acts as an internal (to the Flink cluster) client that receives the requests from external clients, executes them by contacting the Job Manager (if necessary) and the Task Manager holding the requested state, and forwards the answer back to the client.classKvStateClientProxyImplThe default implementation of theKvStateClientProxy. -
Uses of Internal in org.apache.flink.queryablestate.exceptions
Classes in org.apache.flink.queryablestate.exceptions with annotations of type Internal Modifier and Type Class Description classUnknownKeyOrNamespaceExceptionThrown if the KvState does not hold any state for the given key or namespace.classUnknownKvStateIdExceptionThrown if no KvState with the given ID cannot found by the server handler.classUnknownKvStateKeyGroupLocationExceptionException thrown if there is no location information available for the given key group.classUnknownLocationExceptionException to fail Future if the Task Manager on which theClient Proxyis running on, does not know the location of a requested state. -
Uses of Internal in org.apache.flink.queryablestate.messages
Classes in org.apache.flink.queryablestate.messages with annotations of type Internal Modifier and Type Class Description classKvStateInternalRequestThe request to be forwarded by theQueryable State Client Proxyto theState Serverof the Task Manager responsible for the requested state.classKvStateRequestThe request to be sent by theQueryable State Clientto the Client Proxy requesting a given state.classKvStateResponseThe response containing the (serialized) state sent by theState Serverto theClient Proxy, and then forwarded by the proxy to the originalQueryable State Client. -
Uses of Internal in org.apache.flink.queryablestate.network
Classes in org.apache.flink.queryablestate.network with annotations of type Internal Modifier and Type Class Description classAbstractServerBase<REQ extends MessageBody,RESP extends MessageBody>The base class for every server in the queryable state module.classAbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody>The base class of every handler used by anAbstractServerBase.classBadRequestExceptionBase class for exceptions thrown during querying Flink's managed state.classChunkedByteBufAByteBufinstance to be consumed in chunks byChunkedWriteHandler, respecting the high and low watermarks.classClient<REQ extends MessageBody,RESP extends MessageBody>The base class for every client in the queryable state module.classClientHandler<REQ extends MessageBody,RESP extends MessageBody>The handler used by aClientto handling incoming messages.interfaceClientHandlerCallback<RESP extends MessageBody>Callback forClientHandler. -
Uses of Internal in org.apache.flink.queryablestate.network.messages
Classes in org.apache.flink.queryablestate.network.messages with annotations of type Internal Modifier and Type Class Description classMessageBodyinterfaceMessageDeserializer<M extends MessageBody>A utility used to deserialize amessage.classMessageSerializer<REQ extends MessageBody,RESP extends MessageBody>classMessageTypeclassRequestFailureA message indicating a protocol-related error. -
Uses of Internal in org.apache.flink.queryablestate.server
Classes in org.apache.flink.queryablestate.server with annotations of type Internal Modifier and Type Class Description classKvStateServerHandlerThis handler dispatches asynchronous tasks, which queryInternalKvStateinstances and write the result to the channel.classKvStateServerImplThe default implementation of theKvStateServer. -
Uses of Internal in org.apache.flink.runtime.asyncprocessing
Classes in org.apache.flink.runtime.asyncprocessing with annotations of type Internal Modifier and Type Class Description classReferenceCounted<ReleaseHelper>An object that can be reference counted, the internal resource would be released when the reference count reaches zero.interfaceStateExecutorExecutor for executing batchStateRequests.interfaceStateRequestHandlerThe handler which can processStateRequest. -
Uses of Internal in org.apache.flink.runtime.asyncprocessing.operators
Classes in org.apache.flink.runtime.asyncprocessing.operators with annotations of type Internal Modifier and Type Class Description classAbstractAsyncStateStreamOperator<OUT>This operator is an abstract class that give theAbstractStreamOperatorthe ability to performAsyncStateProcessing.classAbstractAsyncStateStreamOperatorV2<OUT>This operator is an abstract class that give theAbstractStreamOperatorV2the ability to performAsyncStateProcessing.classAbstractAsyncStateUdfStreamOperator<OUT,F extends Function>This is used as the base class for operators that have a user-defined function. -
Uses of Internal in org.apache.flink.runtime.checkpoint
Classes in org.apache.flink.runtime.checkpoint with annotations of type Internal Modifier and Type Class Description classCheckpointRetentionPolicyPolicy for whether checkpoints are retained after a job terminates.classCheckpointTypeThe type of checkpoint to perform.classCompletedCheckpointStatsSummarySnapshotImmutable snapshot ofCompletedCheckpointStatsSummary.interfaceOperatorStateRepartitioner<T>Interface that allows to implement different strategies for repartitioning of operator state as parallelism changes.static interfacePerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper<StoreType extends CompletedCheckpointStore>Restores or creates aCompletedCheckpointStore, optionally using an existing one.classPrioritizedOperatorSubtaskStateThis class is a wrapper over multiple alternativeOperatorSubtaskStatethat are (partial) substitutes for each other and imposes a priority ordering over all alternatives for the different states which define an order in which the operator should attempt to restore the state from them.static classPrioritizedOperatorSubtaskState.BuilderA builder for PrioritizedOperatorSubtaskState.classRoundRobinOperatorStateRepartitionerCurrent default implementation ofOperatorStateRepartitionerthat redistributes state in round robin fashion.classStateAssignmentOperationThis class encapsulates the operation of assigning restored state when restoring from a checkpoint.classStatsSummarySnapshotImmutable snapshot ofStatsSummary. -
Uses of Internal in org.apache.flink.runtime.checkpoint.channel
Classes in org.apache.flink.runtime.checkpoint.channel with annotations of type Internal Modifier and Type Interface Description interfaceChannelStateWriterWrites channel state during checkpoint/savepoint.classChannelStateWriterImplChannelStateWriterimplemented usingCheckpointStateOutputStreams.classInputChannelInfoIdentifiesInputChannelin a given subtask.classResultSubpartitionInfoIdentifiesResultSubpartitionin a given subtask.interfaceSequentialChannelStateReaderReads channel state saved during checkpoint/savepoint. -
Uses of Internal in org.apache.flink.runtime.checkpoint.metadata
Classes in org.apache.flink.runtime.checkpoint.metadata with annotations of type Internal Modifier and Type Class Description classMetadataV1SerializerDeserializer for checkpoints written in format1(Flink 1.2.x format).classMetadataV2Serializer(De)serializer for checkpoint metadata format version 2.classMetadataV2V3SerializerBaseBase (De)serializer for checkpoint metadata format version 2 and 3.classMetadataV3Serializer(De)serializer for checkpoint metadata format version 3.classMetadataV4SerializerV4 serializer that addsCheckpointPropertiesserialization.classMetadataV5SerializerV5 serializer that adds Operator name and uid. -
Uses of Internal in org.apache.flink.runtime.dispatcher
Classes in org.apache.flink.runtime.dispatcher with annotations of type Internal Modifier and Type Class Description classConfigurationNotAllowedMessageIfDeploymentOptions.PROGRAM_CONFIG_ENABLEDis disabled, this error denotes the not allowed configuration.interfaceDispatcherBootstrapAn interface containing the logic of bootstrapping theDispatcherof a cluster.interfaceDispatcherBootstrapFactoryA factory to create aDispatcherBootstrap.classNoOpDispatcherBootstrapADispatcherBootstrapwhich submits the providedjob graphsfor execution upon dispatcher initialization.Fields in org.apache.flink.runtime.dispatcher with annotations of type Internal Modifier and Type Field Description static ConfigOption<Duration>Dispatcher. CLIENT_ALIVENESS_CHECK_DURATION -
Uses of Internal in org.apache.flink.runtime.dispatcher.runner
Classes in org.apache.flink.runtime.dispatcher.runner with annotations of type Internal Modifier and Type Class Description classAbstractDispatcherLeaderProcessA baseDispatcherLeaderProcess.classDefaultDispatcherGatewayServiceA facade over theDispatcherthat exposes specific functionality.interfaceDispatcherLeaderProcessFactoryFactoryFactory forDispatcherLeaderProcessFactory.classSessionDispatcherLeaderProcessFactoryFactory for theSessionDispatcherLeaderProcess. -
Uses of Internal in org.apache.flink.runtime.entrypoint
Fields in org.apache.flink.runtime.entrypoint with annotations of type Internal Modifier and Type Field Description static ConfigOption<String>ClusterEntrypoint. INTERNAL_CLUSTER_EXECUTION_MODE -
Uses of Internal in org.apache.flink.runtime.entrypoint.component
Fields in org.apache.flink.runtime.entrypoint.component with annotations of type Internal Modifier and Type Field Description static ConfigOption<String>FileJobGraphRetriever. JOB_GRAPH_FILE_PATH -
Uses of Internal in org.apache.flink.runtime.entrypoint.parser
Classes in org.apache.flink.runtime.entrypoint.parser with annotations of type Internal Modifier and Type Class Description classConfigurationCommandLineOptionsRepresents the set of command-line options related to update and get configuration. -
Uses of Internal in org.apache.flink.runtime.executiongraph
Classes in org.apache.flink.runtime.executiongraph with annotations of type Internal Modifier and Type Class Description classSimpleInitializeOnMasterContextA simple pojo based implementation ofJobVertex.InitializeOnMasterContext. -
Uses of Internal in org.apache.flink.runtime.fs.hdfs
Classes in org.apache.flink.runtime.fs.hdfs with annotations of type Internal Modifier and Type Class Description classBaseHadoopFsRecoverableFsDataOutputStreamBase class for ABFS and Hadoop recoverable stream.classHadoopFsRecoverableAn implementation of the resume and commit descriptor objects for Hadoop's/AzureBlob file system abstraction.classHadoopRecoverableWriterAn implementation of theRecoverableWriterfor Hadoop's file system abstraction. -
Uses of Internal in org.apache.flink.runtime.highavailability
Classes in org.apache.flink.runtime.highavailability with annotations of type Internal Modifier and Type Interface Description interfaceJobResultStoreA storage for the results of globally terminated jobs. -
Uses of Internal in org.apache.flink.runtime.io
Classes in org.apache.flink.runtime.io with annotations of type Internal Modifier and Type Interface Description interfaceAvailabilityProviderInterface defining couple of essential methods for listening on data availability usingCompletableFuture.interfacePullingAsyncDataInput<T>Interface defining couple of essential methods for asynchronous and non blocking data polling. -
Uses of Internal in org.apache.flink.runtime.io.disk
Classes in org.apache.flink.runtime.io.disk with annotations of type Internal Modifier and Type Class Description classFileBasedBufferIteratorCloseableIteratorofbuffersover file content. -
Uses of Internal in org.apache.flink.runtime.io.network.api
Classes in org.apache.flink.runtime.io.network.api with annotations of type Internal Modifier and Type Class Description classEndOfSegmentEventEndOfSegmentEventis used to notify the downstream switch tiers in tiered storage shuffle mode.classRecoveryMetadataRecoveryMetadatacontains the metadata used during a recovery process.classStopModeTells if the job is stopping because of consuming all data. -
Uses of Internal in org.apache.flink.runtime.io.network.api.writer
Classes in org.apache.flink.runtime.io.network.api.writer with annotations of type Internal Modifier and Type Class Description classSubtaskStateMapperTheSubtaskStateMappernarrows down the subtasks that need to be read during rescaling to recover from a particular subtask when in-flight data has been stored in the checkpoint. -
Uses of Internal in org.apache.flink.runtime.io.network.partition
Classes in org.apache.flink.runtime.io.network.partition with annotations of type Internal Modifier and Type Class Description classPrioritizedDeque<T>A deque-like data structure that supports prioritization of elements, such they will be polled before any non-priority elements. -
Uses of Internal in org.apache.flink.runtime.io.network.partition.consumer
Classes in org.apache.flink.runtime.io.network.partition.consumer with annotations of type Internal Modifier and Type Interface Description interfaceCheckpointableInputInput, with just basic methods for blocking and resuming consumption. -
Uses of Internal in org.apache.flink.runtime.jobgraph.jsonplan
Classes in org.apache.flink.runtime.jobgraph.jsonplan with annotations of type Internal Modifier and Type Class Description classJsonPlanGenerator -
Uses of Internal in org.apache.flink.runtime.jobgraph.tasks
Classes in org.apache.flink.runtime.jobgraph.tasks with annotations of type Internal Modifier and Type Interface Description interfaceCheckpointableTaskA task that participates in checkpointing.interfaceCoordinatedTaskAn task that is coordinated, i.e. contains operators coordinated byOperatorCoordinator.interfaceTaskInvokableAn invokable part of the task. -
Uses of Internal in org.apache.flink.runtime.jobmaster
Classes in org.apache.flink.runtime.jobmaster with annotations of type Internal Modifier and Type Class Description static classJobResult.BuilderBuilder forJobResult. -
Uses of Internal in org.apache.flink.runtime.metrics.groups
Classes in org.apache.flink.runtime.metrics.groups with annotations of type Internal Modifier and Type Class Description classAbstractMetricGroup<A extends AbstractMetricGroup<?>>AbstractMetricGroupthat contains key functionality for adding metrics and groups.classComponentMetricGroup<P extends AbstractMetricGroup<?>>AbstractMetricGroupfor system components (e.g., TaskManager, Job, Task, Operator).classGenericKeyMetricGroupAGenericMetricGroupfor representing the key part of a key-value metric group pair.classGenericMetricGroupA simple namedMetricGroupthat is used to hold subgroups of metrics.classGenericValueMetricGroupAGenericMetricGroupfor representing the value part of a key-value metric group pair.classInternalCacheMetricGroupACacheMetricGroupwhich register all cache related metrics under a subgroup of the parent metric group.classInternalOperatorCoordinatorMetricGroupSpecialMetricGrouprepresenting an OperatorCoordinator.classInternalOperatorIOMetricGroupMetric group that contains shareable pre-defined IO-related metrics.classInternalOperatorMetricGroupSpecialMetricGrouprepresenting an Operator.classInternalSinkCommitterMetricGroupSpecialMetricGrouprepresenting an Operator.classInternalSinkWriterMetricGroupSpecialMetricGrouprepresenting an Operator.classInternalSourceReaderMetricGroupSpecialMetricGrouprepresenting an Operator.classInternalSplitEnumeratorMetricGroupSpecialMetricGrouprepresenting anSplitEnumerator.classJobManagerJobMetricGroupSpecialMetricGrouprepresenting everything belonging to a specific job, running on the JobManager.classJobMetricGroup<C extends ComponentMetricGroup<C>>Special abstractMetricGrouprepresenting everything belonging to a specific job.classTaskManagerJobMetricGroupSpecialMetricGrouprepresenting everything belonging to a specific job, running on the TaskManager.classTaskManagerMetricGroupSpecialMetricGrouprepresenting a TaskManager.classTaskMetricGroupSpecialMetricGrouprepresenting a Flink runtime Task. -
Uses of Internal in org.apache.flink.runtime.minicluster
Methods in org.apache.flink.runtime.minicluster with annotations of type Internal Modifier and Type Method Description voidMiniCluster. overrideRestoreModeForChangelogStateBackend() -
Uses of Internal in org.apache.flink.runtime.operators.coordination
Classes in org.apache.flink.runtime.operators.coordination with annotations of type Internal Modifier and Type Interface Description interfaceCoordinatorStoreCoordinatorStorecan be used for sharing some information amongOperatorCoordinatorinstances.classCoordinatorStoreImplBasic implementation ofCoordinatorStore.interfaceOperatorCoordinatorA coordinator for runtime operators. -
Uses of Internal in org.apache.flink.runtime.query
Classes in org.apache.flink.runtime.query with annotations of type Internal Modifier and Type Class Description classKvStateEntry<K,N,V>An entry holding theInternalKvStatealong with itsKvStateInfo. -
Uses of Internal in org.apache.flink.runtime.rest.handler.job.checkpoints
Classes in org.apache.flink.runtime.rest.handler.job.checkpoints with annotations of type Internal Modifier and Type Class Description classAbstractCheckpointStatsHandler<R extends ResponseBody,M extends JobMessageParameters>Abstract class for checkpoint handlers that will cache theCheckpointStatsSnapshotobject. -
Uses of Internal in org.apache.flink.runtime.rest.handler.job.metrics
Classes in org.apache.flink.runtime.rest.handler.job.metrics with annotations of type Internal Modifier and Type Class Description classJobManagerOperatorMetricsHandlerHandler that returns job manager operator metrics. -
Uses of Internal in org.apache.flink.runtime.rest.messages.job.metrics
Classes in org.apache.flink.runtime.rest.messages.job.metrics with annotations of type Internal Modifier and Type Class Description classJobManagerOperatorMetricsHeadersclassJobManagerOperatorMetricsMessageParameters -
Uses of Internal in org.apache.flink.runtime.scheduler.adaptive
Classes in org.apache.flink.runtime.scheduler.adaptive with annotations of type Internal Modifier and Type Class Description classJobSchedulingPlanA plan that describes how to executeJobGraph. -
Uses of Internal in org.apache.flink.runtime.scheduler.adaptive.allocator
Classes in org.apache.flink.runtime.scheduler.adaptive.allocator with annotations of type Internal Modifier and Type Class Description classJobAllocationsInformationInformation about allocations of Job Vertices.interfaceSlotAssignerInterface for assigning slots to slot sharing groups.classStateLocalitySlotAssignerASlotAssignerthat assigns slots based on the number of local key groups.classStateSizeEstimatesManaged Keyed State size estimates used to make scheduling decisions. -
Uses of Internal in org.apache.flink.runtime.security
Classes in org.apache.flink.runtime.security with annotations of type Internal Modifier and Type Class Description classKerberosUtilsProvides vendor-specific KerberosAppConfigurationEntryinstances. -
Uses of Internal in org.apache.flink.runtime.security.modules
Classes in org.apache.flink.runtime.security.modules with annotations of type Internal Modifier and Type Class Description classJaasModuleResponsible for installing a process-wide JAAS configuration. -
Uses of Internal in org.apache.flink.runtime.security.token
Classes in org.apache.flink.runtime.security.token with annotations of type Internal Modifier and Type Class Description classDefaultDelegationTokenManagerManager for delegation tokens in a Flink cluster.classDefaultDelegationTokenManagerFactoryA factory forDefaultDelegationTokenManager.interfaceDelegationTokenManagerManager for delegation tokens in a Flink cluster.static interfaceDelegationTokenManager.ListenerListener for events in theDelegationTokenManager.classDelegationTokenReceiverRepositoryRepository for delegation token receivers.classNoOpDelegationTokenManagerDelegationTokenManagerimplementation which does nothing. -
Uses of Internal in org.apache.flink.runtime.security.token.hadoop
Classes in org.apache.flink.runtime.security.token.hadoop with annotations of type Internal Modifier and Type Class Description classHadoopDelegationTokenConverterDelegation token serializer and deserializer functionality.classHadoopDelegationTokenReceiverHadoop delegation token receiver base class.classHadoopFSDelegationTokenProviderDelegation token provider for Hadoop filesystems.classHadoopFSDelegationTokenReceiverDelegation token receiver for Hadoop filesystems.classHBaseDelegationTokenProviderDelegation token provider implementation for HBase.classHBaseDelegationTokenReceiverDelegation token receiver implementation for HBase.classKerberosLoginProviderProvides Kerberos login functionality. -
Uses of Internal in org.apache.flink.runtime.source.coordinator
Classes in org.apache.flink.runtime.source.coordinator with annotations of type Internal Modifier and Type Class Description classSourceCoordinator<SplitT extends SourceSplit,EnumChkT>The default implementation of theOperatorCoordinatorfor theSource.classSourceCoordinatorContext<SplitT extends SourceSplit>A context class for theOperatorCoordinator.classSplitAssignmentTracker<SplitT extends SourceSplit>A class that is responsible for tracking the past split assignments made bySplitEnumerator. -
Uses of Internal in org.apache.flink.runtime.state
Classes in org.apache.flink.runtime.state with annotations of type Internal Modifier and Type Class Description classAbstractChannelStateHandle<Info>Abstract channel state handle.interfaceAsyncKeyedStateBackend<K>An async keyed state backend provides methods supporting to access keyed state asynchronously and in batch.classCheckpointStateOutputStreamA dedicated output stream that produces aStreamStateHandlewhen closed.interfaceCheckpointStateToolsetA toolset of operations that can be performed on a location embedded within the class.classCheckpointStorageLoaderThis class contains utility methods to load checkpoint storage from configurations.interfaceCheckpointStorageWorkerViewThis interface implements the durable storage of checkpoint data and metadata streams.interfaceConfigurableCheckpointStorageAn interface for checkpoint storage types that pick up additional parameters from a configuration.interfaceConfigurableStateBackendAn interface for state backends that pick up additional parameters from a configuration.classDefaultOperatorStateBackendDefault implementation of OperatorStateStore that provides the ability to make snapshots.interfaceFullSnapshotResources<K>ASnapshotResourcesto be used with the backend-independentFullSnapshotAsyncWriter.classHeapPriorityQueuesManagerManages creating heap priority queues along with their counterpart meta info.classInputChannelStateHandleHandleto anInputChannelstate.interfaceInternalKeyContext<K>This interface is the current context of a keyed state.interfaceInternalPriorityQueue<T>Interface for collection that gives in order access to elements w.r.t their priority.interfaceIterableStateSnapshot<K,N,S>AStateSnapshotthat can return an iterator over all containedStateEntries.classJavaSerializer<T extends Serializable>ATypeSerializerthat uses Java serialization.classKeyedStateBackendParametersImpl<K>Internal POJO implementingStateBackend.KeyedStateBackendParametersclassOperatorStateBackendParametersImplInternal POJO implementingStateBackend.OperatorStateBackendParametersinterfaceOwnedTaskLocalStateStoreThis interface represents the administrative interface toTaskLocalStateStore, that only the owner of the object should see.classResultSubpartitionStateHandleHandleto aResultSubpartitionstate.classSavepointResources<K>Savepoint resources for aKeyedStateBackend.classSerializedCompositeKeyBuilder<K>Responsible for serialization of currentKey, currentGroup and namespace.classSharedStateRegistryImplSharedStateRegistryimplementation.classSnappyStreamCompressionDecoratorThis implementation decorates the stream with snappy compression.interfaceSnapshotable<S extends StateObject>Interface for objects that can snapshot its state (state backends currently).interfaceSnapshotResourcesA set of resources produced in the synchronous part of a snapshot required to finish the snapshot.interfaceSnapshotStrategy<S extends StateObject,SR extends SnapshotResources>Interface for different snapshot approaches in state backends.classStateSerializerProvider<T>AStateSerializerProviderwraps logic on how to obtain serializers for registered state, either with the previous schema of state in checkpoints or the current schema of state.interfaceStateSnapshotGeneral interface for state snapshots that should be written partitioned by key-groups.interfaceStateSnapshotKeyGroupReaderInterface for state de-serialization intoStateTables by key-group.interfaceStateSnapshotRestoreInterface to deal with state snapshot and restore of state.interfaceStateTransformationFunction<S,T>Interface for a binary function that is used for push-down of state transformation into state backends.classStreamCompressionDecoratorImplementations of this interface decorate streams with a compression scheme.interfaceTaskLocalStateStoreClasses that implement this interface serve as a task-manager-level local storage for local checkpointed state.classUncompressedStreamCompressionDecoratorThis implementation does not decorate the stream with any compression. -
Uses of Internal in org.apache.flink.runtime.state.changelog
Classes in org.apache.flink.runtime.state.changelog with annotations of type Internal Modifier and Type Interface Description interfaceChangelogStateBackendHandleA handle to ChangelogStateBackend state.interfaceChangelogStateHandleA handle to savedstate changes.classChangelogStateHandleStreamImplChangelogStateHandleimplementation based onStreamStateHandle.interfaceLocalChangelogRegistryThis registry is responsible for deleting changlog's local handles which are not in use.classLocalChangelogRegistryImplinterfaceSequenceNumberA logical timestamp to draw a boundary between the materialized and non-materialized changes.classStateChangeChange of state of a keyed operator.interfaceStateChangelogHandleReader<Handle extends ChangelogStateHandle>Allows to read state changelog referenced by the providedChangelogStateHandle.classStateChangelogHandleStreamHandleReaderA reader forChangelogStateHandleStreamImplthat iterates over its underlyingstream handlesand offsets.interfaceStateChangelogStorage<Handle extends ChangelogStateHandle>A storage for changelog.interfaceStateChangelogStorageFactoryA factory forStateChangelogStorage.classStateChangelogStorageLoaderA thin wrapper aroundPluginManagerto loadStateChangelogStorage.interfaceStateChangelogStorageView<Handle extends ChangelogStateHandle>A storage view for changelog.interfaceStateChangelogWriter<Handle extends ChangelogStateHandle>Allows to write data to the log. -
Uses of Internal in org.apache.flink.runtime.state.changelog.inmemory
Classes in org.apache.flink.runtime.state.changelog.inmemory with annotations of type Internal Modifier and Type Class Description classInMemoryChangelogStateHandleIn-memoryChangelogStateHandle. -
Uses of Internal in org.apache.flink.runtime.state.delegate
Classes in org.apache.flink.runtime.state.delegate with annotations of type Internal Modifier and Type Interface Description interfaceDelegatingStateBackendAn interface to delegate state backend. -
Uses of Internal in org.apache.flink.runtime.state.filesystem
Classes in org.apache.flink.runtime.state.filesystem with annotations of type Internal Modifier and Type Class Description classFSDataOutputStreamWrapperImplementation ofMetadataOutputStreamWrapperencapsulates theFSDataOutputStreamforFsCheckpointMetadataOutputStream.classMetadataOutputStreamWrapperThe wrapper manages metadata output stream close and commit.classRecoverableStreamWrapperImplementation ofMetadataOutputStreamWrapperencapsulates theRecoverableFsDataOutputStreamforFsCheckpointMetadataOutputStream.Methods in org.apache.flink.runtime.state.filesystem with annotations of type Internal Modifier and Type Method Description static FsCompletedCheckpointStorageLocationAbstractFsCheckpointStorageAccess. resolveCheckpointPointer(String checkpointPointer)Takes the given string (representing a pointer to a checkpoint) and resolves it to a file status for the checkpoint's metadata file. -
Uses of Internal in org.apache.flink.runtime.state.heap
Classes in org.apache.flink.runtime.state.heap with annotations of type Internal Modifier and Type Class Description classCopyOnWriteStateTableSnapshot<K,N,S>This class represents the snapshot of aCopyOnWriteStateTableand has a role in operator state checkpointing.classHeapKeyValueStateIteratorAKeyValueStateIteratorover Heap backend snapshot resources.interfaceHeapPriorityQueueElementInterface for objects that can be managed by aHeapPriorityQueue.classStateTableByKeyGroupReadersThis class provides a static factory method to create different implementations ofStateSnapshotKeyGroupReaderdepending on the provided serialization format version. -
Uses of Internal in org.apache.flink.runtime.state.metrics
Classes in org.apache.flink.runtime.state.metrics with annotations of type Internal Modifier and Type Class Description classLatencyTrackingStateConfigConfig to create latency tracking state metric. -
Uses of Internal in org.apache.flink.runtime.state.restore
Classes in org.apache.flink.runtime.state.restore with annotations of type Internal Modifier and Type Class Description classFullSnapshotRestoreOperation<K>The procedure of restoring state from a savepoint written with the unified binary format.classKeyGroupPart of a savepoint representing data for a single key group.classKeyGroupEntryPart of a savepoint representing data for a single state entry in a key group.interfaceThrowingIterator<E>ModifiedIteratorinterface that lets the implementation throw anIOException. -
Uses of Internal in org.apache.flink.runtime.state.v2
Classes in org.apache.flink.runtime.state.v2 with annotations of type Internal Modifier and Type Class Description classAbstractKeyedState<K,N,V>TheAbstractKeyedStateis the root of the abstract state implementation hierarchy, similar to theStatebeing the root of the public API state hierarchy.interfaceKeyedStateStoreV2This interface contains methods for registeringState.classStateDescriptor<T>Base class for state descriptors. -
Uses of Internal in org.apache.flink.runtime.state.v2.internal
Classes in org.apache.flink.runtime.state.v2.internal with annotations of type Internal Modifier and Type Interface Description interfaceInternalKeyedState<K,N,V>This class defines the internal interface for all keyed state.interfaceInternalListState<K,N,V>This class defines the internal interface for list state.interfaceInternalMapState<K,N,UK,UV>This class defines the internal interface for map state.interfaceInternalPartitionedState<N>A state that is partitioned into different namespaces.interfaceInternalValueState<K,N,V>This class defines the internal interface for value state. -
Uses of Internal in org.apache.flink.runtime.taskmanager
Classes in org.apache.flink.runtime.taskmanager with annotations of type Internal Modifier and Type Class Description classAsynchronousExceptionAn exception for wrapping exceptions that are thrown by an operator in threads other than the main compute thread of that operator.interfaceCheckpointResponderResponder for checkpoint acknowledge and decline messages in theTask. -
Uses of Internal in org.apache.flink.runtime.util
Classes in org.apache.flink.runtime.util with annotations of type Internal Modifier and Type Class Description classForwardingInputStreamInput stream, that wraps another input stream and forwards all method calls to the wrapped stream.classForwardingOutputStreamOutputStream, that wraps anotherOutputStreamand forwards all method calls to the wrapped stream.classNonClosingInputStreamDecoratorDecorator for input streams that ignores calls toInputStream.close().classNonClosingOutputStreamDecoratorDecorator for input streams that ignores calls toOutputStream.close(). -
Uses of Internal in org.apache.flink.sql.parser.ddl
Classes in org.apache.flink.sql.parser.ddl with annotations of type Internal Modifier and Type Class Description classSqlCompilePlanAST node forCOMPILE PLAN 'planfile' [IF NOT EXISTS] FOR [DML].classSqlResetSQL call for "RESET" and "RESET 'key'".classSqlSetSQL call for "SET" and "SET 'key' = 'value'". -
Uses of Internal in org.apache.flink.sql.parser.dml
Classes in org.apache.flink.sql.parser.dml with annotations of type Internal Modifier and Type Class Description classSqlCompileAndExecutePlanAST node forCOMPILE AND EXECUTE PLAN 'planfile' FOR [DML].classSqlExecutePlanAST node forEXECUTE PLAN 'planfile'. -
Uses of Internal in org.apache.flink.sql.parser.type
Classes in org.apache.flink.sql.parser.type with annotations of type Internal Modifier and Type Class Description classSqlRawTypeNameSpecRepresents a raw type such asRAW('org.my.Class', 'sW3Djsds...').classSqlTimestampLtzTypeNameSpecRepresents type TIMESTAMP_LTZ(int) which is a synonym of type TIMESTAMP(int) WITH LOCAL TIME ZONE. -
Uses of Internal in org.apache.flink.state.api
Methods in org.apache.flink.state.api with annotations of type Internal Modifier and Type Method Description OperatorIDOperatorIdentifier. getOperatorId()Optional<String>OperatorIdentifier. getUid()<R> StateBootstrapTransformation<T>WindowedStateTransformation. reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function)Applies the given window function to each window. -
Uses of Internal in org.apache.flink.state.api.input
Classes in org.apache.flink.state.api.input with annotations of type Internal Modifier and Type Class Description classBroadcastStateInputFormat<K,V>The input format for readingBroadcastState.classKeyedStateInputFormat<K,N,OUT>Input format for reading partitioned state.classListStateInputFormat<OT>Input format for reading operator list state.classMultiStateKeyIterator<K>An iterator for reading all keys in a state backend across multiple partitioned states.classSourceBuilderA utility for constructingInputFormatbased sources that are marked as BOUNDED.classUnionStateInputFormat<OT>Input format for reading operator union state. -
Uses of Internal in org.apache.flink.state.api.input.operator
Classes in org.apache.flink.state.api.input.operator with annotations of type Internal Modifier and Type Class Description classKeyedStateReaderOperator<KEY,OUT>AStateReaderOperatorfor executing aKeyedStateReaderFunction.classStateReaderOperator<F extends Function,KEY,N,OUT>Base class for executing functions that read keyed state.classWindowReaderOperator<S extends State,KEY,IN,W extends Window,OUT>AStateReaderOperatorfor readingWindowOperatorstate. -
Uses of Internal in org.apache.flink.state.api.input.operator.window
Classes in org.apache.flink.state.api.input.operator.window with annotations of type Internal Modifier and Type Class Description classAggregateEvictingWindowReaderFunction<IN,ACC,R,OUT,KEY,W extends Window>A wrapper for reading an evicting window operator with an aggregate function.classEvictingWindowReaderFunction<IN,R,OUT,KEY,W extends Window>Wrapper for reading state from an evicting window operator.classProcessEvictingWindowReader<IN,OUT,KEY,W extends Window>A wrapper function for reading an evicting window with no pre-aggregation.classReduceEvictingWindowReaderFunction<IN,OUT,KEY,W extends Window>A wrapper function for reading state from an evicting window operator with a reduce function. -
Uses of Internal in org.apache.flink.state.api.input.splits
Classes in org.apache.flink.state.api.input.splits with annotations of type Internal Modifier and Type Class Description classKeyGroupRangeInputSplitAn input split representing a key-group range from a savepoint.classOperatorStateInputSplitAn input split containing state handles for operator state.interfacePrioritizedOperatorSubtaskStateInputSplitAn input split that returnsPrioritizedOperatorSubtaskState. -
Uses of Internal in org.apache.flink.state.api.output
Classes in org.apache.flink.state.api.output with annotations of type Internal Modifier and Type Class Description classBootstrapStreamTaskRunner<IN>The runtime for aBootstrapStreamTask.classFileCopyFunctionThis output format copies files from an existing savepoint into a new directory.classMergeOperatorStatesA reducer that aggregates multipleOperatorState's into a singleCheckpointMetadata.classOperatorSubtaskStateReducerA reducer that aggregates allOperatorSubtaskState's for a particular operator into a singleOperatorState.classSavepointOutputFormatAn output format to serializeCheckpointMetadatametadata to distributed storage.classSnapshotUtilsTakes a final snapshot of the state of an operator subtask.classStatePathExtractorExtracts all file paths that are part of the providedOperatorState.classTaggedOperatorSubtaskStateA simple wrapper pojo that tagsOperatorSubtaskStatewith metadata. -
Uses of Internal in org.apache.flink.state.api.output.operators
Classes in org.apache.flink.state.api.output.operators with annotations of type Internal Modifier and Type Class Description classBroadcastStateBootstrapOperator<IN>AStreamOperatorfor executingBroadcastStateBootstrapFunction's.classGroupReduceOperator<IN,OUT>An operator for executing aGroupReduceFunctionon a bounded DataStream.classKeyedStateBootstrapOperator<K,IN>AStreamOperatorfor executingKeyedStateBootstrapFunction's.classLazyTimerServiceA timer service that initializes its internal timer service lazily.classStateBootstrapOperator<IN>AStreamOperatorfor executingStateBootstrapFunction's.classStateBootstrapWrapperOperator<IN,OUT,OP extends AbstractStreamOperator<OUT> & OneInputStreamOperator<IN,OUT>>Wraps an existing operator so it can be bootstrapped. -
Uses of Internal in org.apache.flink.state.api.runtime
Classes in org.apache.flink.state.api.runtime with annotations of type Internal Modifier and Type Class Description classMutableConfigA utility for creating a mutableConfigurationfrom aReadableConfig.classNeverFireProcessingTimeServiceA processing time service whose timers never fire so all timers are included in savepoints.classOperatorIDGeneratorUtility for generating Operator Id's from uid strings.classSavepointEnvironmentA minimally implementedEnvironmentthat provides the functionality required to run thestate-processor-api.classSavepointLoaderUtility class for loadingCheckpointMetadatametadata.classSavepointRuntimeContextA streamingRuntimeContextwhich delegates to the underlying batchRuntimeContextalong with a specifiedKeyedStateStore.classStateBootstrapTransformationWithID<T>A simple container class that represents a newly bootstrapped operator state within savepoints.classVoidTriggerable<K,N>ATriggerablethat does nothing. -
Uses of Internal in org.apache.flink.state.api.runtime.metadata
Classes in org.apache.flink.state.api.runtime.metadata with annotations of type Internal Modifier and Type Class Description classSavepointMetadataV2Savepoint metadata that can be modified. -
Uses of Internal in org.apache.flink.state.changelog
Classes in org.apache.flink.state.changelog with annotations of type Internal Modifier and Type Class Description classAbstractChangelogStateBackendAn abstract base implementation of theStateBackendinterface whose subclasses use delegatedStateBackend and State changes to restore.classChangelogKeyedStateBackend<K>AKeyedStateBackendthat keeps state on the underlying delegated keyed state backend as well as on the state change log.interfaceChangelogStateState used byChangelogKeyedStateBackend.classChangelogStateBackendThis state backend holds the working state in the underlying delegatedStateBackend, and forwards state changes to State Changelog.classDeactivatedChangelogStateBackendThis state backend use delegatedStateBackend and State changes to restore to the delegatedStateBackend in which switching Changelog from enabled to disabled.interfaceKvStateChangeLogger<Value,Namespace>A logger for some key-partitioned state (not onlyValueState.interfaceStateChangeLogger<Value,Namespace>Logs changes to a state created byChangelogKeyedStateBackend.classStateChangeOperationThe operation applied toChangelogState. -
Uses of Internal in org.apache.flink.state.changelog.restore
Classes in org.apache.flink.state.changelog.restore with annotations of type Internal Modifier and Type Interface Description interfaceChangelogApplierFactoryStateChangeApplierfactory.classChangelogBackendRestoreOperationRestoresChangelogKeyedStateBackendfrom the providedhandles.interfaceChangelogRestoreTarget<K>Maintains metadata operation related to Changelog recovery.classFunctionDelegationHelperDelegating functionsare used to create metadata on recovery when the actual function code is not known yet.interfaceStateChangeApplierApplies state data change to some state. -
Uses of Internal in org.apache.flink.state.common
Classes in org.apache.flink.state.common with annotations of type Internal Modifier and Type Class Description classChangelogMaterializationMetricGroupMetrics related to the materialization part of Changelog.classPeriodicMaterializationManagerStateless Materialization Manager. -
Uses of Internal in org.apache.flink.state.forst
Classes in org.apache.flink.state.forst with annotations of type Internal Modifier and Type Interface Description interfaceForStDBOperationData access operation to ForStDB.classForStNativeMetricMonitorA monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.classForStPropertyRocksDBproperties that can be queried by Flink's metrics reporter. -
Uses of Internal in org.apache.flink.state.forst.restore
Classes in org.apache.flink.state.forst.restore with annotations of type Internal Modifier and Type Interface Description interfaceForStRestoreOperationInterface for ForSt restore. -
Uses of Internal in org.apache.flink.state.forst.sync
Classes in org.apache.flink.state.forst.sync with annotations of type Internal Modifier and Type Class Description classAbstractForStStateKeysIterator<K>Base class for iterators over RocksDB column families. -
Uses of Internal in org.apache.flink.state.rocksdb
Classes in org.apache.flink.state.rocksdb with annotations of type Internal Modifier and Type Class Description classRocksDBNativeMetricMonitorA monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.classRocksDBPropertyRocksDBproperties that can be queried by Flink's metrics reporter. -
Uses of Internal in org.apache.flink.state.rocksdb.iterator
Classes in org.apache.flink.state.rocksdb.iterator with annotations of type Internal Modifier and Type Class Description classAbstractRocksStateKeysIterator<K>Base class for iterators over RocksDB column families.interfaceSingleStateIteratorAn interface for iterating over a single state in a RocksDB state backend. -
Uses of Internal in org.apache.flink.state.rocksdb.restore
Classes in org.apache.flink.state.rocksdb.restore with annotations of type Internal Modifier and Type Interface Description interfaceRocksDBRestoreOperationInterface for RocksDB restore. -
Uses of Internal in org.apache.flink.streaming.api
Classes in org.apache.flink.streaming.api with annotations of type Internal Modifier and Type Class Description classSimpleTimerServiceImplementation ofTimerServicethat uses aInternalTimerService. -
Uses of Internal in org.apache.flink.streaming.api.checkpoint
Classes in org.apache.flink.streaming.api.checkpoint with annotations of type Internal Modifier and Type Interface Description interfaceExternallyInducedSource<T,CD>Deprecated.This interface is based on theSourceFunctionAPI, which is due to be removed. -
Uses of Internal in org.apache.flink.streaming.api.connector.sink2
Classes in org.apache.flink.streaming.api.connector.sink2 with annotations of type Internal Modifier and Type Class Description classCommittableMessageSerializer<CommT>The serializer to serializeCommittableMessages in custom operators.classGlobalCommitterOperator<CommT,GlobalCommT>Implements theGlobalCommitter. -
Uses of Internal in org.apache.flink.streaming.api.datastream
Classes in org.apache.flink.streaming.api.datastream with annotations of type Internal Modifier and Type Class Description static classCoGroupedStreams.TaggedUnion<T1,T2>Internal class for implementing tagged union co-group.static classCoGroupedStreams.UnionSerializer<T1,T2>classKeyedPartitionWindowedStream<T,KEY>KeyedPartitionWindowedStreamrepresents a data stream that collects all records with the same key separately into a full window.classNonKeyedPartitionWindowedStream<T>NonKeyedPartitionWindowedStreamrepresents a data stream that collects all records of each subtask separately into a full window.Methods in org.apache.flink.streaming.api.datastream with annotations of type Internal Modifier and Type Method Description static <T> DataStreamSink<T>DataStreamSink. forSink(DataStream<T> inputStream, Sink<T> sink, CustomSinkOperatorUidHashes customSinkOperatorUidHashes)StringCustomSinkOperatorUidHashes. getCommitterUidHash()StringCustomSinkOperatorUidHashes. getGlobalCommitterUidHash()intDataStream. getId()Returns the ID of theDataStreamin the currentStreamExecutionEnvironment.KeySelector<T,KEY>KeyedStream. getKeySelector()Gets the key selector that can get the key by which the stream if partitioned from the elements.TypeInformation<KEY>KeyedStream. getKeyType()Gets the type of the key by which the stream is partitioned.LegacySinkTransformation<T>DataStreamSink. getLegacyTransformation()Transformation<T>DataStream. getTransformation()Returns theTransformationthat represents the operation that logically creates thisDataStream.Transformation<T>DataStreamSink. getTransformation()Returns the transformation that contains the actual sink operator of this sink.StringCustomSinkOperatorUidHashes. getWriterUidHash()<R> SingleOutputStreamOperator<R>ConnectedStreams. process(CoProcessFunction<IN1,IN2,R> coProcessFunction, TypeInformation<R> outputType)Applies the givenCoProcessFunctionon the connected input streams, thereby creating a transformed output stream.<K,R>
SingleOutputStreamOperator<R>ConnectedStreams. process(KeyedCoProcessFunction<K,IN1,IN2,R> keyedCoProcessFunction, TypeInformation<R> outputType)Applies the givenKeyedCoProcessFunctionon the connected input streams, thereby creating a transformed output stream.<R> SingleOutputStreamOperator<R>DataStream. process(ProcessFunction<T,R> processFunction, TypeInformation<R> outputType)Applies the givenProcessFunctionon the input stream, thereby creating a transformed output stream.<R> SingleOutputStreamOperator<R>KeyedStream. process(KeyedProcessFunction<KEY,T,R> keyedProcessFunction, TypeInformation<R> outputType)Applies the givenKeyedProcessFunctionon the input stream, thereby creating a transformed output stream.<R> SingleOutputStreamOperator<R>WindowedStream. process(ProcessWindowFunction<T,R,K,W> function, TypeInformation<R> resultType)Applies the given window function to each window.<R> SingleOutputStreamOperator<R>WindowedStream. reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function, TypeInformation<R> resultType)Applies the given window function to each window. -
Uses of Internal in org.apache.flink.streaming.api.environment
Methods in org.apache.flink.streaming.api.environment with annotations of type Internal Modifier and Type Method Description voidStreamExecutionEnvironment. addOperator(Transformation<?> transformation)Adds an operator to the list of operators that should be executed when callingStreamExecutionEnvironment.execute().<OUT> DataStreamSource<OUT>StreamExecutionEnvironment. addSource(SourceFunction<OUT> function, String sourceName)Deprecated.This method relies on theSourceFunctionAPI, which is due to be removed.<OUT> DataStreamSource<OUT>StreamExecutionEnvironment. addSource(SourceFunction<OUT> function, String sourceName, TypeInformation<OUT> typeInfo)Deprecated.This method relies on theSourceFunctionAPI, which is due to be removed.<OUT> DataStreamSource<OUT>StreamExecutionEnvironment. addSource(SourceFunction<OUT> function, TypeInformation<OUT> typeInfo)Deprecated.This method relies on theSourceFunctionAPI, which is due to be removed.static booleanStreamExecutionEnvironment. areExplicitEnvironmentsAllowed()Checks whether it is currently permitted to explicitly instantiate a LocalEnvironment or a RemoteEnvironment.<F> FStreamExecutionEnvironment. clean(F f)Returns a "closure-cleaned" version of the given function.JobExecutionResultStreamExecutionEnvironment. execute(StreamGraph streamGraph)Triggers the program execution.JobClientStreamExecutionEnvironment. executeAsync(StreamGraph streamGraph)Triggers the program execution asynchronously.StreamGraphStreamExecutionEnvironment. generateStreamGraph(List<Transformation<?>> transformations)Generates aStreamGraphthat consists of the giventransformationsand is configured with the configuration of this environment.ReadableConfigStreamExecutionEnvironment. getConfiguration()Gives read-only access to the underlying configuration of this environment.StreamGraphStreamExecutionEnvironment. getStreamGraph()Getter of theStreamGraphof the streaming job.StreamGraphStreamExecutionEnvironment. getStreamGraph(boolean clearTransformations)Getter of theStreamGraphof the streaming job with the option to clear previously registeredtransformations.List<Transformation<?>>StreamExecutionEnvironment. getTransformations()voidStreamExecutionEnvironment. invalidateClusterDataset(AbstractID datasetId)<T> voidStreamExecutionEnvironment. registerCacheTransformation(AbstractID intermediateDataSetID, CacheTransformation<T> t)voidStreamExecutionEnvironment. registerCollectIterator(CollectResultIterator<?> iterator)ConfigurationCheckpointConfig. toConfiguration()Constructors in org.apache.flink.streaming.api.environment with annotations of type Internal Constructor Description CheckpointConfig(Configuration configuration) -
Uses of Internal in org.apache.flink.streaming.api.functions.aggregation
Classes in org.apache.flink.streaming.api.functions.aggregation with annotations of type Internal Modifier and Type Class Description classAggregationFunction<T>Holder class for aggregation types that can be used on a windowed stream or keyed stream.classComparableAggregator<T>AnAggregationFunctionthat computes values based on comparisons ofComparables.classComparatorInternal comparator implementation, for use withComparableAggregator.classSumAggregator<T>AnAggregationFunctionthat sums up fields.classSumFunctionInternal function for summing up contents of fields. -
Uses of Internal in org.apache.flink.streaming.api.functions.python
Classes in org.apache.flink.streaming.api.functions.python with annotations of type Internal Modifier and Type Class Description classDataStreamPythonFunctionDataStreamPythonFunctionmaintains the serialized python function which will be used in BeamDataStreamPythonFunctionRunner.classDataStreamPythonFunctionInfoDataStreamPythonFunctionInfoholds a PythonFunction and its function type.classKeyByKeySelectorKeyByKeySelectoris responsible for extracting the first field of the input row as key.classPartitionCustomKeySelectorThePartitionCustomKeySelectorwill return the first field of the input row value. -
Uses of Internal in org.apache.flink.streaming.api.functions.python.eventtime
Classes in org.apache.flink.streaming.api.functions.python.eventtime with annotations of type Internal Modifier and Type Class Description classCustomTimestampAssigner<T>TimestampAssigner which extracts timestamp from the second field of the input element.classRemoveTimestampMapFunction<T>MapFunction which removes the timestamp field from the input element. -
Uses of Internal in org.apache.flink.streaming.api.functions.query
Classes in org.apache.flink.streaming.api.functions.query with annotations of type Internal Modifier and Type Class Description classQueryableAppendingStateOperator<IN>Internal operator handling queryable AppendingState instances.classQueryableValueStateOperator<IN>Internal operator handling queryable ValueState instances. -
Uses of Internal in org.apache.flink.streaming.api.functions.sink
Classes in org.apache.flink.streaming.api.functions.sink with annotations of type Internal Modifier and Type Class Description classSinkContextUtilUtility for creating SinkContexts. -
Uses of Internal in org.apache.flink.streaming.api.functions.sink.filesystem
Classes in org.apache.flink.streaming.api.functions.sink.filesystem with annotations of type Internal Modifier and Type Class Description classBucket<IN,BucketID>A bucket is the directory organization of the output of theStreamingFileSink.interfaceBucketFactory<IN,BucketID>A factory able to createbucketsfor theStreamingFileSink.interfaceBucketLifeCycleListener<IN,BucketID>Listener about the status ofBucket.classBuckets<IN,BucketID>The manager of the different active buckets in theStreamingFileSink.interfaceBucketWriter<IN,BucketID>An interface for factories that create the differentwriters.classBulkBucketWriter<IN,BucketID>A factory that createsBulkPartWriters.interfaceCompactingFileWriterThe file sink compactors use theCompactingFileWriterto write a compacting file.static classCompactingFileWriter.TypeEnum defining the types ofCompactingFileWriter.classDefaultBucketFactoryImpl<IN,BucketID>A factory returningbuckets.interfaceFileLifeCycleListener<BucketID>Listener about the status of file.classHadoopPathBasedBulkFormatBuilder<IN,BucketID,T extends HadoopPathBasedBulkFormatBuilder<IN,BucketID,T>>Buckets builder to create buckets that useHadoopPathBasedPartFileWriter.interfaceInProgressFileWriter<IN,BucketID>TheBucketuses theInProgressFileWriterto write element to a part file.interfaceOutputStreamBasedCompactingFileWriterThe compactors use theOutputStreamBasedCompactingFileWriterto directly write a compacting file as anOutputStream.interfaceRecordWiseCompactingFileWriter<IN>The compactors use theRecordWiseCompactingFileWriterto write elements to a compacting file.classRowWiseBucketWriter<IN,BucketID>A factory that createsRowWisePartWriters.classRowWisePartWriter<IN,BucketID>AInProgressFileWriterfor row-wise formats that use anEncoder.classSerializableConfigurationWrapper of hadoop Configuration to make it serializable.classStreamingFileSinkHelper<IN>Helper forStreamingFileSink.classWriterPropertiesThis class describes the property of theBucketWriter. -
Uses of Internal in org.apache.flink.streaming.api.functions.sink.filesystem.legacy
Classes in org.apache.flink.streaming.api.functions.sink.filesystem.legacy with annotations of type Internal Modifier and Type Class Description classStreamingFileSink<IN>Deprecated.UseFileSinkinstead.static classStreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>>Deprecated.The base abstract class for theStreamingFileSink.RowFormatBuilderandStreamingFileSink.BulkFormatBuilder.static classStreamingFileSink.BulkFormatBuilder<IN,BucketID,T extends StreamingFileSink.BulkFormatBuilder<IN,BucketID,T>>Deprecated.A builder for configuring the sink for bulk-encoding formats, e.g.static classStreamingFileSink.DefaultBulkFormatBuilder<IN>Deprecated.Builder for the vanillaStreamingFileSinkusing a bulk format.static classStreamingFileSink.DefaultRowFormatBuilder<IN>Deprecated.Builder for the vanillaStreamingFileSinkusing a row format.static classStreamingFileSink.RowFormatBuilder<IN,BucketID,T extends StreamingFileSink.RowFormatBuilder<IN,BucketID,T>>Deprecated.A builder for configuring the sink for row-wise encoding formats.Methods in org.apache.flink.streaming.api.functions.sink.filesystem.legacy with annotations of type Internal Modifier and Type Method Description abstract Buckets<IN,BucketID>StreamingFileSink.BucketsBuilder. createBuckets(int subtaskIndex)Buckets<IN,BucketID>StreamingFileSink.BulkFormatBuilder. createBuckets(int subtaskIndex)Buckets<IN,BucketID>StreamingFileSink.RowFormatBuilder. createBuckets(int subtaskIndex)abstract BucketWriter<IN,BucketID>StreamingFileSink.BucketsBuilder. createBucketWriter()BucketWriter<IN,BucketID>StreamingFileSink.BulkFormatBuilder. createBucketWriter()BucketWriter<IN,BucketID>StreamingFileSink.RowFormatBuilder. createBucketWriter()static <IN> StreamingFileSink.DefaultBulkFormatBuilder<IN>StreamingFileSink. forBulkFormat(Path basePath, BulkWriter.Factory<IN> writerFactory)Deprecated.Creates the builder for aStreamingFileSinkwith bulk-encoding format.static <IN> StreamingFileSink.DefaultRowFormatBuilder<IN>StreamingFileSink. forRowFormat(Path basePath, Encoder<IN> encoder)Deprecated.Creates the builder for aStreamingFileSinkwith row-encoding format. -
Uses of Internal in org.apache.flink.streaming.api.functions.sink.legacy
Classes in org.apache.flink.streaming.api.functions.sink.legacy with annotations of type Internal Modifier and Type Class Description classDiscardingSink<T>Deprecated.This interface will be removed in future versions.classOutputFormatSinkFunction<IN>Deprecated.Please use theStreamingFileSinkfor writing to files from a streaming program.classPrintSinkFunction<IN>Deprecated.This interface will be removed in future versions.classRichSinkFunction<IN>Deprecated.This interface will be removed in future versions.interfaceSinkFunction<IN>Deprecated.This interface will be removed in future versions.classSocketClientSink<IN>Deprecated.This interface will be removed in future versions.classTwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>Deprecated.This interface will be removed in future versions.static classTwoPhaseCommitSinkFunction.State<TXN,CONTEXT>Deprecated.State POJO class coupling pendingTransaction, context and pendingCommitTransactions.static classTwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT>Deprecated.CustomTypeSerializerfor the sink state.static classTwoPhaseCommitSinkFunction.StateSerializerSnapshot<TXN,CONTEXT>Deprecated.Snapshot for theTwoPhaseCommitSinkFunction.StateSerializer.static classTwoPhaseCommitSinkFunction.TransactionHolder<TXN>Deprecated.Adds metadata (currently only the start time of the transaction) to the transaction object. -
Uses of Internal in org.apache.flink.streaming.api.functions.source
Classes in org.apache.flink.streaming.api.functions.source with annotations of type Internal Modifier and Type Class Description classContinuousFileReaderOperator<OUT,T extends TimestampedInputSplit>The operator that reads thesplitsreceived from the precedingContinuousFileMonitoringFunction. -
Uses of Internal in org.apache.flink.streaming.api.functions.source.datagen
Classes in org.apache.flink.streaming.api.functions.source.datagen with annotations of type Internal Modifier and Type Class Description classDataGeneratorSource<T>Deprecated.Useorg.apache.flink.connector.datagen.source.DataGeneratorSourceinstead. -
Uses of Internal in org.apache.flink.streaming.api.functions.source.legacy
Classes in org.apache.flink.streaming.api.functions.source.legacy with annotations of type Internal Modifier and Type Class Description classContinuousFileMonitoringFunction<OUT>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classFileMonitoringFunctionDeprecated.Internal class deprecated in favour ofContinuousFileMonitoringFunction.static classFileMonitoringFunction.WatchTypeDeprecated.The watch type of theFileMonitoringFunction.classFileReadFunctionDeprecated.Internal class deprecated in favour ofContinuousFileMonitoringFunction.classFromElementsFunction<T>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classFromIteratorFunction<T>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classFromSplittableIteratorFunction<T>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classInputFormatSourceFunction<OUT>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.interfaceParallelSourceFunction<OUT>Deprecated.This interface is based on theSourceFunctionAPI, which is due to be removed.classRichParallelSourceFunction<OUT>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classRichSourceFunction<OUT>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classSocketTextStreamFunctionDeprecated.This class is based on theSourceFunctionAPI, which is due to be removed.interfaceSourceFunction<T>Deprecated.This interface will be removed in future versions.classStatefulSequenceSourceDeprecated.This class is based on theSourceFunctionAPI, which is due to be removed. -
Uses of Internal in org.apache.flink.streaming.api.functions.windowing
Classes in org.apache.flink.streaming.api.functions.windowing with annotations of type Internal Modifier and Type Class Description classAggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R>classAggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R>classInternalProcessApplyAllWindowContext<IN,OUT,W extends Window>Internal reusable context wrapper.classInternalProcessApplyWindowContext<IN,OUT,KEY,W extends Window>Internal reusable context wrapper.classPassThroughAllWindowFunction<W extends Window,T>AAllWindowFunctionthat just emits each input element.classPassThroughWindowFunction<K,W extends Window,T>AWindowFunctionthat just emits each input element.classReduceApplyAllWindowFunction<W extends Window,T,R>InternalAllWindowFunctionthat is used for implementing a fold on a window configuration that only allowsAllWindowFunctionand cannot directly execute aReduceFunction.classReduceApplyProcessAllWindowFunction<W extends Window,T,R>InternalProcessAllWindowFunctionthat is used for implementing a fold on a window configuration that only allowsAllWindowFunctionand cannot directly execute aReduceFunction.classReduceApplyProcessWindowFunction<K,W extends Window,T,R>InternalProcessWindowFunctionthat is used for implementing a fold on a window configuration that only allowsAllWindowFunctionand cannot directly execute aReduceFunction.classReduceApplyWindowFunction<K,W extends Window,T,R>InternalWindowFunctionthat is used for implementing a fold on a window configuration that only allowsWindowFunctionand cannot directly execute aReduceFunction. -
Uses of Internal in org.apache.flink.streaming.api.functions.windowing.delta.extractor
Classes in org.apache.flink.streaming.api.functions.windowing.delta.extractor with annotations of type Internal Modifier and Type Class Description classArrayFromTupleConverts a Tuple to an Object-Array.classConcatenatedExtract<FROM,OVER,TO>Combines two extractors which will be executed one after each other.interfaceExtractor<FROM,TO>Extractors allow to extract/convert one type to another.classFieldFromArray<OUT>Extracts a single field out of an array.classFieldFromTuple<OUT>Extracts a single field out of a tuple.classFieldsFromArray<OUT>Extracts multiple fields from an array and puts them into a new array of the specified type.classFieldsFromTupleExtracts one or more fields of the type Double from a tuple and puts them into a new double[]. -
Uses of Internal in org.apache.flink.streaming.api.graph
Classes in org.apache.flink.streaming.api.graph with annotations of type Internal Modifier and Type Interface Description interfaceExecutionPlanAn interface representing a general execution plan, which can be implemented by different types of graphs such as JobGraph and StreamGraph.classGlobalStreamExchangeModeThis mode decides the defaultResultPartitionTypeof job edges.classJSONGeneratorHelper class for generating a JSON representation from aStreamGraph.classNonChainedOutputUsed by operator chain and represents a non-chained output of the corresponding stream operator.classSimpleTransformationTranslator<OUT,T extends Transformation<OUT>>A base class for allTransformationTranslatorswho translateTransformationsthat have a single operator in their runtime implementation.classStreamConfigInternal configuration for aStreamOperator.classStreamEdgeAn edge in the streaming topology.classStreamGraphClass representing the streaming topology.classStreamGraphGeneratorA generator that generates aStreamGraphfrom a graph ofTransformations.classStreamingJobGraphGeneratorThe StreamingJobGraphGenerator converts aStreamGraphinto aJobGraph.classStreamNodeClass representing the operators in the streaming programs, with all their properties.interfaceTransformationTranslator<OUT,T extends Transformation<OUT>>ATransformationTranslatoris responsible for translating a givenTransformationto its runtime implementation depending on the execution mode.static interfaceTransformationTranslator.ContextA context giving the necessary information for the translation of a given transformation. -
Uses of Internal in org.apache.flink.streaming.api.graph.util
Classes in org.apache.flink.streaming.api.graph.util with annotations of type Internal Modifier and Type Class Description classChainedOperatorHashInfoHelper class to help maintain the hash info of an operator chain.classChainedSourceInfoHelper class to help maintain the chained source info of an operator chain.classJobVertexBuildContextHelper class encapsulates all necessary information and configurations required during the construction of job vertices.classOperatorChainInfoHelper class to help maintain the information of an operator chain.classOperatorInfoHelper class to help maintain the information of an operator. -
Uses of Internal in org.apache.flink.streaming.api.lineage
Classes in org.apache.flink.streaming.api.lineage with annotations of type Internal Modifier and Type Class Description classDefaultLineageDatasetDefault implementation forLineageDataset.classDefaultLineageEdgeImplementation of LineageEdge.classDefaultLineageGraphDefault implementation forLineageGraph.static classDefaultLineageGraph.LineageGraphBuilderBuild the default lineage graph fromLineageEdge.classDefaultLineageVertexDefault implementation forLineageVertex.classDefaultSourceLineageVertexDefault implementation forSourceLineageVertex.classLineageGraphUtilsUtils for building lineage graph from transformations. -
Uses of Internal in org.apache.flink.streaming.api.operators
Classes in org.apache.flink.streaming.api.operators with annotations of type Internal Modifier and Type Class Description classBatchGroupedReduceOperator<IN,KEY>AStreamOperatorfor executing aReduceFunctionon aKeyedStreamin aRuntimeExecutionMode.BATCHmode.interfaceCoordinatedOperatorFactory<OUT>A factory class for theStreamOperators implementingOperatorEventHandler.interfaceInputFormatOperatorFactory<OUT>Input format source operator factory.interfaceInternalTimer<K,N>Internal interface for in-flight timers.interfaceInternalTimerService<N>Interface for working with time and timers.classInternalTimerServiceAsyncImpl<K,N>An implementation ofInternalTimerServicethat is used byorg.apache.flink.streaming.runtime.operators.asyncprocessing.AbstractAsyncStateStreamOperator.classInternalTimerServiceSerializationProxy<K>Serialization proxy for the timer services for a given key-group.classInternalTimersSnapshotReaderWritersReaders and writers for different versions of theInternalTimersSnapshot.interfaceInternalTimeServiceManager<K>An entity keeping all the time-related services.static interfaceInternalTimeServiceManager.ShouldStopAdvancingFnSignals whether the watermark should continue advancing.classInternalTimeServiceManagerImpl<K>An entity keeping all the time-related services.interfaceKeyContextHandlerThis interface is used to optimize the calls ofInput.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>),StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>)andStreamOperator.setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>).classKeyedProcessOperator<K,IN,OUT>AStreamOperatorfor executingKeyedProcessFunctions.classLegacyKeyedProcessOperator<K,IN,OUT>Deprecated.Replaced byKeyedProcessOperatorwhich takesKeyedProcessFunctionclassMailboxWatermarkProcessor<OUT>A helper class to let operators emit watermarks incrementally from mailbox.classMapPartitionIterator<IN>TheMapPartitionIteratoris an iterator used in theMapPartitionOperator.The task main thread will add records to it.classMapPartitionOperator<IN,OUT>TheMapPartitionOperatoris used to process all records in each partition on non-keyed stream.interfaceOnWatermarkCallback<KEY>A callback registered with theInternalWatermarkCallbackServiceservice.interfaceOutputFormatOperatorFactory<IN,OUT>Interface for operator factories which create the sink operator containing anOutputFormat.classPartitionAggregateOperator<IN,ACC,OUT>ThePartitionAggregateOperatoris used to apply the aggregate transformation on all records of each partition.classPartitionReduceOperator<IN>ThePartitionReduceOperatoris used to apply the reduce transformation on all records of each partition.classProcessOperator<IN,OUT>AStreamOperatorfor executingProcessFunctions.classSimpleInputFormatOperatorFactory<OUT>Input format source operator factory which just wrap existedStreamSource.classSimpleOperatorFactory<OUT>Simple factory which just wrap existedStreamOperator.classSimpleOutputFormatOperatorFactory<IN,OUT>A simple operator factory which create an operator containing anOutputFormat.classSimpleUdfStreamOperatorFactory<OUT>Udf stream operator factory which just wrap existedAbstractUdfStreamOperator.classSourceOperator<OUT,SplitT extends SourceSplit>Base source operator only used for integrating the source reader which is proposed by FLIP-27.classStreamFilter<IN>AStreamOperatorfor executingFilterFunctions.classStreamFlatMap<IN,OUT>AStreamOperatorfor executingFlatMapFunctions.classStreamGroupedReduceOperator<IN>classStreamingRuntimeContextImplementation of theRuntimeContext, for streaming operators.classStreamMap<IN,OUT>AStreamOperatorfor executingMapFunctions.classStreamOperatorStateHandlerClass encapsulating various state backend handling logic forStreamOperatorimplementations.classStreamOperatorUtilsclassStreamProject<IN,OUT extends Tuple>AStreamOperatorfor executing projections on streams.classStreamSink<IN>AStreamOperatorfor executingSinkFunctions.classStreamSource<OUT,SRC extends SourceFunction<OUT>>Deprecated.This class is based on theSourceFunctionAPI, which is due to be removed.classTimerHeapInternalTimer<K,N>Implementation ofInternalTimerto use with aHeapPriorityQueueSet.classTimerSerializer<K,N>A serializer forTimerHeapInternalTimerobjects that produces a serialization format that is lexicographically aligned the priority of the timers.classTimerSerializerSnapshot<K,N>Snapshot class for theTimerSerializer.classTimestampedCollector<T>interfaceTriggerable<K,N>Interface for things that can be called byInternalTimerService.interfaceUdfStreamOperatorFactory<OUT>Udf stream operator factory.interfaceUserFunctionProvider<F extends Function>The interface with user function.interfaceYieldingOperator<OUT>A V1 operator that needs access to theMailboxExecutorshould implement this interface.Methods in org.apache.flink.streaming.api.operators with annotations of type Internal Modifier and Type Method Description ThrowingConsumer<StreamRecord<IN>,Exception>AbstractInput. getRecordProcessor(int inputId)booleanAbstractStreamOperator. hasKeyContext1()booleanAbstractStreamOperator. hasKeyContext2()booleanAbstractInput. isAsyncStateProcessingEnabled()booleanAbstractStreamOperator. isAsyncStateProcessingEnabled()Indicates whether this operator is enabling the async state.booleanAbstractStreamOperatorV2. isAsyncStateProcessingEnabled()Indicates whether this operator is enabling the async state.protected booleanAbstractStreamOperator. isUsingCustomRawKeyedState()Indicates whether or not implementations of this class is writing to the raw keyed state streams on snapshots, usingAbstractStreamOperator.snapshotState(StateSnapshotContext).protected booleanAbstractStreamOperatorV2. isUsingCustomRawKeyedState()Indicates whether or not implementations of this class is writing to the raw keyed state streams on snapshots, usingAbstractStreamOperatorV2.snapshotState(StateSnapshotContext).voidAbstractStreamOperator. setMailboxExecutor(MailboxExecutor mailboxExecutor)booleanAbstractStreamOperator. useSplittableTimers()Can be overridden to disable splittable timers for this particular operator even if config option is enabled.booleanAbstractStreamOperatorV2. useSplittableTimers()Can be overridden to disable splittable timers for this particular operator even if config option is enabled. -
Uses of Internal in org.apache.flink.streaming.api.operators.async
Classes in org.apache.flink.streaming.api.operators.async with annotations of type Internal Modifier and Type Class Description classAsyncWaitOperator<IN,OUT>TheAsyncWaitOperatorallows to asynchronously process incoming stream records. -
Uses of Internal in org.apache.flink.streaming.api.operators.async.queue
Classes in org.apache.flink.streaming.api.operators.async.queue with annotations of type Internal Modifier and Type Class Description classOrderedStreamElementQueue<OUT>OrderedStreamElementQueueimplementation.interfaceStreamElementQueue<OUT>Interface for stream element queues for theAsyncWaitOperator.classUnorderedStreamElementQueue<OUT>Unordered implementation of theStreamElementQueue. -
Uses of Internal in org.apache.flink.streaming.api.operators.co
-
Uses of Internal in org.apache.flink.streaming.api.operators.collect
Classes in org.apache.flink.streaming.api.operators.collect with annotations of type Internal Modifier and Type Class Description classClientAndIterator<E>classCollectSinkFunction<IN>A sink function that collects query results and sends them back to the client.classCollectStreamSink<T>ADataStreamSinkwhich is used to collect results of a data stream. -
Uses of Internal in org.apache.flink.streaming.api.operators.legacy
Classes in org.apache.flink.streaming.api.operators.legacy with annotations of type Internal Modifier and Type Interface Description interfaceYieldingOperatorFactory<OUT>Deprecated. -
Uses of Internal in org.apache.flink.streaming.api.operators.python
Classes in org.apache.flink.streaming.api.operators.python with annotations of type Internal Modifier and Type Class Description classAbstractPythonFunctionOperator<OUT>Base class for all stream operators to execute Python functions.interfaceDataStreamPythonFunctionOperator<OUT>Interface for Python DataStream operators. -
Uses of Internal in org.apache.flink.streaming.api.operators.python.embedded
Classes in org.apache.flink.streaming.api.operators.python.embedded with annotations of type Internal Modifier and Type Class Description classAbstractEmbeddedDataStreamPythonFunctionOperator<OUT>Base class for all Python DataStream operators executed in embedded Python environment.classAbstractEmbeddedPythonFunctionOperator<OUT>Abstract class for all stream operators to execute Python functions in embedded Python environment.classAbstractOneInputEmbeddedPythonFunctionOperator<IN,OUT>AbstractOneInputEmbeddedPythonFunctionOperatoris responsible for run Python DataStream operators with one input in Embedded Python environment.classAbstractTwoInputEmbeddedPythonFunctionOperator<IN1,IN2,OUT>AbstractTwoInputEmbeddedPythonFunctionOperatoris responsible for run Python DataStream operators with two input user defined python function in Embedded Python environment.classEmbeddedPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT>TheEmbeddedPythonBatchCoBroadcastProcessOperatoris responsible for executing the Python CoBroadcastProcess Function under BATCH mode,EmbeddedPythonCoProcessOperatoris used under STREAMING mode.classEmbeddedPythonBatchKeyedCoBroadcastProcessOperator<K,IN1,IN2,OUT>TheEmbeddedPythonBatchKeyedCoBroadcastProcessOperatoris responsible for executing the Python CoBroadcastProcess function under BATCH mode,EmbeddedPythonKeyedCoProcessOperatoris used under STREAMING mode.classEmbeddedPythonCoProcessOperator<IN1,IN2,OUT>EmbeddedPythonCoProcessOperatoris responsible for executing Python CoProcessFunction in embedded Python environment.classEmbeddedPythonKeyedCoProcessOperator<K,IN1,IN2,OUT>EmbeddedPythonKeyedCoProcessOperatoris responsible for executing user defined python KeyedCoProcessFunction in embedded Python environment.classEmbeddedPythonKeyedProcessOperator<K,IN,OUT>EmbeddedPythonKeyedProcessOperatoris responsible for executing user defined python KeyedProcessFunction in embedded Python environment.classEmbeddedPythonProcessOperator<IN,OUT>EmbeddedPythonProcessOperatoris responsible for executing Python ProcessFunction in embedded Python environment.classEmbeddedPythonWindowOperator<K,IN,OUT,W extends Window>EmbeddedPythonWindowOperatoris responsible for executing user defined python ProcessWindowFunction in embedded Python environment. -
Uses of Internal in org.apache.flink.streaming.api.operators.python.process
Classes in org.apache.flink.streaming.api.operators.python.process with annotations of type Internal Modifier and Type Class Description classAbstractExternalDataStreamPythonFunctionOperator<OUT>Base class for all Python DataStream operators executed in Python process.classAbstractExternalOneInputPythonFunctionOperator<IN,OUT>AbstractExternalOneInputPythonFunctionOperatoris responsible for launching beam runner which will start a python harness to execute user defined python function.classAbstractExternalPythonFunctionOperator<OUT>Abstract class for all stream operators to execute Python functions in external environment.classAbstractExternalTwoInputPythonFunctionOperator<IN1,IN2,OUT>AbstractExternalTwoInputPythonFunctionOperatoris responsible for launching beam runner which will start a python harness to execute two-input user defined python function.classExternalPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT>TheExternalPythonBatchCoBroadcastProcessOperatoris responsible for executing the Python CoBroadcastProcess Function under BATCH mode,ExternalPythonCoProcessOperatoris used under STREAMING mode.classExternalPythonBatchKeyedCoBroadcastProcessOperator<OUT>TheExternalPythonBatchKeyedCoBroadcastProcessOperatoris responsible for executing the Python CoBroadcastProcess function under BATCH mode,ExternalPythonKeyedCoProcessOperatoris used under STREAMING mode.classExternalPythonCoProcessOperator<IN1,IN2,OUT>TheExternalPythonCoProcessOperatoris responsible for executing the Python CoProcess Function.classExternalPythonKeyedCoProcessOperator<OUT>ExternalPythonKeyedCoProcessOperatoris responsible for launching beam runner which will start a python harness to execute user defined python CoProcess function.classExternalPythonKeyedProcessOperator<OUT>ExternalPythonKeyedProcessOperatoris responsible for launching beam runner which will start a python harness to execute user defined python function.classExternalPythonProcessOperator<IN,OUT>ExternalPythonProcessOperatoris responsible for launching beam runner which will start a python harness to execute user defined python ProcessFunction. -
Uses of Internal in org.apache.flink.streaming.api.operators.python.process.collector
Classes in org.apache.flink.streaming.api.operators.python.process.collector with annotations of type Internal Modifier and Type Class Description classRunnerOutputCollector<OUT>Output collector for Python UDF runner. -
Uses of Internal in org.apache.flink.streaming.api.operators.python.process.timer
Classes in org.apache.flink.streaming.api.operators.python.process.timer with annotations of type Internal Modifier and Type Class Description classTimerHandlerUtilities to handle triggered timer.classTimerRegistrationHandles the interaction with the Python worker for registering and deleting timers.classTimerUtilsUtilities for timer. -
Uses of Internal in org.apache.flink.streaming.api.operators.sortpartition
Classes in org.apache.flink.streaming.api.operators.sortpartition with annotations of type Internal Modifier and Type Class Description classFixedLengthByteKeyAndValueComparator<INPUT>TheFixedLengthByteKeyAndValueComparatoris used byKeyedSortPartitionOperatorto compare records according to both the record key and record value.classKeyedSortPartitionOperator<INPUT,KEY>TheKeyedSortPartitionOperatorsorts records of a partition onKeyedStream.classSortPartitionOperator<INPUT>TheSortPartitionOperatorsorts records of a partition on non-keyed data stream.classVariableLengthByteKeyAndValueComparator<INPUT>TheVariableLengthByteKeyAndValueComparatoris used byKeyedSortPartitionOperatorto compare records according to both the record key and record value. -
Uses of Internal in org.apache.flink.streaming.api.operators.source
Classes in org.apache.flink.streaming.api.operators.source with annotations of type Internal Modifier and Type Class Description classNoOpTimestampsAndWatermarks<T>An implementation ofTimestampsAndWatermarkswhere all watermarking/event-time operations are no-ops.classProgressiveTimestampsAndWatermarks<T>An implementation ofTimestampsAndWatermarksthat does periodic watermark emission and keeps track of watermarks on a per-split basis.classSourceOutputWithWatermarks<T>Implementation of the SourceOutput.interfaceTimestampsAndWatermarks<T>Basic interface for the timestamp extraction and watermark generation logic for theSourceReader.static classTimestampsAndWatermarks.TimestampsAndWatermarksContextProviderstatic interfaceTimestampsAndWatermarks.WatermarkUpdateListenerLets the owner/creator of the output know about latest emitted watermark.classTimestampsAndWatermarksContextA simple implementation of a context that is bothTimestampAssignerSupplier.ContextandWatermarkGeneratorSupplier.Context.classWatermarkToDataOutputAn adapter that exposes aWatermarkOutputbased on aPushingAsyncDataInput.DataOutput. -
Uses of Internal in org.apache.flink.streaming.api.operators.util
Classes in org.apache.flink.streaming.api.operators.util with annotations of type Internal Modifier and Type Class Description classPausableRelativeClockARelativeClockwhose time progress with respect to the wall clock can be paused and un-paused. -
Uses of Internal in org.apache.flink.streaming.api.runners.python.beam
Classes in org.apache.flink.streaming.api.runners.python.beam with annotations of type Internal Modifier and Type Class Description classBeamDataStreamPythonFunctionRunnerBeamDataStreamPythonFunctionRunneris responsible for starting a beam python harness to execute user defined python function.classBeamPythonFunctionRunnerABeamPythonFunctionRunnerused to execute Python functions.classPythonSharedResourcesThe set of resources that can be shared by all the Python operators in a slot. -
Uses of Internal in org.apache.flink.streaming.api.transformations
Classes in org.apache.flink.streaming.api.transformations with annotations of type Internal Modifier and Type Class Description classAbstractBroadcastStateTransformation<IN1,IN2,OUT>Base class for Broadcast State transformations.classAbstractMultipleInputTransformation<OUT>Base class for transformations representing the application of aMultipleInputStreamOperatorto inputTransformations.classBroadcastStateTransformation<IN1,IN2,OUT>A non-keyedAbstractBroadcastStateTransformation.classCacheTransformation<T>When in batch mode, theCacheTransformationrepresents the intermediate result of the upper stream should be cached when it is computed at the first time.classDataStreamV2SinkTransformation<InputT,OutputT>TheTransformationfor DataStream V2 based sink.classGlobalCommitterTransform<CommT>Transformation for global committer.classKeyedBroadcastStateTransformation<KEY,IN1,IN2,OUT>A keyedAbstractBroadcastStateTransformation.classKeyedMultipleInputTransformation<OUT>AbstractMultipleInputTransformationimplementation for keyed streams.classLegacySinkTransformation<T>This Transformation represents a stream Sink.classLegacySourceTransformation<T>This represents a Source.classMultipleInputTransformation<OUT>AbstractMultipleInputTransformationimplementation for non-keyed streams.classOneInputTransformation<IN,OUT>This Transformation represents the application of aOneInputStreamOperatorto one inputTransformation.classPartitionTransformation<T>This transformation represents a change of partitioning of the input elements.classPhysicalTransformation<T>ATransformationthat creates a physical operation.classReduceTransformation<IN,K>ATransformationthat describes a reduce operation on aKeyedStream.classSinkTransformation<InputT,OutputT>ATransformationforSink.classSourceTransformation<OUT,SplitT extends SourceSplit,EnumChkT>APhysicalTransformationforSource.classSourceTransformationWrapper<T>This Transformation is a phantom transformation which is used to expose a default parallelism to downstream.classStreamExchangeModeThe data exchange mode between operators duringStreamGraphgeneration.classTimestampsAndWatermarksTransformation<IN>classTransformationWithLineage<T>ATransformationthat contains lineage information.classTwoInputTransformation<IN1,IN2,OUT>This Transformation represents the application of aTwoInputStreamOperatorto two inputTransformations.classUnionTransformation<T>This transformation represents a union of several inputTransformations.interfaceWithBoundednessAn interface to be implemented by transformations that have explicitly setBoundedness. -
Uses of Internal in org.apache.flink.streaming.api.transformations.python
Classes in org.apache.flink.streaming.api.transformations.python with annotations of type Internal Modifier and Type Class Description classPythonBroadcastStateTransformation<IN1,IN2,OUT>ATransformationrepresenting a Python Co-Broadcast-Process operation, which will be translated into different operations byPythonBroadcastStateTransformationTranslator.classPythonKeyedBroadcastStateTransformation<OUT>ATransformationrepresenting a Python Keyed-Co-Broadcast-Process operation, which will be translated into different operations byPythonKeyedBroadcastStateTransformationTranslator. -
Uses of Internal in org.apache.flink.streaming.api.typeinfo.python
Classes in org.apache.flink.streaming.api.typeinfo.python with annotations of type Internal Modifier and Type Class Description classPickledByteArrayTypeInfoA PickledByteArrayTypeInfo indicates that the data of this type is a generated primitive byte array by pickle. -
Uses of Internal in org.apache.flink.streaming.api.utils
Classes in org.apache.flink.streaming.api.utils with annotations of type Internal Modifier and Type Class Description classByteArrayWrapperA wrapper of the byte array.classByteArrayWrapperSerializerThe serializer ofByteArrayWrapper.classPythonOperatorUtilsUtilities used by Python operators.classPythonTypeUtilsA util class for converting the given TypeInformation to other objects. -
Uses of Internal in org.apache.flink.streaming.api.watermark
Classes in org.apache.flink.streaming.api.watermark with annotations of type Internal Modifier and Type Class Description classInternalWatermarkTheWatermarkthat contains extra information to be used internally. -
Uses of Internal in org.apache.flink.streaming.api.windowing.assigners
Classes in org.apache.flink.streaming.api.windowing.assigners with annotations of type Internal Modifier and Type Class Description static classGlobalWindows.EndOfStreamTriggerA trigger that fires iff the input stream reaches EndOfStream.static classGlobalWindows.NeverTriggerA trigger that never fires, as default Trigger for GlobalWindows. -
Uses of Internal in org.apache.flink.streaming.runtime.execution
Classes in org.apache.flink.streaming.runtime.execution with annotations of type Internal Modifier and Type Class Description classDefaultJobCreatedEventDefault implementation forJobCreatedEvent. -
Uses of Internal in org.apache.flink.streaming.runtime.io
Classes in org.apache.flink.streaming.runtime.io with annotations of type Internal Modifier and Type Class Description classBlockingQueueBrokerBrokerfor theBlockingQueueused inStreamIterationHeadandStreamIterationTailfor implementing feedback streams.classDataInputStatusIt is an internal equivalent ofInputStatusthat provides additional non public statuses.classInputGateUtilUtility for dealing with input gates.classMultipleFuturesAvailabilityHelperThis class is semi-thread safe.classMultipleInputSelectionHandlerThis handler is mainly used for selecting the next available input index inStreamMultipleInputProcessor.interfacePushingAsyncDataInput<T>The variant ofPullingAsyncDataInputthat is defined for handling both network input and source input in a unified way viaPushingAsyncDataInput.emitNext(DataOutput)instead of returningOptional.empty()viaPullingAsyncDataInput.pollNext().classRecordWriterOutput<OUT>Implementation of
-