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

Use AbstractDeserializationSchema instead.

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

Factory for AbstractDispatcherLeaderProcess.DispatcherGatewayService.

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

MessageHeaders for AbstractMetricsHandler.

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

Base class for AbstractPythonStreamGroupAggregateOperator and PythonStreamGroupWindowAggregateOperator.

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

Base class for PythonStreamGroupAggregateOperator and PythonStreamGroupTableAggregateOperator.

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

Factory for AdaptiveBatchScheduler.

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

Adds a TablePipeline.

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

See Double.equals(Object).

add(float) - Method in class org.apache.flink.table.runtime.util.collections.FloatHashSet

See Float.equals(Object).

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

Deprecated.

use Configuration.addDeprecation(String key, String newKey, String customMessage) instead

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

Deprecated.

use Configuration.addDeprecation(String key, String newKey) instead

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

Adds a transform to SqlToRelConverter.Config.getRelBuilderConfigTransform().

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