Skip navigation links

Back to Flink Website

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ 

A

A - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
abort(CheckpointFailureReason, Throwable) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Aborts a checkpoint with reason and cause.
abort(CheckpointFailureReason) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Aborts a checkpoint with reason and cause.
abort() - Method in class org.apache.flink.runtime.operators.hash.AbstractMutableHashTable
 
abort() - Method in class org.apache.flink.runtime.operators.hash.CompactingHashTable
 
abort() - Method in class org.apache.flink.runtime.operators.hash.InPlaceMutableHashTable
 
abort() - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable
 
abort() - Method in class org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashJoinIterator
 
abort() - Method in class org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator
 
abort() - Method in class org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashJoinIterator
 
abort() - Method in class org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashJoinIterator
 
abort() - Method in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator
 
abort() - Method in interface org.apache.flink.runtime.operators.util.JoinTaskIterator
Aborts the matching process.
abort(TXN) - Method in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction
Abort a transaction.
abort(FlinkKafkaProducer.KafkaTransactionState) - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
 
abort(FlinkKafkaProducer011.KafkaTransactionState) - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011
 
abortCheckpointOnBarrier(long, Throwable) - Method in class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
Aborts a checkpoint as the result of receiving possibly some checkpoint barriers, but at least one CancelCheckpointMarker.
abortCheckpointOnBarrier(long, Throwable) - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
abortPendingCheckpoints(CheckpointException) - Method in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
Aborts all the pending checkpoints due to en exception.
abortTransaction() - Method in class org.apache.flink.streaming.connectors.kafka.internal.FlinkKafkaInternalProducer
 
abortTransaction() - Method in class org.apache.flink.streaming.connectors.kafka.internal.FlinkKafkaProducer
 
ABS - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
abs() - Method in class org.apache.flink.table.dataformat.Decimal
 
ABS - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ABS - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
abs(Decimal) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
ABSENT - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
absentKeysOrValues() - Method in class org.apache.flink.util.LinkedOptionalMap
Returns the key names of any keys or values that are absent.
ABSOLUTE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
absoluteTimeMillis() - Method in class org.apache.flink.runtime.util.clock.Clock
 
absoluteTimeMillis() - Method in class org.apache.flink.runtime.util.clock.SystemClock
 
AbstractAggregatedMetricsHeaders<P extends AbstractAggregatedMetricsParameters<?>> - Class in org.apache.flink.runtime.rest.messages.job.metrics
Based MessageHeaders class for aggregating metrics.
AbstractAggregatedMetricsHeaders() - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AbstractAggregatedMetricsHeaders
 
AbstractAggregatedMetricsParameters<M extends MessageQueryParameter<?>> - Class in org.apache.flink.runtime.rest.messages.job.metrics
Base MessageParameters class for aggregating metrics.
AbstractAggregatingMetricsHandler<P extends AbstractAggregatedMetricsParameters<?>> - Class in org.apache.flink.runtime.rest.handler.job.metrics
Abstract request handler for querying aggregated metrics.
AbstractAggregatingMetricsHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, AbstractAggregatedMetricsHeaders<P>, Executor, MetricFetcher) - Constructor for class org.apache.flink.runtime.rest.handler.job.metrics.AbstractAggregatingMetricsHandler
 
AbstractAsynchronousOperationHandlers<K extends OperationKey,R> - Class in org.apache.flink.runtime.rest.handler.async
HTTP handlers for asynchronous operations.
AbstractAsynchronousOperationHandlers() - Constructor for class org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers
 
AbstractAsynchronousOperationHandlers.StatusHandler<T extends RestfulGateway,V,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.async
Handler which will be polled to retrieve the asynchronous operation's result.
AbstractAsynchronousOperationHandlers.TriggerHandler<T extends RestfulGateway,B extends RequestBody,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.async
Handler which is responsible for triggering an asynchronous operation.
AbstractAzureFSFactory - Class in org.apache.flink.fs.azurefs
Abstract factory for AzureFS.
AbstractAzureFSFactory() - Constructor for class org.apache.flink.fs.azurefs.AbstractAzureFSFactory
 
AbstractBaseRowConverter(DataType[]) - Constructor for class org.apache.flink.table.dataformat.DataFormatConverters.AbstractBaseRowConverter
 
AbstractBinaryExternalMerger<Entry> - Class in org.apache.flink.table.runtime.operators.sort
Spilled files Merger of BinaryExternalSorter.
AbstractBinaryExternalMerger(IOManager, int, int, SpillChannelManager, boolean, BlockCompressionFactory, int) - Constructor for class org.apache.flink.table.runtime.operators.sort.AbstractBinaryExternalMerger
 
AbstractBinaryWriter - Class in org.apache.flink.table.dataformat
Use the special format to write data to a MemorySegment (its capacity grows automatically).
AbstractBinaryWriter() - Constructor for class org.apache.flink.table.dataformat.AbstractBinaryWriter
 
AbstractBlobCache - Class in org.apache.flink.runtime.blob
Abstract base class for permanent and transient BLOB files.
AbstractBlobCache(Configuration, BlobView, Logger, InetSocketAddress) - Constructor for class org.apache.flink.runtime.blob.AbstractBlobCache
 
AbstractBufferStorage - Class in org.apache.flink.streaming.runtime.io
A default abstract based class for BufferStorage implementations.
AbstractBufferStorage(long, String) - Constructor for class org.apache.flink.streaming.runtime.io.AbstractBufferStorage
 
AbstractBuffersUsageGauge - Class in org.apache.flink.runtime.io.network.metrics
Abstract gauge implementation for calculating the buffer usage percent.
AbstractCachedBuildSideJoinDriver<IT1,IT2,OT> - Class in org.apache.flink.runtime.operators
 
AbstractCachedBuildSideJoinDriver(int, int) - Constructor for class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver
 
AbstractCassandraTupleSink<IN> - Class in org.apache.flink.streaming.connectors.cassandra
Abstract sink to write tuple-like values into a Cassandra cluster.
AbstractCassandraTupleSink(String, ClusterBuilder, CassandraSinkBaseConfig, CassandraFailureHandler) - Constructor for class org.apache.flink.streaming.connectors.cassandra.AbstractCassandraTupleSink
 
AbstractCatalog - Class in org.apache.flink.table.catalog
Abstract class for catalogs.
AbstractCatalog(String, String) - Constructor for class org.apache.flink.table.catalog.AbstractCatalog
 
AbstractCatalogTable - Class in org.apache.flink.table.catalog
An abstract catalog table.
AbstractCatalogTable(TableSchema, Map<String, String>, String) - Constructor for class org.apache.flink.table.catalog.AbstractCatalogTable
 
AbstractCatalogTable(TableSchema, List<String>, Map<String, String>, String) - Constructor for class org.apache.flink.table.catalog.AbstractCatalogTable
 
AbstractCatalogView - Class in org.apache.flink.table.catalog
An abstract catalog view.
AbstractCatalogView(String, String, TableSchema, Map<String, String>, String) - Constructor for class org.apache.flink.table.catalog.AbstractCatalogView
 
AbstractChannelReaderInputView - Class in org.apache.flink.runtime.io.disk.iomanager
A DataInputView that is backed by a FileIOChannel, making it effectively a data input stream.
AbstractChannelReaderInputView(int) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AbstractChannelReaderInputView
 
AbstractChannelWriterOutputView - Class in org.apache.flink.runtime.io.disk.iomanager
A DataOutputView that is backed by a FileIOChannel, making it effectively a data output stream.
AbstractChannelWriterOutputView(int, int) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AbstractChannelWriterOutputView
 
AbstractCheckpointHandler<R extends ResponseBody,M extends CheckpointMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job.checkpoints
Base class for checkpoint related REST handler.
AbstractCheckpointHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor, CheckpointStatsCache) - Constructor for class org.apache.flink.runtime.rest.handler.job.checkpoints.AbstractCheckpointHandler
 
AbstractCheckpointMessage - Class in org.apache.flink.runtime.messages.checkpoint
The base class of all checkpoint messages.
AbstractCheckpointMessage(JobID, ExecutionAttemptID, long) - Constructor for class org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage
 
AbstractCheckpointStats - Class in org.apache.flink.runtime.checkpoint
Base class for checkpoint statistics.
AbstractCloseableRegistry<C extends Closeable,T> - Class in org.apache.flink.util
This is the abstract base class for registries that allow to register instances of Closeable, which are all closed if this registry is closed.
AbstractCloseableRegistry(Map<Closeable, T>) - Constructor for class org.apache.flink.util.AbstractCloseableRegistry
 
AbstractColumnVector - Class in org.apache.flink.table.dataformat.vector
Contains the shared structure for ColumnVectors, including NULL information and dictionary.
AbstractColumnVector() - Constructor for class org.apache.flink.table.dataformat.vector.AbstractColumnVector
 
AbstractCustomCommandLine - Class in org.apache.flink.client.cli
Base class for CustomCommandLine implementations which specify a JobManager address and a ZooKeeper namespace.
AbstractCustomCommandLine(Configuration) - Constructor for class org.apache.flink.client.cli.AbstractCustomCommandLine
 
AbstractDataOutput<T> - Class in org.apache.flink.streaming.runtime.io
Base class for all data outputs.
AbstractDataOutput(StreamStatusMaintainer, Object) - Constructor for class org.apache.flink.streaming.runtime.io.AbstractDataOutput
 
AbstractDeserializationSchema<T> - Class in org.apache.flink.api.common.serialization
The deserialization schema describes how to turn the byte messages delivered by certain data sources (for example Apache Kafka) into data types (Java/Scala objects) that are processed by Flink.
AbstractDeserializationSchema() - Constructor for class org.apache.flink.api.common.serialization.AbstractDeserializationSchema
Creates a new AbstractDeserializationSchema and tries to infer the type returned by this DeserializationSchema.
AbstractDeserializationSchema(Class<T>) - Constructor for class org.apache.flink.api.common.serialization.AbstractDeserializationSchema
Creates an AbstractDeserializationSchema that returns the TypeInformation indicated by the given class.
AbstractDeserializationSchema(TypeHint<T>) - Constructor for class org.apache.flink.api.common.serialization.AbstractDeserializationSchema
Creates an AbstractDeserializationSchema that returns the TypeInformation indicated by the given type hint.
AbstractDeserializationSchema(TypeInformation<T>) - Constructor for class org.apache.flink.api.common.serialization.AbstractDeserializationSchema
Creates an AbstractDeserializationSchema that returns the given TypeInformation for the produced type.
AbstractDeserializationSchema<T> - Class in org.apache.flink.streaming.util.serialization
Deprecated.
AbstractDeserializationSchema() - Constructor for class org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema
Deprecated.
 
AbstractEvent - Class in org.apache.flink.runtime.event
This type of event can be used to exchange notification messages between different TaskExecutor objects at runtime using the communication channels.
AbstractEvent() - Constructor for class org.apache.flink.runtime.event.AbstractEvent
 
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for all AccessExecutionGraph based REST handlers.
AbstractExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler
 
AbstractFetcher<T,KPH> - Class in org.apache.flink.streaming.connectors.kafka.internals
Base class for all fetchers, which implement the connections to Kafka brokers and pull records from Kafka partitions.
AbstractFetcher(SourceFunction.SourceContext<T>, Map<KafkaTopicPartition, Long>, SerializedValue<AssignerWithPeriodicWatermarks<T>>, SerializedValue<AssignerWithPunctuatedWatermarks<T>>, ProcessingTimeService, long, ClassLoader, MetricGroup, boolean) - Constructor for class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher
 
AbstractFileIOChannel - Class in org.apache.flink.runtime.io.disk.iomanager
 
AbstractFileIOChannel(FileIOChannel.ID, boolean) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel
Creates a new channel to the path indicated by the given ID.
AbstractFileStateBackend - Class in org.apache.flink.runtime.state.filesystem
A base class for all state backends that store their metadata (and data) in files.
AbstractFileStateBackend(URI, URI) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend
Creates a backend with the given optional checkpoint- and savepoint base directories.
AbstractFileStateBackend(Path, Path) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend
Creates a backend with the given optional checkpoint- and savepoint base directories.
AbstractFileStateBackend(Path, Path, Configuration) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend
Creates a new backend using the given checkpoint-/savepoint directories, or the values defined in the given configuration.
AbstractFsCheckpointStorage - Class in org.apache.flink.runtime.state.filesystem
An implementation of durable checkpoint storage to file systems.
AbstractFsCheckpointStorage(JobID, Path) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage
Creates a new checkpoint storage.
AbstractHandler<T extends RestfulGateway,R extends RequestBody,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler
Super class for netty-based handlers that work with RequestBody.
AbstractHandler(GatewayRetriever<? extends T>, Time, Map<String, String>, UntypedResponseMessageHeaders<R, M>) - Constructor for class org.apache.flink.runtime.rest.handler.AbstractHandler
 
AbstractHashTableProber<PT,BT> - Class in org.apache.flink.runtime.operators.hash
 
AbstractHashTableProber(TypeComparator<PT>, TypePairComparator<PT, BT>) - Constructor for class org.apache.flink.runtime.operators.hash.AbstractHashTableProber
 
AbstractHeapPriorityQueue<T extends HeapPriorityQueueElement> - Class in org.apache.flink.runtime.state.heap
Abstract base class for heap (object array) based implementations of priority queues, with support for fast deletes via HeapPriorityQueueElement.
AbstractHeapPriorityQueue(int) - Constructor for class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue
 
AbstractHeapState<K,N,SV> - Class in org.apache.flink.runtime.state.heap
Base class for partitioned State implementations that are backed by a regular heap hash map.
AbstractHeapVector - Class in org.apache.flink.table.dataformat.vector.heap
Heap vector that nullable shared structure.
AbstractHeapVector(int) - Constructor for class org.apache.flink.table.dataformat.vector.heap.AbstractHeapVector
 
AbstractID - Class in org.apache.flink.util
A statistically unique identification number.
AbstractID(byte[]) - Constructor for class org.apache.flink.util.AbstractID
Constructs a new ID with a specific bytes value.
AbstractID(long, long) - Constructor for class org.apache.flink.util.AbstractID
Constructs a new abstract ID.
AbstractID(AbstractID) - Constructor for class org.apache.flink.util.AbstractID
Copy constructor: Creates a new abstract ID from the given one.
AbstractID() - Constructor for class org.apache.flink.util.AbstractID
Constructs a new random ID from a uniform distribution.
AbstractInvokable - Class in org.apache.flink.runtime.jobgraph.tasks
This is the abstract base class for every task that can be executed by a TaskManager.
AbstractInvokable(Environment) - Constructor for class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
Create an Invokable task and set its environment.
AbstractIterativeTask<S extends Function,OT> - Class in org.apache.flink.runtime.iterative.task
The abstract base class for all tasks able to participate in an iteration.
AbstractIterativeTask(Environment) - Constructor for class org.apache.flink.runtime.iterative.task.AbstractIterativeTask
Create an Invokable task and set its environment.
AbstractJarPlanHeaders - Class in org.apache.flink.runtime.webmonitor.handlers
Message headers for JarPlanHandler.
AbstractJarPlanHeaders() - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AbstractJarPlanHeaders
 
AbstractJDBCOutputFormat<T> - Class in org.apache.flink.api.java.io.jdbc
OutputFormat to write Rows into a JDBC database.
AbstractJDBCOutputFormat(String, String, String, String) - Constructor for class org.apache.flink.api.java.io.jdbc.AbstractJDBCOutputFormat
 
