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 column.

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, CheckpointStatsTracker) - 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
Deprecated.
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.runtime.io.network.api.writer.RecordWriter
 
abortCheckpoint(long, CheckpointException) - Method in interface org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter
Abort the checkpoint.
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.runtime.io.network.partition.BufferWritingResultPartition
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.runtime.io.network.partition.hybrid.HsResultPartition
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.runtime.io.network.partition.ResultSubpartition
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.runtime.io.network.partition.SortMergeResultPartition
 
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, long) - Method in class org.apache.flink.runtime.taskexecutor.TaskExecutor
 
abortCheckpoint(ExecutionAttemptID, long, long, long) - Method in interface org.apache.flink.runtime.taskexecutor.TaskExecutorGateway
Abort a checkpoint for the given task.
abortCheckpoint(ExecutionAttemptID, long, long, long) - Method in class org.apache.flink.runtime.taskexecutor.TaskExecutorGatewayDecoratorBase
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.streaming.runtime.io.RecordWriterOutput
 
abortCheckpoint(long, CheckpointException) - Method in class org.apache.flink.streaming.runtime.tasks.OperatorChain
 
abortCheckpointOnBarrier(long, CheckpointException) - Method in class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
 
abortCheckpointOnBarrier(long, CheckpointException) - Method in interface org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask
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
 
abortTxns(List<Long>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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(byte) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
SQL ABS operator applied to byte values.
abs(short) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
SQL ABS operator applied to short values.
abs(int) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
SQL ABS operator applied to int values.
abs(long) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
SQL ABS operator applied to long values.
abs(float) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
SQL ABS operator applied to float values.
abs(double) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
SQL ABS operator applied to double values.
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.
AbstactOperationHeaders - Class in org.apache.flink.table.gateway.rest.header.operation
Abstract operation related message headers.
AbstactOperationHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.operation.AbstactOperationHeaders
 
ABSTRACT - Static variable in class org.apache.flink.table.codesplit.JavaLexer
 
ABSTRACT - Static variable in class org.apache.flink.table.codesplit.JavaLexer
 
ABSTRACT - Static variable in class org.apache.flink.table.codesplit.JavaParser
 
ABSTRACT - Static variable in class org.apache.flink.table.codesplit.JavaParser
 
ABSTRACT() - Method in class org.apache.flink.table.codesplit.JavaParser.ClassOrInterfaceModifierContext
 
ABSTRACT() - Method in class org.apache.flink.table.codesplit.JavaParser.ClassOrInterfaceModifierContext
 
ABSTRACT() - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMethodModifierContext
 
ABSTRACT() - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMethodModifierContext
 
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, RowType, GeneratedProjection) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.arrow.AbstractArrowPythonAggregateFunctionOperator
 
AbstractAsynchronousOperationHandlers<K extends OperationKey,R extends Serializable> - Class in org.apache.flink.runtime.rest.handler.async
HTTP handlers for asynchronous operations.
AbstractAsynchronousOperationHandlers(Duration) - 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.
AbstractAutoCloseableRegistry<R extends AutoCloseable,C extends R,T,E extends Exception> - 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.
AbstractAutoCloseableRegistry(Map<R, T>) - Constructor for class org.apache.flink.util.AbstractAutoCloseableRegistry
 
AbstractAvroBulkFormat<A,T,SplitT extends FileSourceSplit> - Class in org.apache.flink.formats.avro
Provides a BulkFormat for Avro records.
AbstractAvroBulkFormat(Schema) - Constructor for class org.apache.flink.formats.avro.AbstractAvroBulkFormat
 
AbstractAzureFSFactory - Class in org.apache.flink.fs.azurefs
Abstract factory for AzureFS.
AbstractAzureFSFactory() - Constructor for class org.apache.flink.fs.azurefs.AbstractAzureFSFactory
 
AbstractBeamStateHandler<S> - Class in org.apache.flink.streaming.api.runners.python.beam.state
Abstract class extends BeamStateHandler, which implements the common handle logic.
AbstractBeamStateHandler() - Constructor for class org.apache.flink.streaming.api.runners.python.beam.state.AbstractBeamStateHandler
 
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, Reference<File>, 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
 
AbstractChangelogStateBackend - Class in org.apache.flink.state.changelog
An abstract base implementation of the StateBackend interface whose subclasses use delegatedStateBackend and State changes to restore.
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.
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
 
AbstractCompleteCheckpointStore - Class in org.apache.flink.runtime.checkpoint
The abstract class of CompletedCheckpointStore, which holds the SharedStateRegistry and provides the registration of shared state.
AbstractCompleteCheckpointStore(SharedStateRegistry) - Constructor for class org.apache.flink.runtime.checkpoint.AbstractCompleteCheckpointStore
 
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
 
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.
 
AbstractDialect - Class in org.apache.flink.connector.jdbc.dialect
Base class for JdbcDialects that implements basic data type validation and the construction of basic INSERT, UPDATE, DELETE, and SELECT statements.
AbstractDialect() - Constructor for class org.apache.flink.connector.jdbc.dialect.AbstractDialect
 
AbstractDialect.Range - Class in org.apache.flink.connector.jdbc.dialect
A range from [min,max] where min <= max.
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.
AbstractEmbeddedDataStreamPythonFunctionOperator<OUT> - Class in org.apache.flink.streaming.api.operators.python.embedded
Base class for all Python DataStream operators executed in embedded Python environment.
AbstractEmbeddedDataStreamPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedDataStreamPythonFunctionOperator
 
AbstractEmbeddedPythonFunctionOperator<OUT> - Class in org.apache.flink.streaming.api.operators.python.embedded
Abstract class for all stream operators to execute Python functions in embedded Python environment.
AbstractEmbeddedPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedPythonFunctionOperator
 
AbstractEmbeddedStatelessFunctionOperator - Class in org.apache.flink.table.runtime.operators.python
Base class for all stream operators to execute Python Stateless Functions in embedded Python environment.
AbstractEmbeddedStatelessFunctionOperator(Configuration, RowType, RowType, RowType, int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.AbstractEmbeddedStatelessFunctionOperator
 
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
 
AbstractExternalDataStreamPythonFunctionOperator<OUT> - Class in org.apache.flink.streaming.api.operators.python.process
Base class for all Python DataStream operators executed in Python process.
AbstractExternalDataStreamPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.process.AbstractExternalDataStreamPythonFunctionOperator
 
AbstractExternalOneInputPythonFunctionOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.python.process
AbstractExternalOneInputPythonFunctionOperator is responsible for launching beam runner which will start a python harness to execute user defined python function.
AbstractExternalOneInputPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<IN>, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.process.AbstractExternalOneInputPythonFunctionOperator
 
AbstractExternalPythonFunctionOperator<OUT> - Class in org.apache.flink.streaming.api.operators.python.process
Abstract class for all stream operators to execute Python functions in external environment.
AbstractExternalPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.streaming.api.operators.python.process.AbstractExternalPythonFunctionOperator
 
AbstractExternalTwoInputPythonFunctionOperator<IN1,IN2,OUT> - Class in org.apache.flink.streaming.api.operators.python.process
AbstractExternalTwoInputPythonFunctionOperator is responsible for launching beam runner which will start a python harness to execute two-input user defined python function.
AbstractExternalTwoInputPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<IN1>, TypeInformation<IN2>, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.process.AbstractExternalTwoInputPythonFunctionOperator
 
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, JobResultStore) - 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, int, LookupCache) - Constructor for class org.apache.flink.connector.hbase.source.AbstractHBaseDynamicTableSource
 
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.columnar.vector.heap
Heap vector that nullable shared structure.
AbstractHeapVector(int) - Constructor for class org.apache.flink.table.data.columnar.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
A base implementation of TaskInvokable, CheckpointableTask, and CoordinatedTask with most methods throwing UnsupportedOperationException or doing nothing.
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(ClassLoader, String, String, String, String, String) - Constructor for class org.apache.flink.connector.jdbc.catalog.AbstractJdbcCatalog
 
