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 _ 

$

$(String) - Static method in class org.apache.flink.table.api.Expressions
Creates an unresolved reference to a table's field.

A

A - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
A - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
abort(long, Throwable, boolean) - Method in interface org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter
Aborts the checkpoint and fails pending result for this checkpoint.
abort(long, Throwable, boolean) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter.NoOpChannelStateWriter
 
abort(long, Throwable, boolean) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriterImpl
 
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
 
abortCheckpoint(long) - Method in class org.apache.flink.runtime.state.NoOpTaskLocalStateStoreImpl
 
abortCheckpoint(long) - Method in interface org.apache.flink.runtime.state.TaskLocalStateStore
Notifies that the checkpoint with the given id was confirmed as aborted.
abortCheckpoint(long) - Method in class org.apache.flink.runtime.state.TaskLocalStateStoreImpl
 
abortCheckpoint(ExecutionAttemptID, long, long) - Method in class org.apache.flink.runtime.taskexecutor.TaskExecutor
 
abortCheckpoint(ExecutionAttemptID, long, long) - Method in interface org.apache.flink.runtime.taskexecutor.TaskExecutorGateway
Abort a checkpoint for the given task.
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
 
abortCheckpointOnBarrier(long, Throwable, OperatorChain<?, ?>) - Method in interface org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinator
 
abortCurrentTriggering() - Method in interface org.apache.flink.runtime.checkpoint.OperatorCoordinatorCheckpointContext
 
abortCurrentTriggering() - Method in class org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder
 
abortPendingCheckpoint(long, CheckpointException) - Method in class org.apache.flink.streaming.runtime.io.CheckpointBarrierAligner
 
abortPendingCheckpoint(long, CheckpointException) - Method in class org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler
 
abortPendingCheckpoint(long, CheckpointException) - Method in class org.apache.flink.streaming.runtime.io.CheckpointBarrierUnaligner
 
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.hive.impl.FlinkHiveSqlParserImplConstants
 
ABS - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
abs() - Method in class org.apache.flink.table.api.internal.BaseExpressions
Calculates the absolute value of given value.
abs(DecimalData) - Static method in class org.apache.flink.table.data.DecimalDataUtils
 
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(DecimalData) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
ABSENT - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
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.hive.impl.FlinkHiveSqlParserImplConstants
 
ABSOLUTE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
absoluteTimeMillis() - Method in class org.apache.flink.util.clock.Clock
Gets the current absolute time, in milliseconds.
absoluteTimeMillis() - Method in class org.apache.flink.util.clock.ManualClock
 
absoluteTimeMillis() - Method in class org.apache.flink.util.clock.SystemClock
 
absolutizePath(Path) - Static method in class org.apache.flink.util.FileUtils
Absolutize the given path if it is relative.
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
 
AbstractArrowPythonScalarFunctionRunner<IN> - Class in org.apache.flink.table.runtime.runners.python.scalar.arrow
Abstract PythonFunctionRunner used to execute Arrow Python ScalarFunctions.
AbstractArrowPythonScalarFunctionRunner(String, FnDataReceiver<byte[]>, PythonFunctionInfo[], PythonEnvironmentManager, RowType, RowType, int, Map<String, String>, FlinkMetricContainer) - Constructor for class org.apache.flink.table.runtime.runners.python.scalar.arrow.AbstractArrowPythonScalarFunctionRunner
 
AbstractArrowSourceFunction<OUT> - Class in org.apache.flink.table.runtime.arrow.sources
An Arrow SourceFunction which takes the serialized arrow record batch data as input.
AbstractArrowTableSource<T> - Class in org.apache.flink.table.runtime.arrow.sources
A StreamTableSource for serialized arrow record batch data.
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
 
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
 
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
 
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
 
AbstractChannelStateHandle<Info> - Class in org.apache.flink.runtime.state
Abstract channel state handle.
AbstractChannelStateHandle.StateContentMetaInfo - Class in org.apache.flink.runtime.state
Describes the underlying content.
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
 
AbstractColumnReader<VECTOR extends WritableColumnVector> - Class in org.apache.flink.formats.parquet.vector.reader
Abstract ColumnReader.
AbstractColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader
 
AbstractContainerizedClusterClientFactory<ClusterID> - Class in org.apache.flink.client.deployment
An abstract ClusterClientFactory containing some common implementations for different containerized deployment clusters.
AbstractContainerizedClusterClientFactory() - Constructor for class org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory
 
AbstractCsvInputFormat<T> - Class in org.apache.flink.formats.csv
Input format that reads csv.
AbstractCsvInputFormat(Path[], CsvSchema) - Constructor for class org.apache.flink.formats.csv.AbstractCsvInputFormat
 
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) - Constructor for class org.apache.flink.streaming.runtime.io.AbstractDataOutput
 
AbstractDataType<T extends AbstractDataType<T>> - Interface in org.apache.flink.table.types
Highest abstraction that describes the data type of a value in the table ecosystem.
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.
 
AbstractDispatcherLeaderProcess - Class in org.apache.flink.runtime.dispatcher.runner
A base DispatcherLeaderProcess.
AbstractDispatcherLeaderProcess.DispatcherGatewayService - Interface in org.apache.flink.runtime.dispatcher.runner
An accessor of the DispatcherGateway.
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory - Interface in org.apache.flink.runtime.dispatcher.runner
AbstractDispatcherLeaderProcess.State - Enum in org.apache.flink.runtime.dispatcher.runner
The state of the DispatcherLeaderProcess.
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<WatermarkStrategy<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, ReadableConfig) - 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.
AbstractGeneralPythonScalarFunctionRunner<IN> - Class in org.apache.flink.table.runtime.runners.python.scalar
Abstract PythonFunctionRunner used to execute Python ScalarFunctions.
AbstractGeneralPythonScalarFunctionRunner(String, FnDataReceiver<byte[]>, PythonFunctionInfo[], PythonEnvironmentManager, RowType, RowType, Map<String, String>, FlinkMetricContainer) - Constructor for class org.apache.flink.table.runtime.runners.python.scalar.AbstractGeneralPythonScalarFunctionRunner
 
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.data.vector.heap
Heap vector that nullable shared structure.
AbstractHeapVector(int) - Constructor for class org.apache.flink.table.data.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.
AbstractInput<IN,OUT> - Class in org.apache.flink.streaming.api.operators
Base abstract implementation of Input interface intended to be used when extending AbstractStreamOperatorV2.
AbstractInput(AbstractStreamOperatorV2<OUT>, int) - Constructor for class org.apache.flink.streaming.api.operators.AbstractInput
 
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
 
AbstractJdbcCatalog - Class in org.apache.flink.connector.jdbc.catalog
Abstract catalog for any JDBC catalogs.
AbstractJdbcCatalog(String, String, String, String, String) - Constructor for class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
AbstractJdbcOutputFormat<T> - Class in org.apache.flink.connector.jdbc.internal
Base jdbc outputFormat.
AbstractJdbcOutputFormat(JdbcConnectionProvider) - Constructor for class org.apache.flink.connector.jdbc.internal.AbstractJdbcOutputFormat
 
AbstractJdbcRowConverter - Class in org.apache.flink.connector.jdbc.internal.converter
Base class for all converters that convert between JDBC object and Flink internal object.
AbstractJdbcRowConverter(RowType) - Constructor for class org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter
 
AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> - Class in org.apache.flink.client.deployment.executors
An abstract PipelineExecutor used to execute pipelines on dedicated (per-job) clusters.
AbstractJobClusterExecutor(ClientFactory) - Constructor for class org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor
 
AbstractJobManagerFileHandler<M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.cluster
Base class for serving files from the JobManager.
AbstractJobManagerFileHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, UntypedResponseMessageHeaders<EmptyRequestBody, M>) - Constructor for class org.apache.flink.runtime.rest.handler.cluster.AbstractJobManagerFileHandler
 
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
 
AbstractKubernetesParameters - Class in org.apache.flink.kubernetes.kubeclient.parameters
Abstract class for the KubernetesParameters.
AbstractKubernetesParameters(Configuration) - Constructor for class org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters
 
AbstractKubernetesStepDecorator - Class in org.apache.flink.kubernetes.kubeclient.decorators
An abstract KubernetesStepDecorator contains common implementations for different plug-in features.
AbstractKubernetesStepDecorator() - Constructor for class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
 
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
 
AbstractMultipleInputTransformation<OUT> - Class in org.apache.flink.streaming.api.transformations
Base class for transformations representing the application of a MultipleInputStreamOperator to input Transformations.
AbstractMultipleInputTransformation(String, StreamOperatorFactory<OUT>, TypeInformation<OUT>, int) - Constructor for class org.apache.flink.streaming.api.transformations.AbstractMultipleInputTransformation
 
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.
AbstractOrcColumnVector - Class in org.apache.flink.orc.vector
This column vector is used to adapt hive's ColumnVector to Flink's ColumnVector.
AbstractOrcNoHiveVector - Class in org.apache.flink.orc.nohive.vector
This column vector is used to adapt hive's ColumnVector to Flink's ColumnVector.
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
 
AbstractPartFileWriter<IN,BucketID> - Class in org.apache.flink.streaming.api.functions.sink.filesystem
An abstract writer for the currently open part file in a specific Bucket.
AbstractPartFileWriter(BucketID, long) - Constructor for class org.apache.flink.streaming.api.functions.sink.filesystem.AbstractPartFileWriter
 
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
 
AbstractPythonCorrelateRuleBase - Class in org.apache.flink.table.plan.rules
The abstract physical rule base is responsible for converting FlinkLogicalCorrelate to physical Python correlate RelNode.
AbstractPythonCorrelateRuleBase(Convention, String) - Constructor for class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase
 
AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase - Class in org.apache.flink.table.plan.rules
The abstract factory is responsible for creating DataSetPythonCorrelate or DataStreamPythonCorrelate.
AbstractPythonFunctionOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.python
Base class for all stream operators to execute Python functions.
AbstractPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator
 
AbstractPythonFunctionRunner<IN> - Class in org.apache.flink.python
An base class for PythonFunctionRunner.
AbstractPythonFunctionRunner(String, FnDataReceiver<byte[]>, PythonEnvironmentManager, StateRequestHandler, Map<String, String>, FlinkMetricContainer) - Constructor for class org.apache.flink.python.AbstractPythonFunctionRunner
 
AbstractPythonScalarFunctionFlatMap - Class in org.apache.flink.table.runtime.functions.python
The abstract base RichFlatMapFunction used to invoke Python ScalarFunction functions for the old planner.
AbstractPythonScalarFunctionFlatMap(Configuration, PythonFunctionInfo[], RowType, RowType, int[], int[]) - Constructor for class org.apache.flink.table.runtime.functions.python.AbstractPythonScalarFunctionFlatMap
 
AbstractPythonScalarFunctionOperator<IN,OUT,UDFIN> - Class in org.apache.flink.table.runtime.operators.python.scalar
Base class for all stream operators to execute Python ScalarFunctions.
AbstractPythonScalarFunctionRunner<IN> - Class in org.apache.flink.table.runtime.runners.python.scalar
Abstract PythonFunctionRunner used to execute Python ScalarFunctions.
AbstractPythonScalarFunctionRunner(String, FnDataReceiver<byte[]>, PythonFunctionInfo[], PythonEnvironmentManager, RowType, RowType, Map<String, String>, FlinkMetricContainer) - Constructor for class org.apache.flink.table.runtime.runners.python.scalar.AbstractPythonScalarFunctionRunner
 
AbstractPythonStatelessFunctionFlatMap - Class in org.apache.flink.table.runtime.functions.python
Base Python stateless RichFlatMapFunction used to invoke Python stateless functions for the old planner.
AbstractPythonStatelessFunctionFlatMap(Configuration, RowType, RowType, int[]) - Constructor for class org.apache.flink.table.runtime.functions.python.AbstractPythonStatelessFunctionFlatMap
 
AbstractPythonStatelessFunctionRunner<IN> - Class in org.apache.flink.table.runtime.runners.python
Abstract PythonFunctionRunner used to execute Python stateless functions..
AbstractPythonStatelessFunctionRunner(String, FnDataReceiver<byte[]>, PythonEnvironmentManager, RowType, RowType, String, Map<String, String>, FlinkMetricContainer) - Constructor for class org.apache.flink.table.runtime.runners.python.AbstractPythonStatelessFunctionRunner
 
AbstractPythonTableFunctionOperator<IN,OUT,UDTFIN> - Class in org.apache.flink.table.runtime.operators.python.table
 
AbstractPythonTableFunctionOperator(Configuration, PythonFunctionInfo, RowType, RowType, int[], JoinRelType) - Constructor for class org.apache.flink.table.runtime.operators.python.table.AbstractPythonTableFunctionOperator
 
AbstractPythonTableFunctionRunner<IN> - Class in org.apache.flink.table.runtime.runners.python.table
Abstract PythonFunctionRunner used to execute Python TableFunction.
AbstractPythonTableFunctionRunner(String, FnDataReceiver<byte[]>, PythonFunctionInfo, PythonEnvironmentManager, RowType, RowType, Map<String, String>, FlinkMetricContainer) - Constructor for class org.apache.flink.table.runtime.runners.python.table.AbstractPythonTableFunctionRunner
 
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
 
AbstractResourceManagerHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.resourcemanager
Base class for REST handlers which need access to the ResourceManager.
AbstractResourceManagerHandler(GatewayRetriever<? extends T>, Time, Map<String, String>, MessageHeaders<R, P, M>, GatewayRetriever<ResourceManagerGateway>) - Constructor for class org.apache.flink.runtime.rest.handler.resourcemanager.AbstractResourceManagerHandler
 
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.
AbstractRowDataConverter(DataType[]) - Constructor for class org.apache.flink.table.data.util.DataFormatConverters.AbstractRowDataConverter
 