AbstractJobVertexHandler<R extends ResponseBody,M extends JobVertexMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for request handlers whose response depends on a specific job vertex (defined via the "JobVertexIdPathParameter.KEY" parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY" parameter).
AbstractJobVertexHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractJobVertexHandler
Instantiates a new Abstract job vertex handler.
AbstractJoinDescriptor - Class in org.apache.flink.optimizer.operators
Defines the possible global properties for a join.
AbstractJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.AbstractJoinDescriptor
 
AbstractJoinDescriptor(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.AbstractJoinDescriptor
 
AbstractKeyedStateBackend<K> - Class in org.apache.flink.runtime.state
Base implementation of KeyedStateBackend.
AbstractKeyedStateBackend(TaskKvStateRegistry, TypeSerializer<K>, ClassLoader, ExecutionConfig, TtlTimeProvider, CloseableRegistry, InternalKeyContext<K>) - Constructor for class org.apache.flink.runtime.state.AbstractKeyedStateBackend
 
AbstractKeyedStateBackend(TaskKvStateRegistry, TypeSerializer<K>, ClassLoader, ExecutionConfig, TtlTimeProvider, CloseableRegistry, StreamCompressionDecorator, InternalKeyContext<K>) - Constructor for class org.apache.flink.runtime.state.AbstractKeyedStateBackend
 
AbstractKeyedStateBackendBuilder<K> - Class in org.apache.flink.runtime.state
An abstract base implementation of the StateBackendBuilder interface.
AbstractKeyedStateBackendBuilder(TaskKvStateRegistry, TypeSerializer<K>, ClassLoader, int, KeyGroupRange, ExecutionConfig, TtlTimeProvider, Collection<KeyedStateHandle>, StreamCompressionDecorator, CloseableRegistry) - Constructor for class org.apache.flink.runtime.state.AbstractKeyedStateBackendBuilder
 
AbstractMapBundleOperator<K,V,IN,OUT> - Class in org.apache.flink.table.runtime.operators.bundle
The AbstractMapBundleOperator simply used a java Map to store the input elements in key-value form.
AbstractMergeInnerJoinIterator<T1,T2,O> - Class in org.apache.flink.runtime.operators.sort
An implementation of the JoinTaskIterator that realizes the joining through a sort-merge join strategy.
AbstractMergeInnerJoinIterator(MutableObjectIterator<T1>, MutableObjectIterator<T2>, TypeSerializer<T1>, TypeComparator<T1>, TypeSerializer<T2>, TypeComparator<T2>, TypePairComparator<T1, T2>, MemoryManager, IOManager, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.sort.AbstractMergeInnerJoinIterator
 
AbstractMergeIterator<T1,T2,O> - Class in org.apache.flink.runtime.operators.sort
 
AbstractMergeIterator(MutableObjectIterator<T1>, MutableObjectIterator<T2>, TypeSerializer<T1>, TypeComparator<T1>, TypeSerializer<T2>, TypeComparator<T2>, TypePairComparator<T1, T2>, MemoryManager, IOManager, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.sort.AbstractMergeIterator
 
AbstractMergeOuterJoinIterator<T1,T2,O> - Class in org.apache.flink.runtime.operators.sort
An implementation of the JoinTaskIterator that realizes the outer join through a sort-merge join strategy.
AbstractMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType, MutableObjectIterator<T1>, MutableObjectIterator<T2>, TypeSerializer<T1>, TypeComparator<T1>, TypeSerializer<T2>, TypeComparator<T2>, TypePairComparator<T1, T2>, MemoryManager, IOManager, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.sort.AbstractMergeOuterJoinIterator
 
AbstractMesosServices - Class in org.apache.flink.mesos.runtime.clusterframework.services
An abstract implementation of MesosServices.
AbstractMesosServices(ActorSystem, MesosArtifactServer) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices
 
AbstractMetricGroup<A extends AbstractMetricGroup<?>> - Class in org.apache.flink.runtime.metrics.groups
Abstract MetricGroup that contains key functionality for adding metrics and groups.
AbstractMetricGroup(MetricRegistry, String[], A) - Constructor for class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
 
AbstractMetricGroup.ChildType - Enum in org.apache.flink.runtime.metrics.groups
Enum for indicating which child group should be created.
AbstractMetricsHandler<M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.job.metrics
Request handler that returns for a given task a list of all available metrics or the values for a set of metrics.
AbstractMetricsHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, MetricCollectionResponseBody, M>, MetricFetcher) - Constructor for class org.apache.flink.runtime.rest.handler.job.metrics.AbstractMetricsHandler
 
AbstractMetricsHeaders<M extends MessageParameters> - Class in org.apache.flink.runtime.rest.messages.job.metrics
AbstractMetricsHeaders() - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AbstractMetricsHeaders
 
AbstractMutableHashTable<T> - Class in org.apache.flink.runtime.operators.hash
 
AbstractMutableHashTable(TypeSerializer<T>, TypeComparator<T>) - Constructor for class org.apache.flink.runtime.operators.hash.AbstractMutableHashTable
 
AbstractNonHaServices - Class in org.apache.flink.runtime.highavailability.nonha
Abstract base class for non high-availability services.
AbstractNonHaServices() - Constructor for class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices
 
AbstractOperatorDescriptor - Interface in org.apache.flink.optimizer.operators
The root of all descriptions of an operator to the optimizer.
AbstractOuterJoinDriver<IT1,IT2,OT> - Class in org.apache.flink.runtime.operators
The abstract outer join driver implements the logic of an outer join operator at runtime.
AbstractOuterJoinDriver() - Constructor for class org.apache.flink.runtime.operators.AbstractOuterJoinDriver
 
AbstractPagedInputView - Class in org.apache.flink.runtime.memory
The base class for all input views that are backed by multiple memory pages.
AbstractPagedInputView(MemorySegment, int, int) - Constructor for class org.apache.flink.runtime.memory.AbstractPagedInputView
Creates a new view that starts with the given segment.
AbstractPagedInputView(int) - Constructor for class org.apache.flink.runtime.memory.AbstractPagedInputView
Creates a new view that is initially not bound to a memory segment.
AbstractPagedOutputView - Class in org.apache.flink.runtime.memory
The base class for all output views that are backed by multiple memory pages.
AbstractPagedOutputView(MemorySegment, int, int) - Constructor for class org.apache.flink.runtime.memory.AbstractPagedOutputView
Creates a new output view that writes initially to the given initial segment.
AbstractPagedOutputView(int, int) - Constructor for class org.apache.flink.runtime.memory.AbstractPagedOutputView
 
AbstractParameterTool - Class in org.apache.flink.api.java.utils
This class provides common utility methods of ParameterTool and MultipleParameterTool.
AbstractParameterTool() - Constructor for class org.apache.flink.api.java.utils.AbstractParameterTool
 
AbstractPartialSolutionNode - Class in org.apache.flink.optimizer.dag
The optimizer's internal representation of the partial solution that is input to a bulk iteration.
AbstractPartialSolutionNode(Operator<?>) - Constructor for class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode
 
AbstractPartitionDiscoverer - Class in org.apache.flink.streaming.connectors.kafka.internals
Base class for all partition discoverers.
AbstractPartitionDiscoverer(KafkaTopicsDescriptor, int, int) - Constructor for class org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer
 
AbstractPartitionDiscoverer.ClosedException - Exception in org.apache.flink.streaming.connectors.kafka.internals
Thrown if this discoverer was used to discover partitions after it was closed.
AbstractPartitionDiscoverer.WakeupException - Exception in org.apache.flink.streaming.connectors.kafka.internals
Signaling exception to indicate that an actual Kafka call was interrupted.
AbstractPartitionTracker<K,M> - Class in org.apache.flink.runtime.io.network.partition
Base partition tracker implementation, providing underlying data-structures for storing partitions, their associated keys and meta-information.
AbstractPartitionTracker() - Constructor for class org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker
 
AbstractPerWindowStateStore(KeyedStateBackend<?>, ExecutionConfig) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.AbstractPerWindowStateStore
 
AbstractProcessStreamOperator<OUT> - Class in org.apache.flink.table.runtime.operators
AbstractProcessStreamOperator is a base class for stream operators without key.
AbstractProcessStreamOperator() - Constructor for class org.apache.flink.table.runtime.operators.AbstractProcessStreamOperator
 
AbstractProcessStreamOperator.ContextImpl - Class in org.apache.flink.table.runtime.operators
Information available in an invocation of processElement.
AbstractPrometheusReporter - Class in org.apache.flink.metrics.prometheus
base prometheus reporter for prometheus metrics.
AbstractPrometheusReporter() - Constructor for class org.apache.flink.metrics.prometheus.AbstractPrometheusReporter
 
AbstractPythonFunctionOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.python
Base class for all stream operators to execute Python functions.
AbstractPythonFunctionOperator() - Constructor for class org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator
 
AbstractPythonFunctionRunner<IN,OUT> - Class in org.apache.flink.python
An base class for PythonFunctionRunner.
AbstractPythonFunctionRunner(String, FnDataReceiver<OUT>, PythonEnv, StateRequestHandler, String[]) - Constructor for class org.apache.flink.python.AbstractPythonFunctionRunner
 
AbstractPythonScalarFunctionOperator<IN,OUT,UDFIN,UDFOUT> - Class in org.apache.flink.table.runtime.operators.python
Base class for all stream operators to execute Python ScalarFunctions.
AbstractPythonScalarFunctionRunner<IN,OUT> - Class in org.apache.flink.table.runtime.runners.python
Abstract PythonFunctionRunner used to execute Python ScalarFunctions.
AbstractPythonScalarFunctionRunner(String, FnDataReceiver<OUT>, PythonFunctionInfo[], PythonEnv, RowType, RowType, String[]) - Constructor for class org.apache.flink.table.runtime.runners.python.AbstractPythonScalarFunctionRunner
 
AbstractReader - Class in org.apache.flink.runtime.io.network.api.reader
A basic reader implementation, which wraps an input gate and handles events.
AbstractReader(InputGate) - Constructor for class org.apache.flink.runtime.io.network.api.reader.AbstractReader
 
AbstractReporter - Class in org.apache.flink.metrics.reporter
Base interface for custom metric reporters.
AbstractReporter() - Constructor for class org.apache.flink.metrics.reporter.AbstractReporter
 
AbstractRestHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler
Super class for netty-based handlers that work with RequestBodys and ResponseBodys.
AbstractRestHandler(GatewayRetriever<? extends T>, Time, Map<String, String>, MessageHeaders<R, P, M>) - Constructor for class org.apache.flink.runtime.rest.handler.AbstractRestHandler
 
AbstractRichFunction - Class in org.apache.flink.api.common.functions
An abstract stub implementation for rich user-defined functions.
AbstractRichFunction() - Constructor for class org.apache.flink.api.common.functions.AbstractRichFunction
 
AbstractRocksDBRestoreOperation<K> - Class in org.apache.flink.contrib.streaming.state.restore
Base implementation of RocksDB restore operation.
AbstractRocksDBRestoreOperation(KeyGroupRange, int, int, CloseableRegistry, ClassLoader, Map<String, RocksDBKeyedStateBackend.RocksDbKvStateInfo>, StateSerializerProvider<K>, File, File, DBOptions, Function<String, ColumnFamilyOptions>, RocksDBNativeMetricOptions, MetricGroup, Collection<KeyedStateHandle>, RocksDbTtlCompactFiltersManager) - Constructor for class org.apache.flink.contrib.streaming.state.restore.AbstractRocksDBRestoreOperation
 
AbstractRocksDBState<K,N,V> - Class in org.apache.flink.contrib.streaming.state
Base class for State implementations that store state in a RocksDB database.
AbstractRocksDBState(ColumnFamilyHandle, TypeSerializer<N>, TypeSerializer<V>, V, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Creates a new RocksDB backed state.
AbstractRowSerializer<T extends BaseRow> - Class in org.apache.flink.table.runtime.typeutils
Row serializer, provided paged serialize paged method.
AbstractRowSerializer() - Constructor for class org.apache.flink.table.runtime.typeutils.AbstractRowSerializer
 
AbstractRowTimeUnboundedPrecedingOver<K> - Class in org.apache.flink.table.runtime.operators.over
A basic implementation to support unbounded event-time over-window.
AbstractRowTimeUnboundedPrecedingOver(long, long, GeneratedAggsHandleFunction, LogicalType[], LogicalType[], int) - Constructor for class org.apache.flink.table.runtime.operators.over.AbstractRowTimeUnboundedPrecedingOver
 
AbstractRuntimeUDFContext - Class in org.apache.flink.api.common.functions.util
A standalone implementation of the RuntimeContext, created by runtime UDF operators.
AbstractRuntimeUDFContext(TaskInfo, ClassLoader, ExecutionConfig, Map<String, Accumulator<?, ?>>, Map<String, Future<Path>>, MetricGroup) - Constructor for class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext
 
AbstractS3FileSystemFactory - Class in org.apache.flink.fs.s3.common
Base class for file system factories that create S3 file systems.
AbstractS3FileSystemFactory(String, HadoopConfigLoader) - Constructor for class org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory
 
AbstractServerBase<REQ extends MessageBody,RESP extends MessageBody> - Class in org.apache.flink.queryablestate.network
The base class for every server in the queryable state module.
AbstractServerBase(String, InetAddress, Iterator<Integer>, Integer, Integer) - Constructor for class org.apache.flink.queryablestate.network.AbstractServerBase
Creates the AbstractServerBase.
AbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody> - Class in org.apache.flink.queryablestate.network
The base class of every handler used by an AbstractServerBase.
AbstractServerHandler(AbstractServerBase<REQ, RESP>, MessageSerializer<REQ, RESP>, KvStateRequestStats) - Constructor for class org.apache.flink.queryablestate.network.AbstractServerHandler
Create the handler.
AbstractSnapshotStrategy<T extends StateObject> - Class in org.apache.flink.runtime.state
Abstract base class for implementing SnapshotStrategy, that gives a consistent logging across state backends.
AbstractSnapshotStrategy(String) - Constructor for class org.apache.flink.runtime.state.AbstractSnapshotStrategy
 
AbstractSortMergeJoinDescriptor - Class in org.apache.flink.optimizer.operators
 
AbstractSortMergeJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor
 
AbstractSortMergeJoinDescriptor(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor
 
AbstractStateBackend - Class in org.apache.flink.runtime.state
An abstract base implementation of the StateBackend interface.
AbstractStateBackend() - Constructor for class org.apache.flink.runtime.state.AbstractStateBackend
 
AbstractStreamingJoinOperator - Class in org.apache.flink.table.runtime.operators.join.stream
Abstract implementation for streaming unbounded Join operator which defines some member fields can be shared between different implementations.
AbstractStreamingJoinOperator(BaseRowTypeInfo, BaseRowTypeInfo, GeneratedJoinCondition, JoinInputSideSpec, JoinInputSideSpec, boolean[], long) - Constructor for class org.apache.flink.table.runtime.operators.join.stream.AbstractStreamingJoinOperator
 
AbstractStreamingJoinOperator.AssociatedRecords - Class in org.apache.flink.table.runtime.operators.join.stream
The AbstractStreamingJoinOperator.AssociatedRecords is the records associated to the input row.
AbstractStreamingJoinOperator.OuterRecord - Class in org.apache.flink.table.runtime.operators.join.stream
An AbstractStreamingJoinOperator.OuterRecord is a composite of record and numOfAssociations.
AbstractStreamOperator<OUT> - Class in org.apache.flink.streaming.api.operators
Base class for all stream operators.
AbstractStreamOperator() - Constructor for class org.apache.flink.streaming.api.operators.AbstractStreamOperator
 
AbstractStreamOperator.CountingOutput<OUT> - Class in org.apache.flink.streaming.api.operators
Wrapping Output that updates metrics on the number of emitted elements.
AbstractSubtaskAttemptHandler<R extends ResponseBody,M extends SubtaskAttemptMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for request handlers whose response depends on a specific attempt (defined via the "SubtaskAttemptPathParameter.KEY" of a specific subtask (defined via the "SubtaskIndexPathParameter.KEY" in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY" parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY" parameter).
AbstractSubtaskAttemptHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractSubtaskAttemptHandler
Instantiates a new Abstract job vertex handler.
AbstractSubtaskHandler<R extends ResponseBody,M extends SubtaskMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for request handlers whose response depends on a specific subtask (defined via the "SubtaskIndexPathParameter.KEY" in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY" parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY" parameter).
AbstractSubtaskHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractSubtaskHandler
Instantiates a new Abstract job vertex handler.
AbstractTableInputFormat<T> - Class in org.apache.flink.addons.hbase
Abstract InputFormat to read data from HBase tables.
AbstractTableInputFormat() - Constructor for class org.apache.flink.addons.hbase.AbstractTableInputFormat
 
AbstractTaskManagerFileHandler<M extends TaskManagerMessageParameters> - Class in org.apache.flink.runtime.rest.handler.taskmanager
Base class for serving files from the TaskExecutor.
AbstractTaskManagerFileHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, UntypedResponseMessageHeaders<EmptyRequestBody, M>, GatewayRetriever<ResourceManagerGateway>, TransientBlobService, Time) - Constructor for class org.apache.flink.runtime.rest.handler.taskmanager.AbstractTaskManagerFileHandler
 
AbstractTestBase - Class in org.apache.flink.test.util
Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.
AbstractTestBase() - Constructor for class org.apache.flink.test.util.AbstractTestBase
 
AbstractTopNFunction - Class in org.apache.flink.table.runtime.operators.rank
Base class for TopN Function.
AbstractTwoInputStreamTask<IN1,IN2,OUT> - Class in org.apache.flink.streaming.runtime.tasks
Abstract class for executing a TwoInputStreamOperator.
AbstractTwoInputStreamTask(Environment) - Constructor for class org.apache.flink.streaming.runtime.tasks.AbstractTwoInputStreamTask
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
AbstractUdfOperator<OUT,FT extends Function> - Class in org.apache.flink.api.common.operators
Abstract superclass for all contracts that represent actual operators.
AbstractUdfOperator(UserCodeWrapper<FT>, OperatorInformation<OUT>, String) - Constructor for class org.apache.flink.api.common.operators.AbstractUdfOperator
Creates a new abstract operator with the given name wrapping the given user function.
AbstractUdfStreamOperator<OUT,F extends Function> - Class in org.apache.flink.streaming.api.operators
This is used as the base class for operators that have a user-defined function.
AbstractUdfStreamOperator(F) - Constructor for class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
 
AbstractUserClassPathJobGraphRetriever - Class in org.apache.flink.runtime.entrypoint.component
Abstract class for the JobGraphRetriever which supports getting user classpaths.
AbstractUserClassPathJobGraphRetriever(File) - Constructor for class org.apache.flink.runtime.entrypoint.component.AbstractUserClassPathJobGraphRetriever
 
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.base.BulkIterationBase.PartialSolutionPlaceHolder
 
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.base.DeltaIterationBase.SolutionSetPlaceHolder
 
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.base.DeltaIterationBase.WorksetPlaceHolder
 
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
 
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.GenericDataSinkBase
Accepts the visitor and applies it this instance.
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.GenericDataSourceBase
Accepts the visitor and applies it this instance.
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
Accepts the visitor and applies it this instance.
accept(Visitor<Operator<?>>) - Method in class org.apache.flink.api.common.Plan
Traverses the job depth first from all data sinks on towards the sources.
accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode
 
accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.DataSinkNode
 
accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.DataSourceNode
 
accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
This method implements the visit of a depth-first graph traversing visitor.
accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.SingleInputNode
 
accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.TwoInputNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.NAryUnionPlanNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.OptimizedPlan
Applies the given visitor top down to all nodes, starting at the sinks.
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.SourcePlanNode
 
accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.CallExpression
 
accept(ExpressionVisitor<R>) - Method in interface org.apache.flink.table.expressions.Expression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.FieldReferenceExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.LocalReferenceExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.LookupCallExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.TableReferenceExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.TypeLiteralExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.UnresolvedCallExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.UnresolvedReferenceExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.ValueLiteralExpression
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.AggregateQueryOperation
 
accept(QueryOperationVisitor<U>) - Method in class org.apache.flink.table.operations.CalculatedQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.CatalogQueryOperation
 
accept(ModifyOperationVisitor<T>) - Method in class org.apache.flink.table.operations.CatalogSinkModifyOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.DataSetQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.DistinctQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.FilterQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.JavaDataStreamQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.JoinQueryOperation
 
accept(ModifyOperationVisitor<T>) - Method in interface org.apache.flink.table.operations.ModifyOperation
 
accept(ModifyOperationVisitor<R>) - Method in class org.apache.flink.table.operations.OutputConversionModifyOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.ProjectQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in interface org.apache.flink.table.operations.QueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.ScalaDataStreamQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.SetQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.SortQueryOperation
 
accept(QueryOperationVisitor<R>) - Method in class org.apache.flink.table.operations.TableSourceQueryOperation
 
accept(ModifyOperationVisitor<R>) - Method in class org.apache.flink.table.operations.UnregisteredSinkModifyOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.WindowAggregateQueryOperation
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.planner.expressions.RexNodeExpression
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.planner.operations.DataStreamQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.planner.operations.PlannerQueryOperation
 
accept(Collection<OUT>, Throwable) - Method in class org.apache.flink.table.runtime.operators.join.lookup.DelegatingResultFuture
 
accept(DataTypeVisitor<R>) - Method in class org.apache.flink.table.types.AtomicDataType
 
accept(DataTypeVisitor<R>) - Method in class org.apache.flink.table.types.CollectionDataType
 
accept(DataTypeVisitor<R>) - Method in class org.apache.flink.table.types.DataType
 
accept(DataTypeVisitor<R>) - Method in class org.apache.flink.table.types.FieldsDataType
 
accept(DataTypeVisitor<R>) - Method in class org.apache.flink.table.types.KeyValueDataType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.AnyType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.ArrayType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.BigIntType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.BinaryType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.BooleanType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.CharType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.DateType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.DayTimeIntervalType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.DecimalType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.DistinctType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.DoubleType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.FloatType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.IntType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.LegacyTypeInformationType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.LocalZonedTimestampType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.LogicalType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.MapType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.MultisetType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.NullType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.RowType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.SmallIntType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.StructuredType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.SymbolType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.TimestampType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.TimeType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.TinyIntType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.TypeInformationAnyType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.UnresolvedUserDefinedType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.VarBinaryType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.VarCharType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.YearMonthIntervalType
 
accept(LogicalTypeVisitor<R>) - Method in class org.apache.flink.table.types.logical.ZonedTimestampType
 
accept(T) - Method in interface org.apache.flink.util.concurrent.FutureConsumerWithException
 
accept(T, U) - Method in interface org.apache.flink.util.function.BiConsumerWithException
Performs this operation on the given arguments.
accept(T) - Method in interface org.apache.flink.util.function.ThrowingConsumer
Performs this operation on the given argument.
accept(S, T, U) - Method in interface org.apache.flink.util.function.TriConsumer
Performs this operation on the given arguments.
accept(String, K, V) - Method in interface org.apache.flink.util.LinkedOptionalMap.ConsumerWithException
 
accept(Visitor<T>) - Method in interface org.apache.flink.util.Visitable
Contains the logic to invoke the visitor and continue the traversal.
acceptFile(FileStatus) - Method in class org.apache.flink.api.common.io.FileInputFormat
A simple hook to filter files and directories from the input.
acceptForStepFunction(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode
 
acceptForStepFunction(Visitor<OptimizerNode>) - Method in interface org.apache.flink.optimizer.dag.IterationNode
 
acceptForStepFunction(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode
 
acceptForStepFunction(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode
 
acceptForStepFunction(Visitor<PlanNode>) - Method in interface org.apache.flink.optimizer.plan.IterationPlanNode
 
acceptForStepFunction(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode
 
acceptOffers(AcceptOffers) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager
Accept offers as advised by the launch coordinator.
acceptOffers(AcceptOffers) - Method in interface org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerActions
Accept the given offers as advised by the launch coordinator.
AcceptOffers - Class in org.apache.flink.mesos.scheduler.messages
Local message sent by the launch coordinator to the scheduler to accept offers.
AcceptOffers(String, Collection<Protos.OfferID>, Collection<Protos.Offer.Operation>) - Constructor for class org.apache.flink.mesos.scheduler.messages.AcceptOffers
 
AcceptOffers(String, Collection<Protos.OfferID>, Collection<Protos.Offer.Operation>, Protos.Filters) - Constructor for class org.apache.flink.mesos.scheduler.messages.AcceptOffers
 
acceptsFileUploads() - Method in class org.apache.flink.runtime.rest.messages.job.JobSubmitHeaders
 
acceptsFileUploads() - Method in interface org.apache.flink.runtime.rest.messages.UntypedResponseMessageHeaders
Returns whether this header allows file uploads.
acceptsFileUploads() - Method in class org.apache.flink.runtime.webmonitor.handlers.JarUploadHeaders
 
acceptWithException(T) - Method in interface org.apache.flink.util.concurrent.FutureConsumerWithException
 
ACCESS_CONTROL_ALLOW_ORIGIN - Static variable in class org.apache.flink.configuration.WebOptions
The config parameter defining the Access-Control-Allow-Origin header for all responses from the web-frontend.
AccessExecution - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime Execution and {@link ArchivedExecution}.
AccessExecutionGraph - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime ExecutionGraph and ArchivedExecutionGraph.
AccessExecutionJobVertex - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
AccessExecutionVertex - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime ExecutionVertex and ArchivedExecutionVertex.
accessField(Field, Object) - Method in class org.apache.flink.api.java.typeutils.runtime.PojoComparator
This method is handling the IllegalAccess exceptions of Field.get()
accessKeyId(String) - Static method in class org.apache.flink.streaming.connectors.kinesis.config.AWSConfigConstants
 
accumulate(GenericUDAFEvaluator.AggregationBuffer, Object...) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF
 
accumulate(CollectAggFunction.CollectAccumulator<T>, T) - Method in class org.apache.flink.table.planner.functions.aggfunctions.CollectAggFunction
 
accumulate(GenericRow, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(GenericRow, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(GenericRow, Decimal) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.DecimalFirstValueAggFunction
 
accumulate(GenericRow, Decimal, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.DecimalFirstValueAggFunction
 
accumulate(GenericRow, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.StringFirstValueAggFunction
 
accumulate(GenericRow, BinaryString, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.StringFirstValueAggFunction
 
accumulate(GenericRow, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(GenericRow, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(GenericRow, Decimal) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction
 
accumulate(GenericRow, Decimal, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction
 
accumulate(GenericRow, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction
 
accumulate(GenericRow, BinaryString, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction
 
accumulate(GenericRow, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(GenericRow, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(GenericRow, Decimal) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.DecimalLastValueAggFunction
 
accumulate(GenericRow, Decimal, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.DecimalLastValueAggFunction
 
accumulate(GenericRow, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.StringLastValueAggFunction
 
accumulate(GenericRow, BinaryString, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.StringLastValueAggFunction
 
accumulate(GenericRow, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(GenericRow, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(GenericRow, Decimal) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction
 
accumulate(GenericRow, Decimal, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction
 
accumulate(GenericRow, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
 
accumulate(GenericRow, BinaryString, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
 
accumulate(ListAggWithRetractAggFunction.ListAggWithRetractAccumulator, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.ListAggWithRetractAggFunction
 
accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator, BinaryString, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.ListAggWsWithRetractAggFunction
 
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction
 
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<Decimal>, Decimal) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction
 
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<BinaryString>, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction.StringMaxWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<Decimal>, Decimal) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction.DecimalMinWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<BinaryString>, BinaryString) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction.StringMinWithRetractAggFunction
 
accumulate(BaseRow) - Method in interface org.apache.flink.table.runtime.generated.AggsHandleFunctionBase
Accumulates the input values to the accumulators.
accumulate(BaseRow) - Method in interface org.apache.flink.table.runtime.generated.NamespaceAggsHandleFunctionBase
Accumulates the input values to the accumulators.
ACCUMULATE_MSG - Static variable in class org.apache.flink.table.dataformat.util.BaseRowUtil
Indicates the row as an accumulate message.
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.Count1AggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.CountAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.DeclarativeAggregateFunction
Expressions for accumulating the mutable aggregation buffer based on an input row.
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.DenseRankAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.IncrSumAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.IncrSumWithRetractAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.ListAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.RankAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.RowNumberAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction
 
accumulateExpressions() - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction
 
Accumulator<V,R extends Serializable> - Interface in org.apache.flink.api.common.accumulators
Accumulators collect distributed statistics or aggregates in a from user functions and operators.
AccumulatorHelper - Class in org.apache.flink.api.common.accumulators
Helper functions for the interaction with Accumulator.
AccumulatorHelper() - Constructor for class org.apache.flink.api.common.accumulators.AccumulatorHelper
 
accumulatorMap - Variable in class org.apache.flink.runtime.operators.BatchTask
The accumulator map used in the RuntimeContext.
AccumulatorRegistry - Class in org.apache.flink.runtime.accumulators
Main accumulator registry which encapsulates user-defined accumulators.
AccumulatorRegistry(JobID, ExecutionAttemptID) - Constructor for class org.apache.flink.runtime.accumulators.AccumulatorRegistry
 
AccumulatorReport - Class in org.apache.flink.runtime.taskexecutor
A report about the current values of all accumulators of the TaskExecutor for a given job.
AccumulatorReport(List<AccumulatorSnapshot>) - Constructor for class org.apache.flink.runtime.taskexecutor.AccumulatorReport
 
accumulatorResults(Map<String, SerializedValue<OptionalFailure<Object>>>) - Method in class org.apache.flink.runtime.jobmaster.JobResult.Builder
 
AccumulatorsIncludeSerializedValueQueryParameter - Class in org.apache.flink.runtime.rest.messages
Query parameter for job's accumulator handler JobAccumulatorsHandler.
AccumulatorsIncludeSerializedValueQueryParameter() - Constructor for class org.apache.flink.runtime.rest.messages.AccumulatorsIncludeSerializedValueQueryParameter
 
AccumulatorSnapshot - Class in org.apache.flink.runtime.accumulators
This class encapsulates a map of accumulators for a single task.
AccumulatorSnapshot(JobID, ExecutionAttemptID, Map<String, Accumulator<?, ?>>) - Constructor for class org.apache.flink.runtime.accumulators.AccumulatorSnapshot
 
accumulatorTypes - Variable in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
accumulatorTypeStrategy(TypeStrategy) - Method in class org.apache.flink.table.functions.BuiltInFunctionDefinition.Builder
 
accumulatorTypeStrategy(TypeStrategy) - Method in class org.apache.flink.table.types.inference.TypeInference.Builder
Sets the strategy for inferring the intermediate accumulator data type of a function call.
Acknowledge - Class in org.apache.flink.runtime.messages
A generic acknowledgement message.
acknowledge(List<String>) - Method in class org.apache.flink.streaming.connectors.gcp.pubsub.BlockingGrpcPubSubSubscriber
 
acknowledge(List<AcknowledgeId>) - Method in interface org.apache.flink.streaming.connectors.gcp.pubsub.common.Acknowledger
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in interface org.apache.flink.runtime.checkpoint.CheckpointCoordinatorGateway
 
acknowledgeCheckpoint(long, CheckpointMetrics) - Method in interface org.apache.flink.runtime.execution.Environment
Confirms that the invokable has successfully completed all steps it needed to to for the checkpoint with the give checkpoint-ID.
acknowledgeCheckpoint(long, CheckpointMetrics, TaskStateSnapshot) - Method in interface org.apache.flink.runtime.execution.Environment
Confirms that the invokable has successfully completed all required steps for the checkpoint with the give checkpoint-ID.
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in class org.apache.flink.runtime.jobmaster.JobMaster
 
AcknowledgeCheckpoint - Class in org.apache.flink.runtime.messages.checkpoint
This message is sent from the TaskExecutor to the JobMaster to signal that the checkpoint of an individual task is completed.
AcknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Constructor for class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint
 
AcknowledgeCheckpoint(JobID, ExecutionAttemptID, long) - Constructor for class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in class org.apache.flink.runtime.scheduler.SchedulerBase
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in interface org.apache.flink.runtime.scheduler.SchedulerNG
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in class org.apache.flink.runtime.taskexecutor.rpc.RpcCheckpointResponder
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in interface org.apache.flink.runtime.taskmanager.CheckpointResponder
Acknowledges the given checkpoint.
acknowledgeCheckpoint(long, CheckpointMetrics) - Method in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment
 
acknowledgeCheckpoint(long, CheckpointMetrics, TaskStateSnapshot) - Method in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment
 
acknowledgeCheckpoint(long, CheckpointMetrics) - Method in class org.apache.flink.state.api.runtime.SavepointEnvironment
 
acknowledgeCheckpoint(long, CheckpointMetrics, TaskStateSnapshot) - Method in class org.apache.flink.state.api.runtime.SavepointEnvironment
 
acknowledgeIDs(long, Set<UId>) - Method in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase
This method must be implemented to acknowledge the given set of IDs back to the message queue.
acknowledgeIDs(long, Set<UId>) - Method in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
Acknowledges the session ids.
AcknowledgeIdsForCheckpoint<AcknowledgeId> - Class in org.apache.flink.streaming.connectors.gcp.pubsub.common
This class contains a checkpointId and a List of AcknowledgementIds.
acknowledgeMasterState(String, MasterState) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Acknowledges a master state (state generated on the checkpoint coordinator) to the pending checkpoint.
AcknowledgeOnCheckpoint<ACKID extends Serializable> - Class in org.apache.flink.streaming.connectors.gcp.pubsub.common
Helper class for SourceFunctions to acknowledge messages to external systems after a successful checkpoint.
AcknowledgeOnCheckpoint(Acknowledger<ACKID>) - Constructor for class org.apache.flink.streaming.connectors.gcp.pubsub.common.AcknowledgeOnCheckpoint
 
acknowledgeOnCheckpoint - Variable in class org.apache.flink.streaming.connectors.gcp.pubsub.PubSubSource
 
acknowledgeOnCheckpointFactory - Variable in class org.apache.flink.streaming.connectors.gcp.pubsub.PubSubSource
 
Acknowledger<AcknowledgeId> - Interface in org.apache.flink.streaming.connectors.gcp.pubsub.common
 
acknowledgeSessionIDs(List<SessionId>) - Method in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
Acknowledges the session ids.
acknowledgeSessionIDs(List<Long>) - Method in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
acknowledgeTask(ExecutionAttemptID, TaskStateSnapshot, CheckpointMetrics) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Acknowledges the task with the given execution attempt id and the given subtask state.
ACOS - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ACOS - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
acos(Decimal) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
acquire(int) - Method in interface org.apache.flink.api.common.io.ratelimiting.FlinkConnectorRateLimiter
Acquires permits for the rate limiter.
acquire(int) - Method in class org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter
 
acquireBudgetForKey(K, long) - Method in class org.apache.flink.runtime.util.KeyedBudgetManager
Tries to acquire budget for a given key.
acquireLease() - Method in class org.apache.flink.runtime.state.NonClosingCheckpointOutputStream
Returns a ResourceGuard.Lease that prevents closing this stream.
acquirePagedBudget(Iterable<K>, long) - Method in class org.apache.flink.runtime.util.KeyedBudgetManager
Tries to acquire budget for given keys which equals to the number of pages times default page size.
acquireResource() - Method in class org.apache.flink.util.ResourceGuard
Acquired access from one new client for the guarded resource.
ACTION - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ActionRequestFailureHandler - Interface in org.apache.flink.streaming.connectors.elasticsearch
An implementation of ActionRequestFailureHandler is provided by the user to define how failed ActionRequests should be handled, e.g.
ACTIVE - Static variable in class org.apache.flink.streaming.runtime.streamstatus.StreamStatus
 
ACTIVE_STATUS - Static variable in class org.apache.flink.streaming.runtime.streamstatus.StreamStatus
 
ActiveResourceManagerFactory<T extends ResourceIDRetrievable> - Class in org.apache.flink.runtime.resourcemanager
Resource manager factory which creates active ResourceManager implementations.
ActiveResourceManagerFactory() - Constructor for class org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory
 
ActorSystemScheduledExecutorAdapter - Class in org.apache.flink.runtime.concurrent.akka
Adapter to use a ActorSystem as a ScheduledExecutor.
ActorSystemScheduledExecutorAdapter(ActorSystem) - Constructor for class org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter
 
actualModVersion() - Method in exception org.apache.flink.runtime.executiongraph.GlobalModVersionMismatch
 
ADA - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
AdamicAdar<K extends CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.drivers
Driver for AdamicAdar.
AdamicAdar() - Constructor for class org.apache.flink.graph.drivers.AdamicAdar
 
AdamicAdar<K extends CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.similarity
http://social.cs.uiuc.edu/class/cs591kgk/friendsadamic.pdf
AdamicAdar() - Constructor for class org.apache.flink.graph.library.similarity.AdamicAdar
 
AdamicAdar.Result<T> - Class in org.apache.flink.graph.library.similarity
A result for the Adamic-Adar algorithm.
AdaptedRestartPipelinedRegionStrategyNG - Class in org.apache.flink.runtime.executiongraph.failover
This failover strategy uses flip1.RestartPipelinedRegionStrategy to make task failover decisions.
AdaptedRestartPipelinedRegionStrategyNG(ExecutionGraph) - Constructor for class org.apache.flink.runtime.executiongraph.failover.AdaptedRestartPipelinedRegionStrategyNG
 
AdaptedRestartPipelinedRegionStrategyNG.Factory - Class in org.apache.flink.runtime.executiongraph.failover
Factory that instantiates the AdaptedRestartPipelinedRegionStrategyNG.
adapterForIterator(Iterator<T>) - Static method in interface org.apache.flink.util.CloseableIterator
 
add(V) - Method in interface org.apache.flink.api.common.accumulators.Accumulator
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(double) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(long) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(int) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleCounter
Consider using DoubleCounter.add(double) instead for primitive double values
add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleCounter
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleMaximum
Consider using DoubleMaximum.add(double) instead for primitive double values
add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleMaximum
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleMinimum
Consider using DoubleMinimum.add(double) instead for primitive double values
add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleMinimum
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.Histogram
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntCounter
Consider using IntCounter.add(int) instead for primitive int values
add(int) - Method in class org.apache.flink.api.common.accumulators.IntCounter
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntMaximum
Consider using IntMaximum.add(int) instead for primitive integer values
add(int) - Method in class org.apache.flink.api.common.accumulators.IntMaximum
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntMinimum
Consider using IntMinimum.add(int) instead for primitive integer values
add(int) - Method in class org.apache.flink.api.common.accumulators.IntMinimum
 
add(T) - Method in class org.apache.flink.api.common.accumulators.ListAccumulator
 
add(Long) - Method in class org.apache.flink.api.common.accumulators.LongCounter
Consider using LongCounter.add(long) instead for primitive long values
add(long) - Method in class org.apache.flink.api.common.accumulators.LongCounter
 
add(Long) - Method in class org.apache.flink.api.common.accumulators.LongMaximum
Consider using LongMaximum.add(long) instead for primitive long values
add(long) - Method in class org.apache.flink.api.common.accumulators.LongMaximum
 
add(Long) - Method in class org.apache.flink.api.common.accumulators.LongMinimum
Consider using LongMinimum.add(long) instead for primitive long values
add(long) - Method in class org.apache.flink.api.common.accumulators.LongMinimum
 
add(T) - Method in class org.apache.flink.api.common.accumulators.SerializedListAccumulator
 
add(T, TypeSerializer<T>) - Method in class org.apache.flink.api.common.accumulators.SerializedListAccumulator
 
add(IN, ACC) - Method in interface org.apache.flink.api.common.functions.AggregateFunction
Adds the given input value to the given accumulator, returning the new accumulator value.
add(IN, ACC) - Method in class org.apache.flink.api.common.functions.RichAggregateFunction
 
add(IN) - Method in interface org.apache.flink.api.common.state.AppendingState
Updates the operator state accessible by AppendingState.get() by adding the given value to the list of values.
add(double, double) - Method in class org.apache.flink.api.java.summarize.aggregation.CompensatedSum
Increments the Kahan sum by adding a value and a correction term.
add(double) - Method in class org.apache.flink.api.java.summarize.aggregation.CompensatedSum
Increments the Kahan sum by adding a value without a correction term.
add(CompensatedSum) - Method in class org.apache.flink.api.java.summarize.aggregation.CompensatedSum
Increments the Kahan sum by adding two sums, and updating the correction term for reducing numeric errors.
add() - Method in class org.apache.flink.api.java.tuple.builder.Tuple0Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in class org.apache.flink.api.java.tuple.builder.Tuple10Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10) - Method in class org.apache.flink.api.java.tuple.builder.Tuple11Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11) - Method in class org.apache.flink.api.java.tuple.builder.Tuple12Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12) - Method in class org.apache.flink.api.java.tuple.builder.Tuple13Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13) - Method in class org.apache.flink.api.java.tuple.builder.Tuple14Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14) - Method in class org.apache.flink.api.java.tuple.builder.Tuple15Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15) - Method in class org.apache.flink.api.java.tuple.builder.Tuple16Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16) - Method in class org.apache.flink.api.java.tuple.builder.Tuple17Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17) - Method in class org.apache.flink.api.java.tuple.builder.Tuple18Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18) - Method in class org.apache.flink.api.java.tuple.builder.Tuple19Builder
 
add(T0) - Method in class org.apache.flink.api.java.tuple.builder.Tuple1Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19) - Method in class org.apache.flink.api.java.tuple.builder.Tuple20Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20) - Method in class org.apache.flink.api.java.tuple.builder.Tuple21Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21) - Method in class org.apache.flink.api.java.tuple.builder.Tuple22Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22) - Method in class org.apache.flink.api.java.tuple.builder.Tuple23Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, T23) - Method in class org.apache.flink.api.java.tuple.builder.Tuple24Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, T23, T24) - Method in class org.apache.flink.api.java.tuple.builder.Tuple25Builder
 
add(T0, T1) - Method in class org.apache.flink.api.java.tuple.builder.Tuple2Builder
 
add(T0, T1, T2) - Method in class org.apache.flink.api.java.tuple.builder.Tuple3Builder
 
add(T0, T1, T2, T3) - Method in class org.apache.flink.api.java.tuple.builder.Tuple4Builder
 
add(T0, T1, T2, T3, T4) - Method in class org.apache.flink.api.java.tuple.builder.Tuple5Builder
 
add(T0, T1, T2, T3, T4, T5) - Method in class org.apache.flink.api.java.tuple.builder.Tuple6Builder
 
add(T0, T1, T2, T3, T4, T5, T6) - Method in class org.apache.flink.api.java.tuple.builder.Tuple7Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7) - Method in class org.apache.flink.api.java.tuple.builder.Tuple8Builder
 
add(T0, T1, T2, T3, T4, T5, T6, T7, T8) - Method in class org.apache.flink.api.java.tuple.builder.Tuple9Builder
 
add(Utils.ChecksumHashCode) - Method in class org.apache.flink.api.java.Utils.ChecksumHashCode
 
add(String) - Method in class org.apache.flink.api.java.utils.RequiredParameters
Add a parameter based on its name.
add(Option) - Method in class org.apache.flink.api.java.utils.RequiredParameters
Add a parameter encapsulated in an Option object.
add(BlockElement) - Method in class org.apache.flink.configuration.description.Description.DescriptionBuilder
Block of description add.
add(MemorySize) - Method in class org.apache.flink.configuration.MemorySize
 
add(E) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 
add(byte[]) - Method in interface org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet.OrderedByteArraySetCache
Adds the given element, if it was not already contained.
add(byte[]) - Method in class org.apache.flink.contrib.streaming.state.TreeOrderedSetCache
 
add(KMeans.Point) - Method in class org.apache.flink.examples.java.clustering.KMeans.Point
 
add(Integer) - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator
Increases the result vector component at the specified position by 1.
add(int, Object) - Method in interface org.apache.flink.formats.parquet.utils.ParentDataHolder
 
add(int, Object) - Method in class org.apache.flink.formats.parquet.utils.RowConverter
 
add(ChecksumHashCode.Checksum) - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
 
add(ByteValue) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
 
add(CharValue) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
 
add(DoubleValue) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
 
add(FloatValue) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
 
add(IntValue) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
 
add(LongValue) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
 
add(NullValue) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
 
add(ShortValue) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
 
add(StringValue) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
 
add(T) - Method in interface org.apache.flink.graph.types.valuearray.ValueArray
Appends the value to this array if and only if the array capacity would not be exceeded.
add(int, int, double) - Method in class org.apache.flink.ml.common.linalg.DenseMatrix
Add the given value to a single element.
add(int, double) - Method in class org.apache.flink.ml.common.linalg.DenseVector
 
add(int, double) - Method in class org.apache.flink.ml.common.linalg.SparseVector
 
add(int, double) - Method in class org.apache.flink.ml.common.linalg.Vector
Add the i-th element of the vector by value "val".
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.Between
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.Equals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.In
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.IsNull
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.LessThan
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.LessThanEquals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.Not
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.NullSafeEquals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.Or
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcRowInputFormat.Predicate
 
add(Object) - Method in class org.apache.flink.queryablestate.client.state.ImmutableAggregatingState
 
add(Object) - Method in class org.apache.flink.queryablestate.client.state.ImmutableFoldingState
Deprecated.
 
add(V) - Method in class org.apache.flink.queryablestate.client.state.ImmutableListState
 
add(V) - Method in class org.apache.flink.queryablestate.client.state.ImmutableReducingState
 
add(T) - Method in class org.apache.flink.runtime.checkpoint.StateObjectCollection
 
add(BufferConsumer) - Method in class org.apache.flink.runtime.io.network.partition.ResultSubpartition
Adds the given buffer.
add(MetricDump) - Method in class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricStore
 
add(T) - Method in class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue
 
add(T) - Method in class org.apache.flink.runtime.state.heap.HeapPriorityQueueSet
Adds the element to the queue.
add(T) - Method in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue
 
add(T) - Method in interface org.apache.flink.runtime.state.InternalPriorityQueue
Adds the given element to the set, if it is not already contained.
add(S) - Method in class org.apache.flink.runtime.state.PartitionableListState
 
add(Task) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlot
Add the given task to the task slot.
add(T) - Method in class org.apache.flink.runtime.util.EvictingBoundedList
 
add(int) - Method in class org.apache.flink.runtime.util.IntArrayList
 
add(long) - Method in class org.apache.flink.runtime.util.LongArrayList
 
ADD - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction
 
add(Extractor<TO, OUT>) - Method in class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtract
 
add(ActionRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
Deprecated.
use the DeleteRequest, IndexRequest or UpdateRequest
add(DeleteRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
Add multiple DeleteRequest to the indexer to prepare for sending requests to Elasticsearch.
add(IndexRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
Add multiple IndexRequest to the indexer to prepare for sending requests to Elasticsearch.
add(UpdateRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
Add multiple UpdateRequest to the indexer to prepare for sending requests to Elasticsearch.
add(ActionRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch2.RequestIndexer
Deprecated.
 
add(E) - Method in class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Adds the element to the queue, or fails with an exception, if the queue is closed.
add(BufferOrEvent) - Method in class org.apache.flink.streaming.runtime.io.BufferSpiller
Deprecated.
 
add(BufferOrEvent) - Method in interface org.apache.flink.streaming.runtime.io.BufferStorage
Adds a buffer or event to the BufferStorage.
add(BufferOrEvent) - Method in class org.apache.flink.streaming.runtime.io.CachedBufferStorage
 
add(BufferOrEvent) - Method in class org.apache.flink.streaming.runtime.io.EmptyBufferStorage
 
add(BufferOrEvent) - Method in class org.apache.flink.streaming.runtime.io.LinkedBufferStorage
 
add(T) - Method in class org.apache.flink.table.api.dataview.ListView
Adds the given value to the list.
add(Decimal, Decimal, int, int) - Static method in class org.apache.flink.table.dataformat.Decimal
 
add(T) - Method in class org.apache.flink.table.runtime.dataview.StateListView
 
add(byte) - Method in class org.apache.flink.table.runtime.util.collections.ByteHashSet
 
add(double) - Method in class org.apache.flink.table.runtime.util.collections.DoubleHashSet
add(float) - Method in class org.apache.flink.table.runtime.util.collections.FloatHashSet
add(int) - Method in class org.apache.flink.table.runtime.util.collections.IntHashSet
 
add(long) - Method in class org.apache.flink.table.runtime.util.collections.LongHashSet
 
add(T) - Method in class org.apache.flink.table.runtime.util.collections.ObjectHashSet
 
add(short) - Method in class org.apache.flink.table.runtime.util.collections.ShortHashSet
 
add(BaseRow) - Method in class org.apache.flink.table.runtime.util.ResettableExternalBuffer
 
add(BaseRow) - Method in interface org.apache.flink.table.runtime.util.ResettableRowBuffer
Appends the specified row to the end of this buffer.
add(int, V) - Method in class org.apache.flink.types.ListValue
 
add(V) - Method in class org.apache.flink.types.ListValue
 
add(Iterator<T>) - Method in class org.apache.flink.util.UnionIterator
 
add_escapes(String) - Method in exception org.apache.flink.sql.parser.impl.ParseException
Used to convert raw characters to their escaped version when these raw version cannot be used as part of an ASCII string literal.
add_partition(Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
add_partitions(List<Partition>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
addAccumulator(String, Accumulator<V, A>) - Method in interface org.apache.flink.api.common.functions.RuntimeContext
Add this accumulator.
addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext
 
addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.graph.AnalyticHelper
Adds an accumulator by prepending the given name with a random string.
addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.state.api.runtime.SavepointRuntimeContext
 
addAcknowledgeId(ACKID) - Method in class org.apache.flink.streaming.connectors.gcp.pubsub.common.AcknowledgeOnCheckpoint
 
addAll(AggregatorRegistry) - Method in class org.apache.flink.api.common.aggregators.AggregatorRegistry
 
addAll(List<T>) - Method in interface org.apache.flink.api.common.state.ListState
Updates the operator state accessible by AppendingState.get() by adding the given values to existing list of values.
addAll(Configuration) - Method in class org.apache.flink.configuration.Configuration
 
addAll(Configuration, String) - Method in class org.apache.flink.configuration.Configuration
Adds all entries from the given configuration into this configuration.
addAll(Configuration) - Method in class org.apache.flink.configuration.DelegatingConfiguration
 
addAll(Configuration, String) - Method in class org.apache.flink.configuration.DelegatingConfiguration
 
addAll(Configuration) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
 
addAll(Configuration, String) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
 
addAll(Collection<? extends E>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
 
addAll(ValueArray<ByteValue>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
 
addAll(ValueArray<CharValue>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
 
addAll(ValueArray<DoubleValue>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
 
addAll(ValueArray<FloatValue>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
 
addAll(ValueArray<IntValue>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
 
addAll(ValueArray<LongValue>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
 
addAll(ValueArray<NullValue>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
 
addAll(ValueArray<ShortValue>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
 
addAll(ValueArray<StringValue>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
 
addAll(ValueArray<T>) - Method in interface org.apache.flink.graph.types.valuearray.ValueArray
Appends all of the values in the specified array to the end of this array.
addAll(List<V>) - Method in class org.apache.flink.queryablestate.client.state.ImmutableListState
 
addAll(Collection<? extends T>) - Method in class org.apache.flink.runtime.checkpoint.StateObjectCollection
 
addAll(Collection<? extends T>) - Method in class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue
 
addAll(Collection<? extends T>) - Method in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue
 
addAll(List<T>) - Method in interface org.apache.flink.runtime.state.internal.InternalListState
Updates the operator state accessible by AppendingState.get() by adding the given values to existing list of values.
addAll(Collection<? extends T>) - Method in interface org.apache.flink.runtime.state.InternalPriorityQueue
Adds all the given elements to the set.
addAll(List<S>) - Method in class org.apache.flink.runtime.state.PartitionableListState
 
addAll(List<T>) - Method in class org.apache.flink.table.api.dataview.ListView
Adds all of the elements of the specified list to this list view.
addAll(List<T>) - Method in class org.apache.flink.table.runtime.dataview.StateListView
 
addAll(Collection<? extends V>) - Method in class org.apache.flink.types.ListValue
 
addAll(int, Collection<? extends V>) - Method in class org.apache.flink.types.ListValue
 
addAllFields(Iterable<? extends FlinkFnApi.Schema.Field>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addAllInputs(Iterable<? extends FlinkFnApi.UserDefinedFunction.Input>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addAllToProperties(Properties) - Method in class org.apache.flink.configuration.Configuration
Adds all entries in this Configuration to the given Properties.
addAllToProperties(Properties) - Method in class org.apache.flink.configuration.DelegatingConfiguration
 
addAllToProperties(Properties) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
 
addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedFunction>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addAndLock(String, T) - Method in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore
Creates a state handle, stores it in ZooKeeper and locks it.
addAny(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addAppConfigurationEntry(String, AppConfigurationEntry...) - Method in class org.apache.flink.runtime.security.DynamicConfiguration
Add entries for the given application name.
addArgument(String) - Method in class org.apache.flink.tests.util.flink.JobSubmission.JobSubmissionBuilder
Adds a program argument.
addArgument(String, String) - Method in class org.apache.flink.tests.util.flink.JobSubmission.JobSubmissionBuilder
Convenience method for providing key-value program arguments.
addArtificialDamCost(EstimateProvider, long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addArtificialDamCost(EstimateProvider, long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addAvroGenericDataArrayRegistration(LinkedHashMap<String, KryoRegistration>) - Method in class org.apache.flink.api.java.typeutils.AvroUtils
Registers a special Serializer for GenericData.Array.
addAvroGenericDataArrayRegistration(LinkedHashMap<String, KryoRegistration>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
 
addAvroSerializersIfRequired(ExecutionConfig, Class<?>) - Method in class org.apache.flink.api.java.typeutils.AvroUtils
Loads the utility class from flink-avro and adds Avro-specific serializers.
addAvroSerializersIfRequired(ExecutionConfig, Class<?>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
 
addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addBroadcastConnection(String, DagConnection) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
Adds the broadcast connection identified by the given name to this node.
addBroadcastCost(EstimateProvider, int, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addBroadcastCost(EstimateProvider, int, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addBroadcastInputToGroup(int) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addBroadcastSet(String, DataSet<?>) - Method in class org.apache.flink.graph.pregel.VertexCentricConfiguration
Adds a data set as a broadcast set to the compute function.
addBroadcastSetForApplyFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration
Adds a data set as a broadcast set to the apply function.
addBroadcastSetForGatherFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration
Adds a data set as a broadcast set to the gather function.
addBroadcastSetForGatherFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration
Adds a data set as a broadcast set to the gather function.
addBroadcastSetForScatterFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration
Adds a data set as a broadcast set to the scatter function.
addBroadcastSetForSumFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration
Adds a data set as a broadcast set to the sum function.
addBufferConsumer(BufferConsumer, int) - Method in interface org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter
Adds the bufferConsumer to the subpartition with the given index.
addBufferConsumer(BufferConsumer, int) - Method in class org.apache.flink.runtime.io.network.partition.ResultPartition
 
addBufferConsumer(BufferConsumer, int) - Method in class org.apache.flink.runtime.taskmanager.ConsumableNotifyingResultPartitionWriterDecorator
 
addBufferListener(BufferListener) - Method in interface org.apache.flink.runtime.io.network.buffer.BufferProvider
Adds a buffer availability listener to the buffer provider.
addCachedHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addCachedHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
Calculates the costs for the cached variant of the hybrid hash join.
addChainedTask(Class<? extends ChainedDriver>, TaskConfig, String) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addChannel(FileIOChannel.ID) - Method in class org.apache.flink.table.runtime.operators.sort.SpillChannelManager
Add a new File channel.
addCheckpoint(CompletedCheckpoint) - Method in interface org.apache.flink.runtime.checkpoint.CompletedCheckpointStore
Adds a CompletedCheckpoint instance to the list of completed checkpoints.
addCheckpoint(CompletedCheckpoint) - Method in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
 
addCheckpoint(CompletedCheckpoint) - Method in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore
Synchronously writes the new checkpoints to ZooKeeper and asynchronously removes older ones.
addChoices(String...) - Method in class org.apache.flink.graph.drivers.parameter.ChoiceParameter
Add additional choices.
addCloseableInternal(Closeable, T) - Method in class org.apache.flink.util.AbstractCloseableRegistry
Adds a mapping to the registry map, respecting locking.
addClosedBranch(OptimizerNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
addClosedBranches(Set<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
addColumn(String, String, Class<?>) - Method in class org.apache.flink.addons.hbase.HBaseTableSchema
Adds a column defined by family, qualifier, and type to the table schema.
addColumn(String, String, Class<?>) - Method in class org.apache.flink.addons.hbase.HBaseTableSource
Adds a column defined by family, qualifier, and type to the table schema.
addColumnFamilyOptionsToCloseLater(List<ColumnFamilyOptions>, ColumnFamilyHandle) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
 
addColumns(String) - Method in class org.apache.flink.table.api.internal.TableImpl
 
addColumns(Expression...) - Method in class org.apache.flink.table.api.internal.TableImpl
 
addColumns(String) - Method in interface org.apache.flink.table.api.Table
Adds additional columns.
addColumns(Expression...) - Method in interface org.apache.flink.table.api.Table
Adds additional columns.
addColumns(boolean, List<Expression>, QueryOperation) - Method in class org.apache.flink.table.operations.utils.OperationTreeBuilder
Adds additional columns.
addComparatorField(int, TypeComparator<?>) - Method in interface org.apache.flink.api.common.typeutils.CompositeType.TypeComparatorBuilder
 
addConfigAsMainClassArgs(Configuration) - Method in class org.apache.flink.test.util.TestProcessBuilder
 
addConfiguration(Configuration) - Method in class org.apache.flink.table.api.TableConfig
Adds the given key-value configuration to the underlying configuration.
addConfiguration(Configuration) - Method in interface org.apache.flink.tests.util.flink.FlinkResource
Adds the given configuration to the existing configuration of this resource.
addConfiguration(Configuration) - Method in class org.apache.flink.tests.util.flink.LocalStandaloneFlinkResource
 
addConnect(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addConsumer(JobEdge) - Method in class org.apache.flink.runtime.jobgraph.IntermediateDataSet
 
addCoOperator(Integer, String, String, StreamOperatorFactory<OUT>, TypeInformation<IN1>, TypeInformation<IN2>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addCosts(Costs) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given costs to these costs.
addCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given CPU cost to the current CPU cost for this Costs object.
addCredit(int) - Method in interface org.apache.flink.runtime.io.network.NetworkSequenceViewReader
The credits from consumer are added in incremental way.
addDataSink(GenericDataSinkBase<?>) - Method in class org.apache.flink.api.common.Plan
Adds a data sink to the set of sinks in this program.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.common.ExecutionConfig
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.common.ExecutionConfig
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.java.ExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.java.ExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultResource(String) - Static method in class org.apache.hadoop.conf.Configuration
Add a default resource.
addDelete(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addDeprecation(String, String[], String) - Static method in class org.apache.hadoop.conf.Configuration
addDeprecation(String, String, String) - Static method in class org.apache.hadoop.conf.Configuration
Adds the deprecated key to the global deprecation map.
addDeprecation(String, String[]) - Static method in class org.apache.hadoop.conf.Configuration
addDeprecation(String, String) - Static method in class org.apache.hadoop.conf.Configuration
Adds the deprecated key to the global deprecation map when no custom message is provided.
addDeprecations(Configuration.DeprecationDelta[]) - Static method in class org.apache.hadoop.conf.Configuration
Adds a set of deprecated keys to the global deprecations.
addDimension(long, boolean) - Method in class org.apache.flink.graph.generator.GridGraph
Required configuration for each dimension of the graph.
addDiscoveredPartitions(List<KafkaTopicPartition>) - Method in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher
Adds a list of newly discovered partitions to the fetcher for consuming.
addDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the costs for disk to the current disk costs for this Costs object.
addEdge(SharedBufferEdge) - Method in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNode
 
addEdge(Vertex<K, VV>, Vertex<K, VV>, EV) - Method in class org.apache.flink.graph.Graph
Adds the given edge to the graph.
addEdge(Integer, Integer, int) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addEdges(List<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph
Adds the given list edges to the graph.
addElement(T) - Method in interface org.apache.flink.api.common.serialization.BulkWriter
Adds an element to the encoder.
addElement(T) - Method in class org.apache.flink.formats.parquet.ParquetBulkWriter
 
addElement(Tuple2<K, V>) - Method in class org.apache.flink.formats.sequencefile.SequenceFileWriter
 
addEscapes(String) - Static method in error org.apache.flink.sql.parser.impl.TokenMgrError
Replaces unprintable characters by their espaced (or unicode escaped) equivalents in the given string
addFeedbackEdge(Transformation<F>) - Method in class org.apache.flink.streaming.api.transformations.CoFeedbackTransformation
Adds a feedback edge.
addFeedbackEdge(Transformation<T>) - Method in class org.apache.flink.streaming.api.transformations.FeedbackTransformation
Adds a feedback edge.
addField(Integer) - Method in class org.apache.flink.api.common.operators.util.FieldList
 
addField(Integer) - Method in class org.apache.flink.api.common.operators.util.FieldSet
 
addField(Value) - Method in class org.apache.flink.types.Record
 
addFields(int...) - Method in class org.apache.flink.api.common.operators.util.FieldList
 
addFields(FieldSet) - Method in class org.apache.flink.api.common.operators.util.FieldList
 
addFields(int...) - Method in class org.apache.flink.api.common.operators.util.FieldSet
 
addFields(FieldSet) - Method in class org.apache.flink.api.common.operators.util.FieldSet
 
addFields(FlinkFnApi.Schema.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addFields(int, FlinkFnApi.Schema.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addFields(FlinkFnApi.Schema.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addFields(int, FlinkFnApi.Schema.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addFieldsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addFieldsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
addFile(File, String) - Method in class org.apache.flink.mesos.util.MesosArtifactServer
Adds a file to the artifact server.
addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addFirstInput(Operator<IN1>...) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addFirstInputs(List<Operator<IN1>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addForwardedField(int, int, int) - Method in class org.apache.flink.api.common.operators.DualInputSemanticProperties
Adds, to the existing information, a field that is forwarded directly from the source record(s) in the first input to the destination record(s).
addForwardedField(int, int) - Method in class org.apache.flink.api.common.operators.SingleInputSemanticProperties
Adds, to the existing information, a field that is forwarded directly from the source record(s) to the destination record(s).
addForwardedField(int, int) - Method in class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties
 
addGeneralOptions(Options) - Method in class org.apache.flink.client.cli.AbstractCustomCommandLine
 
addGeneralOptions(Options) - Method in interface org.apache.flink.client.cli.CustomCommandLine
Adds custom options to the existing general options.
addGeneralOptions(Options) - Method in class org.apache.flink.client.cli.DefaultCLI
 
addGeneralOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
 
addGet(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addGlobalProperties(RequestedGlobalProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
addGroup(int) - Method in class org.apache.flink.metrics.groups.UnregisteredMetricsGroup
 
addGroup(String) - Method in class org.apache.flink.metrics.groups.UnregisteredMetricsGroup
 
addGroup(String, String) - Method in class org.apache.flink.metrics.groups.UnregisteredMetricsGroup
 
addGroup(int) - Method in interface org.apache.flink.metrics.MetricGroup
Creates a new MetricGroup and adds it to this groups sub-groups.
addGroup(String) - Method in interface org.apache.flink.metrics.MetricGroup
Creates a new MetricGroup and adds it to this groups sub-groups.
addGroup(String, String) - Method in interface org.apache.flink.metrics.MetricGroup
Creates a new key-value MetricGroup pair.
addGroup(int) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
 
addGroup(String) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
 
addGroup(String, String) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
 
addGroup(String, String) - Method in class org.apache.flink.runtime.metrics.groups.GenericKeyMetricGroup
 
addGroup(int) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addGroup(String) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addGroup(String, String) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addHash(int) - Method in class org.apache.flink.runtime.operators.util.BloomFilter
 
addHashPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addHashPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addHead(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addHeuristicCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given heuristic CPU cost to the current heuristic CPU cost for this Costs object.
addHeuristicDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the heuristic costs for disk to the current heuristic disk costs for this Costs object.
addHeuristicNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the heuristic costs for network to the current heuristic network costs for this Costs object.
addHiddenChoices(String...) - Method in class org.apache.flink.graph.drivers.parameter.ChoiceParameter
Add additional hidden choices.
addHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addId(UId) - Method in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase
Adds an ID to be stored with the current checkpoint.
addIfOpen(E) - Method in class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Tries to add an element to the queue, if the queue is still open.
addIgnore(IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addIgnore(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addInEdge(StreamEdge) - Method in class org.apache.flink.streaming.api.graph.StreamNode
 
addInput(Operator<IN>...) - Method in class org.apache.flink.api.common.operators.GenericDataSinkBase
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInput(Operator<IN>...) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInput(List<Operator<IN>>) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInput(BaseRow, BaseRow) - Method in class org.apache.flink.table.runtime.operators.aggregate.MiniBatchGlobalGroupAggFunction
The previousAcc is accumulator, but input is a row in <key, accumulator> schema, the specific generated MiniBatchGlobalGroupAggFunction.localAgg will project the input to accumulator in merge method.
addInput(List<BaseRow>, BaseRow) - Method in class org.apache.flink.table.runtime.operators.aggregate.MiniBatchGroupAggFunction
 
addInput(BaseRow, BaseRow) - Method in class org.apache.flink.table.runtime.operators.aggregate.MiniBatchIncrementalGroupAggFunction
 
addInput(BaseRow, BaseRow) - Method in class org.apache.flink.table.runtime.operators.aggregate.MiniBatchLocalGroupAggFunction
 
addInput(V, IN) - Method in class org.apache.flink.table.runtime.operators.bundle.MapBundleFunction
Adds the given input to the given value, returning the new bundle value.
addInput(BaseRow, BaseRow) - Method in class org.apache.flink.table.runtime.operators.deduplicate.MiniBatchDeduplicateKeepFirstRowFunction
 
addInput(BaseRow, BaseRow) - Method in class org.apache.flink.table.runtime.operators.deduplicate.MiniBatchDeduplicateKeepLastRowFunction
 
addInputChannel(RemoteInputChannel) - Method in interface org.apache.flink.runtime.io.network.NetworkClientHandler
 
addInputFormat(OperatorID, InputFormat<?, ?>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
 
addInputFormat(OperatorID, UserCodeWrapper<? extends InputFormat<?, ?>>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
 
addInputFormat(OperatorID, UserCodeWrapper<? extends InputFormat<?, ?>>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.FormatUserCodeTable
 
addInputs(List<? extends Operator<IN>>) - Method in class org.apache.flink.api.common.operators.GenericDataSinkBase
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInputs(FlinkFnApi.UserDefinedFunction.Input) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(int, FlinkFnApi.UserDefinedFunction.Input) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(FlinkFnApi.UserDefinedFunction.Input.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(int, FlinkFnApi.UserDefinedFunction.Input.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputToBuffer(BinaryRow) - Method in class org.apache.flink.table.runtime.operators.window.grouping.WindowsGrouping
 
addInputToGroup(int) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addInterestingProperties(InterestingProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
addInternal(T) - Method in class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue
Implements how to add an element to the queue.
addInternal(T) - Method in class org.apache.flink.runtime.state.heap.HeapPriorityQueue
 
addIntoBuffer(BinaryRow) - Method in class org.apache.flink.table.runtime.operators.window.grouping.HeapWindowsGrouping
 
addIntoBuffer(BinaryRow) - Method in class org.apache.flink.table.runtime.operators.window.grouping.WindowsGrouping
 
addIOMetrics(AccessExecution, MetricFetcher, String, String) - Method in class org.apache.flink.runtime.rest.handler.util.MutableIOMetrics
Adds the IO metrics for the given attempt to this object.
addIterationAggregator(String, Aggregator<?>) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addIterationAggregators(Collection<AggregatorWithName<?>>) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
additionalProperties() - Method in class org.apache.flink.table.catalog.CatalogTableBuilder
 
additionalProperties() - Method in class org.apache.flink.table.descriptors.ConnectTableDescriptor
 
additionalProperties() - Method in class org.apache.flink.table.descriptors.TableDescriptor
Enables adding more specific properties to TableDescriptor.toProperties().
addJar(Path) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds the path of a JAR file required to run the job on a task manager.
addJars(List<URL>) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds the given jar files to the JobGraph via JobGraph.addJar(org.apache.flink.core.fs.Path).
addJob(JobGraph) - Method in class org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup
 
addJob(JobGraph) - Method in class org.apache.flink.runtime.metrics.groups.UnregisteredMetricGroups.UnregisteredJobManagerMetricGroup
 
addJob(JobID) - Method in class org.apache.flink.runtime.resourcemanager.JobLeaderIdService
Add a job to be monitored to retrieve the job leader id.
addJob(JobID, String) - Method in class org.apache.flink.runtime.taskexecutor.JobLeaderService
Add the given job to be monitored.
addList(List<T>) - Method in class org.apache.flink.util.UnionIterator
 
addLocalCandidates(Channel, List<Set<? extends NamedChannel>>, RequestedGlobalProperties, List<PlanNode>, CostEstimator) - Method in class org.apache.flink.optimizer.dag.SingleInputNode
 
addLocalCandidates(Channel, Channel, List<Set<? extends NamedChannel>>, RequestedGlobalProperties, RequestedGlobalProperties, List<PlanNode>, OperatorDescriptorDual.LocalPropertiesPair[], CostEstimator) - Method in class org.apache.flink.optimizer.dag.TwoInputNode
 
addLocalMergeCost(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addLocalMergeCost(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addLocalProperties(RequestedLocalProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
addLocalSortCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addLocalSortCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
AddLongValue() - Constructor for class org.apache.flink.graph.utils.GraphUtils.AddLongValue
 
addMainClassArg(String) - Method in class org.apache.flink.test.util.TestProcessBuilder
 
addMasterHook(MasterTriggerRestoreHook<?>) - Method in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
Adds the given master hook to the checkpoint coordinator.
addMetric(DMetric) - Method in class org.apache.flink.metrics.datadog.DSeries
 
addMetric(String, Metric, AbstractMetricGroup) - Method in class org.apache.flink.runtime.metrics.dump.MetricQueryService
 
addMetric(String, Metric) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
Adds the given metric to the group and registers it at the registry, if the group is not yet closed, and if no metric with the same name has been registered before.
addMonths(long, int) - Static method in class org.apache.calcite.avatica.util.DateTimeUtils
Adds a given number of months to a timestamp, represented as the number of milliseconds since the epoch.
addMonths(int, int) - Static method in class org.apache.calcite.avatica.util.DateTimeUtils
Adds a given number of months to a date, represented as the number of days since the epoch.
addNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the costs for network to the current network costs for this Costs object.
addNode(Integer, String, String, Class<? extends AbstractInvokable>, StreamOperatorFactory<?>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addNull() - Method in class org.apache.flink.table.runtime.util.collections.ByteHashSet
 
addNull() - Method in class org.apache.flink.table.runtime.util.collections.OptimizableHashSet
Add a null key.
addOpenChannels(List<FileIOChannel>) - Method in class org.apache.flink.table.runtime.operators.sort.SpillChannelManager
Open File channels.
addOperator(String, BootstrapTransformation<?>) - Method in class org.apache.flink.state.api.runtime.metadata.SavepointMetadata
 
addOperator(Transformation<?>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds an operator to the list of operators that should be executed when calling StreamExecutionEnvironment.execute().
addOperator(Integer, String, String, StreamOperatorFactory<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addOptions(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addOrReplaceColumns(String) - Method in class org.apache.flink.table.api.internal.TableImpl
 
addOrReplaceColumns(Expression...) - Method in class org.apache.flink.table.api.internal.TableImpl
 
addOrReplaceColumns(String) - Method in interface org.apache.flink.table.api.Table
Adds additional columns.
addOrReplaceColumns(Expression...) - Method in interface org.apache.flink.table.api.Table
Adds additional columns.
addOrReplaceColumns(List<String>, List<Expression>) - Static method in class org.apache.flink.table.operations.utils.factories.ColumnOperationUtils
Creates a projection list that adds new or replaces existing (if a column with corresponding name already exists) columns.
addOutEdge(StreamEdge) - Method in class org.apache.flink.streaming.api.graph.StreamNode
 
addOutgoingChannel(Channel) - Method in class org.apache.flink.optimizer.plan.PlanNode
Adds a channel to a successor node to this node.
addOutgoingConnection(DagConnection) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode
 
addOutgoingConnection(DagConnection) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
Adds a new outgoing connection to this node.
addOutputFormat(OperatorID, OutputFormat<?>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
 
addOutputFormat(OperatorID, UserCodeWrapper<? extends OutputFormat<?>>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
 
addOutputFormat(OperatorID, UserCodeWrapper<? extends OutputFormat<?>>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.FormatUserCodeTable
 
addOutputSelector(Integer, OutputSelector<T>) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addOutputSelector(OutputSelector<?>) - Method in class org.apache.flink.streaming.api.graph.StreamNode
 
addOutputShipStrategy(ShipStrategyType) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addParameter(Parameter<?>) - Method in class org.apache.flink.graph.drivers.parameter.ParameterizedBase
Adds a parameter to the list.
addParameters(OperatorID, Configuration) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
 
addParameters(OperatorID, String, String) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
 
addPatch(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addPath(Path, Path) - Method in class org.apache.flink.mesos.util.MesosArtifactServer
Adds a path to the artifact server.
addPost(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addPredicate(OrcRowInputFormat.Predicate) - Method in class org.apache.flink.orc.OrcRowInputFormat
Adds a filter predicate to reduce the number of rows to be returned by the input format.
addProceed(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addPropertiesWithPrefix(String, DescriptorProperties) - Method in class org.apache.flink.table.descriptors.ClassInstance
Internal method for properties conversion.
addPropertiesWithPrefix(String, DescriptorProperties) - Method in class org.apache.flink.table.descriptors.HierarchyDescriptor
Internal method for properties conversion.
addPropertiesWithPrefix(String, DescriptorProperties) - Method in class org.apache.flink.table.descriptors.LiteralValue
 
addPut(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addRange(long, long) - Method in class org.apache.flink.graph.generator.CirculantGraph
Required configuration for each range of offsets in the graph.
addRangePartitionCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addRangePartitionCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addReadFields(int, FieldSet) - Method in class org.apache.flink.api.common.operators.DualInputSemanticProperties
Adds, to the existing information, field(s) that are read in the source record(s) from the first input.
addReadFields(FieldSet) - Method in class org.apache.flink.api.common.operators.SingleInputSemanticProperties
Adds, to the existing information, field(s) that are read in the source record(s).
addRecord(Tuple2<Boolean, Row>) - Method in class org.apache.flink.api.java.io.jdbc.writer.AppendOnlyWriter
 
addRecord(Tuple2<Boolean, Row>) - Method in interface org.apache.flink.api.java.io.jdbc.writer.JDBCWriter
Add record to writer, the writer may cache the data.
addRecord(Tuple2<Boolean, Row>) - Method in class org.apache.flink.api.java.io.jdbc.writer.UpsertWriter
 
addRecord(T) - Method in class org.apache.flink.runtime.operators.sort.LargeRecordHandler
 
addRecord(BaseRow) - Method in interface org.apache.flink.table.runtime.operators.join.stream.state.JoinRecordStateView
Add a new record to the state view.
addRecord(BaseRow, int) - Method in interface org.apache.flink.table.runtime.operators.join.stream.state.OuterJoinRecordStateView
Adds a new record with the number of associations to the state view.
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Field.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.FieldType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.MapType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Input.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
 
addRequest(R) - Method in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
 
addResource(String) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(String, boolean) - Method in class org.apache.hadoop.conf.Configuration
 
addResource(URL) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(URL, boolean) - Method in class org.apache.hadoop.conf.Configuration
 
addResource(Path) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(Path, boolean) - Method in class org.apache.hadoop.conf.Configuration
 
addResource(InputStream) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(InputStream, boolean) - Method in class org.apache.hadoop.conf.Configuration
 
addResource(InputStream, String) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(InputStream, String, boolean) - Method in class org.apache.hadoop.conf.Configuration
 
addResource(Configuration) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
Address - Class in org.apache.flink.avro.generated
 
Address() - Constructor for class org.apache.flink.avro.generated.Address
Default constructor.
Address(Integer, String, String, String, String, String) - Constructor for class org.apache.flink.avro.generated.Address
All-args constructor.
ADDRESS - Static variable in class org.apache.flink.configuration.JobManagerOptions
The config parameter defining the network address to connect to for communication with the job manager.
ADDRESS - Static variable in class org.apache.flink.configuration.RestOptions
The address that should be used by clients to connect to the server.
ADDRESS - Static variable in class org.apache.flink.configuration.WebOptions
Config parameter defining the runtime monitor web-frontend server address.
address - Variable in class org.apache.flink.core.memory.MemorySegment
The address to the data, relative to the heap memory byte array.
address() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerLocation
Returns the network address the instance's task manager binds its sockets to.
address() - Method in class org.apache.flink.streaming.examples.statemachine.event.Alert
 
Address.Builder - Class in org.apache.flink.avro.generated
RecordBuilder for Address instances.
ADDRESS_OPTION - Static variable in class org.apache.flink.client.cli.CliFrontendParser
 
addressLimit - Variable in class org.apache.flink.core.memory.MemorySegment
The address one byte after the last addressable byte, i.e.
addressOption - Variable in class org.apache.flink.client.cli.AbstractCustomCommandLine
 
addressString() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerLocation
Gets the IP address where the TaskManager operates.
addRetrievedShardsToStream(String, List<StreamShardHandle>) - Method in class org.apache.flink.streaming.connectors.kinesis.proxy.GetShardListResult
 
addRetrievedShardToStream(String, StreamShardHandle) - Method in class org.apache.flink.streaming.connectors.kinesis.proxy.GetShardListResult
 
addRoute(HttpMethod, String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
Add route.
addRunOptions(Options) - Method in class org.apache.flink.client.cli.AbstractCustomCommandLine
 
addRunOptions(Options) - Method in interface org.apache.flink.client.cli.CustomCommandLine
Adds custom options to the existing run options.
addRunOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
 
addSecondInput(Operator<IN2>...) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addSecondInputs(List<Operator<IN2>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addShipFiles(List<File>) - Method in class org.apache.flink.yarn.YarnClusterDescriptor
Adds the given files to the list of files to ship.
addShutdownHook(AutoCloseable, String, Logger) - Static method in class org.apache.flink.util.ShutdownHookUtil
Adds a shutdown hook to the JVM and returns the Thread, which has been registered.
addShutdownHookThread(Thread, String, Logger) - Static method in class org.apache.flink.util.ShutdownHookUtil
Adds a shutdown hook to the JVM.
addSink(SinkFunction<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
Adds the given sink to this DataStream.
addSink(SinkFunction<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
 
addSink(Integer, String, String, StreamOperatorFactory<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addSink(DataStream<IN>) - Static method in class org.apache.flink.streaming.connectors.cassandra.CassandraSink
Writes a DataStream into a Cassandra database.
addSink(DataStream<IN>) - Static method in class org.apache.flink.streaming.connectors.cassandra.CassandraSink
Writes a DataStream into a Cassandra database.
addSource(SourceFunction<OUT>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a Data Source to the streaming topology.
addSource(SourceFunction<OUT>, String) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a data source with a custom type information thus opening a DataStream.
addSource(SourceFunction<OUT>, TypeInformation<OUT>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Ads a data source with a custom type information thus opening a DataStream.
addSource(SourceFunction<OUT>, String, TypeInformation<OUT>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Ads a data source with a custom type information thus opening a DataStream.
addSource(Integer, String, String, StreamOperatorFactory<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addSourceFieldOffset(SingleInputSemanticProperties, int, int) - Static method in class org.apache.flink.api.java.functions.SemanticPropUtil
Creates SemanticProperties by adding an offset to each input field index of the given SemanticProperties.
addSourceFieldOffsets(DualInputSemanticProperties, int, int, int, int) - Static method in class org.apache.flink.api.java.functions.SemanticPropUtil
Creates SemanticProperties by adding offsets to each input field index of the given SemanticProperties.
addStage() - Method in class org.apache.flink.cep.nfa.DeweyNumber
Creates a new dewey number from this such that a 0 is appended as new last digit.
addStateTransition(StateTransitionAction, State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addStreamedNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addStreamedNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addTake(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addTake(IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addTask(JobVertexID, ExecutionAttemptID, String, int, int) - Method in class org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup
 
addTask(JobVertexID, ExecutionAttemptID, String, int, int) - Method in class org.apache.flink.runtime.metrics.groups.UnregisteredMetricGroups.UnregisteredTaskManagerJobMetricGroup
 
addTask(Task) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Add the given task to the slot identified by the task's allocation id.
addTaskForJob(JobID, String, JobVertexID, ExecutionAttemptID, String, int, int) - Method in class org.apache.flink.runtime.metrics.groups.TaskManagerMetricGroup
 
addTaskForJob(JobID, String, JobVertexID, ExecutionAttemptID, String, int, int) - Method in class org.apache.flink.runtime.metrics.groups.UnregisteredMetricGroups.UnregisteredTaskManagerMetricGroup
 
addToDefaults(String, String) - Method in class org.apache.flink.api.java.utils.AbstractParameterTool
 
addToEnvironment(Map<String, String>, String, String) - Static method in class org.apache.flink.yarn.Utils
Copied method from org.apache.hadoop.yarn.util.Apps.
addToMessageDigest(MessageDigest) - Method in class org.apache.flink.runtime.blob.BlobKey
Adds the BLOB key to the given MessageDigest.
addToSelectList(List<SqlNode>, Set<String>, List<Map.Entry<String, RelDataType>>, SqlNode, SqlValidatorScope, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl
Adds an expression to a select list, ensuring that its alias does not clash with any existing expressions on the list.
addTrace(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addUdfs(FlinkFnApi.UserDefinedFunction) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addUdfs(int, FlinkFnApi.UserDefinedFunction) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addUdfs(FlinkFnApi.UserDefinedFunction.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addUdfs(int, FlinkFnApi.UserDefinedFunction.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addUdfsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addUdfsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
addUniqueField(FieldSet) - Method in class org.apache.flink.api.common.operators.CompilerHints
Adds a FieldSet to be unique
addUniqueField(int) - Method in class org.apache.flink.api.common.operators.CompilerHints
Adds a field as having only unique values.
addUniqueFieldCombination(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties
 
addUniqueFields(Set<FieldSet>) - Method in class org.apache.flink.api.common.operators.CompilerHints
Adds multiple FieldSets to be unique
addUniqueFields(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties
Adds a combination of fields that are unique in these data properties.
addUserArtifact(String, DistributedCache.DistributedCacheEntry) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds the path of a custom file required to run the job on a task manager.
addUserArtifactEntries(Collection<Tuple2<String, DistributedCache.DistributedCacheEntry>>, JobGraph) - Static method in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator
 
addUserJarBlobKey(PermanentBlobKey) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds the BLOB referenced by the key to the JobGraph's dependencies.
addVertex(Vertex<K, VV>) - Method in class org.apache.flink.graph.Graph
Adds the input vertex to the graph.
addVertex(JobVertex) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds a new task vertex to the job graph if it is not already included.
addVertex(JobVertex) - Method in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup
 
addVertexToGroup(JobVertexID) - Method in class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup
 
addVertices(List<Vertex<K, VV>>) - Method in class org.apache.flink.graph.Graph
Adds the list of vertices, passed as input, to the graph.
addView(ViewEntry) - Method in class org.apache.flink.table.client.gateway.SessionContext
 
addVirtualPartitionNode(Integer, Integer, StreamPartitioner<?>, ShuffleMode) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Adds a new virtual node that is used to connect a downstream vertex to an input with a certain partitioning.
addVirtualSelectNode(Integer, Integer, List<String>) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Adds a new virtual node that is used to connect a downstream vertex to only the outputs with the selected names.
addVirtualSideOutputNode(Integer, Integer, OutputTag) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Adds a new virtual node that is used to connect a downstream vertex to only the outputs with the selected side-output OutputTag.
addWindow(W, MergingWindowSet.MergeFunction<W>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.MergingWindowSet
Adds a new Window to the set of in-flight windows.
addWindow(W, MergingWindowSet.MergeFunction<W>) - Method in class org.apache.flink.table.runtime.operators.window.internal.MergingWindowSet
Adds a new Window to the set of in-flight windows.
adjustBeginLineColumn(int, int) - Method in class org.apache.flink.sql.parser.impl.SimpleCharStream
Method to adjust line and column numbers for the start of a token.
adjustGlobalPropertiesForFullParallelismChange() - Method in class org.apache.flink.optimizer.plan.Channel
 
adjustModifiedElement(T) - Method in class org.apache.flink.runtime.state.heap.HeapPriorityQueue
 
adjustRunLoopFrequency(long, long) - Method in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer
Adjusts loop timing to match target frequency if specified.
adjustTop() - Method in class org.apache.flink.runtime.operators.sort.PartialOrderPriorityQueue
Should be called when the Object at top changes values.
ADMIN - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
advance() - Method in class org.apache.flink.runtime.io.disk.iomanager.HeaderlessChannelReaderInputView
 
advance() - Method in class org.apache.flink.runtime.memory.AbstractPagedInputView
Advances the view to the next memory segment.
advance() - Method in class org.apache.flink.runtime.memory.AbstractPagedOutputView
Moves the output view to the next page.
advanceLastDiscoveredShardOfStream(String, String) - Method in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher
Updates the last discovered shard of a subscribed stream; only updates if the update is valid.
advanceNext() - Method in class org.apache.flink.table.runtime.hashtable.BuildSideIterator
 
advanceNext() - Method in class org.apache.flink.table.runtime.hashtable.BuildSideIterator.BucketIterator
 
advanceNext() - Method in class org.apache.flink.table.runtime.hashtable.LongHashPartition.MatchIterator
 
advanceNext() - Method in class org.apache.flink.table.runtime.hashtable.LookupBucketIterator
 
advanceNext() - Method in class org.apache.flink.table.runtime.hashtable.WrappedRowIterator
 
advanceNext() - Method in class org.apache.flink.table.runtime.util.ResettableExternalBuffer.BufferIterator
 
advanceNext() - Method in interface org.apache.flink.table.runtime.util.RowIterator
Advance this iterator by a single row.
advanceNextSuitableBufferedRow() - Method in class org.apache.flink.table.runtime.operators.join.SortMergeJoinIterator
 
advanceNextSuitableProbeRow() - Method in class org.apache.flink.table.runtime.operators.join.SortMergeJoinIterator
 
advanceTime(SharedBufferAccessor<T>, NFAState, long) - Method in class org.apache.flink.cep.nfa.NFA
Prunes states assuming there will be no events with timestamp lower than the given one.
advanceTime(long) - Method in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor
Notifies shared buffer that there will be no events with timestamp <&eq; the given value.
advanceToEndOfEventTime() - Method in class org.apache.flink.streaming.api.operators.StreamSource
 
advanceToEndOfEventTime() - Method in class org.apache.flink.streaming.runtime.tasks.SourceStreamTask
 
advanceToEndOfEventTime() - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
Emits the MAX_WATERMARK so that all registered timers are fired.
advanceWatermark(long) - Method in class org.apache.flink.streaming.api.operators.InternalTimerServiceImpl
 
advanceWatermark(Watermark) - Method in class org.apache.flink.streaming.api.operators.InternalTimeServiceManager
 
advanceWatermarkToTriggerAllWindows() - Method in class org.apache.flink.table.runtime.operators.window.grouping.WindowsGrouping
Advance the watermark to trigger all the possible windows.
AFTER - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
after() - Method in class org.apache.flink.test.util.MiniClusterWithClientResource
 
afterEndOfWindow() - Static method in class org.apache.flink.table.runtime.operators.window.triggers.EventTimeTriggers
Creates a trigger that fires when the watermark passes the end of the window.
AfterEndOfWindow() - Constructor for class org.apache.flink.table.runtime.operators.window.triggers.EventTimeTriggers.AfterEndOfWindow
 
afterEndOfWindow() - Static method in class org.apache.flink.table.runtime.operators.window.triggers.ProcessingTimeTriggers
Creates a trigger that fires when the processing time passes the end of the window.
AfterEndOfWindow() - Constructor for class org.apache.flink.table.runtime.operators.window.triggers.ProcessingTimeTriggers.AfterEndOfWindow
 
afterGrow() - Method in class org.apache.flink.table.dataformat.AbstractBinaryWriter
After grow, need point to new memory.
afterGrow() - Method in class org.apache.flink.table.dataformat.BinaryArrayWriter
 
afterGrow() - Method in class org.apache.flink.table.dataformat.BinaryRowWriter
 
AfterMatchSkipStrategy - Class in org.apache.flink.cep.nfa.aftermatch
Indicate the skip strategy after a match process.
afterTestFailure() - Method in class org.apache.flink.tests.util.flink.LocalStandaloneFlinkResource
 
afterTestFailure() - Method in class org.apache.flink.tests.util.FlinkDistribution
 
afterTestFailure() - Method in interface org.apache.flink.util.ExternalResource
 
afterTestSuccess() - Method in class org.apache.flink.tests.util.cache.LolCache
 
afterTestSuccess() - Method in class org.apache.flink.tests.util.flink.LocalStandaloneFlinkResource
 
afterTestSuccess() - Method in class org.apache.flink.tests.util.FlinkDistribution
 
afterTestSuccess() - Method in class org.apache.flink.tests.util.kafka.LocalStandaloneKafkaResource
 
afterTestSuccess() - Method in interface org.apache.flink.util.ExternalResource
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.Count1AggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.CountAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.DeclarativeAggregateFunction
All fields of the aggregate buffer.
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.DenseRankAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.IncrSumAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.IncrSumWithRetractAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.LeadLagAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.ListAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.RankAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.RowNumberAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.SingleValueAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction
 
aggBufferAttributes() - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction
 
aggregate(T) - Method in interface org.apache.flink.api.common.aggregators.Aggregator
Aggregates the given element.
aggregate(DoubleValue) - Method in class org.apache.flink.api.common.aggregators.DoubleSumAggregator
 
aggregate(double) - Method in class org.apache.flink.api.common.aggregators.DoubleSumAggregator
Adds the given value to the current aggregate.
aggregate(LongValue) - Method in class org.apache.flink.api.common.aggregators.LongSumAggregator
 
aggregate(long) - Method in class org.apache.flink.api.common.aggregators.LongSumAggregator
Adds the given value to the current aggregate.
aggregate(long) - Method in class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator
 
aggregate(LongValue) - Method in class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator
 
aggregate(T) - Method in class org.apache.flink.api.java.aggregation.AggregationFunction
 
aggregate(Aggregations, int) - Method in class org.apache.flink.api.java.DataSet
Applies an Aggregate transformation on a non-grouped Tuple DataSet.
aggregate(Aggregations, int) - Method in class org.apache.flink.api.java.operators.UnsortedGrouping
Applies an Aggregate transformation on a grouped Tuple DataSet.
aggregate(T) - Method in interface org.apache.flink.api.java.summarize.aggregation.Aggregator
Add a value to the current aggregation.
aggregate(Boolean) - Method in class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator
 
aggregate(Double) - Method in class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MaxDoubleAggregator
 
aggregate(Double) - Method in class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MinDoubleAggregator
 
aggregate(Double) - Method in class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.SumDoubleAggregator
 
aggregate(Float) - Method in class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MaxFloatAggregator
 
aggregate(Float) - Method in class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MinFloatAggregator
 
aggregate(Float) - Method in class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.SumFloatAggregator
 
aggregate(Integer) - Method in class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MaxIntegerAggregator
 
aggregate(Integer) - Method in class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MinIntegerAggregator
 
aggregate(Integer) - Method in class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.SumIntegerAggregator
 
aggregate(Long) - Method in class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MaxLongAggregator
 
aggregate(Long) - Method in class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MinLongAggregator
 
aggregate(T) - Method in class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator
Add a value to the current aggregation.
aggregate(Object) - Method in class org.apache.flink.api.java.summarize.aggregation.ObjectSummaryAggregator
 
aggregate(Short) - Method in class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MaxShortAggregator
 
aggregate(Short) - Method in class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MinShortAggregator
 
aggregate(Short) - Method in class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.SumShortAggregator
 
aggregate(String) - Method in class org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregator
 
aggregate(Tuple) - Method in class org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator
 
aggregate(VT) - Method in class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator
 
aggregate(AggregateFunction<T, ACC, R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given AggregateFunction to each window.
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given AggregateFunction to each window.
aggregate(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessAllWindowFunction<V, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessAllWindowFunction<V, R, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregationFunction<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
 
aggregate(AggregateFunction<T, ACC, R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(String) - Method in interface org.apache.flink.table.api.GroupedTable
Performs an aggregate operation with an aggregate function.
aggregate(Expression) - Method in interface org.apache.flink.table.api.GroupedTable
Performs an aggregate operation with an aggregate function.
aggregate(String) - Method in class org.apache.flink.table.api.internal.TableImpl
 
aggregate(Expression) - Method in class org.apache.flink.table.api.internal.TableImpl
 
aggregate(String) - Method in interface org.apache.flink.table.api.Table
Performs a global aggregate operation with an aggregate function.
aggregate(Expression) - Method in interface org.apache.flink.table.api.Table
Performs a global aggregate operation with an aggregate function.
aggregate(String) - Method in interface org.apache.flink.table.api.WindowGroupedTable
Performs an aggregate operation on a window grouped table.
aggregate(Expression) - Method in interface org.apache.flink.table.api.WindowGroupedTable
Performs an aggregate operation on a window grouped table.
aggregate(List<Expression>, List<Expression>, QueryOperation) - Method in class org.apache.flink.table.operations.utils.OperationTreeBuilder
 
aggregate(List<Expression>, Expression, QueryOperation) - Method in class org.apache.flink.table.operations.utils.OperationTreeBuilder
 
aggregate(LogicalType[], LogicalType[], LogicalType[]) - Method in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
aggregate(NamespaceAggsHandleFunction<?>, RecordEqualiser, LogicalType[], LogicalType[], LogicalType[]) - Method in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
aggregate(GeneratedNamespaceAggsHandleFunction<?>, GeneratedRecordEqualiser, LogicalType[], LogicalType[], LogicalType[]) - Method in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
aggregate(NamespaceTableAggsHandleFunction<?>, LogicalType[], LogicalType[], LogicalType[]) - Method in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
aggregate(GeneratedNamespaceTableAggsHandleFunction<?>, LogicalType[], LogicalType[], LogicalType[]) - Method in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
AggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R> - Class in org.apache.flink.streaming.api.functions.windowing
AggregateApplyAllWindowFunction(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>) - Constructor for class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction
 
AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R> - Class in org.apache.flink.streaming.api.functions.windowing
AggregateApplyWindowFunction(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>) - Constructor for class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction
 
AggregatedJobMetricsHeaders - Class in org.apache.flink.runtime.rest.messages.job.metrics
Headers for aggregating job metrics.
AggregatedJobMetricsParameters - Class in org.apache.flink.runtime.rest.messages.job.metrics
Parameters for aggregating job metrics.
AggregatedJobMetricsParameters() - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedJobMetricsParameters
 
AggregatedMetric - Class in org.apache.flink.runtime.rest.messages.job.metrics
Response type for aggregated metrics.
AggregatedMetric(String, Double, Double, Double, Double) - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric
 
AggregatedMetric(String) - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric
 
AggregatedMetricsResponseBody - Class in org.apache.flink.runtime.rest.messages.job.metrics
Response type for a collection of aggregated metrics.
AggregatedMetricsResponseBody(Collection<AggregatedMetric>) - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody
 
AggregatedMetricsResponseBody.Deserializer - Class in org.apache.flink.runtime.rest.messages.job.metrics
JSON deserializer for AggregatedMetricsResponseBody.
AggregatedMetricsResponseBody.Serializer - Class in org.apache.flink.runtime.rest.messages.job.metrics
JSON serializer for AggregatedMetricsResponseBody.
AggregatedSubtaskMetricsHeaders - Class in org.apache.flink.runtime.rest.messages.job.metrics
Headers for aggregating subtask metrics.
AggregatedSubtaskMetricsParameters - Class in org.apache.flink.runtime.rest.messages.job.metrics
Parameters for aggregating subtask metrics.
AggregatedSubtaskMetricsParameters() - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedSubtaskMetricsParameters
 
AggregatedTable - Interface in org.apache.flink.table.api
A table that has been performed on the aggregate function.
AggregatedTaskManagerMetricsHeaders - Class in org.apache.flink.runtime.rest.messages.job.metrics
Headers for aggregating task manager metrics.
AggregateFunction<IN,ACC,OUT> - Interface in org.apache.flink.api.common.functions
The AggregateFunction is a flexible aggregation function, characterized by the following features: The aggregates may use different types for input values, intermediate aggregates, and result type, to support a wide range of aggregation types. Support for distributive aggregations: Different intermediate aggregates can be merged together, to allow for pre-aggregation/final-aggregation optimizations.
AggregateFunction<T,ACC> - Class in org.apache.flink.table.functions
Base class for user-defined aggregates.
AggregateFunction() - Constructor for class org.apache.flink.table.functions.AggregateFunction
 
AggregateFunctionDefinition - Class in org.apache.flink.table.functions
The function definition of an user-defined aggregate function.
AggregateFunctionDefinition(String, AggregateFunction<?, ?>, TypeInformation<?>, TypeInformation<?>) - Constructor for class org.apache.flink.table.functions.AggregateFunctionDefinition
 
AggregateOperationFactory - Class in org.apache.flink.table.operations.utils.factories
Utility class for creating a valid AggregateQueryOperation or WindowAggregateQueryOperation.
AggregateOperationFactory(boolean) - Constructor for class org.apache.flink.table.operations.utils.factories.AggregateOperationFactory
 
AggregateOperator<IN> - Class in org.apache.flink.api.java.operators
This operator represents the application of a "aggregate" operation on a data set, and the result data set produced by the function.
AggregateOperator(DataSet<IN>, Aggregations, int, String) - Constructor for class org.apache.flink.api.java.operators.AggregateOperator
Non grouped aggregation.
AggregateOperator(Grouping<IN>, Aggregations, int, String) - Constructor for class org.apache.flink.api.java.operators.AggregateOperator
Grouped aggregation.
AggregatePhaseStrategy - Enum in org.apache.flink.table.planner.utils
Aggregate phase strategy which could be specified in OptimizerConfigOptions.TABLE_OPTIMIZER_AGG_PHASE_STRATEGY.
AggregateQueryOperation - Class in org.apache.flink.table.operations
Relational operation that performs computations on top of subsets of input rows grouped by key.
AggregateQueryOperation(List<ResolvedExpression>, List<ResolvedExpression>, QueryOperation, TableSchema) - Constructor for class org.apache.flink.table.operations.AggregateQueryOperation
 
AggregateTaskManagerMetricsParameters - Class in org.apache.flink.runtime.rest.messages.job.metrics
Parameters for aggregating task manager metrics.
AggregateTaskManagerMetricsParameters() - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AggregateTaskManagerMetricsParameters
 
aggregateUserAccumulators() - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
Merges all accumulator results from the tasks previously executed in the Executions.
AggregateWindowOperator<K,W extends Window> - Class in org.apache.flink.table.runtime.operators.window
A WindowOperator for grouped window aggregates.
AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?>, GeneratedRecordEqualiser, WindowOperatorBuilder) - Constructor for class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder.AggregateWindowOperatorBuilder
 
AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?>, RecordEqualiser, WindowOperatorBuilder) - Constructor for class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder.AggregateWindowOperatorBuilder
 
AggregatingJobsMetricsHandler - Class in org.apache.flink.runtime.rest.handler.job.metrics
Request handler that returns, aggregated across jobs, a list of all available metrics or the values for a set of metrics.
AggregatingJobsMetricsHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, Executor, MetricFetcher) - Constructor for class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler
 
AggregatingState<IN,OUT> - Interface in org.apache.flink.api.common.state
State interface for aggregating state, based on an AggregateFunction.
AggregatingStateDescriptor<IN,ACC,OUT> - Class in org.apache.flink.api.common.state
A StateDescriptor for AggregatingState.
AggregatingStateDescriptor(String, AggregateFunction<IN, ACC, OUT>, Class<ACC>) - Constructor for class org.apache.flink.api.common.state.AggregatingStateDescriptor
Creates a new state descriptor with the given name, function, and type.
AggregatingStateDescriptor(String, AggregateFunction<IN, ACC, OUT>, TypeInformation<ACC>) - Constructor for class org.apache.flink.api.common.state.AggregatingStateDescriptor
Creates a new ReducingStateDescriptor with the given name and default value.
AggregatingStateDescriptor(String, AggregateFunction<IN, ACC, OUT>, TypeSerializer<ACC>) - Constructor for class org.apache.flink.api.common.state.AggregatingStateDescriptor
Creates a new ValueStateDescriptor with the given name and default value.
AggregatingSubtasksMetricsHandler - Class in org.apache.flink.runtime.rest.handler.job.metrics
Request handler that returns, aggregated across subtasks, a list of all available metrics or the values for a set of metrics.
AggregatingSubtasksMetricsHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, Executor, MetricFetcher) - Constructor for class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler
 
AggregatingTaskManagersMetricsHandler - Class in org.apache.flink.runtime.rest.handler.job.metrics
Request handler that returns, aggregated across task managers, a list of all available metrics or the values for a set of metrics.
AggregatingTaskManagersMetricsHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, Executor, MetricFetcher) - Constructor for class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler
 
AGGREGATION_MAX_COUNT - Static variable in class org.apache.flink.streaming.connectors.kinesis.config.ProducerConfigConstants
Deprecated.
This is deprecated in favor of the official AWS Kinesis producer configuration keys. Please use AggregationMaxCount instead.
AGGREGATION_MAX_COUNT - Static variable in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtil
Maximum number of items to pack into an aggregated record.
AggregationFunction<T> - Class in org.apache.flink.api.java.aggregation
 
AggregationFunction() - Constructor for class org.apache.flink.api.java.aggregation.AggregationFunction
 
AggregationFunction<T> - Class in org.apache.flink.streaming.api.functions.aggregation
Holder class for aggregation types that can be used on a windowed stream or keyed stream.
AggregationFunction() - Constructor for class org.apache.flink.streaming.api.functions.aggregation.AggregationFunction
 
AggregationFunction.AggregationType - Enum in org.apache.flink.streaming.api.functions.aggregation
Aggregation types that can be used on a windowed stream or keyed stream.
AggregationFunctionFactory - Interface in org.apache.flink.api.java.aggregation
Interface of factory for creating AggregationFunction.
Aggregations - Enum in org.apache.flink.api.java.aggregation
Shortcuts for Aggregation factories.
Aggregator<T extends Value> - Interface in org.apache.flink.api.common.aggregators
Aggregators are a means of aggregating values across parallel instances of a function.
Aggregator<T,R> - Interface in org.apache.flink.api.java.summarize.aggregation
Generic interface for aggregation.
AGGREGATOR_NAME - Static variable in class org.apache.flink.runtime.iterative.convergence.WorksetEmptyConvergenceCriterion
 
AggregatorRegistry - Class in org.apache.flink.api.common.aggregators
A registry for iteration Aggregators.
AggregatorRegistry() - Constructor for class org.apache.flink.api.common.aggregators.AggregatorRegistry
 
AggregatorWithName<T extends Value> - Class in org.apache.flink.api.common.aggregators
Simple utility class holding an Aggregator with the name it is registered under.
AggregatorWithName(String, Aggregator<T>) - Constructor for class org.apache.flink.api.common.aggregators.AggregatorWithName
Creates a new instance for the given aggregator and name.
aggResultTypes - Variable in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
AggsHandleFunction - Interface in org.apache.flink.table.runtime.generated
The base class for handling aggregate functions.
AggsHandleFunctionBase - Interface in org.apache.flink.table.runtime.generated
The base class for handling aggregate or table aggregate functions.
AKKA_ASK_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_CLIENT_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_DISPATCHER_THROUGHPUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_FRAMESIZE - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_JVM_EXIT_ON_FATAL_ERROR - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_LOG_LIFECYCLE_EVENTS - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_LOOKUP_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_SSL_ENABLED - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_STARTUP_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_TCP_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_TRANSPORT_HEARTBEAT_INTERVAL - Static variable in class org.apache.flink.configuration.ConfigConstants
AKKA_TRANSPORT_HEARTBEAT_PAUSE - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_TRANSPORT_THRESHOLD - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
AKKA_WATCH_HEARTBEAT_INTERVAL - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
This option is no longer used and has no effect on Flink.
AKKA_WATCH_HEARTBEAT_PAUSE - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
This option is no longer used and has no effect on Flink.
AKKA_WATCH_THRESHOLD - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
This option is no longer used and has no effect on Flink.
AkkaHandshakeException - Exception in org.apache.flink.runtime.rpc.akka.exceptions
Exception which is thrown if the handshake fails.
AkkaHandshakeException(String) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaHandshakeException
 
AkkaHandshakeException(String, Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaHandshakeException
 
AkkaHandshakeException(Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaHandshakeException
 
AkkaOptions - Class in org.apache.flink.configuration
Akka configuration options.
AkkaOptions() - Constructor for class org.apache.flink.configuration.AkkaOptions
 
AkkaRpcException - Exception in org.apache.flink.runtime.rpc.akka.exceptions
Base class for Akka RPC related exceptions.
AkkaRpcException(String) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException
 
AkkaRpcException(String, Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException
 
AkkaRpcException(Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException
 
AkkaRpcInvalidStateException - Exception in org.apache.flink.runtime.rpc.akka.exceptions
Exception which indicates an invalid state.
AkkaRpcInvalidStateException(String) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcInvalidStateException
 
AkkaRpcInvalidStateException(Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcInvalidStateException
 
AkkaRpcInvalidStateException(String, Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcInvalidStateException
 
AkkaRpcService - Class in org.apache.flink.runtime.rpc.akka
Akka based RpcService implementation.
AkkaRpcService(ActorSystem, AkkaRpcServiceConfiguration) - Constructor for class org.apache.flink.runtime.rpc.akka.AkkaRpcService
 
AkkaRpcServiceConfiguration - Class in org.apache.flink.runtime.rpc.akka
Configuration for the AkkaRpcService.
AkkaRpcServiceConfiguration(Configuration, Time, long) - Constructor for class org.apache.flink.runtime.rpc.akka.AkkaRpcServiceConfiguration
 
AkkaRpcServiceUtils - Class in org.apache.flink.runtime.rpc.akka
These RPC utilities contain helper methods around RPC use, such as starting an RPC service, or constructing RPC addresses.
AkkaRpcServiceUtils.AkkaProtocol - Enum in org.apache.flink.runtime.rpc.akka
Whether to use TCP or encrypted TCP for Akka.
AkkaUnknownMessageException - Exception in org.apache.flink.runtime.rpc.akka.exceptions
Exception which indicates that the AkkaRpcActor has received an unknown message type.
AkkaUnknownMessageException(String) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaUnknownMessageException
 
AkkaUnknownMessageException(String, Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaUnknownMessageException
 
AkkaUnknownMessageException(Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaUnknownMessageException
 
Alert - Class in org.apache.flink.streaming.examples.statemachine.event
Data type for alerts.
Alert(int, State, EventType) - Constructor for class org.apache.flink.streaming.examples.statemachine.event.Alert
Creates a new alert.
Alert - Class in org.apache.flink.walkthrough.common.entity
A simple alert event.
Alert() - Constructor for class org.apache.flink.walkthrough.common.entity.Alert
 
AlertSink - Class in org.apache.flink.walkthrough.common.sink
A sink for outputting alerts.
AlertSink() - Constructor for class org.apache.flink.walkthrough.common.sink.AlertSink
 
AlgoOperator<T extends AlgoOperator<T>> - Class in org.apache.flink.ml.operator
Base class for algorithm operators.
AlgoOperator() - Constructor for class org.apache.flink.ml.operator.AlgoOperator
Construct the operator with empty Params.
AlgoOperator(Params) - Constructor for class org.apache.flink.ml.operator.AlgoOperator
Construct the operator with the initial Params.
AlgorithmOptions - Class in org.apache.flink.configuration
Configuration parameters for join/sort algorithms.
AlgorithmOptions() - Constructor for class org.apache.flink.configuration.AlgorithmOptions
 
alias(List<Expression>, QueryOperation) - Method in class org.apache.flink.table.operations.utils.OperationTreeBuilder
 
AliasOperationUtils - Class in org.apache.flink.table.operations.utils.factories
Utility class for creating valid alias expressions that can be later used as a projection.
all() - Static method in class org.apache.flink.runtime.types.FlinkChillPackageRegistrar
 
ALL - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ALL - Static variable in class org.apache.flink.streaming.api.operators.InputSelection
The InputSelection instance which indicates to select all inputs.
allActionsCompleted() - Method in interface org.apache.flink.streaming.runtime.tasks.mailbox.MailboxDefaultAction.Controller
This method must be called to end the stream task when all actions for the tasks have been performed.
allActionsCompleted() - Method in class org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor
This method must be called to end the stream task when all actions for the tasks have been performed.
allAllowedMethods() - Method in class org.apache.flink.runtime.rest.handler.router.Router
Returns all methods that this router handles.
AllFieldsForwardedProperties() - Constructor for class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties
 
AllGroupCombineDriver<IN,OUT> - Class in org.apache.flink.runtime.operators
Non-chained driver for the partial group reduce operator that acts like a combiner with a custom output type OUT.
AllGroupCombineDriver() - Constructor for class org.apache.flink.runtime.operators.AllGroupCombineDriver
 
AllGroupCombineProperties - Class in org.apache.flink.optimizer.operators
 
AllGroupCombineProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupCombineProperties
 
AllGroupReduceDriver<IT,OT> - Class in org.apache.flink.runtime.operators
GroupReduceDriver task which is executed by a Task Manager.
AllGroupReduceDriver() - Constructor for class org.apache.flink.runtime.operators.AllGroupReduceDriver
 
AllGroupReduceProperties - Class in org.apache.flink.optimizer.operators
 
AllGroupReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupReduceProperties
 
AllGroupWithPartialPreGroupProperties - Class in org.apache.flink.optimizer.operators
 
AllGroupWithPartialPreGroupProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties
 
alloc() - Method in class org.apache.flink.runtime.io.network.buffer.NetworkBuffer
 
allocate(int) - Method in interface org.apache.flink.runtime.state.heap.space.Allocator
Allocate space with the given size.
allocate(int) - Method in interface org.apache.flink.runtime.state.heap.space.Chunk
Try to allocate size bytes from the chunk.
allocate(JobID, AllocationID) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlot
Allocate the task slot for the given job and allocation id.
ALLOCATE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
allocateAvailableSlot(SlotRequestId, AllocationID) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.SlotPool
Allocates the available slot with the given allocation id under the given request id.
allocateAvailableSlot(SlotRequestId, AllocationID) - Method in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
 
allocateBatchSlot(SlotRequestId, ScheduledUnit, SlotProfile) - Method in class org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl
 
allocateBatchSlot(SlotRequestId, ScheduledUnit, SlotProfile) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.SlotProvider
Allocating batch slot with specific requirement.
allocatedFloatingNum - Variable in class org.apache.flink.table.runtime.hashtable.BaseHybridHashTable
record number of the allocated segments from the floating pool.
AllocatedSlotActions - Interface in org.apache.flink.runtime.jobmaster.slotpool
Interface for components which have to perform actions on allocated slots.
AllocatedSlotInfo - Class in org.apache.flink.runtime.jobmaster
Information about an allocated slot which is owned by a JobMaster.
AllocatedSlotInfo(int, AllocationID) - Constructor for class org.apache.flink.runtime.jobmaster.AllocatedSlotInfo
 
AllocatedSlotReport - Class in org.apache.flink.runtime.jobmaster
The report of currently allocated slots from a given TaskExecutor by a JobMaster.
AllocatedSlotReport(JobID, Collection<AllocatedSlotInfo>) - Constructor for class org.apache.flink.runtime.jobmaster.AllocatedSlotReport
 
allocateHeapVectors(LogicalType[], int) - Static method in class org.apache.flink.table.dataformat.vector.heap.AbstractHeapVector
 
allocateOffHeapUnsafeMemory(int, Object) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates an off-heap unsafe memory and creates a new memory segment to represent that memory.
allocatePages(Object, int) - Method in class org.apache.flink.runtime.memory.MemoryManager
allocatePages(Object, Collection<MemorySegment>, int) - Method in class org.apache.flink.runtime.memory.MemoryManager
allocatePages(MemoryManager.AllocationRequest) - Method in class org.apache.flink.runtime.memory.MemoryManager
Allocates a set of memory segments from this memory manager.
allocateResource(ResourceProfile) - Method in interface org.apache.flink.runtime.resourcemanager.ResourceManagerServices
Allocates a resource according to the resource profile.
allocateResource(ResourceProfile) - Method in interface org.apache.flink.runtime.resourcemanager.slotmanager.ResourceActions
Requests to allocate a resource with the given ResourceProfile.
allocateReuseBytes(int) - Static method in class org.apache.flink.table.runtime.util.SegmentsUtil
Allocate bytes that is only for temporary usage, it should not be stored in somewhere else.
allocateReuseChars(int) - Static method in class org.apache.flink.table.runtime.util.SegmentsUtil
 
allocateSegments(int) - Method in class org.apache.flink.runtime.operators.hash.InMemoryPartition
attempts to allocate specified number of segments and should only be used by compaction partition fails silently if not enough segments are available since next compaction could still succeed
allocateSlot(SlotRequestId, ScheduledUnit, SlotProfile) - Method in class org.apache.flink.runtime.executiongraph.SlotProviderStrategy
Allocating slot with specific requirement.
allocateSlot(SlotRequestId, ScheduledUnit, SlotProfile, Time) - Method in class org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl
 
allocateSlot(SlotRequestId, ScheduledUnit, SlotProfile, Time) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.SlotProvider
Allocating slot with specific requirement.
allocateSlot(ScheduledUnit, SlotProfile, Time) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.SlotProvider
Allocating slot with specific requirement.
allocateSlot(int, JobID, AllocationID, Time) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Allocate the slot with the given index for the given job and allocation id.
allocateSlotsAndDeploy(Collection<ExecutionVertexDeploymentOption>) - Method in class org.apache.flink.runtime.scheduler.DefaultScheduler
 
allocateSlotsAndDeploy(Collection<ExecutionVertexDeploymentOption>) - Method in interface org.apache.flink.runtime.scheduler.SchedulerOperations
Allocate slots and deploy the vertex when slots are returned.
allocateSlotsFor(Collection<ExecutionVertexSchedulingRequirements>) - Method in class org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator
 
allocateSlotsFor(Collection<ExecutionVertexSchedulingRequirements>) - Method in interface org.apache.flink.runtime.scheduler.ExecutionSlotAllocator
Allocate slots for the given executions.
allocateUnpooledOffHeapMemory(int) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates some unpooled off-heap memory and creates a new memory segment that represents that memory.
allocateUnpooledOffHeapMemory(int, Object) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates some unpooled off-heap memory and creates a new memory segment that represents that memory.
allocateUnpooledSegment(int, Object) - Method in class org.apache.flink.core.memory.HeapMemorySegment.HeapMemorySegmentFactory
Allocates some unpooled memory and creates a new memory segment that represents that memory.
allocateUnpooledSegment(int) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates some unpooled memory and creates a new memory segment that represents that memory.
allocateUnpooledSegment(int, Object) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates some unpooled memory and creates a new memory segment that represents that memory.
allocationBaseDirectory(long) - Method in interface org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider
Returns the local state allocation base directory for given checkpoint id w.r.t.
allocationBaseDirectory(long) - Method in class org.apache.flink.runtime.state.LocalRecoveryDirectoryProviderImpl
 
allocationBaseDirsCount() - Method in interface org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider
Returns the total number of allocation base directories.
allocationBaseDirsCount() - Method in class org.apache.flink.runtime.state.LocalRecoveryDirectoryProviderImpl
 
allocationFuture - Variable in class org.apache.flink.runtime.executiongraph.ExecutionAndAllocationFuture
 
AllocationID - Class in org.apache.flink.runtime.clusterframework.types
Unique identifier for a physical slot allocated by a JobManager via the ResourceManager from a TaskManager.
AllocationID() - Constructor for class org.apache.flink.runtime.clusterframework.types.AllocationID
Constructs a new random AllocationID.
AllocationID(long, long) - Constructor for class org.apache.flink.runtime.clusterframework.types.AllocationID
Constructs a new AllocationID with the given parts.
Allocator - Interface in org.apache.flink.runtime.state.heap.space
Implementations are responsible for allocate space.
allOutputs - Variable in class org.apache.flink.streaming.api.collector.selector.DirectedOutput
 
ALLOW - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
allowCombinations() - Method in class org.apache.flink.cep.pattern.Pattern
Applicable only to Quantifier.looping(ConsumingStrategy) and Quantifier.times(ConsumingStrategy) patterns, this option allows more flexibility to the matching events.
allowComments() - Method in class org.apache.flink.table.descriptors.Csv
Ignores comment lines that start with '#' (disabled by default).
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Sets the time by which elements are allowed to be late.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow
Sets the time by which elements are allowed to be late.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Sets the time by which elements are allowed to be late.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Sets the time by which elements are allowed to be late.
allowedLateness - Variable in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator
The allowed lateness for elements.
allowedLateness - Variable in class org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction
 
allowedLateness - Variable in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
allowedMethods(String) - Method in class org.apache.flink.runtime.rest.handler.router.Router
Returns allowed methods for a specific URI.
allowExplicitRowValueConstructor() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowExtend() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowExtendedTrim() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowGeometry() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowInsertIntoPartition() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
Whether to allow "insert into tbl1 partition(col1=val1)" grammar.
allowInsertOverwrite() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
Whether to allow "insert overwrite tbl1 partition(col1=val1)" grammar.
allowLazyDeployment() - Method in enum org.apache.flink.runtime.jobgraph.ScheduleMode
Returns whether we are allowed to deploy consumers lazily.
allowNiladicParentheses() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowNonRestoredState() - Method in class org.apache.flink.runtime.jobgraph.SavepointRestoreSettings
Returns whether non restored state is allowed if the savepoint contains state that cannot be mapped back to the job.
AllowNonRestoredStateQueryParameter - Class in org.apache.flink.runtime.webmonitor.handlers
Query parameter that specifies whether non restored state is allowed if the savepoint contains state for an operator that is not part of the job.
AllowNonRestoredStateQueryParameter() - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AllowNonRestoredStateQueryParameter
 
AllReduceDriver<T> - Class in org.apache.flink.runtime.operators
Reduce task which is executed by a Task Manager.
AllReduceDriver() - Constructor for class org.apache.flink.runtime.operators.AllReduceDriver
 
AllReduceProperties - Class in org.apache.flink.optimizer.operators
 
AllReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllReduceProperties
 
AllWindowedStream<T,W extends Window> - Class in org.apache.flink.streaming.api.datastream
A AllWindowedStream represents a data stream where the stream of elements is split into windows based on a WindowAssigner.
AllWindowedStream(DataStream<T>, WindowAssigner<? super T, W>) - Constructor for class org.apache.flink.streaming.api.datastream.AllWindowedStream
 
AllWindowFunction<IN,OUT,W extends Window> - Interface in org.apache.flink.streaming.api.functions.windowing
Base interface for functions that are evaluated over non-keyed windows.
AllWorkersDoneEvent - Class in org.apache.flink.runtime.iterative.event
Event sent by the IterationSynchronizationSinkTask to each IterationHead signaling to start a new superstep.
AllWorkersDoneEvent() - Constructor for class org.apache.flink.runtime.iterative.event.AllWorkersDoneEvent
 
AllWorkersDoneEvent(Map<String, Aggregator<?>>) - Constructor for class org.apache.flink.runtime.iterative.event.AllWorkersDoneEvent
 
AlsoRunWithSchedulerNG - Interface in org.apache.flink.testutils.junit.category
Category marker interface to run tests with SchedulerNG.
alt(String) - Method in class org.apache.flink.api.java.utils.Option
Define an alternative / short name of the parameter.
ALTER - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
alter_partition(String, String, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
alter_table(String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
alterDatabase(String, CatalogDatabase, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Modify an existing database.
alterDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterDatabase(String, Database) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
alterDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterFunction(ObjectPath, CatalogFunction, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Modify an existing function.
alterFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterFunction(String, String, Function) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
alterFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Alter a partition.
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterPartition(IMetaStoreClient, String, String, Partition) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim
 
alterPartition(IMetaStoreClient, String, String, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100
 
alterPartition(IMetaStoreClient, String, String, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV210
 
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Update the column statistics of a table partition.
alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Update the statistics of a table partition.
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterTable(ObjectPath, CatalogBaseTable, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Modify an existing table or view.
alterTable(CatalogBaseTable, ObjectIdentifier, boolean) - Method in class org.apache.flink.table.catalog.CatalogManager
Alters a table in a given fully qualified path.
alterTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterTable(IMetaStoreClient, String, String, Table) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim
Alters a Hive table.
alterTable(IMetaStoreClient, String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100
 
alterTable(IMetaStoreClient, String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120
 
alterTable(IMetaStoreClient, String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV230
 
alterTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Update the column statistics of a table.
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in interface org.apache.flink.table.catalog.Catalog
Update the statistics of a table.
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in class org.apache.flink.table.catalog.GenericInMemoryCatalog
 
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog
 
ALWAYS - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ALWAYS_PARENT_FIRST_LOADER_PATTERNS - Static variable in class org.apache.flink.configuration.CoreOptions
The namespace patterns for classes that are loaded with a preference from the parent classloader, meaning the application class path, rather than any user code jar file.
ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL - Static variable in class org.apache.flink.configuration.CoreOptions
 
AmbiguousTableFactoryException - Exception in org.apache.flink.table.api
Exception for finding more than one TableFactory for the given properties.
AmbiguousTableFactoryException(List<? extends TableFactory>, Class<? extends TableFactory>, List<TableFactory>, Map<String, String>, Throwable) - Constructor for exception org.apache.flink.table.api.AmbiguousTableFactoryException
 
AmbiguousTableFactoryException(List<? extends TableFactory>, Class<? extends TableFactory>, List<TableFactory>, Map<String, String>) - Constructor for exception org.apache.flink.table.api.AmbiguousTableFactoryException
 
amount - Variable in class org.apache.flink.table.examples.java.StreamSQLExample.Order
 
AnalyticHelper<T> - Class in org.apache.flink.graph
A GraphAnalytic computes over a DataSet and returns the results via Flink accumulators.
AnalyticHelper() - Constructor for class org.apache.flink.graph.AnalyticHelper
 
analyzePojo(Class<OUT>, ArrayList<Type>, ParameterizedType, TypeInformation<IN1>, TypeInformation<IN2>) - Method in class org.apache.flink.api.java.typeutils.TypeExtractor
 
and(Aggregations, int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
and(Aggregations, int) - Method in class org.apache.flink.api.scala.operators.ScalaAggregateOperator
 
AND - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
AND - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
and(Expression, Expression) - Static method in class org.apache.flink.table.planner.expressions.ExpressionBuilder
 
AND - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
AndCondition<T> - Class in org.apache.flink.cep.pattern.conditions
Deprecated.
Please use RichAndCondition instead. This class exists just for backwards compatibility and will be removed in FLINK-10113.
AndCondition(IterativeCondition<T>, IterativeCondition<T>) - Constructor for class org.apache.flink.cep.pattern.conditions.AndCondition
Deprecated.
 
andMax(int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
andMin(int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
andSum(int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
AnotherDummyFSFactory - Class in org.apache.flink.fs.anotherdummy
Factory of dummy FileSystem.
AnotherDummyFSFactory() - Constructor for class org.apache.flink.fs.anotherdummy.AnotherDummyFSFactory
 
AntiJoinVisits() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis.AntiJoinVisits
 
ANY - Static variable in class org.apache.flink.runtime.clusterframework.types.ResourceProfile
A ResourceProfile that indicates infinite resource that matches any resource requirement, for testability purpose only.
ANY - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ANY(Class<T>, TypeSerializer<T>) - Static method in class org.apache.flink.table.api.DataTypes
Data type of an arbitrary serialized type.
ANY(TypeInformation<T>) - Static method in class org.apache.flink.table.api.DataTypes
Data type of an arbitrary serialized type backed by TypeInformation.
AnyMatchingSlotMatchingStrategy - Enum in org.apache.flink.runtime.resourcemanager.slotmanager
SlotMatchingStrategy which picks the first matching slot.
anyNull() - Method in class org.apache.flink.table.dataformat.BinaryArray
 
anyNull() - Method in class org.apache.flink.table.dataformat.BinaryRow
The bit is 1 when the field is null.
anyNull(int[]) - Method in class org.apache.flink.table.dataformat.BinaryRow
 
AnyType<T> - Class in org.apache.flink.table.types.logical
Logical type of an arbitrary serialized type.
AnyType(boolean, Class<T>, TypeSerializer<T>) - Constructor for class org.apache.flink.table.types.logical.AnyType
 
AnyType(Class<T>, TypeSerializer<T>) - Constructor for class org.apache.flink.table.types.logical.AnyType
 
API_KEY - Static variable in class org.apache.flink.metrics.datadog.DatadogHttpReporter
 
ApiExpressionDefaultVisitor<T> - Class in org.apache.flink.table.expressions.utils
A utility ApiExpressionVisitor that calls ApiExpressionDefaultVisitor.defaultMethod(Expression) by default, unless other methods are overridden explicitly.
ApiExpressionDefaultVisitor() - Constructor for class org.apache.flink.table.expressions.utils.ApiExpressionDefaultVisitor
 
ApiExpressionUtils - Class in org.apache.flink.table.expressions.utils
Utilities for API-specific Expressions.
ApiExpressionVisitor<R> - Class in org.apache.flink.table.expressions
A visitor for all Expressions that might be created during API translation.
ApiExpressionVisitor() - Constructor for class org.apache.flink.table.expressions.ApiExpressionVisitor
 
APP_MASTER_RPC_ADDRESS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The hostname or address where the application master RPC system is listening.
APP_MASTER_RPC_PORT - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The port where the application master RPC system is listening.
APP_MASTER_VCORES - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The vcores used by YARN application master.
append(double) - Method in class org.apache.flink.ml.common.linalg.DenseVector
 
append(double) - Method in class org.apache.flink.ml.common.linalg.SparseVector
 
append(double) - Method in class org.apache.flink.ml.common.linalg.Vector
Create a new vector by adding an element to the end of the vector.
append(ByteBuffer) - Method in class org.apache.flink.runtime.io.network.buffer.BufferBuilder
Append as many data as possible from source.
append(BytesHashMap.LookupInfo, BinaryRow) - Method in class org.apache.flink.table.runtime.operators.aggregate.BytesHashMap
Append an value into the hash map's record area.
append(char) - Method in class org.apache.flink.types.StringValue
 
append(CharSequence) - Method in class org.apache.flink.types.StringValue
 
append(CharSequence, int, int) - Method in class org.apache.flink.types.StringValue
 
append(StringValue) - Method in class org.apache.flink.types.StringValue
 
append(StringValue, int, int) - Method in class org.apache.flink.types.StringValue
 
appendAndCommit(ByteBuffer) - Method in class org.apache.flink.runtime.io.network.buffer.BufferBuilder
Same as BufferBuilder.append(ByteBuffer) but additionally BufferBuilder.commit() the appending.
appendConfiguration(Configuration) - Method in class org.apache.flink.tests.util.FlinkDistribution
 
AppendingState<IN,OUT> - Interface in org.apache.flink.api.common.state
Base interface for partitioned state that supports adding elements and inspecting the current state.
appendKeyExtractor(Operator<T>, Keys.SelectorFunctionKeys<T, K>) - Static method in class org.apache.flink.api.java.operators.KeyFunctions
 
appendKeyExtractor(Operator<T>, Keys.SelectorFunctionKeys<T, K1>, Keys.SelectorFunctionKeys<T, K2>) - Static method in class org.apache.flink.api.java.operators.KeyFunctions
 
appendKeyRemover(Operator<Tuple2<K, T>>, Keys.SelectorFunctionKeys<T, K>) - Static method in class org.apache.flink.api.java.operators.KeyFunctions
 
AppendOnlyTopNFunction - Class in org.apache.flink.table.runtime.operators.rank
The function could and only could handle append input stream.
AppendOnlyTopNFunction(long, long, BaseRowTypeInfo, GeneratedRecordComparator, BaseRowKeySelector, RankType, RankRange, boolean, boolean, long) - Constructor for class org.apache.flink.table.runtime.operators.rank.AppendOnlyTopNFunction
 
AppendOnlyWriter - Class in org.apache.flink.api.java.io.jdbc.writer
Just append record to jdbc, can not receive retract/delete message.
AppendOnlyWriter(String, int[]) - Constructor for class org.apache.flink.api.java.io.jdbc.writer.AppendOnlyWriter
 
appendOrdering(Integer, Class<? extends Comparable<?>>, Order) - Method in class org.apache.flink.api.common.operators.Ordering
Extends this ordering by appending an additional order requirement.
appendRecord(T) - Method in class org.apache.flink.runtime.operators.hash.InMemoryPartition
Inserts the given object into the current buffer.
appendStage(PipelineStage) - Method in class org.apache.flink.ml.api.core.Pipeline
Appends a PipelineStage to the tail of this pipeline.
AppendStreamTableSink<T> - Interface in org.apache.flink.table.sinks
Defines an external TableSink to emit streaming Table with only insert changes.
APPLICATION_ATTEMPT_FAILURE_VALIDITY_INTERVAL - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The config parameter defining the attemptFailuresValidityInterval of Yarn application.
APPLICATION_ATTEMPTS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
Set the number of retries for failed YARN ApplicationMasters/JobManagers in high availability mode.
APPLICATION_ID - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
 
APPLICATION_LOG_CONFIG_FILE - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptionsInternal
 
APPLICATION_MASTER_PORT - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The config parameter defining the Akka actor system port for the ApplicationMaster and JobManager.
APPLICATION_NAME - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
 
APPLICATION_PRIORITY - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
A non-negative integer indicating the priority for submitting a Flink YARN application.
APPLICATION_QUEUE - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
 
APPLICATION_TAGS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
A comma-separated list of strings to use as YARN application tags.
APPLICATION_TYPE - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
 
ApplicationStatus - Enum in org.apache.flink.runtime.clusterframework
The status of an application.
applicationStatus(ApplicationStatus) - Method in class org.apache.flink.runtime.jobmaster.JobResult.Builder
 
apply(File) - Method in class org.apache.flink.fs.s3.common.utils.RefCountedTmpFileCreator
Gets the next temp file and stream to temp file.
apply(M, VV) - Method in class org.apache.flink.graph.gsa.ApplyFunction
This method is invoked once per superstep, after the SumFunction in a GatherSumApplyIteration.
apply(DenseMatrix, DenseMatrix, Function<Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
y = func(x).
apply(DenseMatrix, DenseMatrix, DenseMatrix, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
y = func(x1, x2).
apply(DenseVector, DenseVector, Function<Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
y = func(x).
apply(DenseVector, DenseVector, DenseVector, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
y = func(x1, x2).
apply(SparseVector, SparseVector, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
Create a new SparseVector by element wise operation between two SparseVectors.
apply(S, T) - Method in interface org.apache.flink.runtime.state.StateTransformationFunction
Binary function that applies a given value to the given old state to compute the new state.
APPLY - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
apply(AllWindowFunction<T, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
apply(AllWindowFunction<T, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
apply(ReduceFunction<T>, AllWindowFunction<T, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(ReduceFunction<T>, AllWindowFunction<T, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(CoGroupFunction<T1, T2, T>) - Method in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(CoGroupFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(JoinFunction<T1, T2, T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(FlatJoinFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(FlatJoinFunction<T1, T2, T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(JoinFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(WindowFunction<T, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
apply(WindowFunction<T, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
apply(ReduceFunction<T>, WindowFunction<T, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(ReduceFunction<T>, WindowFunction<T, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction
 
apply(W, Iterable<IN>, Collector<OUT>) - Method in interface org.apache.flink.streaming.api.functions.windowing.AllWindowFunction
Evaluates the window and outputs none or several elements.
apply(W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction
Deprecated.
 
apply(K, W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.FoldApplyWindowFunction
Deprecated.
 
apply(W, Iterable<T>, Collector<T>) - Method in class org.apache.flink.streaming.api.functions.windowing.PassThroughAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<T>) - Method in class org.apache.flink.streaming.api.functions.windowing.PassThroughWindowFunction
 
apply(W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.ReduceApplyAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.ReduceApplyWindowFunction
 
apply(KEY, W, Iterable<IN>, Collector<OUT>) - Method in interface org.apache.flink.streaming.api.functions.windowing.WindowFunction
Evaluates the window and outputs none or several elements.
apply(TimeWindow, Iterable<Integer>, Collector<Double[]>) - Method in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.PartialModelBuilder
 
apply(List<Transformation<?>>) - Method in interface org.apache.flink.table.delegation.Executor
Applies all given transformations.
apply(List<Transformation<?>>) - Method in class org.apache.flink.table.executor.StreamExecutor
 
apply(List<Expression>, ResolverRule.ResolutionContext) - Method in interface org.apache.flink.table.expressions.resolver.rules.ResolverRule
 
apply(Join, JoinRelType, RexNode) - Method in interface org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.Predicate
 
apply(List<Transformation<?>>) - Method in class org.apache.flink.table.planner.delegation.ExecutorBase
 
apply(BaseRow, BaseRow) - Method in interface org.apache.flink.table.runtime.generated.JoinCondition
 
apply(IN) - Method in interface org.apache.flink.table.runtime.generated.Projection
 
apply(Statement, Description) - Method in class org.apache.flink.testutils.junit.RetryRule
 
apply(Statement, Description) - Method in interface org.apache.flink.util.ExternalResource
 
apply(T, U) - Method in interface org.apache.flink.util.function.BiFunctionWithException
Apply the given values t and u to obtain the resulting value.
apply(T) - Method in interface org.apache.flink.util.function.FunctionWithException
Calls this function.
apply(S, T, U) - Method in interface org.apache.flink.util.function.TriFunction
Applies this function to the given arguments.
apply(S, T, U) - Method in interface org.apache.flink.util.function.TriFunctionWithException
Applies this function to the given arguments.
applyCommandLineOptionsToConfiguration(CommandLine) - Method in class org.apache.flink.client.cli.AbstractCustomCommandLine
 
applyCommandLineOptionsToConfiguration(CommandLine) - Method in interface org.apache.flink.client.cli.CustomCommandLine
Override configuration settings by specified command line options.
applyCommandLineOptionsToConfiguration(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
 
ApplyFunction<K,VV,M> - Class in org.apache.flink.graph.gsa
The base class for the third and last step of a GatherSumApplyIteration.
ApplyFunction() - Constructor for class org.apache.flink.graph.gsa.ApplyFunction
 
applyLimit(long) - Method in interface org.apache.flink.table.sources.LimitableTableSource
Check and push down the limit to the table source.
applyOverlays(Configuration, ContainerSpecification) - Static method in class org.apache.flink.mesos.util.MesosUtils
Generate a container specification as a TaskManager template.
applyPartitionPruning(List<Map<String, String>>) - Method in class org.apache.flink.connectors.hive.HiveTableSource
 
applyPartitionPruning(List<Map<String, String>>) - Method in interface org.apache.flink.table.sources.PartitionableTableSource
Applies the remaining partitions to the table source.
applyPredicate(List<Expression>) - Method in class org.apache.flink.formats.parquet.ParquetTableSource
 
applyPredicate(List<Expression>) - Method in class org.apache.flink.orc.OrcTableSource
 
applyPredicate(List<Expression>) - Method in interface org.apache.flink.table.sources.FilterableTableSource
Check and pick all predicates this table source can support.
applyRegistrations(Kryo, Collection<KryoRegistration>) - Static method in class org.apache.flink.api.java.typeutils.runtime.KryoUtils
Apply a list of KryoRegistration to a Kryo instance.
applyRepartitioner(OperatorID, OperatorStateRepartitioner, List<List<OperatorStateHandle>>, int, int) - Static method in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation
 
applyRepartitioner(OperatorStateRepartitioner, List<List<OperatorStateHandle>>, int, int) - Static method in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation
Repartitions the given operator state using the given OperatorStateRepartitioner with respect to the new parallelism.
applySum(DenseVector, DenseVector, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
\sum_i func(x1_i, x2_i) .
applySum(SparseVector, SparseVector, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
\sum_i func(x1_i, x2_i) .
applySum(DenseVector, SparseVector, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
\sum_i func(x1_i, x2_i) .
applySum(SparseVector, DenseVector, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
\sum_i func(x1_i, x2_i) .
applySum(DenseMatrix, DenseMatrix, BiFunction<Double, Double, Double>) - Static method in class org.apache.flink.ml.common.linalg.MatVecOp
\sum_ij func(x1_ij, x2_ij) .
applyTo(ParameterTool) - Method in class org.apache.flink.api.java.utils.RequiredParameters
Check for all required parameters defined: - has a value been passed - if not, does the parameter have an associated default value - does the type of the parameter match the one defined in RequiredParameters - does the value provided in the parameterTool adhere to the choices defined in the option.
applyToAllKeys(N, TypeSerializer<N>, StateDescriptor<S, T>, KeyedStateFunction<K, S>) - Method in class org.apache.flink.runtime.state.AbstractKeyedStateBackend
 
applyToAllKeys(N, TypeSerializer<N>, StateDescriptor<S, T>, KeyedStateFunction<K, S>) - Method in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
 
applyToAllKeys(N, TypeSerializer<N>, StateDescriptor<S, T>, KeyedStateFunction<K, S>) - Method in interface org.apache.flink.runtime.state.KeyedStateBackend
Applies the provided KeyedStateFunction to the state with the provided StateDescriptor of all the currently active keys.
applyToAllWhileSuppressingExceptions(Iterable<T>, ThrowingConsumer<T, ? extends Exception>) - Static method in class org.apache.flink.util.LambdaUtil
This method supplies all elements from the input to the consumer.
applyToKeyedState(StateDescriptor<S, VS>, KeyedStateFunction<KS, S>) - Method in class org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction.Context
Applies the provided function to the state associated with the provided state descriptor.
applyWithShuffleTypeCheck(Class<SD>, ShuffleDescriptor, Function<UnknownShuffleDescriptor, T>, Function<SD, T>) - Static method in class org.apache.flink.runtime.shuffle.ShuffleUtils
Apply different functions to known and unknown ShuffleDescriptors.
APPROX_NUMERIC_LITERAL - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
archive() - Method in interface org.apache.flink.api.common.Archiveable
 
archive() - Method in class org.apache.flink.api.common.ExecutionConfig
 
archive() - Method in class org.apache.flink.runtime.executiongraph.Execution
 
archive() - Method in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex
 
archive() - Method in class org.apache.flink.runtime.executiongraph.ExecutionVertex
 
ARCHIVE_COUNT - Static variable in class org.apache.flink.configuration.WebOptions
The config parameter defining the number of archived jobs for the JobManager.
ARCHIVE_DIR - Static variable in class org.apache.flink.configuration.JobManagerOptions
The location where the JobManager stores the archives of completed jobs.
Archiveable<T extends Serializable> - Interface in org.apache.flink.api.common
 
ArchivedExecution - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecution(Execution) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecution
 
ArchivedExecution(StringifiedAccumulatorResult[], IOMetrics, ExecutionAttemptID, int, ExecutionState, String, TaskManagerLocation, AllocationID, int, long[]) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecution
 
ArchivedExecutionConfig - Class in org.apache.flink.api.common
Serializable class which is created when archiving the job.
ArchivedExecutionConfig(ExecutionConfig) - Constructor for class org.apache.flink.api.common.ArchivedExecutionConfig
 
ArchivedExecutionConfig(String, String, int, boolean, Map<String, String>) - Constructor for class org.apache.flink.api.common.ArchivedExecutionConfig
 
ArchivedExecutionGraph - Class in org.apache.flink.runtime.executiongraph
An archived execution graph represents a serializable form of the ExecutionGraph.
ArchivedExecutionGraph(JobID, String, Map<JobVertexID, ArchivedExecutionJobVertex>, List<ArchivedExecutionJobVertex>, long[], JobStatus, ErrorInfo, String, StringifiedAccumulatorResult[], Map<String, SerializedValue<OptionalFailure<Object>>>, ArchivedExecutionConfig, boolean, CheckpointCoordinatorConfiguration, CheckpointStatsSnapshot) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph
 
ArchivedExecutionGraphStore - Interface in org.apache.flink.runtime.dispatcher
Interface for a ArchivedExecutionGraph store.
ArchivedExecutionJobVertex - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecutionJobVertex(ExecutionJobVertex) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionJobVertex
 
ArchivedExecutionJobVertex(ArchivedExecutionVertex[], JobVertexID, String, int, int, ResourceProfile, StringifiedAccumulatorResult[]) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionJobVertex
 
ArchivedExecutionVertex - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecutionVertex(ExecutionVertex) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionVertex
 
ArchivedExecutionVertex(int, String, ArchivedExecution, EvictingBoundedList<ArchivedExecution>) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionVertex
 
ArchivedJson - Class in org.apache.flink.runtime.webmonitor.history
A simple container for a handler's JSON response and the REST URLs for which the response would've been returned.
ArchivedJson(String, String) - Constructor for class org.apache.flink.runtime.webmonitor.history.ArchivedJson
 
ArchivedJson(String, ResponseBody) - Constructor for class org.apache.flink.runtime.webmonitor.history.ArchivedJson
 
archiveExecutionGraph(AccessExecutionGraph) - Method in interface org.apache.flink.runtime.dispatcher.HistoryServerArchivist
Archives the given AccessExecutionGraph on the history server.
archiveExecutionGraph(AccessExecutionGraph) - Method in enum org.apache.flink.runtime.dispatcher.VoidHistoryServerArchivist
 
archiveJob(Path, JobID, Collection<ArchivedJson>) - Static method in class org.apache.flink.runtime.history.FsJobArchivist
Writes the given AccessExecutionGraph to the FileSystem pointed to by JobManagerOptions.ARCHIVE_DIR.
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobConfigHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobDetailsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobPlanHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler
 
archiveJsonWithPath(AccessExecutionGraph) - Method in interface org.apache.flink.runtime.webmonitor.history.JsonArchivist
Returns a Collection of ArchivedJsons containing JSON responses and their respective REST URL for a given job.
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
 
ARE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
areAllInputsSelected() - Method in class org.apache.flink.streaming.api.operators.InputSelection
Tests if all inputs are selected.
areBranchCompatible(PlanNode, PlanNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
Checks whether to candidate plans for the sub-plan of this node are comparable.
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor
 
areCompatible(Keys<?>) - Method in class org.apache.flink.api.common.operators.Keys
Check if two sets of keys are compatible to each other (matching types, key counts)
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractJoinDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor
 
areExplicitEnvironmentsAllowed() - Static method in class org.apache.flink.api.java.ExecutionEnvironment
Checks whether it is currently permitted to explicitly instantiate a LocalEnvironment or a RemoteEnvironment.
areFieldsUnique(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties
Checks whether the given set of fields is unique, as specified in these local properties.
areMasterStatesFullyAcknowledged() - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
 
areTasksFullyAcknowledged() - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
 
areTypesCompatible(LogicalType, LogicalType) - Static method in class org.apache.flink.table.types.logical.utils.LogicalTypeChecks
Returns true if the two given types are compatible.
Arg(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.flink.sql.parser.impl.FlinkSqlParserImpl
 
Arg0(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.flink.sql.parser.impl.FlinkSqlParserImpl
 
ARG0_VARCHAR_FORCE_NULLABLE - Static variable in class org.apache.flink.table.planner.plan.type.FlinkReturnTypes
Type-inference strategy whereby the result type of a call is the type of the operand #0 (0-based), with nulls always allowed.
ARG_CONVERSION_DURATION - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_CONVERSION_RATE - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_HOST - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_HOST - Static variable in class org.apache.flink.metrics.statsd.StatsDReporter
 
ARG_PORT - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_PORT - Static variable in class org.apache.flink.metrics.statsd.StatsDReporter
 
ARG_PREFIX - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_PROTOCOL - Static variable in class org.apache.flink.metrics.graphite.GraphiteReporter
 
argTypes - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction
 
ArgumentCount - Interface in org.apache.flink.table.types.inference
Defines the count of accepted arguments (including open intervals) that a function can take.
arity - Variable in class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase
 
array() - Method in class org.apache.flink.runtime.io.network.buffer.NetworkBuffer
 
ARRAY - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ARRAY(DataType) - Static method in class org.apache.flink.table.api.DataTypes
Data type of an array of elements with same subtype.
ARRAY - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ARRAY_ELEMENT - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ARRAY_MAX_CARDINALITY - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ARRAY_VALUE - Static variable in enum org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TypeName
ARRAY = 16;
ARRAY_VALUE_CONSTRUCTOR - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
arrayAwareToString(Object) - Static method in class org.apache.flink.util.StringUtils
This method calls Object.toString() on the given object, unless the object is an array.
ArrayConstructor - Class in org.apache.flink.api.common.python.pickle
Creates arrays of objects.
ArrayConstructor() - Constructor for class org.apache.flink.api.common.python.pickle.ArrayConstructor
 
ArrayConstructor() - Method in class org.apache.flink.sql.parser.impl.FlinkSqlParserImpl
Parses an ARRAY constructor
arrayElementDelimiter(String) - Method in class org.apache.flink.table.descriptors.Csv
Sets the array element delimiter string for separating array or row element values (";" by default).
ArrayFromTuple - Class in org.apache.flink.streaming.api.functions.windowing.delta.extractor
Converts a Tuple to an Object-Array.
ArrayFromTuple() - Constructor for class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple
Using this constructor the extractor will convert the whole tuple (all fields in the original order) to an array.
ArrayFromTuple(int...) - Constructor for class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple
Using this constructor the extractor will combine the fields as specified in the indexes parameter in an object array.
ArrayListSerializer<T> - Class in org.apache.flink.runtime.state
 
ArrayListSerializer(TypeSerializer<T>) - Constructor for class org.apache.flink.runtime.state.ArrayListSerializer
 
ArrayListSerializerSnapshot<T> - Class in org.apache.flink.runtime.state
Snapshot class for the ArrayListSerializer.
ArrayListSerializerSnapshot() - Constructor for class org.apache.flink.runtime.state.ArrayListSerializerSnapshot
Constructor for read instantiation.
ArrayListSerializerSnapshot(ArrayListSerializer<T>) - Constructor for class org.apache.flink.runtime.state.ArrayListSerializerSnapshot
Constructor for creating the snapshot for writing.
arrayNext() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
 
arrayOffset() - Method in class org.apache.flink.runtime.io.network.buffer.NetworkBuffer
 
arraySize(int, float) - Static method in class org.apache.flink.table.runtime.util.collections.OptimizableHashSet
Returns the least power of two smaller than or equal to 230 and larger than or equal to Math.ceil( expected / f ).
arrayToMap(String[]) - Static method in class org.apache.flink.runtime.metrics.scope.ScopeFormat
 
arrayToString(Object) - Static method in class org.apache.flink.util.StringUtils
Returns a string representation of the given array.
ArrayType - Class in org.apache.flink.table.types.logical
Logical type of an array of elements with same subtype.
ArrayType(boolean, LogicalType) - Constructor for class org.apache.flink.table.types.logical.ArrayType
 
ArrayType(LogicalType) - Constructor for class org.apache.flink.table.types.logical.ArrayType
 
ArrayUtils - Class in org.apache.flink.util
Utility class for Java arrays.
ArrayUtils() - Constructor for class org.apache.flink.util.ArrayUtils
 
Artifact(Path, Path, boolean, boolean, boolean) - Constructor for class org.apache.flink.runtime.clusterframework.ContainerSpecification.Artifact
 
ARTIFACT_SERVER_PORT - Static variable in class org.apache.flink.mesos.configuration.MesosOptions
The config parameter defining the Mesos artifact server port to use.
ARTIFACT_SERVER_SSL_ENABLED - Static variable in class org.apache.flink.mesos.configuration.MesosOptions
Config parameter to override SSL support for the Artifact Server.
artifactFileNames - Variable in class org.apache.flink.runtime.rest.messages.job.JobSubmitRequestBody
 
ArtificalOperatorStateMapper<IN,OUT> - Class in org.apache.flink.streaming.tests.artificialstate
A self-verifiable RichMapFunction used to verify checkpointing and restore semantics for various kinds of operator state.
ArtificalOperatorStateMapper(MapFunction<IN, OUT>) - Constructor for class org.apache.flink.streaming.tests.artificialstate.ArtificalOperatorStateMapper
 
ArtificialKeyedStateMapper<IN,OUT> - Class in org.apache.flink.streaming.tests.artificialstate
A generic, stateful MapFunction that allows specifying what states to maintain based on a provided list of ArtificialStateBuilders.
ArtificialKeyedStateMapper(MapFunction<IN, OUT>, ArtificialStateBuilder<IN>) - Constructor for class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper
 
ArtificialKeyedStateMapper(MapFunction<IN, OUT>, List<ArtificialStateBuilder<IN>>) - Constructor for class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper
 
ArtificialListStateBuilder<IN,STATE> - Class in org.apache.flink.streaming.tests.artificialstate.builder
An ArtificialListStateBuilder for user operator and keyed state.
ArtificialListStateBuilder(String, JoinFunction<IN, Iterable<STATE>, List<STATE>>, JoinFunction<IN, Iterable<STATE>, List<STATE>>, ListStateDescriptor<STATE>) - Constructor for class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialListStateBuilder
 
ArtificialMapStateBuilder<IN,K,V> - Class in org.apache.flink.streaming.tests.artificialstate.builder
ArtificialMapStateBuilder(String, JoinFunction<IN, Iterator<Map.Entry<K, V>>, Iterator<Map.Entry<K, V>>>, TypeSerializer<K>, TypeSerializer<V>) - Constructor for class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialMapStateBuilder
 
ArtificialStateBuilder<T> - Class in org.apache.flink.streaming.tests.artificialstate.builder
The state builder wraps the logic of registering state in user functions, as well as how state is updated per input element..
artificialStateForElement(IN) - Method in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialListStateBuilder
 
artificialStateForElement(IN) - Method in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialMapStateBuilder
 
artificialStateForElement(T) - Method in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialStateBuilder
Manipulate the state for an input element.
artificialStateForElement(IN) - Method in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialValueStateBuilder
 
ArtificialValueStateBuilder<IN,STATE> - Class in org.apache.flink.streaming.tests.artificialstate.builder
ArtificialValueStateBuilder(String, JoinFunction<IN, STATE, STATE>, ValueStateDescriptor<STATE>) - Constructor for class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialValueStateBuilder
 
AS - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
as(String) - Method in class org.apache.flink.table.api.internal.TableImpl
 
as(Expression...) - Method in class org.apache.flink.table.api.internal.TableImpl
 
as(String) - Method in class org.apache.flink.table.api.OverWindowPartitionedOrdered
Assigns an alias for this window that the following select() clause can refer to.
as(Expression) - Method in class org.apache.flink.table.api.OverWindowPartitionedOrdered
Assigns an alias for this window that the following select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.OverWindowPartitionedOrderedPreceding
Assigns an alias for this window that the following select() clause can refer to.
as(Expression) - Method in class org.apache.flink.table.api.OverWindowPartitionedOrderedPreceding
Assigns an alias for this window that the following select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.SessionWithGapOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(Expression) - Method in class org.apache.flink.table.api.SessionWithGapOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.SlideWithSizeAndSlideOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(Expression) - Method in class org.apache.flink.table.api.SlideWithSizeAndSlideOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Method in interface org.apache.flink.table.api.Table
Renames the fields of the expression result.
as(Expression...) - Method in interface org.apache.flink.table.api.Table
Renames the fields of the expression result.
as(Expression) - Method in class org.apache.flink.table.api.TumbleWithSizeOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.TumbleWithSizeOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(ResolvedExpression, String) - Method in class org.apache.flink.table.expressions.resolver.ExpressionResolver.PostResolverFactory
 
AS - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
AS - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
asArray(Class<U>) - Static method in class org.apache.flink.api.common.operators.AbstractUdfOperator
Generic utility function that wraps a single class object into an array of that class type.
asByteBuf() - Method in interface org.apache.flink.runtime.io.network.buffer.Buffer
 
asByteBuf() - Method in class org.apache.flink.runtime.io.network.buffer.NetworkBuffer
 
asByteBuf() - Method in class org.apache.flink.runtime.io.network.buffer.ReadOnlySlicedNetworkBuffer
 
ASC - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ascending - Variable in class org.apache.flink.api.common.typeutils.base.array.PrimitiveArrayComparator
 
ascendingComparison - Variable in class org.apache.flink.api.common.typeutils.base.BasicTypeComparator
 
ascendingComparison - Variable in class org.apache.flink.api.common.typeutils.base.LocalDateComparator
 
ascendingComparison - Variable in class org.apache.flink.api.common.typeutils.base.LocalDateTimeComparator
 
AscendingTimestampExtractor<T> - Class in org.apache.flink.streaming.api.functions
Deprecated.
AscendingTimestampExtractor() - Constructor for class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor
Deprecated.
 
AscendingTimestampExtractor<T> - Class in org.apache.flink.streaming.api.functions.timestamps
A timestamp assigner and watermark generator for streams where timestamps are monotonously ascending.
AscendingTimestampExtractor() - Constructor for class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor
 
AscendingTimestampExtractor.FailingHandler - Class in org.apache.flink.streaming.api.functions.timestamps
Handler that fails the program when timestamp monotony is violated.
AscendingTimestampExtractor.IgnoringHandler - Class in org.apache.flink.streaming.api.functions.timestamps
Handler that does nothing when timestamp monotony is violated.
AscendingTimestampExtractor.LoggingHandler - Class in org.apache.flink.streaming.api.functions.timestamps
Handler that only logs violations of timestamp monotony, on WARN log level.
AscendingTimestampExtractor.MonotonyViolationHandler - Interface in org.apache.flink.streaming.api.functions.timestamps
Interface for handlers that handle violations of the monotonous ascending timestamps property.
AscendingTimestamps - Class in org.apache.flink.table.sources.wmstrategies
A watermark strategy for ascending rowtime attributes.
AscendingTimestamps() - Constructor for class org.apache.flink.table.sources.wmstrategies.AscendingTimestamps
 
ASCII - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
ASENSITIVE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
asExecutor(String, Object...) - Method in interface org.apache.flink.streaming.api.operators.MailboxExecutor
Provides an Executor view on this MailboxExecutor, where submitted tasks will receive the given description.
asFile(String) - Static method in class org.apache.flink.test.util.TestBaseUtils
 
asFlinkTuples() - Method in class org.apache.flink.hcatalog.HCatInputFormatBase
Specifies that the InputFormat returns Flink tuples instead of HCatRecord.
ASIN - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ASIN - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
asin(Decimal) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
ask(Object, Time) - Method in class org.apache.flink.runtime.rpc.akka.FencedAkkaInvocationHandler
 
ASK_TIMEOUT - Static variable in class org.apache.flink.configuration.AkkaOptions
Timeout for akka ask calls.
asLatencyMarker() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a LatencyMarker.
asList() - Method in class org.apache.flink.configuration.ConfigOptions.TypedConfigOptionBuilder
Defines that the option's type should be a list of previously defined atomic type.
asList() - Method in class org.apache.flink.runtime.checkpoint.StateObjectCollection
 
asMap() - Method in class org.apache.flink.table.descriptors.DescriptorProperties
Returns the properties as a map copy.
asPrefixedMap(String) - Method in class org.apache.flink.table.descriptors.DescriptorProperties
Returns the properties as a map copy with a prefix key.
asQueryableState(String) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Publishes the keyed stream as queryable ValueState instance.
asQueryableState(String, ValueStateDescriptor<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Publishes the keyed stream as a queryable ValueState instance.
asQueryableState(String, FoldingStateDescriptor<T, ACC>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Deprecated.
will be removed in a future version
asQueryableState(String, ReducingStateDescriptor<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Publishes the keyed stream as a queryable ReducingState instance.
asRecord() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a StreamRecord.
asRootSchema(Schema) - Static method in class org.apache.calcite.jdbc.CalciteSchemaBuilder
Creates a CalciteSchema with a given Schema as the root.
asSerializableString() - Method in class org.apache.flink.table.catalog.ObjectIdentifier
Returns a string that fully serializes this instance.
asSerializableString() - Method in interface org.apache.flink.table.expressions.ResolvedExpression
Returns a string that fully serializes this instance.
asSerializableString() - Method in interface org.apache.flink.table.operations.QueryOperation
Returns a string that fully serializes this instance.
asSerializableString() - Method in class org.apache.flink.table.types.logical.AnyType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.ArrayType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.BigIntType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.BinaryType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.BooleanType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.CharType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.DateType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.DayTimeIntervalType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.DecimalType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.DoubleType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.FloatType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.IntType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.LegacyTypeInformationType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.LocalZonedTimestampType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.LogicalType
Returns a string that fully serializes this instance.
asSerializableString() - Method in class org.apache.flink.table.types.logical.MapType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.MultisetType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.NullType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.RowType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.RowType.RowField
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.SmallIntType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.SymbolType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.TimestampType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.TimeType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.TinyIntType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.TypeInformationAnyType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.UnresolvedUserDefinedType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.UserDefinedType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.VarBinaryType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.VarCharType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.YearMonthIntervalType
 
asSerializableString() - Method in class org.apache.flink.table.types.logical.ZonedTimestampType
 
ASSERTION - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
assertNoException(CompletableFuture<?>) - Static method in class org.apache.flink.runtime.concurrent.FutureUtils
Asserts that the given CompletableFuture is not completed exceptionally.
assertRunningInMainThread() - Method in interface org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor
Returns true if the method was called in the thread of this executor.
assertRunningInMainThread() - Method in class org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor.DummyComponentMainThreadExecutor
 
assertRunningInMainThread() - Method in class org.apache.flink.runtime.rpc.RpcEndpoint.MainThreadExecutor
 
assign(KafkaTopicPartition, int) - Static method in class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionAssigner
Returns the index of the target subtask that a specific Kafka partition should be assigned to.
assign(StreamShardHandle, int) - Method in interface org.apache.flink.streaming.connectors.kinesis.KinesisShardAssigner
Returns the index of the target subtask that a specific shard should be assigned to.
assignActualWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.GeneralWindowProcessFunction
 
assignActualWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction
Assigns the input element into the actual windows which the Trigger should trigger on.
assignActualWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.MergingWindowProcessFunction
 
assignActualWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.PanedWindowProcessFunction
 
assigner(WindowAssigner<?>) - Method in class org.apache.flink.table.runtime.operators.window.WindowOperatorBuilder
 
AssignerWithPeriodicWatermarks<T> - Interface in org.apache.flink.streaming.api.functions
The AssignerWithPeriodicWatermarks assigns event time timestamps to elements, and generates low watermarks that signal event time progress within the stream.
AssignerWithPunctuatedWatermarks<T> - Interface in org.apache.flink.streaming.api.functions
The AssignerWithPunctuatedWatermarks assigns event time timestamps to elements, and generates low watermarks that signal event time progress within the stream.
assignExclusiveSegments() - Method in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate
Assign the exclusive buffers to all remote input channels directly for credit-based mode.
assignKeyToParallelOperator(Object, int, int) - Static method in class org.apache.flink.runtime.state.KeyGroupRangeAssignment
Assigns the given key to a parallel operator index.
ASSIGNMENT - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
assignPane(Object, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.PanedWindowAssigner
Given the timestamp and element, returns the pane into which it should be placed.
assignPane(Object, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.SlidingWindowAssigner
 
assignPartition(int, byte) - Static method in class org.apache.flink.runtime.operators.hash.MutableHashTable
Assigns a partition to a bucket.
assignPartitions(KafkaConsumer<?, ?>, List<TopicPartition>) - Method in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerCallBridge010
 
assignPartitions(KafkaConsumer<?, ?>, List<TopicPartition>) - Method in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerCallBridge09
 
assignPendingSlotRequest(PendingSlotRequest) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.PendingTaskManagerSlot
 
assignPendingSlotRequest(PendingSlotRequest) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerSlot
 
assignPendingTaskManagerSlot(PendingTaskManagerSlot) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.PendingSlotRequest
 
AssignRangeIndex<IN> - Class in org.apache.flink.runtime.operators.udf
This mapPartition function require a DataSet with RangeBoundaries as broadcast input, it generate Tuple2 which includes range index and record itself as output.
AssignRangeIndex(TypeComparatorFactory<IN>) - Constructor for class org.apache.flink.runtime.operators.udf.AssignRangeIndex
 
assignStateNamespace(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.GeneralWindowProcessFunction
 
assignStateNamespace(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction
Assigns the input element into the state namespace which the input element should be accumulated/retracted into.
assignStateNamespace(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.MergingWindowProcessFunction
 
assignStateNamespace(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.internal.PanedWindowProcessFunction
 
assignStates() - Method in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation
 
assignTimestamps(TimestampExtractor<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
Assigns timestamps to the elements in the data stream and periodically creates watermarks to signal event time progress.
assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
Assigns timestamps to the elements in the data stream and creates watermarks to signal event time progress based on the elements themselves.
assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
Specifies an AssignerWithPunctuatedWatermarks to emit watermarks in a punctuated manner.
assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
Specifies an AssignerWithPunctuatedWatermarks to emit watermarks in a punctuated manner.
assignToKeyGroup(Object, int) - Static method in class org.apache.flink.runtime.state.KeyGroupRangeAssignment
Assigns the given key to a key-group index.
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.BaseAlignedWindowAssigner
Deprecated.
 
assignWindows(T, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.DynamicEventTimeSessionWindows
 
assignWindows(T, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.DynamicProcessingTimeSessionWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.GlobalWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows
 
assignWindows(T, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner
Returns a Collection of windows that should be assigned to the element.
assignWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.CountSlidingWindowAssigner
 
assignWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.CountTumblingWindowAssigner
 
assignWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.SessionWindowAssigner
 
assignWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.SlidingWindowAssigner
 
assignWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.TumblingWindowAssigner
 
assignWindows(BaseRow, long) - Method in class org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner
Given the timestamp and element, returns the set of windows into which it should be placed.
asStreamStatus() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a StreamStatus.
assumeCredentialsAvailable() - Static method in class org.apache.flink.testutils.oss.OSSTestCredentials
 
assumeCredentialsAvailable() - Static method in class org.apache.flink.testutils.s3.S3TestCredentials
Checks whether credentials are available in the environment variables of this JVM.
asSummaryString() - Method in class org.apache.flink.table.catalog.ObjectIdentifier
Returns a string that summarizes this instance for printing to a console or log.
asSummaryString() - Method in class org.apache.flink.table.expressions.CallExpression
 
asSummaryString() - Method in interface org.apache.flink.table.expressions.Expression
Returns a string that summarizes this expression for printing to a console.
asSummaryString() - Method in class org.apache.flink.table.expressions.FieldReferenceExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.LocalReferenceExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.LookupCallExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.TableReferenceExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.TypeLiteralExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.UnresolvedCallExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.UnresolvedReferenceExpression
 
asSummaryString() - Method in class org.apache.flink.table.expressions.ValueLiteralExpression
 
asSummaryString() - Method in class org.apache.flink.table.functions.FunctionIdentifier
Returns a string that summarizes this instance for printing to a console or log.
asSummaryString() - Method in class org.apache.flink.table.operations.AggregateQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.CalculatedQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.CatalogQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.CatalogSinkModifyOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.DataSetQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.ddl.CreateTableOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.ddl.DropTableOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.DistinctQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.FilterQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.JavaDataStreamQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.JoinQueryOperation
 
asSummaryString() - Method in interface org.apache.flink.table.operations.Operation
Returns a string that summarizes this operation for printing to a console.
asSummaryString() - Method in class org.apache.flink.table.operations.OutputConversionModifyOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.ProjectQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.ScalaDataStreamQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.SetQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.SortQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.TableSourceQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.UnregisteredSinkModifyOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.WindowAggregateQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.operations.WindowAggregateQueryOperation.ResolvedGroupWindow
 
asSummaryString() - Method in class org.apache.flink.table.planner.expressions.RexNodeExpression
 
asSummaryString() - Method in class org.apache.flink.table.planner.operations.DataStreamQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.planner.operations.PlannerQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.planner.operations.RichTableSourceQueryOperation
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.AnyType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.ArrayType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.BinaryType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.CharType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.LegacyTypeInformationType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.LocalZonedTimestampType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.LogicalType
Returns a string that summarizes this type for printing to a console.
asSummaryString() - Method in class org.apache.flink.table.types.logical.MapType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.MultisetType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.RowType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.RowType.RowField
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.SymbolType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.TimestampType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.TypeInformationAnyType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.UnresolvedUserDefinedType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.VarBinaryType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.VarCharType
 
asSummaryString() - Method in class org.apache.flink.table.types.logical.ZonedTimestampType
 
asTopLevelMap() - Method in class org.apache.flink.table.client.config.entries.DeploymentEntry
 
asTopLevelMap() - Method in class org.apache.flink.table.client.config.entries.ExecutionEntry
 
asum(int, double[], int) - Static method in class org.apache.flink.ml.common.linalg.BLAS
\sum_i |x_i| .
asum(DenseVector) - Static method in class org.apache.flink.ml.common.linalg.BLAS
\sum_i |x_i| .
asum(SparseVector) - Static method in class org.apache.flink.ml.common.linalg.BLAS
\sum_i |x_i| .
asVariable(String) - Static method in class org.apache.flink.runtime.metrics.scope.ScopeFormat
Formats the given string to resemble a scope variable.
asWatermark() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a Watermark.
ASYMMETRIC - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ASYNC_SNAPSHOTS - Static variable in class org.apache.flink.configuration.CheckpointingOptions
Option whether the state backend should use an asynchronous snapshot method where possible and configurable.
AsyncDataStream - Class in org.apache.flink.streaming.api.datastream
A helper class to apply AsyncFunction to a data stream.
AsyncDataStream() - Constructor for class org.apache.flink.streaming.api.datastream.AsyncDataStream
 
AsyncDataStream.OutputMode - Enum in org.apache.flink.streaming.api.datastream
Output mode for asynchronous operations.
asyncException - Variable in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase
Errors encountered in the async producer are stored here.
AsyncExceptionHandler - Interface in org.apache.flink.streaming.runtime.tasks
An interface marking a task as capable of handling exceptions thrown by different threads, other than the one executing the task itself.
AsyncFunction<IN,OUT> - Interface in org.apache.flink.streaming.api.functions.async
A function to trigger Async I/O operation.
AsynchronousBlockReader - Class in org.apache.flink.runtime.io.disk.iomanager
A reader that reads data in blocks from a file channel.
AsynchronousBlockReader(FileIOChannel.ID, RequestQueue<ReadRequest>, LinkedBlockingQueue<MemorySegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBlockReader
Creates a new block channel reader for the given channel.
AsynchronousBlockWriter - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBlockWriter(FileIOChannel.ID, RequestQueue<WriteRequest>, LinkedBlockingQueue<MemorySegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBlockWriter
Creates a new block channel writer for the given channel.
AsynchronousBlockWriterWithCallback - Class in org.apache.flink.runtime.io.disk.iomanager
An asynchronous implementation of the BlockChannelWriterWithCallback that queues I/O requests and calls a callback once they have been handled.
AsynchronousBlockWriterWithCallback(FileIOChannel.ID, RequestQueue<WriteRequest>, RequestDoneCallback<MemorySegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBlockWriterWithCallback
Creates a new asynchronous block writer for the given channel.
AsynchronousBufferFileReader - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBufferFileReader(FileIOChannel.ID, RequestQueue<ReadRequest>, RequestDoneCallback<Buffer>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileReader
 
AsynchronousBufferFileSegmentReader - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBufferFileSegmentReader(FileIOChannel.ID, RequestQueue<ReadRequest>, RequestDoneCallback<FileSegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileSegmentReader
 
AsynchronousBufferFileWriter - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBufferFileWriter(FileIOChannel.ID, RequestQueue<WriteRequest>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileWriter
 
AsynchronousBulkBlockReader - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBulkBlockReader(FileIOChannel.ID, RequestQueue<ReadRequest>, List<MemorySegment>, int) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBulkBlockReader
 
AsynchronousException - Exception in org.apache.flink.streaming.runtime.tasks
An exception for wrapping exceptions that are thrown by an operator in threads other than the main compute thread of that operator.
AsynchronousException(Throwable) - Constructor for exception org.apache.flink.streaming.runtime.tasks.AsynchronousException
 
AsynchronousException(String, Throwable) - Constructor for exception org.apache.flink.streaming.runtime.tasks.AsynchronousException
 
AsynchronousFileIOChannel<T,R extends org.apache.flink.runtime.io.disk.iomanager.IORequest> - Class in org.apache.flink.runtime.io.disk.iomanager
A base class for readers and writers that accept read or write requests for whole blocks.
AsynchronousFileIOChannel(FileIOChannel.ID, RequestQueue<R>, RequestDoneCallback<T>, boolean) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
Creates a new channel access to the path indicated by the given ID.
AsynchronousJobOperationKey - Class in org.apache.flink.runtime.rest.handler.job
A pair of JobID and TriggerId used as a key to a hash based collection.
AsynchronouslyCreatedResource<T> - Interface in org.apache.flink.runtime.rest.messages.queue
Interface for REST resources that are created asynchronously.
AsynchronousOperationInfo - Class in org.apache.flink.runtime.rest.handler.async
Basic information object for asynchronous operations.
AsynchronousOperationResult<V> - Class in org.apache.flink.runtime.rest.handler.async
Result of an asynchronous operation.
AsynchronousOperationStatusMessageHeaders<V,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.async
Message headers for the status polling of an asynchronous operation.
AsynchronousOperationStatusMessageHeaders() - Constructor for class org.apache.flink.runtime.rest.handler.async.AsynchronousOperationStatusMessageHeaders
 
AsynchronousOperationTriggerMessageHeaders<R extends RequestBody,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.async
Message headers for the triggering of an asynchronous operation.
AsynchronousOperationTriggerMessageHeaders() - Constructor for class org.apache.flink.runtime.rest.handler.async.AsynchronousOperationTriggerMessageHeaders
 
asynchronousSnapshots - Variable in class org.apache.flink.runtime.state.DefaultOperatorStateBackendBuilder
Flag to de/activate asynchronous snapshots.
asyncInvoke(IN, ResultFuture<OUT>) - Method in interface org.apache.flink.streaming.api.functions.async.AsyncFunction
Trigger async operation for each stream input.
asyncInvoke(IN, ResultFuture<OUT>) - Method in class org.apache.flink.streaming.api.functions.async.RichAsyncFunction
 
asyncInvoke(BaseRow, ResultFuture<BaseRow>) - Method in class org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner
 
AsyncIOExample - Class in org.apache.flink.streaming.examples.async
Example to illustrates how to use AsyncFunction.
AsyncIOExample() - Constructor for class org.apache.flink.streaming.examples.async.AsyncIOExample
 
AsyncLookupJoinRunner - Class in org.apache.flink.table.runtime.operators.join.lookup
The async join runner to lookup the dimension table.
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<BaseRow, Object>>, GeneratedResultFuture<TableFunctionResultFuture<BaseRow>>, TypeInformation<?>, BaseRowTypeInfo, boolean, int) - Constructor for class org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner
 
AsyncLookupJoinWithCalcRunner - Class in org.apache.flink.table.runtime.operators.join.lookup
The async join runner with an additional calculate function on the dimension table.
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<BaseRow, Object>>, GeneratedFunction<FlatMapFunction<BaseRow, BaseRow>>, GeneratedResultFuture<TableFunctionResultFuture<BaseRow>>, TypeInformation<?>, BaseRowTypeInfo, boolean, int) - Constructor for class org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinWithCalcRunner
 
AsyncSnapshotCallable<T> - Class in org.apache.flink.runtime.state
Base class that outlines the strategy for asynchronous snapshots.
AsyncSnapshotCallable() - Constructor for class org.apache.flink.runtime.state.AsyncSnapshotCallable
 
AsyncSnapshotCallable.AsyncSnapshotTask - Class in org.apache.flink.runtime.state
FutureTask that wraps a AsyncSnapshotCallable and connects it with cancellation and closing.
AsyncTableFunction<T> - Class in org.apache.flink.table.functions
Base class for a user-defined asynchronously table function (UDTF).
AsyncTableFunction() - Constructor for class org.apache.flink.table.functions.AsyncTableFunction
 
AsyncWaitOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.async
The AsyncWaitOperator allows to asynchronously process incoming stream records.
AsyncWaitOperator(AsyncFunction<IN, OUT>, long, int, AsyncDataStream.OutputMode, MailboxExecutor) - Constructor for class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator
 
AsyncWaitOperatorFactory<IN,OUT> - Class in org.apache.flink.streaming.api.operators.async
The factory of AsyncWaitOperator.
AsyncWaitOperatorFactory(AsyncFunction<IN, OUT>, long, int, AsyncDataStream.OutputMode) - Constructor for class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorFactory
 
AT - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
AT - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ATAN - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ATAN - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
atan(Decimal) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
ATAN2 - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ATAN2 - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
atan2(Decimal, Decimal) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
ATOMIC - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
AtomicDataType - Class in org.apache.flink.table.types
A data type that does not contain further data types (e.g.
AtomicDataType(LogicalType, Class<?>) - Constructor for class org.apache.flink.table.types.AtomicDataType
 
AtomicDataType(LogicalType) - Constructor for class org.apache.flink.table.types.AtomicDataType
 
AtomicDisposableReferenceCounter - Class in org.apache.flink.runtime.util
Atomic reference counter, which enters a "disposed" state after it reaches a configurable reference count (default 0).
AtomicDisposableReferenceCounter() - Constructor for class org.apache.flink.runtime.util.AtomicDisposableReferenceCounter
 
AtomicDisposableReferenceCounter(int) - Constructor for class org.apache.flink.runtime.util.AtomicDisposableReferenceCounter
 
AtomicKvStateRequestStats - Class in org.apache.flink.queryablestate.network.stats
Atomic KvStateRequestStats implementation.
AtomicKvStateRequestStats() - Constructor for class org.apache.flink.queryablestate.network.stats.AtomicKvStateRequestStats
 
AtomicRowExpression() - Method in class org.apache.flink.sql.parser.impl.FlinkSqlParserImpl
Parses an atomic row expression.
AtomicType<T> - Interface in org.apache.flink.api.common.typeinfo
An atomic type is a type that is treated as one indivisible unit and where the entire type acts as a key.
ATTACHED - Static variable in class org.apache.flink.configuration.DeploymentOptions
 
attachJobGraph(List<JobVertex>) - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
 
attemptNumber() - Method in class org.apache.flink.runtime.metrics.groups.TaskMetricGroup
 
ATTRIBUTE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ATTRIBUTES - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
AUTHORIZATION - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
autoAck - Variable in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
AutoClosablePath - Class in org.apache.flink.tests.util
Utility class to delete a given Path when exiting a try-with-resources statement.
AutoClosablePath(Path) - Constructor for class org.apache.flink.tests.util.AutoClosablePath
 
AutoClosableProcess - Class in org.apache.flink.tests.util
Utility class to terminate a given Process when exiting a try-with-resources statement.
AutoClosableProcess(Process) - Constructor for class org.apache.flink.tests.util.AutoClosableProcess
 
AutoClosableProcess.AutoClosableProcessBuilder - Class in org.apache.flink.tests.util
Builder for most sophisticated processes.
AutoCloseableAsync - Interface in org.apache.flink.util
Closeable interface which allows to close a resource in a non blocking fashion.
AUXILIARY_GROUP - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
AUXILIARY_GROUP aggregate function.
AuxiliaryConverter - Interface in org.apache.calcite.sql2rel
Converts an expression for a group window function (e.g.
AuxiliaryConverter.Impl - Class in org.apache.calcite.sql2rel
Simple implementation of AuxiliaryConverter.
AvailabilityHelper() - Constructor for class org.apache.flink.runtime.io.AvailabilityProvider.AvailabilityHelper
 
availabilityHelper - Variable in class org.apache.flink.runtime.io.network.partition.consumer.InputGate
 
AvailabilityProvider - Interface in org.apache.flink.runtime.io
Interface defining couple of essential methods for listening on data availability using CompletableFuture.
AvailabilityProvider.AvailabilityHelper - Class in org.apache.flink.runtime.io
A availability implementation for providing the helpful functions of resetting the available/unavailable states.
available() - Method in class org.apache.flink.core.fs.FSDataInputStreamWrapper
 
available() - Method in class org.apache.flink.core.fs.local.LocalDataInputStream
 
available() - Method in class org.apache.flink.core.memory.DataInputDeserializer
 
available() - Method in class org.apache.flink.core.memory.MemorySegmentInputStreamWithPos
 
available() - Method in class org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream
 
AVAILABLE - Static variable in interface org.apache.flink.runtime.io.AvailabilityProvider
Constant that allows to avoid volatile checks CompletableFuture.isDone().
available()