AbstractJdbcRowConverter - Class in org.apache.flink.connector.jdbc.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.converter.AbstractJdbcRowConverter
 
AbstractJdbcRowConverter.JdbcDeserializationConverter - Interface in org.apache.flink.connector.jdbc.converter
Runtime converter to convert JDBC field to RowData type object.
AbstractJdbcRowConverter.JdbcSerializationConverter - Interface in org.apache.flink.connector.jdbc.converter
Runtime converter to convert RowData field to java object and fill into the PreparedStatement.
AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> - Class in org.apache.flink.client.deployment.executors
Deprecated.
AbstractJobClusterExecutor(ClientFactory) - Constructor for class org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor
Deprecated.
 
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(AbstractKeyedStateBackend<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
 
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
 
AbstractOneInputEmbeddedPythonFunctionOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.python.embedded
AbstractOneInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream operators with one input in Embedded Python environment.
AbstractOneInputEmbeddedPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<IN>, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.embedded.AbstractOneInputEmbeddedPythonFunctionOperator
 
AbstractOneInputPythonFunctionOperator<IN,OUT> - Class in org.apache.flink.table.runtime.operators.python
Base class for all one input stream operators to execute Python functions.
AbstractOneInputPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.table.runtime.operators.python.AbstractOneInputPythonFunctionOperator
 
AbstractOperationHandler - Class in org.apache.flink.table.gateway.rest.handler.operation
Abstract operation handler.
AbstractOperationHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, OperationStatusResponseBody, OperationMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.operation.AbstractOperationHandler
 
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
 
AbstractPrometheusReporter - Class in org.apache.flink.metrics.prometheus
base prometheus reporter for prometheus metrics.
AbstractPrometheusReporter() - Constructor for class org.apache.flink.metrics.prometheus.AbstractPrometheusReporter
 
AbstractPythonEnvironmentManager - Class in org.apache.flink.python.env
The base class of python environment manager which is used to create the PythonEnvironment object used to execute Python functions.
AbstractPythonEnvironmentManager(PythonDependencyInfo, String[], Map<String, String>, JobID) - Constructor for class org.apache.flink.python.env.AbstractPythonEnvironmentManager
 
AbstractPythonEnvironmentManager.PythonLeasedResource - Class in org.apache.flink.python.env
Python lease resource which includes environment variables and working directory of execution python environment.
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
 
AbstractPythonScalarFunctionOperator - Class in org.apache.flink.table.runtime.operators.python.scalar
Base class for all stream operators to execute Python ScalarFunctions.
AbstractPythonScalarFunctionOperator(Configuration, PythonFunctionInfo[], RowType, RowType, RowType, GeneratedProjection, GeneratedProjection) - Constructor for class org.apache.flink.table.runtime.operators.python.scalar.AbstractPythonScalarFunctionOperator
 
AbstractPythonStreamAggregateOperator - Class in org.apache.flink.table.runtime.operators.python.aggregate
AbstractPythonStreamAggregateOperator(Configuration, RowType, RowType, PythonAggregateFunctionInfo[], DataViewSpec[][], int[], int, boolean) - 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[], DataViewSpec[][], int[], int, boolean, long, long) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.AbstractPythonStreamGroupAggregateOperator
 
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.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
 
AbstractRetryStrategy - Class in org.apache.flink.testutils.junit.extensions.retry.strategy
Retry strategy base class.
AbstractRetryStrategy(int, boolean) - Constructor for class org.apache.flink.testutils.junit.extensions.retry.strategy.AbstractRetryStrategy
 
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
 
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
 
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>>, OperatorMetricGroup) - 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.
AbstractSqlGatewayRestHandler<R extends RequestBody,P extends ResponseBody,M extends MessageParameters> - Class in org.apache.flink.table.gateway.rest.handler
Super class for sql gateway handlers that work with RequestBodys and ResponseBodys.
AbstractSqlGatewayRestHandler(SqlGatewayService, Map<String, String>, MessageHeaders<R, P, M>) - Constructor for class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler
 
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
 
AbstractStateChangeFsUploader - Class in org.apache.flink.changelog.fs
Base implementation of StateChangeUploader.
AbstractStateChangeFsUploader(boolean, int, ChangelogStorageMetricGroup, TaskChangelogRegistry, BiFunction<Path, Long, StreamStateHandle>) - Constructor for class org.apache.flink.changelog.fs.AbstractStateChangeFsUploader
 
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, RowType) - 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, RowType, int, long, GeneratedProjection) - 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, RowType, int, long, GeneratedProjection) - 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, RowType, int, long, GeneratedProjection) - 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.connector.file.table.stream
Operator for file system sink.
AbstractStreamingWriter(long, StreamingFileSink.BucketsBuilder<IN, String, ? extends StreamingFileSink.BucketsBuilder<IN, String, ?>>) - Constructor for class org.apache.flink.connector.file.table.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
 
AbstractStreamTableEnvironmentImpl - Class in org.apache.flink.table.api.bridge.internal
Abstract class to implement a StreamTableEnvironment.
AbstractStreamTableEnvironmentImpl(CatalogManager, ModuleManager, ResourceManager, TableConfig, Executor, FunctionCatalog, Planner, boolean, StreamExecutionEnvironment) - Constructor for class org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl
 
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
 
AbstractThreadsafeJobResultStore - Class in org.apache.flink.runtime.highavailability
An abstract class for threadsafe implementations of the JobResultStore.
AbstractThreadsafeJobResultStore() - Constructor for class org.apache.flink.runtime.highavailability.AbstractThreadsafeJobResultStore
 
AbstractTopNFunction - Class in org.apache.flink.table.runtime.operators.rank
Base class for TopN Function.
AbstractTwoInputEmbeddedPythonFunctionOperator<IN1,IN2,OUT> - Class in org.apache.flink.streaming.api.operators.python.embedded
AbstractTwoInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream operators with two input user defined python function in Embedded Python environment.
AbstractTwoInputEmbeddedPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<IN1>, TypeInformation<IN2>, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.embedded.AbstractTwoInputEmbeddedPythonFunctionOperator
 
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
 
AbstractWindowProperty - Class in org.apache.flink.table.runtime.groupwindow
Deprecated.
The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
AbstractWindowProperty(WindowReference) - Constructor for class org.apache.flink.table.runtime.groupwindow.AbstractWindowProperty
Deprecated.
 
AbstractWritableVector - Class in org.apache.flink.table.data.columnar.vector.writable
Contains the shared structure for ColumnVectors, including NULL information and dictionary.
AbstractWritableVector() - Constructor for class org.apache.flink.table.data.columnar.vector.writable.AbstractWritableVector
 