AbstractRowDataPythonScalarFunctionOperator - Class in org.apache.flink.table.runtime.operators.python.scalar
The Python ScalarFunction operator for the blink planner.
AbstractRowDataPythonScalarFunctionOperator(Configuration, PythonFunctionInfo[], RowType, RowType, int[], int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.scalar.AbstractRowDataPythonScalarFunctionOperator
 
AbstractRowDataSerializer<T extends RowData> - Class in org.apache.flink.table.runtime.typeutils
Row serializer, provided paged serialize paged method.
AbstractRowDataSerializer() - Constructor for class org.apache.flink.table.runtime.typeutils.AbstractRowDataSerializer
 
AbstractRowPythonScalarFunctionOperator - Class in org.apache.flink.table.runtime.operators.python.scalar
Base Python ScalarFunction operator for the legacy planner.
AbstractRowPythonScalarFunctionOperator(Configuration, PythonFunctionInfo[], RowType, RowType, int[], int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.scalar.AbstractRowPythonScalarFunctionOperator
 
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, String, 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.
AbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> - Class in org.apache.flink.client.deployment.executors
An abstract PipelineExecutor used to execute pipelines on an existing (session) cluster.
AbstractSessionClusterExecutor(ClientFactory) - Constructor for class org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor
 
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
 
AbstractSqlCallContext - Class in org.apache.flink.table.planner.functions.inference
A CallContext backed by SqlOperatorBinding.
AbstractSqlCallContext(DataTypeFactory, FunctionDefinition, String) - Constructor for class org.apache.flink.table.planner.functions.inference.AbstractSqlCallContext
 
AbstractSqlCallContext.LiteralValueAccessor - Interface in org.apache.flink.table.planner.functions.inference
Helper interface for abstracting accessing literals.
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
 
AbstractStatelessFunctionOperator<IN,OUT,UDFIN> - Class in org.apache.flink.table.runtime.operators.python
Base class for all stream operators to execute Python Stateless Functions.
AbstractStatelessFunctionOperator(Configuration, RowType, RowType, int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.AbstractStatelessFunctionOperator
 
AbstractStatelessFunctionOperator.StreamRecordCRowWrappingCollector - Class in org.apache.flink.table.runtime.operators.python
The collector is used to convert a Row to a CRow.
AbstractStatelessFunctionOperator.StreamRecordRowDataWrappingCollector - Class in org.apache.flink.table.runtime.operators.python
The collector is used to convert a RowData to a StreamRecord.
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(RowDataTypeInfo, RowDataTypeInfo, 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
 
AbstractStreamOperatorFactory<OUT> - Class in org.apache.flink.streaming.api.operators
Base class for all stream operator factories.
AbstractStreamOperatorFactory() - Constructor for class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory
 
AbstractStreamOperatorV2<OUT> - Class in org.apache.flink.streaming.api.operators
New base class for all stream operators, intended to eventually replace AbstractStreamOperator.
AbstractStreamOperatorV2(StreamOperatorParameters<OUT>, int) - Constructor for class org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2
 
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.
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
 
AbstractTimeIndexGenerator - Class in org.apache.flink.streaming.connectors.elasticsearch.index
Abstract class for time related IndexGenerator.
AbstractTimeIndexGenerator(String, String) - Constructor for class org.apache.flink.streaming.connectors.elasticsearch.index.AbstractTimeIndexGenerator
 
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
 
AbstractWritableVector - Class in org.apache.flink.table.data.vector.writable
Contains the shared structure for ColumnVectors, including NULL information and dictionary.
AbstractWritableVector() - Constructor for class org.apache.flink.table.data.vector.writable.AbstractWritableVector
 
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.api.ApiExpression
 
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.ValuesQueryOperation
 
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.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.RawType
 
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.TypeInformationRawType
Deprecated.
 
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(S, T, U, V) - Method in interface org.apache.flink.util.function.QuadConsumer
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.
acceptCall(SqlVisitor<R>, SqlCall, boolean, SqlBasicVisitor.ArgHandler<R>) - Method in class org.apache.calcite.sql.SqlMatchRecognize.SqlMatchRecognizeOperator
 
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.
AccessControlListHandler() - Constructor for class com.amazonaws.services.s3.model.transform.XmlResponsesSaxParser.AccessControlListHandler
 
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(ByteBuf, ByteBuf, int, int) - Static method in class org.apache.flink.runtime.io.network.netty.ByteBufUtils
Accumulates data from source to target.
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(GenericRowData, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(GenericRowData, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(GenericRowData, DecimalData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.DecimalFirstValueAggFunction
 
accumulate(GenericRowData, DecimalData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.DecimalFirstValueAggFunction
 
accumulate(GenericRowData, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.StringFirstValueAggFunction
 
accumulate(GenericRowData, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction.StringFirstValueAggFunction
 
accumulate(GenericRowData, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(GenericRowData, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(GenericRowData, DecimalData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction
 
accumulate(GenericRowData, DecimalData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction
 
accumulate(GenericRowData, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction
 
accumulate(GenericRowData, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction
 
accumulate(GenericRowData, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(GenericRowData, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(GenericRowData, DecimalData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.DecimalLastValueAggFunction
 
accumulate(GenericRowData, DecimalData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.DecimalLastValueAggFunction
 
accumulate(GenericRowData, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.StringLastValueAggFunction
 
accumulate(GenericRowData, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction.StringLastValueAggFunction
 
accumulate(GenericRowData, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(GenericRowData, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(GenericRowData, DecimalData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction
 
accumulate(GenericRowData, DecimalData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction
 
accumulate(GenericRowData, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
 
accumulate(GenericRowData, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
 
accumulate(ListAggWithRetractAggFunction.ListAggWithRetractAccumulator, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.ListAggWithRetractAggFunction
 
accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator, StringData, StringData) - 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<DecimalData>, DecimalData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction
 
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<StringData>, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction.StringMaxWithRetractAggFunction
 
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<TimestampData>, TimestampData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction.TimestampMaxWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<DecimalData>, DecimalData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction.DecimalMinWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<StringData>, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction.StringMinWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<TimestampData>, TimestampData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction.TimestampMinWithRetractAggFunction
 
accumulate(RowData) - Method in interface org.apache.flink.table.runtime.generated.AggsHandleFunctionBase
Accumulates the input values to the accumulators.
accumulate(RowData) - Method in interface org.apache.flink.table.runtime.generated.NamespaceAggsHandleFunctionBase
Accumulates the input values to the accumulators.
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
 
accumulateFinalResults() - Method in class org.apache.flink.streaming.api.operators.collect.CollectSinkFunction
 
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
 
acknowledgeCoordinatorState(OperatorInfo, ByteStreamStateHandle) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
 
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.
acknowledgeMessage() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
ATTENTION to subclass implementors: When overriding this method, please always call super.acknowledgeMessage() to keep the invariants of the internal bookkeeping of the producer.
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.
ackReport() - Method in class org.apache.flink.metrics.datadog.DCounter
 
ackReport() - Method in class org.apache.flink.metrics.datadog.DMetric
 
acos() - Method in class org.apache.flink.table.api.internal.BaseExpressions
Calculates the arc cosine of a given number.
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(DecimalData) - 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
 
acquireLease() - Method in class org.apache.flink.runtime.state.NonClosingCheckpointOutputStream
Returns a ResourceGuard.Lease that prevents closing this stream.
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.hive.impl.FlinkHiveSqlParserImplConstants
 
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
 
ActiveResourceManager<WorkerType extends ResourceIDRetrievable> - Class in org.apache.flink.runtime.resourcemanager
Base class for ResourceManager implementations which contains some common variables and methods.
ActiveResourceManager(Configuration, Map<String, String>, RpcService, ResourceID, HighAvailabilityServices, HeartbeatServices, SlotManager, ResourceManagerPartitionTrackerFactory, JobLeaderIdService, ClusterInformation, FatalErrorHandler, ResourceManagerMetricGroup) - Constructor for class org.apache.flink.runtime.resourcemanager.ActiveResourceManager
 
ActiveResourceManager.PendingWorkerNums - Class in org.apache.flink.runtime.resourcemanager
Number of workers pending for allocation/registration.
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.hive.impl.FlinkHiveSqlParserImplConstants
 
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.
adaptArguments(TypeInference, CallContext, DataType) - Static method in class org.apache.flink.table.types.inference.TypeInferenceUtil
Adapts the call's argument if necessary.
AdaptedCallContext - Class in org.apache.flink.table.types.inference.utils
Helper context that deals with adapted arguments.
AdaptedCallContext(CallContext, DataType) - Constructor for class org.apache.flink.table.types.inference.utils.AdaptedCallContext
 
adapterForIterator(Iterator<T>) - Static method in interface org.apache.flink.util.CloseableIterator
 
adapterForIterator(Iterator<T>, AutoCloseable) - 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
Deprecated.
Add a parameter based on its name.
add(Option) - Method in class org.apache.flink.api.java.utils.RequiredParameters
Deprecated.
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(String, E) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
Add the record from the given split ID.
add(SourceSplit, E) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
Add the record from the given source split.
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.OrcSplitReader.Between
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.Equals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.In
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.IsNull
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.LessThan
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.LessThanEquals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.Not
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.NullSafeEquals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.Or
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcSplitReader.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, boolean) - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition
 
add(BufferConsumer, boolean) - Method in class org.apache.flink.runtime.io.network.partition.ResultSubpartition
Adds the given buffer.
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(T) - 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.hive.impl.FlinkHiveSqlParserImplConstants
 
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(T) - Method in class org.apache.flink.streaming.api.operators.util.SimpleVersionedListState
 
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(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(T) - Method in class org.apache.flink.table.api.dataview.ListView
Adds the given value to the list.
add(TableColumn) - Method in class org.apache.flink.table.api.TableSchema.Builder
Adds a TableColumn to this builder.
add(DecimalData, DecimalData, int, int) - Static method in class org.apache.flink.table.data.DecimalDataUtils
 
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(RowData) - Method in class org.apache.flink.table.runtime.util.ResettableExternalBuffer
 
add(RowData) - 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.hive.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_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(String, Collection<E>) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
Add multiple records from the given split ID.
addAll(SourceSplit, Collection<E>) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
Add multiple records from the given source split.
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.streaming.api.operators.util.SimpleVersionedListState
 
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 class org.apache.flink.runtime.io.network.api.writer.RecordWriter
 
addBufferConsumer(BufferConsumer, int, boolean) - 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 interface org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter
Adds the bufferConsumer to the subpartition with the given index.
addBufferConsumer(BufferConsumer, int, boolean) - Method in class org.apache.flink.runtime.io.network.partition.ResultPartition
 
addBufferConsumer(BufferConsumer, int, boolean) - 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.connector.hbase.source.HBaseTableSource
Adds a column defined by family, qualifier, and type to the table schema.
addColumn(String, String, Class<?>) - Method in class org.apache.flink.connector.hbase.util.HBaseTableSchema
Adds a column defined by family, qualifier, and type to the table schema.
addColumn(String, String, DataType) - Method in class org.apache.flink.connector.hbase.util.HBaseTableSchema
 
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
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 class org.apache.flink.tests.util.flink.FlinkResourceSetup.FlinkResourceSetupBuilder
 
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
 
addContainedKind(RowKind) - Method in class org.apache.flink.table.connector.ChangelogMode.Builder
 
addContainedKind(ModifyKind) - Method in class org.apache.flink.table.planner.plan.trait.ModifyKindSet.Builder
 
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.
addCounter(DCounter) - Method in class org.apache.flink.metrics.datadog.DSeries
 
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.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.planner.utils.DummyStreamExecutionEnvironment
 
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.table.planner.utils.DummyStreamExecutionEnvironment
 
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment
 
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment
 
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.avro.AvroBulkWriter
 
addElement(T) - Method in class org.apache.flink.formats.compress.writers.HadoopCompressionBulkWriter
 
addElement(T) - Method in class org.apache.flink.formats.compress.writers.NoCompressionBulkWriter
 
addElement(T) - Method in class org.apache.flink.formats.parquet.ParquetBulkWriter
 
addElement(Tuple2<K, V>) - Method in class org.apache.flink.formats.sequencefile.SequenceFileWriter
 
addElement(T) - Method in class org.apache.flink.orc.writer.OrcBulkWriter
 
addEscapes(String) - Static method in error org.apache.flink.sql.parser.hive.impl.TokenMgrError
Replaces unprintable characters by their espaced (or unicode escaped) equivalents in the given string
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
addExtendedResource(String, Resource) - Method in class org.apache.flink.runtime.clusterframework.types.ResourceProfile.Builder
 
addExtendedResources(Map<String, Resource>) - Method in class org.apache.flink.runtime.clusterframework.types.ResourceProfile.Builder
 
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
 
addFinishedSplit(String) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
Mark the split with the given ID as finished.
addFinishedSplits(Collection<String>) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
Mark multiple splits with the given IDs as finished.
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
 
addGauge(DGauge) - Method in class org.apache.flink.metrics.datadog.DSeries
 
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.client.cli.GenericCLI
 
addGeneralOptions(Options) - Method in class org.apache.flink.yarn.cli.FallbackYarnSessionCli
 
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(Transformation<?>, KeySelector<?, ?>) - Method in class org.apache.flink.streaming.api.transformations.KeyedMultipleInputTransformation
 
addInput(Transformation<?>) - Method in class org.apache.flink.streaming.api.transformations.MultipleInputTransformation
 
addInput(RowData, RowData) - 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<RowData>, RowData) - Method in class org.apache.flink.table.runtime.operators.aggregate.MiniBatchGroupAggFunction
 
addInput(RowData, RowData) - Method in class org.apache.flink.table.runtime.operators.aggregate.MiniBatchIncrementalGroupAggFunction
 
addInput(RowData, RowData) - 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(RowData, RowData) - Method in class org.apache.flink.table.runtime.operators.deduplicate.MiniBatchDeduplicateKeepFirstRowFunction
 
addInput(RowData, RowData) - Method in class org.apache.flink.table.runtime.operators.deduplicate.MiniBatchDeduplicateKeepLastRowFunction
 
addInputChannel(RemoteInputChannel) - Method in interface org.apache.flink.runtime.io.network.NetworkClientHandler
 
addInputData(long, InputChannelInfo, int, CloseableIterator<Buffer>) - Method in interface org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter
Add in-flight buffers from the InputChannel.
addInputData(long, InputChannelInfo, int, CloseableIterator<Buffer>) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter.NoOpChannelStateWriter
 
addInputData(long, InputChannelInfo, int, CloseableIterator<Buffer>) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriterImpl
 
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(BinaryRowData) - Method in class org.apache.flink.table.runtime.operators.window.grouping.WindowsGrouping
 
addInputToGroup(int) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addInsert(String, Table) - Method in interface org.apache.flink.table.api.StatementSet
add Table with the given sink table name to the set.
addInsert(String, Table, boolean) - Method in interface org.apache.flink.table.api.StatementSet
add Table with the given sink table name to the set.
addInsertSql(String) - Method in interface org.apache.flink.table.api.StatementSet
add insert statement to the set.
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(BinaryRowData) - Method in class org.apache.flink.table.runtime.operators.window.grouping.HeapWindowsGrouping
 
addIntoBuffer(BinaryRowData) - 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.
addJar(Path) - Method in class org.apache.flink.tests.util.flink.SQLJobSubmission.SQLJobSubmissionBuilder
 
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).
addJars(List<Path>) - Method in class org.apache.flink.tests.util.flink.SQLJobSubmission.SQLJobSubmissionBuilder
 
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.DefaultJobLeaderService
 
addJob(JobID, String) - Method in interface org.apache.flink.runtime.taskexecutor.JobLeaderService
Add the given job to be monitored.
addJobParameter(String, String) - Method in class org.apache.flink.table.api.TableConfig
Sets a custom user parameter that can be accessed via FunctionContext.getJobParameter(String, String).
addJvmArg(String) - Method in class org.apache.flink.test.util.TestProcessBuilder
 
addLegacySource(Integer, String, String, StreamOperatorFactory<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
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.
addMeter(DMeter) - 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.flink.table.runtime.functions.SqlFunctionUtils
TODO: remove addMonths and subtractMonths if CALCITE-3881 fixed.
addMonths(int, int) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
addMultipleInputOperator(Integer, String, String, StreamOperatorFactory<OUT>, List<TypeInformation<?>>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
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
 
addOperatorCoordinator(SerializedValue<OperatorCoordinator.Provider>) - Method in class org.apache.flink.runtime.jobgraph.JobVertex
 
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
addOrReplaceColumns(Expression...) - Method in interface org.apache.flink.table.api.Table
Adds additional 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.
addOutputData(long, ResultSubpartitionInfo, int, Buffer...) - Method in interface org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter
Add in-flight buffers from the ResultSubpartition.
addOutputData(long, ResultSubpartitionInfo, int, Buffer...) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter.NoOpChannelStateWriter
 
addOutputData(long, ResultSubpartitionInfo, int, Buffer...) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriterImpl
 
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
 
addPartition(String) - Method in interface org.apache.flink.table.filesystem.stream.PartitionCommitTrigger
Add a pending partition.
addPartition(String) - Method in class org.apache.flink.table.filesystem.stream.PartitionTimeCommitTigger
 
addPartition(String) - Method in class org.apache.flink.table.filesystem.stream.ProcTimeCommitTigger
 
AddPartitionsOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe ALTER TABLE ADD PARTITION statement.
AddPartitionsOperation(ObjectIdentifier, boolean, List<CatalogPartitionSpec>, List<CatalogPartition>) - Constructor for class org.apache.flink.table.operations.ddl.AddPartitionsOperation
 
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(OrcSplitReader.Predicate) - Method in class org.apache.flink.orc.OrcInputFormat
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
 
addReader(int) - Method in class org.apache.flink.api.connector.source.lib.util.IteratorSourceEnumerator
 
addReader(int) - Method in interface org.apache.flink.api.connector.source.SplitEnumerator
Add a new source reader with the given subtask ID.
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(T) - Method in class org.apache.flink.runtime.operators.sort.LargeRecordHandler
 
addRecord(RowData) - Method in interface org.apache.flink.table.runtime.operators.join.stream.state.JoinRecordStateView
Add a new record to the state view.
addRecord(RowData, 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.BinaryInfo.Builder
 
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.CharInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.DecimalInfo.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.LocalZonedTimestampInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.MapInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimeInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimestampInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarBinaryInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarCharInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.ZonedTimestampInfo.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
Deprecated.
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.client.cli.GenericCLI
 
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, SourceOperatorFactory<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.
AddSplitEvent<SplitT> - Class in org.apache.flink.runtime.source.event
A source event that adds splits to a source reader.
AddSplitEvent(List<SplitT>, SimpleVersionedSerializer<SplitT>) - Constructor for class org.apache.flink.runtime.source.event.AddSplitEvent
 
addSplits(List<SplitT>) - Method in class org.apache.flink.api.connector.source.lib.util.IteratorSourceReader
 
addSplits(List<SplitT>) - Method in interface org.apache.flink.api.connector.source.SourceReader
Adds a list of splits for this reader to read.
addSplits(List<SplitT>) - Method in class org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager
 
addSplits(List<SplitT>) - Method in class org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher
Add splits to the split fetcher.
addSplits(List<SplitT>) - Method in class org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager
 
addSplits(List<SplitT>) - Method in class org.apache.flink.connector.base.source.reader.SourceReaderBase
 
addSplitsBack(List<SplitT>, int) - Method in class org.apache.flink.api.connector.source.lib.util.IteratorSourceEnumerator
 
addSplitsBack(List<SplitT>, int) - Method in interface org.apache.flink.api.connector.source.SplitEnumerator
Add a split back to the split enumerator.
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(T) - Method in interface org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Add the given task to the slot identified by the task's allocation id.
addTask(T) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
 
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
 
addToBatch(RowData) - Method in class org.apache.flink.connector.jdbc.internal.executor.BufferReduceStatementExecutor
 
addToBatch(R) - Method in class org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor
 
addToBatch(T) - Method in interface org.apache.flink.connector.jdbc.internal.executor.JdbcBatchStatementExecutor
 
addToBatch(In, JdbcIn) - Method in class org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat
 
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.
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 enum org.apache.flink.runtime.jobgraph.JobGraphUtils
 
addUserJarBlobKey(PermanentBlobKey) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds the BLOB referenced by the key to the JobGraph's dependencies.
addUserMetadata(String, ByteBuffer) - Method in class org.apache.flink.orc.vector.Vectorizer
Adds arbitrary user metadata to the outgoing ORC file.
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, ResourceSpec) - 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.
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.
adjustAutoCommitConfig(Properties, OffsetCommitMode) - Static method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
Make sure that auto commit is disabled when our offset commit mode is ON_CHECKPOINTS.
adjustBeginLineColumn(int, int) - Method in class org.apache.flink.sql.parser.hive.impl.SimpleCharStream
Method to adjust line and column numbers for the start of a token.
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.
adjustForLocalExecution(Configuration) - Static method in class org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils
 
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.hive.impl.FlinkHiveSqlParserImplConstants
 
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.
advanceTime(long, TimeUnit) - Method in class org.apache.flink.util.clock.ManualClock
Advances the time by the given duration.
advanceTime(Duration) - Method in class org.apache.flink.util.clock.ManualClock
Advances the time by the given duration.
advanceToEndOfEventTime() - Method in class org.apache.flink.streaming.api.operators.StreamSource
 
advanceToEndOfEventTime() - Method in class org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask
 
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.hive.impl.FlinkHiveSqlParserImplConstants
 
AFTER - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
after() - Method in class org.apache.flink.streaming.util.StreamCollector
 
after() - Method in class org.apache.flink.test.util.MiniClusterWithClientResource
 
after() - Method in class org.apache.flink.testutils.executor.TestExecutorResource
 
after() - Method in class org.apache.flink.testutils.logging.TestLoggerResource
 
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.data.writer.BinaryArrayWriter
 
afterGrow() - Method in class org.apache.flink.table.data.writer.BinaryRowWriter
 
afterInvoke() - Method in class org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask
 
afterInvoke() - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
AfterMatchSkipStrategy - Class in org.apache.flink.cep.nfa.aftermatch
Indicate the skip strategy after a match process.
afterReadPage() - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader
After read a page, we may need some initialization.
afterReadPage() - Method in class org.apache.flink.formats.parquet.vector.reader.BooleanColumnReader
 
afterSourceBarrierInjection(long) - Method in interface org.apache.flink.runtime.checkpoint.OperatorCoordinatorCheckpointContext
 
afterSourceBarrierInjection(long) - Method in class org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder
 
afterTestFailure() - Method in class org.apache.flink.tests.util.flink.LocalStandaloneFlinkResource
 
afterTestFailure() - Method in class org.apache.flink.tests.util.kafka.LocalStandaloneKafkaResource
 
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.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
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
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
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
 
AGGREGATE_ACCUMULATE - Static variable in class org.apache.flink.table.functions.UserDefinedFunctionHelper
 
AGGREGATE_MERGE - Static variable in class org.apache.flink.table.functions.UserDefinedFunctionHelper
 
AGGREGATE_RESET - Static variable in class org.apache.flink.table.functions.UserDefinedFunctionHelper
 
AGGREGATE_RETRACT - Static variable in class org.apache.flink.table.functions.UserDefinedFunctionHelper
 
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.
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
A "marker" function definition of an user-defined aggregate function that uses the old type system stack.
AggregateFunctionDefinition(String, AggregateFunction<?, ?>, TypeInformation<?>, TypeInformation<?>) - Constructor for class org.apache.flink.table.functions.AggregateFunctionDefinition
 
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.
Use ClientOptions#CLIENT_TIMEOUT instead.
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
 
AkkaRpcRuntimeException - Exception in org.apache.flink.runtime.rpc.akka.exceptions
Base class for Akka RPC related runtime exceptions.
AkkaRpcRuntimeException(String) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcRuntimeException
 
AkkaRpcRuntimeException(Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcRuntimeException
 
AkkaRpcRuntimeException(String, Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcRuntimeException
 
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, boolean) - 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.
AkkaRpcServiceUtils.AkkaRpcServiceBuilder - Class in org.apache.flink.runtime.rpc.akka
Builder for AkkaRpcService.
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
 
all() - Static method in class org.apache.flink.runtime.types.FlinkChillPackageRegistrar
 
ALL - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
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.
ALL_CHANGES - Static variable in class org.apache.flink.table.planner.plan.trait.ModifyKindSet
A modify kind set contains all change operations.
ALL_JOB_MANAGER - Static variable in class org.apache.flink.annotation.docs.Documentation.Sections
 
ALL_TASK_MANAGER - Static variable in class org.apache.flink.annotation.docs.Documentation.Sections
 
ALL_TASK_MANAGER_NETWORK - Static variable in class org.apache.flink.annotation.docs.Documentation.Sections
 
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.
allActionsCompleted() - Method in class org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.MailboxController
 
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 - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
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.
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
 
allocateOffHeapUnsafeMemory(int) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
 
allocateOffHeapUnsafeMemory(int, Object, Runnable) - 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
Allocates a set of memory segments from this memory manager.
allocatePages(Object, Collection<MemorySegment>, int) - 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(WorkerResourceSpec) - Method in interface org.apache.flink.runtime.resourcemanager.slotmanager.ResourceActions
Requests to allocate a resource with the given WorkerResourceSpec.
allocateReuseBytes(int) - Static method in class org.apache.flink.table.data.binary.BinarySegmentUtils
Allocate bytes that is only for temporary usage, it should not be stored in somewhere else.
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.data.binary.BinarySegmentUtils
 
allocateReuseChars(int) - Static method in class org.apache.flink.table.runtime.util.SegmentsUtil
 
allocateRocksDBSharedResources(long, double, double) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils
Allocate memory controllable RocksDB shared resources.
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
allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration, MemoryManager, Logger) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
 
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(SlotRequestId, ScheduledUnit, SlotProfile, Time) - Method in class org.apache.flink.runtime.jobmaster.slotpool.ThrowingSlotProvider
 
allocateSlot(int, JobID, AllocationID, Time) - Method in interface org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Allocate the slot with the given index for the given job and allocation id.
allocateSlot(int, JobID, AllocationID, ResourceProfile, Time) - Method in interface org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Allocate the slot with the given index for the given job and allocation id.
allocateSlot(int, JobID, AllocationID, Time) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
 
allocateSlot(int, JobID, AllocationID, ResourceProfile, Time) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
 
allocateSlotsAndDeploy(List<ExecutionVertexDeploymentOption>) - Method in class org.apache.flink.runtime.scheduler.DefaultScheduler
 
allocateSlotsAndDeploy(List<ExecutionVertexDeploymentOption>) - Method in interface org.apache.flink.runtime.scheduler.SchedulerOperations
Allocate slots and deploy the vertex when slots are returned.
allocateSlotsFor(List<ExecutionVertexSchedulingRequirements>) - Method in class org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator
 
allocateSlotsFor(List<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
 
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.hive.impl.FlinkHiveSqlParserImplConstants
 
ALLOW - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ALLOW_COMMENTS - Static variable in class org.apache.flink.formats.csv.CsvOptions
 
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).
ALLOWED_FALLBACK_FILESYSTEMS - Static variable in class org.apache.flink.configuration.CoreOptions
 
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
 
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
 
allowPluralTimeUnits() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowQualifyingCommonColumn() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
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
 
alt(String) - Method in class org.apache.flink.api.java.utils.Option
Deprecated.
Define an alternative / short name of the parameter.
ALTER - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
ALTER - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ALTER_COL_CASCADE - Static variable in class org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveTable
 
ALTER_DATABASE_OP - Static variable in class org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveDatabase
 
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
 
ALTER_TABLE_OP - Static variable in class org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveTable
 
AlterCatalogFunctionOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe a ALTER FUNCTION statement for catalog functions.
AlterCatalogFunctionOperation(ObjectIdentifier, CatalogFunction, boolean, boolean) - Constructor for class org.apache.flink.table.operations.ddl.AlterCatalogFunctionOperation
 
alterColumns(StorageDescriptor, CatalogTable) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil
 
alterDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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
 
AlterDatabaseOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe a ALTER DATABASE statement.
AlterDatabaseOperation(String, String, CatalogDatabase) - Constructor for class org.apache.flink.table.operations.ddl.AlterDatabaseOperation
 
alterFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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
 
AlterOperation - Interface in org.apache.flink.table.operations.ddl
A Operation that describes the DDL statements, e.g.
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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 class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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
 
AlterPartitionOperation - Class in org.apache.flink.table.operations.ddl
Abstract Operation to describe all ALTER TABLE statements that should be applied to partitions.
AlterPartitionOperation(ObjectIdentifier, CatalogPartitionSpec) - Constructor for class org.apache.flink.table.operations.ddl.AlterPartitionOperation
 
AlterPartitionPropertiesOperation - Class in org.apache.flink.table.operations.ddl
Operation to alter the properties of partition.
AlterPartitionPropertiesOperation(ObjectIdentifier, CatalogPartitionSpec, CatalogPartition) - Constructor for class org.apache.flink.table.operations.ddl.AlterPartitionPropertiesOperation
 
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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 class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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
 
AlterTableAddConstraintOperation - Class in org.apache.flink.table.operations.ddl
Operation of "ALTER TABLE ADD [CONSTRAINT constraintName] ..." clause.
AlterTableAddConstraintOperation(ObjectIdentifier, String, String[]) - Constructor for class org.apache.flink.table.operations.ddl.AlterTableAddConstraintOperation
 
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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
 
AlterTableDropConstraintOperation - Class in org.apache.flink.table.operations.ddl
Operation of "ALTER TABLE ADD [CONSTRAINT constraintName] ..." clause.
AlterTableDropConstraintOperation(ObjectIdentifier, String) - Constructor for class org.apache.flink.table.operations.ddl.AlterTableDropConstraintOperation
 
AlterTableOperation - Class in org.apache.flink.table.operations.ddl
Abstract Operation to describe all ALTER TABLE statements such as rename table /set properties.
AlterTableOperation(ObjectIdentifier) - Constructor for class org.apache.flink.table.operations.ddl.AlterTableOperation
 
AlterTablePropertiesOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe a ALTER TABLE ..
AlterTablePropertiesOperation(ObjectIdentifier, CatalogTable) - Constructor for class org.apache.flink.table.operations.ddl.AlterTablePropertiesOperation
 
AlterTableRenameOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe a ALTER TABLE ..
AlterTableRenameOperation(ObjectIdentifier, ObjectIdentifier) - Constructor for class org.apache.flink.table.operations.ddl.AlterTableRenameOperation
 
AlterTableSchemaOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe altering the schema of a table.
AlterTableSchemaOperation(ObjectIdentifier, CatalogTable) - Constructor for class org.apache.flink.table.operations.ddl.AlterTableSchemaOperation
 
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
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
 
alterTableViaCatalogBaseTable(ObjectPath, CatalogBaseTable, Table, HiveConf) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil
 
AlterViewAsOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe an ALTER VIEW ...
AlterViewAsOperation(ObjectIdentifier, CatalogView) - Constructor for class org.apache.flink.table.operations.ddl.AlterViewAsOperation
 
AlterViewOperation - Class in org.apache.flink.table.operations.ddl
Abstract Operation to describe all ALTER VIEW statements.
AlterViewOperation(ObjectIdentifier) - Constructor for class org.apache.flink.table.operations.ddl.AlterViewOperation
 
AlterViewPropertiesOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe a ALTER VIEW ..
AlterViewPropertiesOperation(ObjectIdentifier, CatalogView) - Constructor for class org.apache.flink.table.operations.ddl.AlterViewPropertiesOperation
 
AlterViewRenameOperation - Class in org.apache.flink.table.operations.ddl
Operation to describe a ALTER VIEW ..
AlterViewRenameOperation(ObjectIdentifier, ObjectIdentifier) - Constructor for class org.apache.flink.table.operations.ddl.AlterViewRenameOperation
 
ALWAYS - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
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.basics.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.hive.impl.FlinkHiveSqlParserImplConstants
 
AND - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
and(Object, Object, Object...) - Static method in class org.apache.flink.table.api.Expressions
Boolean AND in three-valued logic.
and(InType) - Method in class org.apache.flink.table.api.internal.BaseExpressions
Boolean AND in three-valued logic.
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
 
and(ArgumentTypeStrategy...) - Static method in class org.apache.flink.table.types.inference.InputTypeStrategies
Strategy for a conjunction of multiple ArgumentTypeStrategys into one like f(NUMERIC && LITERAL).
AndArgumentTypeStrategy - Class in org.apache.flink.table.types.inference.strategies
Strategy for inferring and validating an argument using a conjunction of multiple ArgumentTypeStrategys into one like f(NUMERIC && LITERAL)
AndArgumentTypeStrategy(List<? extends ArgumentTypeStrategy>) - Constructor for class org.apache.flink.table.types.inference.strategies.AndArgumentTypeStrategy
 
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
 
AnswerFormatter - Class in org.apache.flink.table.tpcds.utils
Answer set format tool class.
AnswerFormatter() - Constructor for class org.apache.flink.table.tpcds.utils.AnswerFormatter
 
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.hive.impl.FlinkHiveSqlParserImplConstants
 
ANY - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
any() - Static method in class org.apache.flink.table.types.inference.ConstantArgumentCount
 
ANY - Static variable in class org.apache.flink.table.types.inference.InputTypeStrategies
Strategy for an argument that can be of any type.
AnyArgumentTypeStrategy - Class in org.apache.flink.table.types.inference.strategies
Strategy for an argument that can be of any type.
AnyArgumentTypeStrategy() - Constructor for class org.apache.flink.table.types.inference.strategies.AnyArgumentTypeStrategy
 
AnyMatchingSlotMatchingStrategy - Enum in org.apache.flink.runtime.resourcemanager.slotmanager
SlotMatchingStrategy which picks the first matching slot.
anyNull() - Method in class org.apache.flink.table.data.binary.BinaryArrayData
 
anyNull() - Method in class org.apache.flink.table.data.binary.BinaryRowData
The bit is 1 when the field is null.
anyNull(int[]) - Method in class org.apache.flink.table.data.binary.BinaryRowData
 
API_KEY - Static variable in class org.apache.flink.metrics.datadog.DatadogHttpReporter
 
API_VERSION - Static variable in class org.apache.flink.kubernetes.utils.Constants
 
ApiExpression - Class in org.apache.flink.table.api
Java API class that gives access to expression operations.
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
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_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, BinaryRowData) - 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.
appendBytes(int, byte[], int, int) - Method in class org.apache.flink.table.data.vector.heap.HeapBytesVector
 
appendBytes(int, byte[], int, int) - Method in interface org.apache.flink.table.data.vector.writable.WritableBytesVector
Append byte[] at rowId with the provided value.
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
A TopN function could handle insert-only stream.
AppendOnlyTopNFunction(long, long, RowDataTypeInfo, GeneratedRecordComparator, RowDataKeySelector, RankType, RankRange, boolean, boolean, long) - Constructor for class org.apache.flink.table.runtime.operators.rank.AppendOnlyTopNFunction
 
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.
appendRawStripe(ByteBuffer, OrcProto.StripeInformation.Builder) - Method in class org.apache.flink.orc.writer.PhysicalWriterImpl
 
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_ARGS - Static variable in class org.apache.flink.client.deployment.application.ApplicationConfiguration
 
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_MAIN_CLASS - Static variable in class org.apache.flink.client.deployment.application.ApplicationConfiguration
 
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
 
ApplicationClusterDeployer - Class in org.apache.flink.client.deployment.application.cli
An entity responsible for submitting an application for execution in "Application Mode", i.e.
ApplicationClusterDeployer(ClusterClientServiceLoader) - Constructor for class org.apache.flink.client.deployment.application.cli.ApplicationClusterDeployer
 
ApplicationClusterEntryPoint - Class in org.apache.flink.client.deployment.application
Base class for cluster entry points targeting executing applications in "Application Mode".
ApplicationClusterEntryPoint(Configuration, PackagedProgram, ResourceManagerFactory<?>) - Constructor for class org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint
 
ApplicationConfiguration - Class in org.apache.flink.client.deployment.application
Application-specific configurations.
ApplicationConfiguration(String[], String) - Constructor for class org.apache.flink.client.deployment.application.ApplicationConfiguration
 
ApplicationDeployer - Interface in org.apache.flink.client.cli
An interface to be used by the CliFrontend to submit user programs for execution.
ApplicationDispatcherBootstrap - Class in org.apache.flink.client.deployment.application
A DispatcherBootstrap used for running the user's main() in "Application Mode" (see FLIP-85).
ApplicationDispatcherBootstrap(PackagedProgram, Collection<JobID>, Configuration, DispatcherGateway, ScheduledExecutor, FatalErrorHandler) - Constructor for class org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap
 
ApplicationDispatcherGatewayServiceFactory - Class in org.apache.flink.client.deployment.application
A DispatcherGatewayServiceFactory used when executing a job in Application Mode, i.e.
ApplicationDispatcherGatewayServiceFactory(Configuration, DispatcherFactory, PackagedProgram, RpcService, PartialDispatcherServices) - Constructor for class org.apache.flink.client.deployment.application.ApplicationDispatcherGatewayServiceFactory
 
ApplicationDispatcherLeaderProcessFactoryFactory - Class in org.apache.flink.client.deployment.application
Factory for a DispatcherLeaderProcessFactoryFactory designed to be used when executing an application in Application Mode.
ApplicationExecutionException - Exception in org.apache.flink.client.deployment.application
A FlinkException thrown in case something during application execution went wrong.
ApplicationExecutionException(String) - Constructor for exception org.apache.flink.client.deployment.application.ApplicationExecutionException
 
ApplicationExecutionException(Throwable) - Constructor for exception org.apache.flink.client.deployment.application.ApplicationExecutionException
 
ApplicationExecutionException(String, Throwable) - Constructor for exception org.apache.flink.client.deployment.application.ApplicationExecutionException
 
ApplicationRunner - Interface in org.apache.flink.client.deployment.application
An interface to be implemented by the entities responsible for application submission for the different deployment environments.
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.hive.impl.FlinkHiveSqlParserImplConstants
 
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<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(RowData, RowData) - 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(long) - Method in interface org.apache.flink.util.function.LongFunctionWithException
Applies this function to the given argument.
apply(S, T, U, V) - Method in interface org.apache.flink.util.function.QuadFunction
Applies this function to the given arguments.
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.client.cli.GenericCLI
 
applyCommandLineOptionsToConfiguration(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
 
applyComputedColumn(SupportsComputedColumnPushDown.ComputedColumnConverter, DataType) - Method in interface org.apache.flink.table.connector.source.abilities.SupportsComputedColumnPushDown
Provides a converter that converts the produced RowData containing the physical fields of the external system into a new RowData with push-downed computed columns.
applyFilters(List<ResolvedExpression>) - Method in interface org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown
Provides a list of filters in conjunctive form.
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 class org.apache.flink.connectors.hive.HiveTableSource
 
applyLimit(long) - Method in interface org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown
Provides the expected maximum number of produced records for limiting on a best-effort basis.
applyLimit(long) - Method in class org.apache.flink.table.filesystem.FileSystemTableSource
 
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.
applyOverwrite(boolean) - Method in interface org.apache.flink.table.connector.sink.abilities.SupportsOverwrite
Provides whether existing data should be overwritten or not.
applyPartitionPruning(List<Map<String, String>>) - Method in class org.apache.flink.connectors.hive.HiveTableSource
 
applyPartitionPruning(List<Map<String, String>>) - Method in class org.apache.flink.table.filesystem.FileSystemTableSource
 
applyPartitionPruning(List<Map<String, String>>) - Method in interface org.apache.flink.table.sources.PartitionableTableSource
Applies the remaining partitions to the table source.
applyPartitions(List<Map<String, String>>) - Method in interface org.apache.flink.table.connector.source.abilities.SupportsPartitionPushDown
Provides a list of remaining partitions.
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 class org.apache.flink.table.filesystem.FileSystemTableSource
 
applyPredicate(List<Expression>) - Method in interface org.apache.flink.table.sources.FilterableTableSource
Check and pick all predicates this table source can support.
applyProjection(int[][]) - Method in class org.apache.flink.connector.hbase.source.HBaseDynamicTableSource
 
applyProjection(int[][]) - Method in class org.apache.flink.connector.jdbc.table.JdbcDynamicTableSource
 
applyProjection(int[][]) - Method in interface org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown
Provides the field index paths that should be used for a projection.
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<T>, List<List<T>>, int, int) - Static method in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation
 
applyRepartitioner(OperatorStateRepartitioner<T>, List<List<T>>, 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.
applyStaticPartition(Map<String, String>) - Method in interface org.apache.flink.table.connector.sink.abilities.SupportsPartitioning
Provides the static part of a partition.
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
Deprecated.
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.
applyToConfiguration(Configuration) - Method in class org.apache.flink.client.cli.ExecutionConfigAccessor
 
applyToConfiguration(Configuration) - Method in class org.apache.flink.client.cli.ProgramOptions
 
applyToConfiguration(Configuration) - Method in class org.apache.flink.client.cli.PythonProgramOptions
 
applyToConfiguration(Configuration) - Method in class org.apache.flink.client.deployment.application.ApplicationConfiguration
 
applyToConfiguration(Configuration) - Method in class org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils.JarHandlerContext
 
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.
applyWatermark(SupportsWatermarkPushDown.WatermarkProvider) - Method in interface org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown
Provides actual runtime implementation for generating watermarks.
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.hive.impl.FlinkHiveSqlParserImplConstants
 
APPROX_NUMERIC_LITERAL - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
APPS_API_VERSION - Static variable in class org.apache.flink.kubernetes.utils.Constants
 
ArbitraryWorkerResourceSpecFactory - Class in org.apache.flink.runtime.resourcemanager
Implementation of WorkerResourceSpecFactory that creates arbitrary WorkerResourceSpec.
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, String) - 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.hive.impl.FlinkHiveSqlParserImplConstants
 
ARE - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
areAllInputsFinished() - Method in class org.apache.flink.streaming.runtime.io.MultipleInputSelectionHandler
 
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.
areKerberosCredentialsValid(UserGroupInformation, boolean) - Static method in class org.apache.flink.runtime.util.HadoopUtils
 
Arg(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImpl
 
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.hive.impl.FlinkHiveSqlParserImpl
 
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
 
ARGS_OPTION - Static variable in class org.apache.flink.client.cli.CliFrontendParser
 
argTypes - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction
 
argument(int) - Static method in class org.apache.flink.table.types.inference.TypeStrategies
Type strategy that returns the n-th input argument.
ArgumentCount - Interface in org.apache.flink.table.types.inference
Defines the count of accepted arguments (including open intervals) that a function can take.
ArgumentCountRange - Class in org.apache.flink.table.planner.functions.inference
A SqlOperandCountRange backed by ArgumentCount.
ArgumentCountRange(ArgumentCount) - Constructor for class org.apache.flink.table.planner.functions.inference.ArgumentCountRange
 
ArgumentTypeStrategy - Interface in org.apache.flink.table.types.inference
Strategy for inferring and validating a single input argument type of a function call.
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.hive.impl.FlinkHiveSqlParserImplConstants
 
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(AbstractDataType<?>) - Static method in class org.apache.flink.table.api.DataTypes
Unresolved data type of an array of elements with same subtype.
array(Object, Object...) - Static method in class org.apache.flink.table.api.Expressions
Creates an array of literals.
array(DataType, ResolvedExpression...) - Method in class org.apache.flink.table.expressions.resolver.ExpressionResolver.PostResolverFactory
 
ARRAY - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ARRAY - Static variable in class org.apache.flink.table.types.inference.TypeStrategies
Type strategy that returns a DataTypes.ARRAY(DataType) with element type equal to the type of the first argument.
ARRAY_ELEMENT - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ARRAY_ELEMENT_DELIMITER - Static variable in class org.apache.flink.formats.csv.CsvOptions
 
ARRAY_MAX_CARDINALITY - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
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
Converts the given object into a string representation by calling Object.toString() and formatting (possibly nested) arrays and null.
ArrayBooleanArrayConverter - Class in org.apache.flink.table.data.conversion
Converter for ArrayType of boolean[] external type.
ArrayBooleanArrayConverter() - Constructor for class org.apache.flink.tabl