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, CheckpointsCleaner, Runnable, Executor, PendingCheckpointStats) - 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
 
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.
abortCheckpoint(ExecutionAttemptID, long, long) - Method in class org.apache.flink.runtime.taskexecutor.TaskExecutorGatewayDecoratorBase
 
abortCheckpointOnBarrier(long, CheckpointException) - 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, CheckpointException) - Method in class org.apache.flink.streaming.runtime.tasks.MultipleInputStreamTask
 
abortCheckpointOnBarrier(long, CheckpointException) - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
abortCheckpointOnBarrier(long, CheckpointException, 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
 
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.internals.FlinkKafkaInternalProducer
 
abortTransactionStatement() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
abortTransactionStatement_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.abortTransactionStatement_return
 
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.
AbstractAccessExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
AbstractAccessExecutionGraphHandler handles requests that require accessing the job's AccessExecutionGraph.
AbstractAccessExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractAccessExecutionGraphHandler
 
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
 
AbstractArrowPythonAggregateFunctionOperator - Class in org.apache.flink.table.runtime.operators.python.aggregate.arrow
The Abstract class of Arrow Aggregate Operator for Pandas AggregateFunction.
AbstractArrowPythonAggregateFunctionOperator(Configuration, PythonFunctionInfo[], RowType, RowType, int[], int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.arrow.AbstractArrowPythonAggregateFunctionOperator
 
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
 
AbstractBroadcastStateTransformation<IN1,IN2,OUT> - Class in org.apache.flink.streaming.api.transformations
Base class for Broadcast State transformations.
AbstractBroadcastStateTransformation(String, Transformation<IN1>, Transformation<IN2>, List<MapStateDescriptor<?, ?>>, TypeInformation<OUT>, int) - Constructor for class org.apache.flink.streaming.api.transformations.AbstractBroadcastStateTransformation
 
AbstractBuffersUsageGauge - Class in org.apache.flink.runtime.io.network.metrics
Abstract gauge implementation for calculating the buffer usage percent.
AbstractBytesHashMap<K> - Class in org.apache.flink.table.runtime.util.collections.binary
Bytes based hash map.
AbstractBytesHashMap(Object, MemoryManager, long, PagedTypeSerializer<K>, LogicalType[]) - Constructor for class org.apache.flink.table.runtime.util.collections.binary.AbstractBytesHashMap
 
AbstractBytesHashMap(Object, MemoryManager, long, PagedTypeSerializer<K>, int) - Constructor for class org.apache.flink.table.runtime.util.collections.binary.AbstractBytesHashMap
 
AbstractBytesMultiMap<K> - Class in org.apache.flink.table.runtime.util.collections.binary
A binary map in the structure like Map<K, List<V>>, where there are multiple values under a single key, and they are all bytes based.
AbstractBytesMultiMap(Object, MemoryManager, long, PagedTypeSerializer<K>, LogicalType[]) - Constructor for class org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap
 
AbstractBytesMultiMap(Object, MemoryManager, long, PagedTypeSerializer<K>, int) - Constructor for class org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap
 
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
 
AbstractCollectResultBuffer<T> - Class in org.apache.flink.streaming.api.operators.collect
A buffer which encapsulates the logic of dealing with the response from the CollectSinkFunction.
AbstractCollectResultBuffer(TypeSerializer<T>) - Constructor for class org.apache.flink.streaming.api.operators.collect.AbstractCollectResultBuffer
 
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() - 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
 
AbstractExecNodeExactlyOnceVisitor - Class in org.apache.flink.table.planner.plan.nodes.exec.visitor
Implement of ExecNodeVisitor.
AbstractExecNodeExactlyOnceVisitor() - Constructor for class org.apache.flink.table.planner.plan.nodes.exec.visitor.AbstractExecNodeExactlyOnceVisitor
 
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for all ExecutionGraphInfo 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.
AbstractFileSource<T,SplitT extends FileSourceSplit> - Class in org.apache.flink.connector.file.src
The base class for File Sources.
AbstractFileSource(Path[], FileEnumerator.Provider, FileSplitAssigner.Provider, BulkFormat<T, SplitT>, ContinuousEnumerationSettings) - Constructor for class org.apache.flink.connector.file.src.AbstractFileSource
 
AbstractFileSource.AbstractFileSourceBuilder<T,SplitT extends FileSourceSplit,SELF extends AbstractFileSource.AbstractFileSourceBuilder<T,SplitT,SELF>> - Class in org.apache.flink.connector.file.src
The generic base builder.
AbstractFileSourceBuilder(Path[], BulkFormat<T, SplitT>, FileEnumerator.Provider, FileSplitAssigner.Provider) - Constructor for class org.apache.flink.connector.file.src.AbstractFileSource.AbstractFileSourceBuilder
 
AbstractFileStateBackend - Class in org.apache.flink.runtime.state.filesystem
Deprecated.
State backends should no longer implement CheckpointStorage functionality. Please inherit AbstractStateBackend instead. Custom checkpoint storage can be additionally implemented as a separate class.
AbstractFileStateBackend(URI, URI) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend
Deprecated.
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
Deprecated.
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
Deprecated.
Creates a new backend using the given checkpoint-/savepoint directories, or the values defined in the given configuration.
AbstractFsCheckpointStorageAccess - Class in org.apache.flink.runtime.state.filesystem
An implementation of durable checkpoint storage to file systems.
AbstractFsCheckpointStorageAccess(JobID, Path) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorageAccess
Creates a new checkpoint storage.
AbstractHandler<T extends RestfulGateway,R extends RequestBody,M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler
Super class for netty-based handlers that work with RequestBody.
AbstractHandler(GatewayRetriever<? extends T>, Time, Map<String, String>, UntypedResponseMessageHeaders<R, M>) - Constructor for class org.apache.flink.runtime.rest.handler.AbstractHandler
 
AbstractHaServices - Class in org.apache.flink.runtime.highavailability
Abstract high availability services based on distributed system(e.g.
AbstractHaServices(Configuration, Executor, BlobStoreService) - Constructor for class org.apache.flink.runtime.highavailability.AbstractHaServices
 
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
 
AbstractHBaseDynamicTableSource - Class in org.apache.flink.connector.hbase.source
HBase table source implementation.
AbstractHBaseDynamicTableSource(Configuration, String, HBaseTableSchema, String, HBaseLookupOptions) - Constructor for class org.apache.flink.connector.hbase.source.AbstractHBaseDynamicTableSource
 
AbstractHBaseTableSource - Class in org.apache.flink.connector.hbase.source
Creates a TableSource to scan an HBase table.
AbstractHBaseTableSource(Configuration, String, HBaseTableSchema, int[]) - Constructor for class org.apache.flink.connector.hbase.source.AbstractHBaseTableSource
 
AbstractHBaseValidator - Class in org.apache.flink.table.descriptors
The validator for HBase.
AbstractHBaseValidator() - Constructor for class org.apache.flink.table.descriptors.AbstractHBaseValidator
 
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, LatencyTrackingStateConfig, CloseableRegistry, InternalKeyContext<K>) - Constructor for class org.apache.flink.runtime.state.AbstractKeyedStateBackend
 
AbstractKeyedStateBackend(TaskKvStateRegistry, TypeSerializer<K>, ClassLoader, ExecutionConfig, TtlTimeProvider, LatencyTrackingStateConfig, CloseableRegistry, StreamCompressionDecorator, InternalKeyContext<K>) - Constructor for class org.apache.flink.runtime.state.AbstractKeyedStateBackend
 
AbstractKeyedStateBackend.PartitionStateFactory - Interface in org.apache.flink.runtime.state
 
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, LatencyTrackingStateConfig, 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
 
AbstractKubernetesWatcher<T extends io.fabric8.kubernetes.api.model.HasMetadata,K extends KubernetesResource<T>> - Class in org.apache.flink.kubernetes.kubeclient.resources
Watcher for resources in Kubernetes.
AbstractManagedMemoryStateBackend - Class in org.apache.flink.runtime.state
Abstract base class for state backends that use managed memory.
AbstractManagedMemoryStateBackend() - Constructor for class org.apache.flink.runtime.state.AbstractManagedMemoryStateBackend
 
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
Deprecated.
Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in the future (see FLINK-22352 for further details).
AbstractMesosServices(ActorSystem, MesosArtifactServer) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices
Deprecated.
 
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
 
AbstractOneInputPythonFunctionOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.python
Base class for all one input stream operators to execute Python functions.
AbstractOneInputPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.streaming.api.operators.python.AbstractOneInputPythonFunctionOperator
 
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.
AbstractOrcFileInputFormat<T,BatchT,SplitT extends FileSourceSplit> - Class in org.apache.flink.orc
The base for ORC readers for the FileSource.
AbstractOrcFileInputFormat(OrcShim<BatchT>, Configuration, TypeDescription, int[], List<OrcFilters.Predicate>, int) - Constructor for class org.apache.flink.orc.AbstractOrcFileInputFormat
 
AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT> - Class in org.apache.flink.orc
The OrcReaderBatch class holds the data structures containing the batch data (column vectors, row arrays, ...) and performs the batch conversion from the ORC representation to the result format.
AbstractOrcFileInputFormat.OrcVectorizedReader<T,BatchT> - Class in org.apache.flink.orc
A vectorized ORC reader.
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
 
AbstractPlannerWindowProperty - Class in org.apache.flink.table.planner.expressions
The base class of PlannerWindowProperty.
AbstractPlannerWindowProperty(PlannerWindowReference) - Constructor for class org.apache.flink.table.planner.expressions.AbstractPlannerWindowProperty
 
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<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
 
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.
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
 
AbstractPythonStreamAggregateOperator - Class in org.apache.flink.table.runtime.operators.python.aggregate
AbstractPythonStreamAggregateOperator(Configuration, RowType, RowType, PythonAggregateFunctionInfo[], DataViewUtils.DataViewSpec[][], int[], int, boolean, String, FlinkFnApi.CoderParam.OutputMode) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.AbstractPythonStreamAggregateOperator
 
AbstractPythonStreamGroupAggregateOperator - Class in org.apache.flink.table.runtime.operators.python.aggregate
AbstractPythonStreamGroupAggregateOperator(Configuration, RowType, RowType, PythonAggregateFunctionInfo[], DataViewUtils.DataViewSpec[][], int[], int, boolean, long, long, FlinkFnApi.CoderParam.OutputMode) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.AbstractPythonStreamGroupAggregateOperator
 
AbstractPythonTableFunctionOperator<IN,OUT,UDTFIN> - Class in org.apache.flink.table.runtime.operators.python.table
 
AbstractPythonTableFunctionOperator(Configuration, PythonFunctionInfo, RowType, RowType, int[], FlinkJoinType) - Constructor for class org.apache.flink.table.runtime.operators.python.table.AbstractPythonTableFunctionOperator
 
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
 
AbstractRegexParseStrategy - Class in org.apache.flink.table.parse
Strategy to parse statement to Operation by regex.
AbstractRegexParseStrategy(Pattern) - Constructor for class org.apache.flink.table.parse.AbstractRegexParseStrategy
 
AbstractRegexParseStrategy - Class in org.apache.flink.table.planner.parse
Strategy to parse statement to Operation by regex.
AbstractRegexParseStrategy(Pattern) - Constructor for class org.apache.flink.table.planner.parse.AbstractRegexParseStrategy
 
AbstractReporter - Class in org.apache.flink.metrics.reporter
Base interface for custom metric reporters.
AbstractReporter() - Constructor for class org.apache.flink.metrics.reporter.AbstractReporter
 
AbstractResourceManagerDriver<WorkerType extends ResourceIDRetrievable> - Class in org.apache.flink.runtime.resourcemanager.active
Abstract common base class for implementations of ResourceManagerDriver.
AbstractResourceManagerDriver(Configuration, Configuration) - Constructor for class org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver
 
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
 
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.
AbstractRocksStateKeysIterator<K> - Class in org.apache.flink.contrib.streaming.state.iterator
Base class for iterators over RocksDB column families.
AbstractRocksStateKeysIterator(RocksIteratorWrapper, String, TypeSerializer<K>, int, boolean) - Constructor for class org.apache.flink.contrib.streaming.state.iterator.AbstractRocksStateKeysIterator
 
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, UserCodeClassLoader, 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.
AbstractServiceConnectionManager<S> - Class in org.apache.flink.runtime.jobmaster.slotpool
Base class for service connection managers, taking care of the connection handling.
AbstractServiceConnectionManager() - Constructor for class org.apache.flink.runtime.jobmaster.slotpool.AbstractServiceConnectionManager
 
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
 
AbstractSlotPoolServiceFactory - Class in org.apache.flink.runtime.jobmaster.slotpool
Abstract SlotPoolServiceFactory.
AbstractSlotPoolServiceFactory(Clock, Time, Time, Time) - Constructor for class org.apache.flink.runtime.jobmaster.slotpool.AbstractSlotPoolServiceFactory
 
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 Calcite abstractions.
AbstractSqlCallContext(DataTypeFactory, FunctionDefinition, String, boolean) - 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
 
AbstractStreamArrowPythonBoundedRangeOperator<K> - Class in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
The Abstract class of Stream Arrow Python AggregateFunction Operator for RANGE clause bounded Over Window Aggregation.
AbstractStreamArrowPythonBoundedRangeOperator(Configuration, PythonFunctionInfo[], RowType, RowType, int, long, int[], int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream.AbstractStreamArrowPythonBoundedRangeOperator
 
AbstractStreamArrowPythonBoundedRowsOperator<K> - Class in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
The Abstract class of Stream Arrow Python AggregateFunction Operator for ROWS clause bounded Over Window Aggregation.
AbstractStreamArrowPythonBoundedRowsOperator(Configuration, long, long, PythonFunctionInfo[], RowType, RowType, int, long, int[], int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream.AbstractStreamArrowPythonBoundedRowsOperator
 
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator<K> - Class in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
The Abstract class of Stream Arrow Python AggregateFunction Operator for Over Window Aggregation.
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator(Configuration, PythonFunctionInfo[], RowType, RowType, int, long, int[], int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream.AbstractStreamArrowPythonOverWindowAggregateFunctionOperator
 
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(InternalTypeInfo<RowData>, InternalTypeInfo<RowData>, 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.
AbstractStreamingWriter<IN,OUT> - Class in org.apache.flink.table.filesystem.stream
Operator for file system sink.
AbstractStreamingWriter(long, StreamingFileSink.BucketsBuilder<IN, String, ? extends StreamingFileSink.BucketsBuilder<IN, String, ?>>) - Constructor for class org.apache.flink.table.filesystem.stream.AbstractStreamingWriter
 
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
 
AbstractStreamTaskNetworkInput<T,R extends RecordDeserializer<DeserializationDelegate<StreamElement>>> - Class in org.apache.flink.streaming.runtime.io
Base class for network-based StreamTaskInput where each channel has a designated RecordDeserializer for spanning records.
AbstractStreamTaskNetworkInput(CheckpointedInputGate, TypeSerializer<T>, StatusWatermarkValve, int, Map<InputChannelInfo, R>) - Constructor for class org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput
 
AbstractSubtaskAttemptHandler<R extends ResponseBody,M extends SubtaskAttemptMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for request handlers whose response depends on a specific attempt (defined via the "SubtaskAttemptPathParameter.KEY" of a specific subtask (defined via the "SubtaskIndexPathParameter.KEY" in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY" parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY" parameter).
AbstractSubtaskAttemptHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractSubtaskAttemptHandler
Instantiates a new Abstract job vertex handler.
AbstractSubtaskHandler<R extends ResponseBody,M extends SubtaskMessageParameters> - Class in org.apache.flink.runtime.rest.handler.job
Base class for request handlers whose response depends on a specific subtask (defined via the "SubtaskIndexPathParameter.KEY" in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY" parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY" parameter).
AbstractSubtaskHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, R, M>, ExecutionGraphCache, Executor) - Constructor for class org.apache.flink.runtime.rest.handler.job.AbstractSubtaskHandler
Instantiates a new Abstract job vertex handler.
AbstractTableInputFormat<T> - Class in org.apache.flink.connector.hbase1.source
Abstract InputFormat to read data from HBase tables.
AbstractTableInputFormat(Configuration) - Constructor for class org.apache.flink.connector.hbase1.source.AbstractTableInputFormat
 
AbstractTableInputFormat<T> - Class in org.apache.flink.connector.hbase2.source
Abstract InputFormat to read data from HBase tables.
AbstractTableInputFormat(Configuration) - Constructor for class org.apache.flink.connector.hbase2.source.AbstractTableInputFormat
 
AbstractTaskManagerFileHandler<M extends TaskManagerMessageParameters> - Class in org.apache.flink.runtime.rest.handler.taskmanager
Base class for serving files from the TaskExecutor.
AbstractTaskManagerFileHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, UntypedResponseMessageHeaders<EmptyRequestBody, M>, GatewayRetriever<ResourceManagerGateway>, TransientBlobService, Time) - Constructor for class org.apache.flink.runtime.rest.handler.taskmanager.AbstractTaskManagerFileHandler
 
AbstractTestBase - Class in org.apache.flink.test.util
Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.
AbstractTestBase() - Constructor for class org.apache.flink.test.util.AbstractTestBase
 
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.
AbstractTwoInputPythonFunctionOperator<IN1,IN2,OUT> - Class in org.apache.flink.streaming.api.operators.python
Base class for all two input stream operators to execute Python functions.
AbstractTwoInputPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.streaming.api.operators.python.AbstractTwoInputPythonFunctionOperator
 
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).
AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,OP extends Transformation<OUT>> - Class in org.apache.flink.streaming.runtime.translators
A base class with functionality used during translating transformations with two inputs.
AbstractTwoInputTransformationTranslator() - Constructor for class org.apache.flink.streaming.runtime.translators.AbstractTwoInputTransformationTranslator
 
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
 
AbstractWindowAggProcessor - Class in org.apache.flink.table.runtime.operators.aggregate.window.processors
A base implementation of SlicingWindowProcessor for window aggregate.
AbstractWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long>, WindowBuffer.Factory, SliceAssigner, TypeSerializer<RowData>, ZoneId) - Constructor for class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor
 
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(RexVisitor<R>) - Method in class org.apache.calcite.rex.RexLiteral
 
accept(RexBiVisitor<R, P>, P) - Method in class org.apache.calcite.rex.RexLiteral
 
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(Row, long) - Method in class org.apache.flink.streaming.api.utils.output.OutputWithTimerRowHandler
 
accept(RecordBatch) - Method in interface org.apache.flink.streaming.connectors.kinesis.internals.publisher.RecordPublisher.RecordBatchConsumer
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.api.ApiExpression
 
accept(ExpressionVisitor<R>) - Method in class org.apache.flink.table.expressions.AggregateExpression
 
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.SqlCallExpression
 
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(ModifyOperationVisitor<T>) - Method in class org.apache.flink.table.operations.CollectModifyOperation
 
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(ModifyOperationVisitor<T>) - Method in class org.apache.flink.table.operations.ExternalModifyOperation
 
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.JavaExternalQueryOperation
 
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.ScalaExternalQueryOperation
 
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(ExecNodeVisitor) - Method in interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode
Accepts a visit from a ExecNodeVisitor.
accept(ExecNodeVisitor) - Method in class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase
 
accept(RelShuttle) - Method in class org.apache.flink.table.planner.plan.nodes.hive.LogicalDistribution
 
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.fun.SqlDotOperator
 
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 interface org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerActions
Deprecated.
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 ArchivedExecution.
AccessExecutionGraph - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime DefaultExecutionGraph 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
 
accSerializer - Variable in class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor
 
accumulate(ByteBuf, ByteBuf, int, int) - Static method in class org.apache.flink.runtime.io.network.netty.ByteBufUtils
Accumulates data from source to target.
accumulate(LastDatedValueFunction.Accumulator<T>, T, LocalDate) - Method in class org.apache.flink.table.examples.java.functions.LastDatedValueFunction
Generic runtime function that will be called with different kind of instances for input depending on actual call in the query.
accumulate(GenericUDAFEvaluator.AggregationBuffer, Object...) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF
 
accumulate(Object, Object...) - Method in class org.apache.flink.table.functions.python.PythonAggregateFunction
 
accumulate(Object, Object...) - Method in class org.apache.flink.table.functions.python.PythonTableAggregateFunction
 
accumulate(CollectAggFunction.CollectAccumulator<T>, T) - Method in class org.apache.flink.table.planner.functions.aggfunctions.CollectAggFunction
 
accumulate(RowData, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(RowData, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(RowData, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(RowData, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.FirstValueWithRetractAggFunction
 
accumulate(LagAggFunction.LagAcc<T>, T) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LagAggFunction
 
accumulate(LagAggFunction.LagAcc<T>, T, int) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LagAggFunction
 
accumulate(LagAggFunction.LagAcc<T>, T, int, T) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LagAggFunction
 
accumulate(RowData, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(RowData, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(GenericRowData, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(GenericRowData, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, Object, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, StringData) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, StringData, Long) - Method in class org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction
 
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>, T) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MaxWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<T>, T) - Method in class org.apache.flink.table.planner.functions.aggfunctions.MinWithRetractAggFunction
 
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.
Accumulator() - Constructor for class org.apache.flink.table.examples.java.functions.LastDatedValueFunction.Accumulator
 
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.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.adaptive.AdaptiveScheduler
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, TaskStateSnapshot) - Method in class org.apache.flink.runtime.scheduler.ExecutionGraphHandler
 
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, PendingCheckpointStats) - 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.active
An active implementation of ResourceManager.
ActiveResourceManager(ResourceManagerDriver<WorkerType>, Configuration, RpcService, ResourceID, HighAvailabilityServices, HeartbeatServices, SlotManager, ResourceManagerPartitionTrackerFactory, JobLeaderIdService, ClusterInformation, FatalErrorHandler, ResourceManagerMetricGroup, ThresholdMeter, Duration, Duration, Executor) - Constructor for class org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager
 
ActiveResourceManagerFactory<WorkerType extends ResourceIDRetrievable> - Class in org.apache.flink.runtime.resourcemanager.active
Factory class for creating ActiveResourceManager with various implementations of ResourceManagerDriver.
ActiveResourceManagerFactory() - Constructor for class org.apache.flink.runtime.resourcemanager.active.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
 
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
 
AdaptivePollingRecordPublisher - Class in org.apache.flink.streaming.connectors.kinesis.internals.publisher.polling
An adaptive record publisher to add a dynamic batch read size for PollingRecordPublisher.
AdaptiveScheduler - Class in org.apache.flink.runtime.scheduler.adaptive
A SchedulerNG implementation that uses the declarative resource management and automatically adapts the parallelism in case not enough resource could be acquired to run at the configured parallelism, as described in FLIP-160.
AdaptiveScheduler(JobGraph, Configuration, DeclarativeSlotPool, SlotAllocator, Executor, ClassLoader, CheckpointRecoveryFactory, Duration, Duration, JobManagerJobMetricGroup, RestartBackoffTimeStrategy, long, ComponentMainThreadExecutor, FatalErrorHandler, JobStatusListener, ExecutionGraphFactory) - Constructor for class org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler
 
AdaptiveSchedulerFactory - Class in org.apache.flink.runtime.scheduler.adaptive
Factory for the adaptive scheduler.
AdaptiveSchedulerFactory(Duration, Duration) - Constructor for class org.apache.flink.runtime.scheduler.adaptive.AdaptiveSchedulerFactory
 
ADAPTOR - Static variable in class org.apache.flink.table.planner.delegation.hive.copy.HiveASTParseDriver
Tree adaptor for making antlr return ASTNodes instead of CommonTree nodes so that the graph walking algorithms and the rules framework defined in ql.lib can be used with the AST Nodes.
ADAPTOR - Static variable in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserSubQueryUtils
 
adaptor - Variable in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTHintParser
 
adaptor - Variable in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
adaptor - Variable in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser_FromClauseASTParser
 
adaptor - Variable in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser_IdentifiersASTParser
 
adaptor - Variable in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser_SelectClauseASTParser
 
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(T) - Method in class org.apache.flink.connector.file.src.util.Pool
Adds an entry to the pool with an optional payload.
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(DMetric) - Method in class org.apache.flink.metrics.datadog.DSeries
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.Between
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.Equals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.In
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.IsNull
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.LessThan
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.LessThanEquals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.Not
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.NullSafeEquals
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.Or
 
add(SearchArgument.Builder) - Method in class org.apache.flink.orc.OrcFilters.Predicate
 
add(Object) - Method in class org.apache.flink.queryablestate.client.state.ImmutableAggregatingState
 
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, int) - Method in interface org.apache.flink.runtime.io.network.partition.CheckpointedResultSubpartition
 
add(BufferConsumer, int) - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition
 
add(T) - Method in class org.apache.flink.runtime.io.network.partition.PrioritizedDeque
Adds a non-priority element to this deque, which will be polled last.
add(T, boolean, boolean) - Method in class org.apache.flink.runtime.io.network.partition.PrioritizedDeque
Convenience method for adding an element with optional priority and prior removal.
add(BufferConsumer) - Method in class org.apache.flink.runtime.io.network.partition.ResultSubpartition
 
add(BufferConsumer, int) - 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.BoundedFIFOQueue
Adds an element to the end of the queue.
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(ResourceCounter) - Method in class org.apache.flink.runtime.util.ResourceCounter
Adds increment to this resource counter value and returns the resulting value.
add(Map<ResourceProfile, Integer>) - Method in class org.apache.flink.runtime.util.ResourceCounter
Adds the given increment to this resource counter value and returns the resulting value.
add(ResourceProfile, int) - Method in class org.apache.flink.runtime.util.ResourceCounter
Adds increment to the count of resourceProfile and returns the new value.
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(T) - Method in class org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue
 
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
Deprecated.
Adds a TableColumn to this builder.
add(DecimalData, DecimalData, int, int) - Static method in class org.apache.flink.table.data.DecimalDataUtils
 
add(long, int) - Method in class org.apache.flink.table.filesystem.stream.TaskTracker
 
add(int, String) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTBuilder
 
add(HiveParserASTBuilder) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTBuilder
 
add(HiveParserRowResolver, HiveParserRowResolver) - Static method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserRowResolver
 
add(EE) - 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
 
addAggregationExprsForClause(String, LinkedHashMap<String, HiveParserASTNode>) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
 
addAlias(String) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQB
 
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(Collection<? extends T>) - Method in class org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue
 
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<EE>) - 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;
addAllFields(Iterable<? extends FlinkFnApi.TypeInfo.RowTypeInfo.Field>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
addAllFieldTypes(Iterable<? extends FlinkFnApi.TypeInfo>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
addAllGrouping(Iterable<? extends Integer>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
The array of the key indexes.
addAllInputs(Iterable<? extends FlinkFnApi.Input>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addAllInputs(Iterable<? extends FlinkFnApi.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.
addAllJobParameters(Iterable<? extends FlinkFnApi.UserDefinedDataStreamFunction.JobParameter>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addAllNamedProperties(Iterable<? extends FlinkFnApi.GroupWindow.WindowProperty>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
addAllNamedPropertiesValue(Iterable<Integer>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
addAllocationOnPendingResource(JobID, PendingTaskManagerId, ResourceProfile) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
 
addAllocationOnRegisteredResource(JobID, InstanceID, ResourceProfile) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
 
addAllSpecs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
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.UserDefinedAggregateFunction>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
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;
addAllWindows(Iterable<? extends FlinkFnApi.OverWindow>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addAndLock(String, T) - Method in class org.apache.flink.kubernetes.highavailability.KubernetesStateHandleStore
Creates a state handle, stores it in ConfigMap.
addAndLock(String, T) - Method in interface org.apache.flink.runtime.persistence.StateHandleStore
Persist the state to distributed storage(e.g.
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.
addArg(HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserPTFInvocationSpec.PartitionedTableFunctionSpec
 
addArg(HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserWindowingSpec.WindowFunctionSpec
 
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
 
addBatch() - Method in interface org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatement
Adds a set of parameters to this NamedPreparedStatement object's batch of commands.
addBatch() - Method in class org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl
 
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.
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, CheckpointsCleaner, Runnable) - Method in interface org.apache.flink.runtime.checkpoint.CompletedCheckpointStore
Adds a CompletedCheckpoint instance to the list of completed checkpoints.
addCheckpoint(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in enum org.apache.flink.runtime.checkpoint.DeactivatedCheckpointCompletedCheckpointStore
 
addCheckpoint(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStore
Synchronously writes the new checkpoints to state handle store and asynchronously removes older ones.
addCheckpoint(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.EmbeddedCompletedCheckpointStore
 
addCheckpoint(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
 
addChild(Tree) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTNode
 
addChildren(List) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTNode
 
addChoices(String...) - Method in class org.apache.flink.graph.drivers.parameter.ChoiceParameter
Add additional choices.
addClasspaths(Collection<URL>) - Method in class org.apache.flink.runtime.jobgraph.JobGraphBuilder
 
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.AbstractHBaseTableSource
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
 
addColumn(ExprNodeDesc) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserExprNodeColumnListDesc
 
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
 
addConsumedPartitionGroup(ConsumedPartitionGroup) - Method in class org.apache.flink.runtime.executiongraph.ExecutionVertex
 
addConsumer(JobEdge) - Method in class org.apache.flink.runtime.jobgraph.IntermediateDataSet
 
addConsumers(ConsumerVertexGroup) - Method in class org.apache.flink.runtime.executiongraph.IntermediateResultPartition
 
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
 
addCopyTranslation(HiveParserASTNode, HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserUnparseTranslator
Register a "copy" translation in which a node will be translated into whatever the translation turns out to be for another node (after previously registered translations have already been performed).
addCosts(Costs) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given costs to these costs.
addCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given CPU cost to the current CPU cost for this Costs object.
addCredit(int) - Method in interface org.apache.flink.runtime.io.network.NetworkSequenceViewReader
The credits from consumer are added in incremental way.
addDataSink(GenericDataSinkBase<?>) - Method in class org.apache.flink.api.common.Plan
Adds a data sink to the set of sinks in this program.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.common.ExecutionConfig
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.common.ExecutionConfig
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.java.ExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.java.ExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
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.
addDestToWindowingSpec(String, HiveParserWindowingSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQB
 
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
 
addElement(RowData, long, RowData) - Method in class org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer
 
addElement(RowData, long, RowData) - Method in interface org.apache.flink.table.runtime.operators.aggregate.window.buffers.WindowBuffer
Adds an element with associated key into the buffer.
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
addExpression(HiveParserPTFInvocationSpec.OrderExpression) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserPTFInvocationSpec.OrderSpec
 
addExpression(HiveParserPTFInvocationSpec.PartitionExpression) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserPTFInvocationSpec.PartitionSpec
 
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(int, boolean, boolean) - Method in class org.apache.flink.table.planner.plan.nodes.exec.spec.SortSpec.SortSpecBuilder
 
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;
addFields(FlinkFnApi.TypeInfo.RowTypeInfo.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
addFields(int, FlinkFnApi.TypeInfo.RowTypeInfo.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
addFields(FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
addFields(int, FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.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;
addFieldsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
addFieldsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
addFieldTypes(FlinkFnApi.TypeInfo) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
addFieldTypes(int, FlinkFnApi.TypeInfo) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
addFieldTypes(FlinkFnApi.TypeInfo.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
addFieldTypes(int, FlinkFnApi.TypeInfo.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
addFieldTypesBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
addFieldTypesBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
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
 
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
 
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(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(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(String) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addGroup(String, String) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addGrouping(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
The array of the key indexes.
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.
addIdentifierTranslation(HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserUnparseTranslator
Register a translation for an identifier.
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(Set<ReadEntity>, ReadEntity, boolean) - Static method in class org.apache.flink.table.planner.delegation.hive.HiveParserUtils
 
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.ProcTimeMiniBatchDeduplicateKeepFirstRowFunction
 
addInput(RowData, RowData) - Method in class org.apache.flink.table.runtime.operators.deduplicate.ProcTimeMiniBatchDeduplicateKeepLastRowFunction
 
addInput(List<RowData>, RowData) - Method in class org.apache.flink.table.runtime.operators.deduplicate.RowTimeMiniBatchDeduplicateFunction
 
addInput(TableOperatorWrapper<?>, int) - Method in class org.apache.flink.table.runtime.operators.multipleinput.TableOperatorWrapper
 
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
 
addInputRequirement(int, StreamConfig.InputRequirement) - Method in class org.apache.flink.streaming.api.graph.StreamNode
 
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.Input) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(int, FlinkFnApi.Input) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(FlinkFnApi.Input.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(int, FlinkFnApi.Input.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
The input arguments of the user-defined function, it could be one of the following: 1.
addInputs(FlinkFnApi.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.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.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.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.UserDefinedAggregateFunction.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.UserDefinedAggregateFunction.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.
addInsertIntoTable(String, HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
 
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(Path...) - Method in class org.apache.flink.tests.util.flink.SQLJobSubmission.SQLJobSubmissionBuilder
 
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.DefaultJobLeaderIdService
 
addJob(JobID) - Method in interface 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).
addJobParameters(FlinkFnApi.UserDefinedDataStreamFunction.JobParameter) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addJobParameters(int, FlinkFnApi.UserDefinedDataStreamFunction.JobParameter) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addJobParameters(FlinkFnApi.UserDefinedDataStreamFunction.JobParameter.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addJobParameters(int, FlinkFnApi.UserDefinedDataStreamFunction.JobParameter.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addJobParametersBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addJobParametersBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
addJobVertex(JobVertex) - Method in class org.apache.flink.runtime.jobgraph.JobGraphBuilder
 
addJobVertices(Collection<? extends JobVertex>) - Method in class org.apache.flink.runtime.jobgraph.JobGraphBuilder
 
addJvmArg(String) - Method in class org.apache.flink.test.util.TestProcessBuilder
 
addLateralViewForAlias(String, HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
 
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
 
addMappingOnly(String, String, ColumnInfo) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserRowResolver
 
addMasterHook(MasterTriggerRestoreHook<?>) - Method in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
Adds the given master hook to the checkpoint coordinator.
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.
addMultipleInputOperator(Integer, String, String, StreamOperatorFactory<OUT>, List<TypeInformation<?>>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addNamedProperties(FlinkFnApi.GroupWindow.WindowProperty) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
addNamedPropertiesValue(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
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.
AddOne - Class in org.apache.flink.python.tests.util
Scala UDF for testing.
AddOne() - Constructor for class org.apache.flink.python.tests.util.AddOne
 
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
 
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.PartitionTimeCommitTrigger
 
addPartition(String) - Method in class org.apache.flink.table.filesystem.stream.ProcTimeCommitTrigger
 
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 interface org.apache.flink.mesos.util.MesosArtifactServer
Deprecated.
Adds a path to the artifact server.
addPath(Path, Path) - Method in class org.apache.flink.mesos.util.MesosArtifactServerImpl
Deprecated.
 
addPendingTaskManager(PendingTaskManager) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedTaskManagerTracker
 
addPendingTaskManagerAllocate(PendingTaskManager) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
 
addPost(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addPredicate(OrcFilters.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.
addPriorityElement(T) - Method in class org.apache.flink.runtime.io.network.partition.PrioritizedDeque
Adds a priority element to this deque, such that it will be polled after all existing priority elements but before any non-priority element.
addProceed(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addProcessedBytes(int) - Method in class org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler
 
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
 
addPTFNodeToSpec(HiveParserASTNode, HiveParserPTFInvocationSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQB
 
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.
addReader(int) - Method in class org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator
 
addReader(int) - Method in class org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator
 
addReader(int) - Method in class org.apache.flink.connector.file.src.impl.StaticFileSplitEnumerator
 
addReader(int) - Method in class org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator
 
addReader(int) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator
 
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.CoderParam.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Input.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow.Builder
 
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.TypeInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.MapTypeInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.JobParameter.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.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.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() - 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
 
AddressNormalizer() - Constructor for class org.apache.flink.table.examples.java.basics.GettingStartedExample.AddressNormalizer
 
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.
addSlot(SlotID, ResourceProfile, TaskExecutorConnection, JobID) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotTracker
 
addSlots(Collection<AllocatedSlot>, long) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlotPool
Adds the given collection of slots to the slot pool.
addSlots(Collection<AllocatedSlot>, long) - Method in class org.apache.flink.runtime.jobmaster.slotpool.DefaultAllocatedSlotPool
 
addSource(NextSourceT) - Method in class org.apache.flink.connector.base.source.hybrid.HybridSource.HybridSourceBuilder
Add pre-configured source (without switch time modification).
addSource(HybridSource.SourceFactory<T, NextSourceT, ? super EnumT>, Boundedness) - Method in class org.apache.flink.connector.base.source.hybrid.HybridSource.HybridSourceBuilder
Add source with deferred instantiation based on previous enumerator.
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.
addSpecs(FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
addSpecs(int, FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
addSpecs(FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
addSpecs(int, FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
addSpecsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
addSpecsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
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<HybridSourceSplit>) - Method in class org.apache.flink.connector.base.source.hybrid.HybridSourceReader
 
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
 
addSplits(Collection<FileSourceSplit>) - Method in interface org.apache.flink.connector.file.src.assigners.FileSplitAssigner
Adds a set of splits to this assigner.
addSplits(Collection<FileSourceSplit>) - Method in class org.apache.flink.connector.file.src.assigners.LocalityAwareSplitAssigner
 
addSplits(Collection<FileSourceSplit>) - Method in class org.apache.flink.connector.file.src.assigners.SimpleSplitAssigner
 
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.
addSplitsBack(List<HybridSourceSplit>, int) - Method in class org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator
 
addSplitsBack(List<FileSourceSplit>, int) - Method in class org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator
 
addSplitsBack(List<FileSourceSplit>, int) - Method in class org.apache.flink.connector.file.src.impl.StaticFileSplitEnumerator
 
addSplitsBack(List<KafkaPartitionSplit>, int) - Method in class org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator
 
addSplitsBack(List<HiveSourceSplit>, int) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator
 
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
 
addTableNameTranslation(HiveParserASTNode, String) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserUnparseTranslator
 
addTableSpec(String, HiveParserBaseSemanticAnalyzer.TableSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
 
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
 
addTaskManager(TaskExecutorConnection, ResourceProfile, ResourceProfile) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedTaskManagerTracker
 
addTo(DSeries) - Method in class org.apache.flink.metrics.datadog.DHistogram
 
addToBatch(R) - Method in class org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor
Deprecated.
 
addToBatch(T) - Method in interface org.apache.flink.connector.jdbc.internal.executor.JdbcBatchStatementExecutor
 
addToBatch(RowData) - Method in class org.apache.flink.connector.jdbc.internal.executor.TableBufferedStatementExecutor
 
addToBatch(RowData) - Method in class org.apache.flink.connector.jdbc.internal.executor.TableBufferReducedStatementExecutor
 
addToBatch(RowData) - Method in class org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor
 
addToBatch(RowData) - Method in class org.apache.flink.connector.jdbc.internal.executor.TableSimpleStatementExecutor
 
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.
addToGBExpr(HiveParserRowResolver, HiveParserRowResolver, HiveParserASTNode, ExprNodeDesc, List<ExprNodeDesc>, List<String>) - Static method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserBaseSemanticAnalyzer
 
addToMessageDigest(MessageDigest) - Method in class org.apache.flink.runtime.blob.BlobKey
Adds the BLOB key to the given MessageDigest.
addToSelectList(List<SqlNode>, Set<String>, List<Map.Entry<String, RelDataType>>, SqlNode, SelectScope, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl
Adds an expression to a select list, ensuring that its alias does not clash with any existing expressions on the list.
addTrace(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
 
addTranslation(HiveParserASTNode, String) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserUnparseTranslator
Register a translation to be performed as part of unparse.
addUdfs(FlinkFnApi.UserDefinedAggregateFunction) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
addUdfs(int, FlinkFnApi.UserDefinedAggregateFunction) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
addUdfs(FlinkFnApi.UserDefinedAggregateFunction.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
addUdfs(int, FlinkFnApi.UserDefinedAggregateFunction.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
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.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
addUdfsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction 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;
addUnfulfillableJob(JobID) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
 
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.
addUserArtifacts(Map<String, DistributedCache.DistributedCacheEntry>) - Method in class org.apache.flink.runtime.jobgraph.JobGraphBuilder
 
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.CoLocationGroupImpl
 
addVertexToGroup(JobVertexID) - Method in class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup
 
addVertices(List<Vertex<K, VV>>) - Method in class org.apache.flink.graph.Graph
Adds the list of vertices, passed as input, to the graph.
addViewTokenRewriteStream(String, TokenRewriteStream) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserContext
 
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.
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.
addWindowFunction(HiveParserWindowingSpec.WindowFunctionSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserWindowingSpec
 
addWindowingExprToClause(String, HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
 
addWindows(FlinkFnApi.OverWindow) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addWindows(int, FlinkFnApi.OverWindow) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addWindows(FlinkFnApi.OverWindow.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addWindows(int, FlinkFnApi.OverWindow.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addWindowsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addWindowsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
addWindowSpec(String, HiveParserWindowingSpec.WindowSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserWindowingSpec
 
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.
adjustDataViews(DataType, boolean) - Static method in class org.apache.flink.table.planner.typeutils.DataViewUtils
Modifies the data type of an accumulator regarding data views.
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
 
AdjustProjectForCountAggregateRule(RelDecorrelator.AdjustProjectForCountAggregateRule.Config) - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator.AdjustProjectForCountAggregateRule
Creates an AdjustProjectForCountAggregateRule.
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
 
adminOptionFor() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
adminOptionFor_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.adminOptionFor_return
 
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.
AdvancedFunctionsExample - Class in org.apache.flink.table.examples.java.functions
Example for implementing more complex UserDefinedFunctions.
AdvancedFunctionsExample() - Constructor for class org.apache.flink.table.examples.java.functions.AdvancedFunctionsExample
 
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 interface org.apache.flink.table.runtime.util.KeyValueIterator
Advance this iterator by a single kv.
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
 
advanceProgress(long) - Method in class org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer
 
advanceProgress(long) - Method in interface org.apache.flink.table.runtime.operators.aggregate.window.buffers.WindowBuffer
Advances the progress time, the progress time is watermark if working in event-time mode, or current processing time if working in processing-time mode.
advanceProgress(long) - Method in class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor
 
advanceProgress(long) - Method in class org.apache.flink.table.runtime.operators.rank.window.processors.WindowRankProcessor
 
advanceProgress(long) - Method in interface org.apache.flink.table.runtime.operators.window.slicing.SlicingWindowProcessor
Advances the progress time, the progress time is watermark if working in event-time mode, or current processing time if working in processing-time mode.
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.MultipleInputStreamTask
 
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 interface org.apache.flink.streaming.api.operators.InternalTimeServiceManager
Advances the Watermark of all managed timer services, potentially firing event time timers.
advanceWatermark(Watermark) - Method in class org.apache.flink.streaming.api.operators.InternalTimeServiceManagerImpl
 
advanceWatermark(Watermark) - Method in class org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionInternalTimeServiceManager
 
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
 
after() - Method in class org.apache.flink.util.LogLevelRule
 
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
 
afterTest(TestDescription, Optional<Throwable>) - Method in class org.apache.flink.tests.util.flink.FlinkContainer
 
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.hbase.LocalStandaloneHBaseResource
 
afterTestSuccess() - Method in class org.apache.flink.tests.util.kafka.LocalStandaloneKafkaResource
 
afterTestSuccess() - Method in interface org.apache.flink.util.ExternalResource
 
aggArg0(Function<LogicalType, LogicalType>, boolean) - Static method in class org.apache.flink.table.types.inference.TypeStrategies
Type strategy specific for aggregations that partially produce different nullability depending whether the result is grouped or not.
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
 
AggCombiner - Class in org.apache.flink.table.runtime.operators.aggregate.window.combines
An implementation of RecordsCombiner that accumulates input records into the window accumulator state.
AggCombiner(WindowTimerService<Long>, StateKeyContext, WindowValueState<Long>, NamespaceAggsHandleFunction<Long>, boolean) - Constructor for class org.apache.flink.table.runtime.operators.aggregate.window.combines.AggCombiner
 
AggCombiner.Factory - Class in org.apache.flink.table.runtime.operators.aggregate.window.combines
Factory to create AggCombiner.
AggInfo(List<ExprNodeDesc>, TypeInfo, String, boolean, boolean, String) - Constructor for class org.apache.flink.table.planner.delegation.hive.copy.HiveParserBaseSemanticAnalyzer.AggInfo
 
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(String, AggregateFunction<T, ACC, R>, TypeInformation<K>, TypeInformation<T>, TypeInformation<R>) - Method in class org.apache.flink.state.api.EvictingWindowReader
Reads window state generated using an AggregateFunction.
aggregate(String, AggregateFunction<T, ACC, R>, WindowReaderFunction<R, OUT, K, W>, TypeInformation<K>, TypeInformation<T>, TypeInformation<OUT>) - Method in class org.apache.flink.state.api.EvictingWindowReader
Reads window state generated using an AggregateFunction.
aggregate(AggregateFunction<T, ACC, R>, WindowReaderFunction<R, OUT, KEY, W>, TypeInformation<KEY>, TypeSerializer<W>, TypeInformation<ACC>) - Static method in class org.apache.flink.state.api.input.operator.WindowReaderOperator
 
aggregate(AggregateFunction<T, ACC, R>) - Method in class org.apache.flink.state.api.WindowedOperatorTransformation
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>) - Method in class org.apache.flink.state.api.WindowedOperatorTransformation
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>) - Method in class org.apache.flink.state.api.WindowedOperatorTransformation
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>, TypeInformation<ACC>) - Method in class org.apache.flink.state.api.WindowedOperatorTransformation
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>) - Method in class org.apache.flink.state.api.WindowedOperatorTransformation
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>, TypeInformation<ACC>) - Method in class org.apache.flink.state.api.WindowedOperatorTransformation
Applies the given window function to each window.
aggregate(String, AggregateFunction<T, ACC, R>, TypeInformation<K>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.state.api.WindowReader
Reads window state generated using an AggregateFunction.
aggregate(String, AggregateFunction<T, ACC, R>, WindowReaderFunction<R, OUT, K, W>, TypeInformation<K>, TypeInformation<ACC>, TypeInformation<OUT>) - Method in class org.apache.flink.state.api.WindowReader
Reads window state generated using an AggregateFunction.
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(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>, TypeInformation<ACC>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder
 
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>, TypeInformation<ACC>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder
 
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(GeneratedNamespaceAggsHandleFunction<Long>, AbstractRowDataSerializer<RowData>) - Method in class org.apache.flink.table.runtime.operators.aggregate.window.SlicingWindowAggOperatorBuilder
 
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_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
 
AggregateCallJsonDeserializer - Class in org.apache.flink.table.planner.plan.nodes.exec.serde
JSON deserializer for AggregateCall.
AggregateCallJsonDeserializer() - Constructor for class org.apache.flink.table.planner.plan.nodes.exec.serde.AggregateCallJsonDeserializer
 
AggregateCallJsonSerializer - Class in org.apache.flink.table.planner.plan.nodes.exec.serde
JSON serializer for AggregateCall.
AggregateCallJsonSerializer() - Constructor for class org.apache.flink.table.planner.plan.nodes.exec.serde.AggregateCallJsonSerializer
 
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.
AggregateEvictingWindowReaderFunction<IN,ACC,R,OUT,KEY,W extends Window> - Class in org.apache.flink.state.api.input.operator.window
A wrapper for reading an evicting window operator with an aggregate function.
AggregateEvictingWindowReaderFunction(WindowReaderFunction<R, OUT, KEY, W>, AggregateFunction<IN, ACC, R>) - Constructor for class org.apache.flink.state.api.input.operator.window.AggregateEvictingWindowReaderFunction
 
AggregateExpression - Class in org.apache.flink.table.expressions
Resolved and validated expression for calling an aggregate function.
AggregateExpression(FunctionDefinition, List<FieldReferenceExpression>, CallExpression, DataType, boolean, boolean, boolean) - Constructor for class org.apache.flink.table.expressions.AggregateExpression
 
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 a user-defined aggregate function.
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, ResolvedSchema) - 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.DefaultExecutionGraph
 
aggregateUserAccumulators() - Method in interface 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.
aggregatingState() - Static method in interface org.apache.flink.state.api.input.operator.window.WindowContents
 
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 - Variable in class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor
 
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
Deprecated.
Use AkkaOptions#TRANSPORT_HEARTBEAT_INTERVAL instead.
AKKA_TRANSPORT_HEARTBEAT_PAUSE - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
Use AkkaOptions#TRANSPORT_HEARTBEAT_PAUSE instead.
AKKA_TRANSPORT_THRESHOLD - Static variable in class org.apache.flink.configuration.ConfigConstants
Deprecated.
Use AkkaOptions#TRANSPORT_THRESHOLD instead.
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
 
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
 
aliasList() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
aliasList() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser_FromClauseASTParser
 
aliasList_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser_FromClauseASTParser.aliasList_return
 
AliasNamespace - Class in org.apache.calcite.sql.validate
Namespace for an AS t(c1, c2, ...) clause.
AliasNamespace(SqlValidatorImpl, SqlCall, SqlNode) - Constructor for class org.apache.calcite.sql.validate.AliasNamespace
Creates an AliasNamespace.
aligned(String, AbstractInvokable, Clock, int, BiFunction<Callable<?>, Duration, CheckpointBarrierHandler.Cancellable>, CheckpointableInput...) - Static method in class org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
 
alignedNoTimeout(CheckpointType, CheckpointStorageLocationReference) - Static method in class org.apache.flink.runtime.checkpoint.CheckpointOptions
 
alignedWithTimeout(CheckpointStorageLocationReference, long) - Static method in class org.apache.flink.runtime.checkpoint.CheckpointOptions
 
ALIGNMENT_TIMEOUT - Static variable in class org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions
 
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() - Static method in class org.apache.flink.table.connector.ChangelogMode
Shortcut for a changelog that can contain all RowKinds.
ALL_CHANGES - Static variable in class org.apache.flink.table.planner.plan.trait.ModifyKindSet
A modify kind set contains all change operations.
ALL_IN_ONE - Static variable in class org.apache.flink.table.planner.plan.nodes.exec.spec.PartitionSpec
PartitionSpec makes all data in one partition.
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.
allChannelsRecovered() - Method in class org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate
 
allChannelsRecovered() - Method in interface org.apache.flink.streaming.runtime.io.checkpointing.UpstreamRecoveryTracker
 
AllFieldsForwardedProperties() - Constructor for class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties
 
allFieldsNoLessThan(ResourceProfile) - Method in class org.apache.flink.runtime.clusterframework.types.ResourceProfile
Check whether all fields of this resource profile are no less than the given resource profile.
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, ResourceProfile) - Method in class org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge
 
allocateAvailableSlot(SlotRequestId, AllocationID, ResourceProfile) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.SlotPool
Allocates the available slot with the given allocation id under the given request id for the given requirement profile.
allocateAvailableSlot(SlotRequestId, AllocationID, ResourceProfile) - Method in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
 
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
 
AllocatedSlotPool - Interface in org.apache.flink.runtime.jobmaster.slotpool
The slot pool is responsible for maintaining a set of AllocatedSlots.
AllocatedSlotPool.FreeSlotInfo - Interface in org.apache.flink.runtime.jobmaster.slotpool
Information about a free slot.
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
 
allocateFromPhysicalSlot(SlotRequestId, PhysicalSlot, Locality, SlotOwner, boolean) - Static method in class org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot
 
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.
allocatePhysicalSlot(PhysicalSlotRequest) - Method in interface org.apache.flink.runtime.jobmaster.slotpool.PhysicalSlotProvider
Submit a request to allocate a physical slot.
allocatePhysicalSlot(PhysicalSlotRequest) - Method in class org.apache.flink.runtime.jobmaster.slotpool.PhysicalSlotProviderImpl
 
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, boolean) - 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
allocateSegments(int) - Method in class org.apache.flink.table.runtime.util.LazyMemorySegmentPool
 
allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration, MemoryManager, double, Logger) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
 
allocateSlot(InstanceID, JobID, String, ResourceProfile) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer
 
allocateSlot(InstanceID, JobID, String, ResourceProfile) - Method in interface org.apache.flink.runtime.resourcemanager.slotmanager.SlotStatusSyncer
Allocate a slot from the task manager.
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<ExecutionVertexID>) - 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) - 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.
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
 
allowAliasUnnestItems() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
allowCharLiteralAlias() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
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(Time) - Method in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder
 
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
 
ALLOWEDLATENESS_FIELD_NUMBER - Static variable in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow
 
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
 
allowHyphenInUnquotedTableName() - Method in enum org.apache.flink.sql.parser.validate.FlinkSqlConformance
 
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
 
allowQuotedId() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTLexer
 
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
 
AlreadyExistException(String, Throwable) - Constructor for exception org.apache.flink.runtime.persistence.StateHandleStore.AlreadyExistException
Creates a new Exception with the given message and cause.
AlreadyExistException(String) - Constructor for exception org.apache.flink.runtime.persistence.StateHandleStore.AlreadyExistException
Creates a new Exception with the given message and null cause.
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
 
alterColConstraint() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterColConstraint_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterColConstraint_return
 
alterColumnConstraint(CommonTree) - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterColumnConstraint_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterColumnConstraint_return
 
alterColumns(StorageDescriptor, CatalogTable) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil
 
alterConstraintWithName() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterConstraintWithName_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterConstraintWithName_return
 
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
 
alterDatabaseStatementSuffix() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterDatabaseStatementSuffix_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterDatabaseStatementSuffix_return
 
alterDatabaseSuffixProperties() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterDatabaseSuffixProperties_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterDatabaseSuffixProperties_return
 
alterDatabaseSuffixSetLocation() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterDatabaseSuffixSetLocation_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterDatabaseSuffixSetLocation_return
 
alterDatabaseSuffixSetOwner() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterDatabaseSuffixSetOwner_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterDatabaseSuffixSetOwner_return
 
alterForeignKeyConstraint(CommonTree) - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterForeignKeyConstraint_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterForeignKeyConstraint_return
 
alterForeignKeyWithName() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterForeignKeyWithName_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterForeignKeyWithName_return
 
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
 
alterIndexStatementSuffix() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterIndexStatementSuffix_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterIndexStatementSuffix_return
 
alternating(String, AbstractInvokable, SubtaskCheckpointCoordinator, Clock, int, BiFunction<Callable<?>, Duration, CheckpointBarrierHandler.Cancellable>, CheckpointableInput...) - Static method in class org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
 
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
 
alterStatement() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatement_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatement_return
 
alterStatementChangeColPosition() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementChangeColPosition_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementChangeColPosition_return
 
alterStatementPartitionKeyType() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementPartitionKeyType_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementPartitionKeyType_return
 
alterStatementSuffixAddCol() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixAddCol_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixAddCol_return
 
alterStatementSuffixAddConstraint() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixAddConstraint_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixAddConstraint_return
 
alterStatementSuffixAddPartitions(boolean) - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixAddPartitions_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixAddPartitions_return
 
alterStatementSuffixAddPartitionsElement() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixAddPartitionsElement_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixAddPartitionsElement_return
 
alterStatementSuffixArchive() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixArchive_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixArchive_return
 
alterStatementSuffixBucketNum() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixBucketNum_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixBucketNum_return
 
alterStatementSuffixClusterbySortby() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixClusterbySortby_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixClusterbySortby_return
 
alterStatementSuffixCompact() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixCompact_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixCompact_return
 
alterStatementSuffixDropConstraint() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixDropConstraint_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixDropConstraint_return
 
alterStatementSuffixDropPartitions(boolean) - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixDropPartitions_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixDropPartitions_return
 
alterStatementSuffixExchangePartition() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixExchangePartition_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixExchangePartition_return
 
alterStatementSuffixFileFormat() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixFileFormat_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixFileFormat_return
 
alterStatementSuffixLocation() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixLocation_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixLocation_return
 
alterStatementSuffixMergeFiles() - Method in class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser
 
alterStatementSuffixMergeFiles_return() - Constructor for class org.apache.flink.table.planner.delegation.hive.parse.HiveASTParser.alterStatementSuffixMergeFiles_return
 
alterStatementSuffixProperties() - Method in class org.a