AbstractZooKeeperHaServices - Class in org.apache.flink.runtime.highavailability.zookeeper
Abstract ZooKeeper based HA services.
AbstractZooKeeperHaServices(CuratorFrameworkWithUnhandledErrorListener, Executor, Configuration, BlobStoreService) - Constructor for class org.apache.flink.runtime.highavailability.zookeeper.AbstractZooKeeperHaServices
 
ACC_TASK_BACK_PRESSURED_TIME - Static variable in class org.apache.flink.runtime.metrics.MetricNames
 
ACC_TASK_BUSY_TIME - Static variable in class org.apache.flink.runtime.metrics.MetricNames
 
ACC_TASK_IDLE_TIME - Static variable in class org.apache.flink.runtime.metrics.MetricNames
 
accept(RexShuttle) - Method in class org.apache.calcite.rel.core.Filter
 
accept(RexShuttle) - Method in class org.apache.calcite.rel.core.Sort
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalCorrelate
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalFilter
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalIntersect
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalMinus
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalSort
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalUnion
 
accept(RelShuttle) - Method in class org.apache.calcite.rel.logical.LogicalValues
 
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(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(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationConstantRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationConstantRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationMethodOrConstantRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationMethodOrConstantRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationMethodRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationMethodRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeElementDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeElementDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeElementRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.AnnotationTypeElementRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ArgumentsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ArgumentsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ArrayCreatorRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ArrayCreatorRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ArrayInitializerContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ArrayInitializerContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.BlockContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.BlockContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.BlockStatementContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.BlockStatementContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CatchClauseContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CatchClauseContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CatchTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CatchTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassBodyDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassBodyDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassCreatorRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassCreatorRestContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassOrInterfaceModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassOrInterfaceModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassOrInterfaceTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassOrInterfaceTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ClassTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CompilationUnitContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CompilationUnitContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstantDeclaratorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstantDeclaratorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstructorCallContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstructorCallContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstructorDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ConstructorDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CreatedNameContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CreatedNameContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CreatorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.CreatorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.DefaultValueContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.DefaultValueContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValueArrayInitializerContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValueArrayInitializerContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValueContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValueContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValuePairContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValuePairContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValuePairsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ElementValuePairsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnhancedForControlContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnhancedForControlContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumBodyDeclarationsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumBodyDeclarationsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumConstantContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumConstantContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumConstantsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumConstantsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.EnumDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExplicitGenericInvocationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExplicitGenericInvocationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExplicitGenericInvocationSuffixContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExplicitGenericInvocationSuffixContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExpressionListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ExpressionListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FieldDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FieldDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FinallyBlockContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FinallyBlockContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FloatLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FloatLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ForControlContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ForControlContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ForInitContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ForInitContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FormalParameterContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FormalParameterContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FormalParameterListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FormalParameterListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FormalParametersContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.FormalParametersContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.GenericConstructorDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.GenericConstructorDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.GenericInterfaceMethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.GenericInterfaceMethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.GenericMethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.GenericMethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ImportDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ImportDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InnerCreatorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InnerCreatorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.IntegerLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.IntegerLiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceBodyDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceBodyDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMemberDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMemberDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMethodModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.InterfaceMethodModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LambdaBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LambdaBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LambdaExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LambdaExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LambdaParametersContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LambdaParametersContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LastFormalParameterContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LastFormalParameterContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LiteralContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LocalTypeDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LocalTypeDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LocalVariableDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.LocalVariableDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MemberDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MemberDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MethodBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MethodBodyContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MethodCallContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MethodCallContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.MethodDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.NonWildcardTypeArgumentsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.NonWildcardTypeArgumentsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.NonWildcardTypeArgumentsOrDiamondContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.NonWildcardTypeArgumentsOrDiamondContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.PackageDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.PackageDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ParExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ParExpressionContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.PrimaryContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.PrimaryContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.PrimitiveTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.PrimitiveTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.QualifiedNameContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.QualifiedNameContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.QualifiedNameListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.QualifiedNameListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ResourceContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ResourceContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ResourcesContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ResourcesContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ResourceSpecificationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.ResourceSpecificationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.StatementContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.StatementContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.SuperSuffixContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.SuperSuffixContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.SwitchBlockStatementGroupContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.SwitchBlockStatementGroupContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.SwitchLabelContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.SwitchLabelContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeArgumentContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeArgumentContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeArgumentsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeArgumentsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeArgumentsOrDiamondContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeArgumentsOrDiamondContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeBoundContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeBoundContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeDeclarationContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeListContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeParameterContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeParameterContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeParametersContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeParametersContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeTypeContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeTypeOrVoidContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.TypeTypeOrVoidContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableDeclaratorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableDeclaratorContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableDeclaratorIdContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableDeclaratorIdContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableDeclaratorsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableDeclaratorsContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableInitializerContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableInitializerContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableModifierContext
 
accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.flink.table.codesplit.JavaParser.VariableModifierContext
 
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(ModifyOperationVisitor<T>) - Method in class org.apache.flink.table.operations.CollectModifyOperation
 
accept(ModifyOperationVisitor<T>) - Method in class org.apache.flink.table.operations.CreateTableASOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.DataStreamQueryOperation
Deprecated.
 
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.ExternalQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.FilterQueryOperation
 
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.SetQueryOperation
 
accept(ModifyOperationVisitor<T>) - Method in class org.apache.flink.table.operations.SinkModifyOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.SortQueryOperation
 
accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.SourceQueryOperation
 
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.InternalDataStreamQueryOperation
Deprecated.
 
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(RelShuttle) - Method in class org.apache.flink.table.planner.plan.nodes.hive.LogicalScriptTransform
 
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(S, T, U) - Method in interface org.apache.flink.util.function.TriConsumerWithException
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
 
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
 
acceptsURL(String) - Method in class org.apache.flink.connector.jdbc.dialect.derby.DerbyDialectFactory
 
acceptsURL(String) - Method in interface org.apache.flink.connector.jdbc.dialect.JdbcDialectFactory
Retrieves whether the dialect thinks that it can open a connection to the given URL.
acceptsURL(String) - Method in class org.apache.flink.connector.jdbc.dialect.mysql.MySqlDialectFactory
 
acceptsURL(String) - Method in class org.apache.flink.connector.jdbc.dialect.oracle.OracleDialectFactory
 
acceptsURL(String) - Method in class org.apache.flink.connector.jdbc.dialect.psql.PostgresDialectFactory
 
acceptWithException(T) - Method in interface org.apache.flink.util.concurrent.FutureConsumerWithException
 
acceptWithoutTimeout(ServerSocket) - Static method in class org.apache.flink.util.NetUtils
Calls ServerSocket.accept() on the provided server socket, suppressing any thrown SocketTimeoutExceptions.
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.connector.aws.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(HllBuffer, Object) - Method in class org.apache.flink.table.runtime.functions.aggregate.BatchApproxCountDistinctAggFunctions.ApproxCountDistinctAggFunction
 
accumulate(CollectAggFunction.CollectAccumulator<T>, T) - Method in class org.apache.flink.table.runtime.functions.aggregate.CollectAggFunction
 
accumulate(RowData, Object) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueAggFunction
 
accumulate(RowData, Object, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueAggFunction
 
accumulate(RowData, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueAggFunction
 
accumulate(RowData, StringData, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueWithRetractAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, Object, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueWithRetractAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueWithRetractAggFunction
 
accumulate(FirstValueWithRetractAggFunction.FirstValueWithRetractAccumulator<T>, StringData, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.FirstValueWithRetractAggFunction
 
accumulate(JsonArrayAggFunction.Accumulator, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.JsonArrayAggFunction
 
accumulate(JsonObjectAggFunction.Accumulator, StringData, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.JsonObjectAggFunction
 
accumulate(LagAggFunction.LagAcc<T>, T) - Method in class org.apache.flink.table.runtime.functions.aggregate.LagAggFunction
 
accumulate(LagAggFunction.LagAcc<T>, T, int) - Method in class org.apache.flink.table.runtime.functions.aggregate.LagAggFunction
 
accumulate(LagAggFunction.LagAcc<T>, T, int, T) - Method in class org.apache.flink.table.runtime.functions.aggregate.LagAggFunction
 
accumulate(RowData, Object) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueAggFunction
 
accumulate(RowData, Object, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueAggFunction
 
accumulate(GenericRowData, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueAggFunction
 
accumulate(GenericRowData, StringData, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueWithRetractAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, Object, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueWithRetractAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueWithRetractAggFunction
 
accumulate(LastValueWithRetractAggFunction.LastValueWithRetractAccumulator<T>, StringData, Long) - Method in class org.apache.flink.table.runtime.functions.aggregate.LastValueWithRetractAggFunction
 
accumulate(ListAggWithRetractAggFunction.ListAggWithRetractAccumulator, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.ListAggWithRetractAggFunction
 
accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator, StringData, StringData) - Method in class org.apache.flink.table.runtime.functions.aggregate.ListAggWsWithRetractAggFunction
 
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>, T) - Method in class org.apache.flink.table.runtime.functions.aggregate.MaxWithRetractAggFunction
 
accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<T>, T) - Method in class org.apache.flink.table.runtime.functions.aggregate.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.
accumulate(CountAggFunction.CountAccumulator, Long) - Method in class org.apache.flink.table.toolbox.CountAggFunction
 
accumulate(CountAggFunction.CountAccumulator) - Method in class org.apache.flink.table.toolbox.CountAggFunction
 
accumulateBackPressuredTime - Variable in class org.apache.flink.runtime.executiongraph.IOMetrics
 
accumulateBusyTime - Variable in class org.apache.flink.runtime.executiongraph.IOMetrics
 
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.CumeDistAggFunction
 
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.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.NTILEAggFunction
 
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
 
accumulateIdleTime - Variable in class org.apache.flink.runtime.executiongraph.IOMetrics
 
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
 
Accumulator() - Constructor for class org.apache.flink.table.runtime.functions.aggregate.JsonArrayAggFunction.Accumulator
 
Accumulator() - Constructor for class org.apache.flink.table.runtime.functions.aggregate.JsonObjectAggFunction.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
 
acknowledgeAllDataProcessed() - Method in class org.apache.flink.runtime.io.network.partition.BoundedBlockingSubpartitionDirectTransferReader
 
acknowledgeAllDataProcessed() - Method in class org.apache.flink.runtime.io.network.partition.hybrid.HsSubpartitionView
 
acknowledgeAllDataProcessed() - Method in class org.apache.flink.runtime.io.network.partition.NoOpResultSubpartitionView
 
acknowledgeAllDataProcessed() - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition
 
acknowledgeAllDataProcessed() - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartitionView
 
acknowledgeAllDataProcessed() - Method in interface org.apache.flink.runtime.io.network.partition.ResultSubpartitionView
 
acknowledgeAllRecordsProcessed(RemoteInputChannel) - Method in class org.apache.flink.runtime.io.network.netty.NettyPartitionRequestClient
 
acknowledgeAllRecordsProcessed() - Method in interface org.apache.flink.runtime.io.network.NetworkSequenceViewReader
Acknowledges all the user records are processed.
acknowledgeAllRecordsProcessed() - Method in class org.apache.flink.runtime.io.network.partition.consumer.InputChannel
When received EndOfData from one channel, it need to acknowledge after this event get processed.
acknowledgeAllRecordsProcessed(InputChannelInfo) - Method in class org.apache.flink.runtime.io.network.partition.consumer.InputGate
 
acknowledgeAllRecordsProcessed() - Method in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel
 
acknowledgeAllRecordsProcessed() - Method in class org.apache.flink.runtime.io.network.partition.consumer.RecoveredInputChannel
 
acknowledgeAllRecordsProcessed() - Method in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel
 
acknowledgeAllRecordsProcessed(InputChannelInfo) - Method in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate
 
acknowledgeAllRecordsProcessed(InputChannelInfo) - Method in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate
 
acknowledgeAllRecordsProcessed(RemoteInputChannel) - Method in interface org.apache.flink.runtime.io.network.PartitionRequestClient
Acknowledges all user records are processed for this channel.
acknowledgeAllRecordsProcessed(InputChannelInfo) - Method in class org.apache.flink.runtime.taskmanager.InputGateWithMetrics
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, SerializedValue<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, SerializedValue<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
 
AcknowledgeCheckpointEvent - Class in org.apache.flink.runtime.operators.coordination
An OperatorEvent sent from a subtask to its OperatorCoordinator to signal that the checkpoint of an individual task is completed.
AcknowledgeCheckpointEvent(long) - Constructor for class org.apache.flink.runtime.operators.coordination.AcknowledgeCheckpointEvent
 
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
Deprecated.
ATTENTION to subclass implementors: When overriding this method, please always call super.acknowledgeMessage() to keep the invariants of the internal bookkeeping of the producer.
acknowledgeMessages(Map<TopicPartition, MessageId>) - Method in class org.apache.flink.connector.pulsar.source.reader.fetcher.PulsarOrderedFetcherManager
 
AcknowledgeOnCheckpoint<ACKID extends Serializable> - Class in org.apache.flink.streaming.connectors.gcp.pubsub.common
Helper class for SourceFunctions to acknowledge messages to external systems after a successful checkpoint.
AcknowledgeOnCheckpoint(Acknowledger<ACKID>) - Constructor for class org.apache.flink.streaming.connectors.gcp.pubsub.common.AcknowledgeOnCheckpoint
 
acknowledgeOnCheckpoint - Variable in class org.apache.flink.streaming.connectors.gcp.pubsub.PubSubSource
 
acknowledgeOnCheckpointFactory - Variable in class org.apache.flink.streaming.connectors.gcp.pubsub.PubSubSource
 
Acknowledger<AcknowledgeId> - Interface in org.apache.flink.streaming.connectors.gcp.pubsub.common
 
acknowledgeSessionIDs(List<SessionId>) - Method in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
Acknowledges the session ids.
acknowledgeSessionIDs(List<Long>) - Method in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
acknowledgeTask(ExecutionAttemptID, TaskStateSnapshot, CheckpointMetrics) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Acknowledges the task with the given execution attempt id and the given subtask state.
ackReport() - Method in class org.apache.flink.metrics.datadog.DCounter
 
ackReport() - Method in class org.apache.flink.metrics.datadog.DMetric
 
acos() - Method in class org.apache.flink.table.api.internal.BaseExpressions
Calculates the arc cosine of a given number.
ACOS - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
 
ACOS - Static variable in class org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
 
acos(DecimalData) - Static method in class org.apache.flink.table.runtime.functions.SqlFunctionUtils
 
acquire(int) - Method in interface org.apache.flink.api.common.io.ratelimiting.FlinkConnectorRateLimiter
Acquires permits for the rate limiter.
acquire(int) - Method in class org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter
 
acquireLease() - Method in class org.apache.flink.runtime.state.NonClosingCheckpointOutputStream
Returns a ResourceGuard.Lease that prevents closing this stream.
acquireResource() - Method in class org.apache.flink.util.ResourceGuard
Acquired access from one new client for the guarded resource.
ACTION - Static variable in interface org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants
 
ACTION - Static variable in interface org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants
 
ActionRequestFailureHandler - Interface in org.apache.flink.streaming.connectors.elasticsearch
Deprecated.
This has been deprecated and will be removed in the future.
ACTIVE - Static variable in class org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus
 
ACTIVE_STATUS - Static variable in class org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus
 
ActiveResourceManager<WorkerType extends ResourceIDRetrievable> - Class in org.apache.flink.runtime.resourcemanager.active
An active implementation of ResourceManager.
ActiveResourceManager(ResourceManagerDriver<WorkerType>, Configuration, RpcService, UUID, ResourceID, HeartbeatServices, DelegationTokenManager, SlotManager, ResourceManagerPartitionTrackerFactory, BlocklistHandler.Factory, JobLeaderIdService, ClusterInformation, FatalErrorHandler, ResourceManagerMetricGroup, ThresholdMeter, Duration, 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, ClassLoader) - 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
 
ADAPTIVE_BATCH_SCHEDULER_AVG_DATA_VOLUME_PER_TASK - Static variable in class org.apache.flink.configuration.JobManagerOptions
 
ADAPTIVE_BATCH_SCHEDULER_DEFAULT_SOURCE_PARALLELISM - Static variable in class org.apache.flink.configuration.JobManagerOptions
 
ADAPTIVE_BATCH_SCHEDULER_MAX_PARALLELISM - Static variable in class org.apache.flink.configuration.JobManagerOptions
 
ADAPTIVE_BATCH_SCHEDULER_MIN_PARALLELISM - Static variable in class org.apache.flink.configuration.JobManagerOptions
 
AdaptiveBatchScheduler - Class in org.apache.flink.runtime.scheduler.adaptivebatch
This scheduler decides the parallelism of JobVertex according to the data volume it consumes.
AdaptiveBatchScheduler(Logger, JobGraph, Executor, Configuration, Consumer<ComponentMainThreadExecutor>, ScheduledExecutor, ClassLoader, CheckpointsCleaner, CheckpointRecoveryFactory, JobManagerJobMetricGroup, SchedulingStrategyFactory, FailoverStrategy.Factory, RestartBackoffTimeStrategy, ExecutionOperations, ExecutionVertexVersioner, ExecutionSlotAllocatorFactory, long, ComponentMainThreadExecutor, JobStatusListener, ExecutionGraphFactory, ShuffleMaster<?>, Time, VertexParallelismDecider, int) - Constructor for class org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler
 
AdaptiveBatchSchedulerFactory - Class in org.apache.flink.runtime.scheduler.adaptivebatch
AdaptiveBatchSchedulerFactory() - Constructor for class org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchSchedulerFactory
 
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, CheckpointsCleaner, 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(DeleteRequest...) - Method in interface org.apache.flink.connector.elasticsearch.sink.RequestIndexer
Add multiple DeleteRequest to the indexer to prepare for sending requests to Elasticsearch.
add(IndexRequest...) - Method in interface org.apache.flink.connector.elasticsearch.sink.RequestIndexer
Add multiple IndexRequest to the indexer to prepare for sending requests to Elasticsearch.
add(UpdateRequest...) - Method in interface org.apache.flink.connector.elasticsearch.sink.RequestIndexer
Add multiple UpdateRequest to the indexer to prepare for sending requests to Elasticsearch.
add(T) - Method in class org.apache.flink.connector.file.src.util.Pool
Adds an entry to the pool with an optional payload.
add(long, int) - Method in class org.apache.flink.connector.file.table.stream.TaskTracker
 
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(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 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(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
Deprecated.
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
Deprecated.
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
Deprecated.
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(TablePipeline) - Method in class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
 
add(TablePipeline) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
 
add(T) - Method in class org.apache.flink.table.api.dataview.ListView
Adds the given value to the list.
add(TablePipeline) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
 
add(TablePipeline) - Method in interface org.apache.flink.table.api.StatementSet
add(TableColumn) - Method in class org.apache.flink.table.api.TableSchema.Builder
Deprecated.
Adds a TableColumn to this builder.
ADD - Static variable in class org.apache.flink.table.codesplit.JavaLexer
 
ADD - Static variable in class org.apache.flink.table.codesplit.JavaLexer
 
ADD - Static variable in class org.apache.flink.table.codesplit.JavaParser
 
ADD - Static variable in class org.apache.flink.table.codesplit.JavaParser
 
add(DecimalData, DecimalData, int, int) - Static method in class org.apache.flink.table.data.DecimalDataUtils
 
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(W, RowData) - Method in class org.apache.flink.table.runtime.operators.window.state.WindowListState
Updates the operator state accessible by #get(W))} by adding the given value to the list of values.
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(T) - Method in class org.apache.flink.testutils.junit.SharedObjects
Adds a new object to this SharedObjects.
add(T) - Method in class org.apache.flink.testutils.junit.SharedObjectsExtension
Adds a new object to this SharedObjects.
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_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaLexer
 
ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaLexer
 
ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaParser
 
ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaParser
 
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_partition(Partition) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
add_partition(Partition, EnvironmentContext) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
add_partitions(List<Partition>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
 
add_partitions(List<Partition>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
add_partitions(List<Partition>, boolean, boolean) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
add_partitions_pspec(PartitionSpecProxy) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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;
addAllStrategies(Iterable<? extends FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
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.test.util.JobSubmission.JobSubmissionBuilder
Adds a program argument.
addArgument(String, String) - Method in class org.apache.flink.test.util.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
 
addAsyncOptionsToBuilder(Properties, AsyncDynamicTableSinkBuilder<?, ?>) - Method in class org.apache.flink.connector.base.table.AsyncDynamicTableSinkFactory
 
addAsyncOptionsToSinkBuilder(AsyncSinkBaseBuilder<?, RequestEntryT, ?>) - Method in class org.apache.flink.connector.base.table.sink.AsyncDynamicTableSink
 
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
 
addBinaryLengthConstraint(ExecutionConfigOptions.TypeLengthEnforcer, List<ConstraintEnforcer.FieldInfo>, List<String>, String[]) - Method in class org.apache.flink.table.runtime.operators.sink.ConstraintEnforcer.Builder
 
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
 
AddBoolBeforeReturnRewriter - Class in org.apache.flink.table.codesplit
A helper class of FunctionSplitter.
AddBoolBeforeReturnRewriter(String, int) - Constructor for class org.apache.flink.table.codesplit.AddBoolBeforeReturnRewriter
 
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.
addBuffers(List<HsFileDataIndex.SpilledBuffer>) - Method in interface org.apache.flink.runtime.io.network.partition.hybrid.HsFileDataIndex
Add buffers to the index.
addBuffers(List<HsFileDataIndex.SpilledBuffer>) - Method in class org.apache.flink.runtime.io.network.partition.hybrid.HsFileDataIndexImpl
 
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.
addCharLengthConstraint(ExecutionConfigOptions.TypeLengthEnforcer, List<ConstraintEnforcer.FieldInfo>, List<String>, String[]) - Method in class org.apache.flink.table.runtime.operators.sink.ConstraintEnforcer.Builder
 
addCheckConstraint(List<SQLCheckConstraint>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in interface org.apache.flink.runtime.checkpoint.CompletedCheckpointStore
Adds a CompletedCheckpoint instance to the list of completed checkpoints.
addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in enum org.apache.flink.runtime.checkpoint.DeactivatedCheckpointCompletedCheckpointStore
 
addCheckpointAndSubsumeOldestOne(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.
addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.EmbeddedCompletedCheckpointStore
 
addCheckpointAndSubsumeOldestOne(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
 
addClosedBranch(OptimizerNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
addClosedBranches(Set<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
addCollectSink(DataStream<T>) - Method in class org.apache.flink.connector.testframe.testsuites.SinkTestSuiteBase
 
addCollectSink(DataStream<T>) - Method in class org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase
Add a collect sink in the job.
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(Expression...) - Method in class org.apache.flink.table.api.internal.TableImpl
 
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 application-specific 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
 
addConvertedNonCorrSubqs(Map<SqlNode, RexNode>) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter
Adds to the current map of non-correlated converted sub-queries the elements from another map that contains non-correlated sub-queries that have been converted by another SqlToRelConverter.
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.
addDefaultConstraint(List<SQLDefaultConstraint>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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
 
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
 
addDeprecatedKeys(Set<ConfigOption<?>>) - Static method in class org.apache.flink.connector.kinesis.table.util.KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper
 
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.
addDynamicPartitions(long, long, String, String, List<String>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
Deprecated.
addDynamicPartitions(long, long, String, String, List<String>, DataOperationType) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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
 
addEdge(Integer, Integer, int, IntermediateDataSetID) - 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.
addEntropy(FileSystem, Path) - Static method in class org.apache.flink.core.fs.EntropyInjector
Handles entropy injection across regular and entropy-aware file systems.
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.
addForeignKey(List<SQLForeignKey>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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
 
addGlobalCommitter(DataStream<CommittableMessage<CommT>>, SerializableSupplier<Committer<CommT>>, SerializableSupplier<SimpleVersionedSerializer<CommT>>) - Static method in class org.apache.flink.streaming.api.connector.sink2.StandardSinkTopologies
Adds a global committer to the pipeline that runs as final operator with a parallelism of one.
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
 
addGroupExpr(SqlNode) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter.AggConverter
 
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(RowData, RowData) - Method in class org.apache.flink.table.runtime.operators.deduplicate.RowTimeMiniBatchLatestChangeDeduplicateFunction
 
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 class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
 
addInsert(String, Table, boolean) - Method in class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
 
addInsert(TableDescriptor, Table) - Method in class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
 
addInsert(TableDescriptor, Table, boolean) - Method in class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
 
addInsert(String, Table) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
 
addInsert(String, Table, boolean) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
 
addInsert(TableDescriptor, Table) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
 
addInsert(TableDescriptor, Table, boolean) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
 
addInsert(String, Table) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
 
addInsert(String, Table, boolean) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
 
addInsert(TableDescriptor, Table) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
 
addInsert(TableDescriptor, Table, boolean) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
 
addInsert(String, Table) - Method in interface org.apache.flink.table.api.StatementSet
Shorthand for statementSet.add(table.insertInto(targetPath)).
addInsert(String, Table, boolean) - Method in interface org.apache.flink.table.api.StatementSet
Shorthand for statementSet.add(table.insertInto(targetPath, overwrite)).
addInsert(TableDescriptor, Table) - Method in interface org.apache.flink.table.api.StatementSet
Shorthand for statementSet.add(table.insertInto(targetDescriptor)).
addInsert(TableDescriptor, Table, boolean) - Method in interface org.apache.flink.table.api.StatementSet
Shorthand for statementSet.add(table.insertInto(targetDescriptor, overwrite)).
addInsertIntoTable(String, HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
 
addInsertSql(String) - Method in class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
 
addInsertSql(String) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
 
addInsertSql(String) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
 
addInsertSql(String) - Method in interface org.apache.flink.table.api.StatementSet
Adds an INSERT INTO SQL statement.
addInterestingProperties(InterestingProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
addIntermediateDataSetIdToConsume(IntermediateDataSetID) - Method in class org.apache.flink.runtime.jobgraph.JobVertex
 
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
 
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.test.util.SQLJobSubmission.SQLJobSubmissionBuilder
 
addJar(Path, JarLocation) - Method in class org.apache.flink.tests.util.flink.FlinkResourceSetup.FlinkResourceSetupBuilder
 
addJarConfiguration(TableConfig) - Method in class org.apache.flink.table.resource.ResourceManager
Adds the local jar resources to the given TableConfig.
AddJarOperation - Class in org.apache.flink.table.operations.command
Operation to describe an ADD JAR statement.
AddJarOperation(String) - Constructor for class org.apache.flink.table.operations.command.AddJarOperation
 
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.test.util.SQLJobSubmission.SQLJobSubmissionBuilder
 
addJars(List<Path>) - Method in class org.apache.flink.test.util.SQLJobSubmission.SQLJobSubmissionBuilder
 
addJob(JobID, String) - Method in class org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup
 
addJob(JobID, String) - Method in class org.apache.flink.runtime.metrics.groups.TaskManagerMetricGroup
 
addJob(JobID, String) - 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.
addMasterKey(String) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
addMessage(CommittableMessage<CommT>) - Method in class org.apache.flink.streaming.runtime.operators.sink.committables.CommittableCollector
Adds a CommittableMessage to the collector to hold it until emission.
addMetric(String, Metric, AbstractMetricGroup) - Method in class org.apache.flink.runtime.metrics.dump.MetricQueryService
 
addMetric(String, Metric) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
Adds the given metric to the group and registers it at the registry, if the group is not yet closed, and if no metric with the same name has been registered before.
addMonths(long, int) - Static method in class org.apache.flink.table.utils.DateTimeUtils
Adds a given number of months to a timestamp, represented as the number of milliseconds since the epoch.
addMonths(int, int) - Static method in class org.apache.flink.table.utils.DateTimeUtils
Adds a given number of months to a date, represented as the number of days since the epoch.
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.
addNewBlockedNodes(Collection<BlockedNode>) - Method in interface org.apache.flink.runtime.blocklist.BlocklistHandler
Add new blocked node records.
addNewBlockedNodes(Collection<BlockedNode>) - Method in interface org.apache.flink.runtime.blocklist.BlocklistOperations
Add new blocked node records.
addNewBlockedNodes(Collection<BlockedNode>) - Method in interface org.apache.flink.runtime.blocklist.BlocklistTracker
Add new blocked node records.
addNewBlockedNodes(Collection<BlockedNode>) - Method in class org.apache.flink.runtime.blocklist.DefaultBlocklistHandler
 
addNewBlockedNodes(Collection<BlockedNode>) - Method in class org.apache.flink.runtime.blocklist.DefaultBlocklistTracker
 
addNewBlockedNodes(Collection<BlockedNode>) - Method in class org.apache.flink.runtime.blocklist.NoOpBlocklistHandler
 
addNode(Integer, String, String, Class<? extends TaskInvokable>, StreamOperatorFactory<?>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addNotNullConstraint(ExecutionConfigOptions.NotNullEnforcer, int[], List<String>, String[]) - Method in class org.apache.flink.table.runtime.operators.sink.ConstraintEnforcer.Builder
 
addNotNullConstraint(List<SQLNotNullConstraint>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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.
addOperationRelatedHandlers(List<Tuple2<RestHandlerSpecification, ChannelInboundHandler>>) - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint
 
addOperator(String, BootstrapTransformation<?>) - Method in class org.apache.flink.state.api.runtime.metadata.SavepointMetadata
Deprecated.
 
addOperator(String, StateBootstrapTransformation<?>) - Method in class org.apache.flink.state.api.runtime.metadata.SavepointMetadataV2
 
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
 
AddOrModifyColumn(SqlAlterTable.AlterTableContext) - Method in class org.apache.flink.sql.parser.impl.FlinkSqlParserImpl
Parses ADD/MODIFY column_name column_data_type [...].
addOrReplaceColumns(Expression...) - Method in class org.apache.flink.table.api.internal.TableImpl
 
addOrReplaceColumns(Expression...) - Method in interface org.apache.flink.table.api.Table
Adds additional columns.
addOrUpdate(StateDescriptor<S, T>) - Method in class org.apache.flink.state.changelog.restore.FunctionDelegationHelper
 
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
 
addOutputDataFuture(long, ResultSubpartitionInfo, int, CompletableFuture<List<Buffer>>) - Method in interface org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter
Add in-flight bufferFuture from the ResultSubpartition.
addOutputDataFuture(long, ResultSubpartitionInfo, int, CompletableFuture<List<Buffer>>) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter.NoOpChannelStateWriter
 
addOutputDataFuture(long, ResultSubpartitionInfo, int, CompletableFuture<List<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
 
addPartialBuffer(Buffer) - Method in class org.apache.flink.runtime.io.network.buffer.CompositeBuffer
 
addPartition(String) - Method in interface org.apache.flink.connector.file.table.stream.PartitionCommitTrigger
Add a pending partition.
addPartition(String) - Method in class org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger
 
addPartition(String) - Method in class org.apache.flink.connector.file.table.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
 
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
 
addPostCommitTopology(DataStream<CommittableMessage<CommT>>) - Method in interface org.apache.flink.streaming.api.connector.sink2.WithPostCommitTopology
Adds a custom post-commit topology where all committables can be processed.
addPreCommitTopology(DataStream<CommittableMessage<FileSinkCommittable>>) - Method in class org.apache.flink.connector.file.sink.FileSink
 
addPreCommitTopology(DataStream<CommittableMessage<CommT>>) - Method in interface org.apache.flink.streaming.api.connector.sink2.WithPreCommitTopology
Intercepts and modifies the committables sent on checkpoint or at end of input.
addPreWriteTopology(DataStream<InputT>) - Method in interface org.apache.flink.streaming.api.connector.sink2.WithPreWriteTopology
Adds an arbitrary topology before the writer.
addPrimaryKey(List<SQLPrimaryKey>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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
 
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.DynamicFileSplitEnumerator
 
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.connector.pulsar.source.enumerator.PulsarSourceEnumerator
 
addReader(int) - Method in class org.apache.flink.connector.testframe.source.enumerator.NoOpEnumerator
 
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.
addRecovered(BufferConsumer) - Method in interface org.apache.flink.runtime.io.network.partition.CheckpointedResultSubpartition
 
addRecovered(BufferConsumer) - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition
 
addRelBuilderConfigTransform(UnaryOperator<RelBuilder.Config>) - Method in interface org.apache.calcite.sql2rel.SqlToRelConverter.Config
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RawType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RowType.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.StateDescriptor.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.RocksdbCompactFilterCleanupStrategy.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.AvroTypeInfo.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 - Static variable in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions
The address that should be used by clients to connect to the sql gateway server.
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
 
AddressResolution - Enum in org.apache.flink.runtime.rpc
Enum specifying whether address resolution should be tried.
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
 
addRuntimeStat(RuntimeStat) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
addSchemaVersion(SchemaVersion) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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.
addSerDe(SerDeInfo) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
addSessionConfig(Map<String, String>) - Method in class org.apache.flink.table.gateway.api.session.SessionEnvironment.Builder
 
addShipFiles(List<File>) - Method in class org.apache.flink.yarn.YarnClusterDescriptor
Adds the given files to the list of files to ship.
addShuffleDescriptors(Map<ResultPartitionID, ShuffleDescriptor>) - Method in class org.apache.flink.runtime.io.network.partition.DataSetMetaInfo
 
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.
addSideOutputTags(Collection<OutputTag<?>>) - Method in interface org.apache.flink.streaming.api.operators.python.DataStreamPythonFunctionOperator
Add a collection of OutputTags to the operator.
addSideOutputTags(Collection<OutputTag<?>>) - Method in class org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedDataStreamPythonFunctionOperator
 
addSideOutputTags(Collection<OutputTag<?>>) - Method in class org.apache.flink.streaming.api.operators.python.process.AbstractExternalDataStreamPythonFunctionOperator
 
addSideOutputTags(Collection<OutputTag<?>>) - Method in class org.apache.flink.streaming.api.transformations.python.DelegateOperatorTransformation.DelegateOperator
 
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
 
addSplits(List<PulsarPartitionSplit>) - Method in class org.apache.flink.connector.pulsar.source.reader.fetcher.PulsarFetcherManagerBase
Override this method for supporting multiple thread fetching, one fetcher thread for one split.
addSplits(List<PulsarPartitionSplit>) - Method in class org.apache.flink.connector.pulsar.source.reader.source.PulsarUnorderedSourceReader
 
addSplits(List<FromElementsSplit>) - Method in class org.apache.flink.connector.testframe.source.FromElementsSourceReader
 
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<SplitT>, int) - Method in class org.apache.flink.connector.file.src.impl.DynamicFileSplitEnumerator
 
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<PulsarPartitionSplit>, int) - Method in class org.apache.flink.connector.pulsar.source.enumerator.assigner.KeySharedSplitAssigner
 
addSplitsBack(List<PulsarPartitionSplit>, int) - Method in interface org.apache.flink.connector.pulsar.source.enumerator.assigner.SplitAssigner
Add a split back to the split assigner if the reader fails.
addSplitsBack(List<PulsarPartitionSplit>, int) - Method in class org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumerator
 
addSplitsBack(List<FromElementsSplit>, int) - Method in class org.apache.flink.connector.testframe.source.enumerator.NoOpEnumerator
 
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
 
addStrategies(FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
addStrategies(int, FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
addStrategies(FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
addStrategies(int, FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
addStrategiesBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
addStrategiesBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
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
 
addSubsumedCheckpoint(CompletedCheckpoint) - Method in class org.apache.flink.runtime.checkpoint.CheckpointsCleaner
Add one subsumed checkpoint to CheckpointsCleaner, the subsumed checkpoint would be discarded at CheckpointsCleaner.cleanSubsumedCheckpoints(long, Set, Runnable, Executor).
addTableNameTranslation(HiveParserASTNode, String, 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(ExecutionAttemptID, String) - Method in class org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup
 
addTask(ExecutionAttemptID, String) - 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
 
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.JdbcOutputFormat
 
addToCompact(FileSinkCommittable) - Method in class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest
 
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
 
addToken(String, String) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
addToMessageDigest(MessageDigest) - Method in class org.apache.flink.runtime.blob.BlobKey
Adds the BLOB key to the given MessageDigest.
addToPassthrough(FileSinkCommittable) - Method in class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest
 
addToRestrictList(String) - Method in class org.apache.hadoop.hive.conf.HiveConf
Append comma separated list of config vars to the restrict List
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
 
addUniqueConstraint(List<SQLUniqueConstraint>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
 
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.
addURL(URL) - Method in class org.apache.flink.util.FlinkUserCodeClassLoaders.SafetyNetWrapperClassLoader
 
addURL(URL) - Method in class org.apache.flink.util.MutableURLClassLoader
 
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.
addUtilRelatedHandlers(List<Tuple2<RestHandlerSpecification, ChannelInboundHandler>>) - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint
 
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<?>, StreamExchangeMode) - 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.
adjustedMinus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction
 
adjustedMinus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction
 
adjustedMinus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction
 
adjustedMinus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.DecimalSum0AggFunction
 
adjustedMinus(Expression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction
 
adjustedMinus(Expression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.Sum0AggFunction.DecimalSum0AggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumAggFunction.DecimalSumAggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction
 
adjustedPlus(UnresolvedReferenceExpression, UnresolvedReferenceExpression) - Method in class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction
 
adjustForLocalExecution(Configuration) - Static method in class org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils
 
adjustGlobalPropertiesForFullParallelismChange() - Method in class org.apache.flink.optimizer.plan.Channel
 
adjustInputRef(SqlToRelConverter.Blackboard, RexInputRef) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter
Adjusts the type of a reference to an input field to account for nulls introduced by outer joins; and adjusts the offset to match the physical implementation.
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.
adjustTypeForArrayConstructor(RelDataType, SqlOperatorBinding) - Static method in class org.apache.flink.table.planner.functions.utils.SqlValidatorUtils
 
adjustTypeForMapConstructor(Pair<RelDataType, RelDataType>, SqlOperatorBinding) - Static method in class org.apache.flink.table.planner.functions.utils.SqlValidatorUtils
 
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
 
ADMIN_CONFIG_PREFIX - Static variable in class org.apache.flink.connector.pulsar.common.config.PulsarOptions
 
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.
advance(long) - Method in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService
 
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.deduplicate.window.processors.RowTimeWindowDeduplicateProcessor
 
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, AfterMatchSkipStrategy) - 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.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(ExtensionContext) - Method in interface org.apache.flink.core.testutils.CustomExtension
 
after(ExtensionContext) - Method in class org.apache.flink.core.testutils.TestContainerExtension
 
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.test.util.MiniClusterWithClientResource
 
after() - Method in class org.apache.flink.testutils.executor.TestExecutorResource
 
after() - Method in class org.apache.flink.testutils.junit.SharedObjects
 
after() - Method in class org.apache.flink.testutils.logging.TestLoggerResource
 
after() - Method in class org.apache.flink.util.LogLevelRule
 
afterAll(ExtensionContext) - Method in class org.apache.flink.connector.testframe.container.FlinkContainers
 
afterAll(ExtensionContext) - Method in class org.apache.flink.connector.testframe.junit.extensions.ConnectorTestingExtension
 
afterAll(ExtensionContext) - Method in class org.apache.flink.core.testutils.AllCallbackWrapper
 
afterAll(ExtensionContext) - Method in class org.apache.flink.test.junit5.MiniClusterExtension
 
afterAll(ExtensionContext) - Method in class org.apache.flink.testutils.executor.TestExecutorExtension
 
afterAll(ExtensionContext) - Method in class org.apache.flink.testutils.junit.extensions.ContextClassLoaderExtension
 
afterAll(ExtensionContext) - Method in class org.apache.flink.testutils.junit.extensions.retry.RetryExtension
 
afterAll(ExtensionContext) - Method in class org.apache.flink.util.LogLevelExtension
 
afterCreatingConsumer(PulsarPartitionSplit, Consumer<byte[]>) - Method in class org.apache.flink.connector.pulsar.source.reader.split.PulsarUnorderedPartitionSplitReader
 
afterEach(ExtensionContext) - Method in class org.apache.flink.core.testutils.EachCallbackWrapper
 
afterEach(ExtensionContext) - Method in class org.apache.flink.test.junit5.MiniClusterExtension
 
afterEach(ExtensionContext) - Method in class org.apache.flink.testutils.junit.extensions.retry.RetryTestExecutionExtension
 
afterEach(ExtensionContext) - Method in class org.apache.flink.testutils.junit.SharedObjectsExtension
 
afterEach(ExtensionContext) - Method in class org.apache.flink.testutils.logging.LoggerAuditingExtension
 
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
 
afterEventTime(long) - Static method in interface org.apache.flink.connector.pulsar.source.enumerator.cursor.StopCursor
Stop consuming when message eventTime is greater than the specified timestamp.
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.StreamTask
 
AfterMatchSkipStrategy - Class in org.apache.flink.cep.nfa.aftermatch
Indicate the skip strategy after a match process.
afterMessageId(MessageId) - Static method in interface org.apache.flink.connector.pulsar.source.enumerator.cursor.StopCursor
Stop consuming when the messageId is greater than the specified messageId.
afterPublishTime(long) - Static method in interface org.apache.flink.connector.pulsar.source.enumerator.cursor.StopCursor
Stop consuming when message publishTime is greater than the specified timestamp.
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
 
afterTableFunction(SqlToRelConverter.Blackboard, SqlCall, LogicalTableFunctionScan) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter
 
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
 
AGG_DECIMAL_MINUS - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
Special "-" operator used internally for implementing SUM/AVG aggregations (with and without retractions) on a Decimal type.
AGG_DECIMAL_PLUS - Static variable in class org.apache.flink.table.functions.BuiltInFunctionDefinitions
Special "+" operator used internally for implementing SUM/AVG aggregations (with and without retractions) on a Decimal type.
AGG_DECIMAL_PLUS - Static variable in class org.apache.flink.table.types.inference.strategies.SpecificTypeStrategies
See AggDecimalPlusTypeStrategy.
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.CumeDistAggFunction
 
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.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.NTILEAggFunction
 
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
 
aggCalls - Variable i