- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- AbstractColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader
-
- AbstractCompleteCheckpointStore - Class in org.apache.flink.runtime.checkpoint
-
- 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
-
- 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
-
- AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory - Interface in org.apache.flink.runtime.dispatcher.runner
-
- AbstractDispatcherLeaderProcess.State - Enum in org.apache.flink.runtime.dispatcher.runner
-
The state of the DispatcherLeaderProcess
.
- AbstractEmbeddedDataStreamPythonFunctionOperator<OUT> - Class in org.apache.flink.streaming.api.operators.python.embedded
-
Base class for all Python DataStream operators executed in embedded Python environment.
- AbstractEmbeddedDataStreamPythonFunctionOperator(Configuration, DataStreamPythonFunctionInfo, TypeInformation<OUT>) - Constructor for class org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedDataStreamPythonFunctionOperator
-
- AbstractEmbeddedPythonFunctionOperator<OUT> - Class in org.apache.flink.streaming.api.operators.python.embedded
-
Abstract class for all stream operators to execute Python functions in embedded Python
environment.
- AbstractEmbeddedPythonFunctionOperator(Configuration) - Constructor for class org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedPythonFunctionOperator
-
- AbstractEmbeddedStatelessFunctionOperator - Class in org.apache.flink.table.runtime.operators.python
-
Base class for all stream operators to execute Python Stateless Functions in embedded Python
environment.
- AbstractEmbeddedStatelessFunctionOperator(Configuration, RowType, RowType, RowType, int[]) - Constructor for class org.apache.flink.table.runtime.operators.python.AbstractEmbeddedStatelessFunctionOperator
-
- AbstractEvent - Class in org.apache.flink.runtime.event
-
This type of event can be used to exchange notification messages between different
TaskExecutor
objects at runtime using the communication channels.
- AbstractEvent() - Constructor for class org.apache.flink.runtime.event.AbstractEvent
-
- AbstractExecNodeExactlyOnceVisitor - Class in org.apache.flink.table.planner.plan.nodes.exec.visitor
-
- 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
-
- 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(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(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
-
- 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
-
- AbstractInput(AbstractStreamOperatorV2<OUT>, int) - Constructor for class org.apache.flink.streaming.api.operators.AbstractInput
-
- AbstractInvokable - Class in org.apache.flink.runtime.jobgraph.tasks
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- AbstractKubernetesParameters(Configuration) - Constructor for class org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters
-
- AbstractKubernetesStepDecorator - Class in org.apache.flink.kubernetes.kubeclient.decorators
-
- 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
-
- AbstractMergeInnerJoinIterator<T1,T2,O> - Class in org.apache.flink.runtime.operators.sort
-
An implementation of the
JoinTaskIterator
that
realizes the joining through a sort-merge join strategy.
- AbstractMergeInnerJoinIterator(MutableObjectIterator<T1>, MutableObjectIterator<T2>, TypeSerializer<T1>, TypeComparator<T1>, TypeSerializer<T2>, TypeComparator<T2>, TypePairComparator<T1, T2>, MemoryManager, IOManager, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.sort.AbstractMergeInnerJoinIterator
-
- AbstractMergeIterator<T1,T2,O> - Class in org.apache.flink.runtime.operators.sort
-
- AbstractMergeIterator(MutableObjectIterator<T1>, MutableObjectIterator<T2>, TypeSerializer<T1>, TypeComparator<T1>, TypeSerializer<T2>, TypeComparator<T2>, TypePairComparator<T1, T2>, MemoryManager, IOManager, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.sort.AbstractMergeIterator
-
- AbstractMergeOuterJoinIterator<T1,T2,O> - Class in org.apache.flink.runtime.operators.sort
-
An implementation of the
JoinTaskIterator
that
realizes the outer join through a sort-merge join strategy.
- AbstractMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType, MutableObjectIterator<T1>, MutableObjectIterator<T2>, TypeSerializer<T1>, TypeComparator<T1>, TypeSerializer<T2>, TypeComparator<T2>, TypePairComparator<T1, T2>, MemoryManager, IOManager, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.sort.AbstractMergeOuterJoinIterator
-
- AbstractMetricGroup<A extends AbstractMetricGroup<?>> - Class in org.apache.flink.runtime.metrics.groups
-
Abstract
MetricGroup
that contains key functionality for adding metrics and groups.
- AbstractMetricGroup(MetricRegistry, String[], A) - Constructor for class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
-
- AbstractMetricGroup.ChildType - Enum in org.apache.flink.runtime.metrics.groups
-
Enum for indicating which child group should be created.
- AbstractMetricsHandler<M extends MessageParameters> - Class in org.apache.flink.runtime.rest.handler.job.metrics
-
Request handler that returns for a given task a list of all available metrics or the values for a
set of metrics.
- AbstractMetricsHandler(GatewayRetriever<? extends RestfulGateway>, Time, Map<String, String>, MessageHeaders<EmptyRequestBody, MetricCollectionResponseBody, M>, MetricFetcher) - Constructor for class org.apache.flink.runtime.rest.handler.job.metrics.AbstractMetricsHandler
-
- AbstractMetricsHeaders<M extends MessageParameters> - Class in org.apache.flink.runtime.rest.messages.job.metrics
-
- AbstractMetricsHeaders() - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.AbstractMetricsHeaders
-
- AbstractMultipleInputTransformation<OUT> - Class in org.apache.flink.streaming.api.transformations
-
- 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(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
-
- 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
-
- 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
ScalarFunction
s.
- AbstractPythonScalarFunctionOperator(Configuration, PythonFunctionInfo[], RowType, RowType, RowType, GeneratedProjection, GeneratedProjection) - Constructor for class org.apache.flink.table.runtime.operators.python.scalar.AbstractPythonScalarFunctionOperator
-
- AbstractPythonStreamAggregateOperator - Class in org.apache.flink.table.runtime.operators.python.aggregate
-
- AbstractPythonStreamAggregateOperator(Configuration, RowType, RowType, PythonAggregateFunctionInfo[], DataViewSpec[][], int[], int, boolean) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.AbstractPythonStreamAggregateOperator
-
- AbstractPythonStreamGroupAggregateOperator - Class in org.apache.flink.table.runtime.operators.python.aggregate
-
- AbstractPythonStreamGroupAggregateOperator(Configuration, RowType, RowType, PythonAggregateFunctionInfo[], DataViewSpec[][], int[], int, boolean, long, long) - Constructor for class org.apache.flink.table.runtime.operators.python.aggregate.AbstractPythonStreamGroupAggregateOperator
-
- AbstractReader - Class in org.apache.flink.runtime.io.network.api.reader
-
A basic reader implementation, which wraps an input gate and handles events.
- AbstractReader(InputGate) - Constructor for class org.apache.flink.runtime.io.network.api.reader.AbstractReader
-
- AbstractRegexParseStrategy - Class in org.apache.flink.table.planner.parse
-
Strategy to parse statement to
Operation
by regex.
- AbstractRegexParseStrategy(Pattern) - Constructor for class org.apache.flink.table.planner.parse.AbstractRegexParseStrategy
-
- AbstractReporter - Class in org.apache.flink.metrics.reporter
-
Base interface for custom metric reporters.
- AbstractReporter() - Constructor for class org.apache.flink.metrics.reporter.AbstractReporter
-
- AbstractResourceManagerDriver<WorkerType extends ResourceIDRetrievable> - Class in org.apache.flink.runtime.resourcemanager.active
-
- 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
-
- 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
-
- 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
-
- AbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody> - Class in org.apache.flink.queryablestate.network
-
- 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
-
- 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
-
- 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
-
- 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
-
- AbstractStreamingJoinOperator.OuterRecord - Class in org.apache.flink.table.runtime.operators.join.stream
-
- 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
-
- 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
-
- 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
-
- 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
-
- AbstractTableInputFormat(Configuration) - Constructor for class org.apache.flink.connector.hbase1.source.AbstractTableInputFormat
-
- AbstractTableInputFormat<T> - Class in org.apache.flink.connector.hbase2.source
-
- 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
-
- 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(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
-
- 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
-
- 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
-
- 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
ColumnVector
s, 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
-
- 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
-
- 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
-
- AccessExecutionGraph - Interface in org.apache.flink.runtime.executiongraph
-
- AccessExecutionJobVertex - Interface in org.apache.flink.runtime.executiongraph
-
- AccessExecutionVertex - Interface in org.apache.flink.runtime.executiongraph
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- ActiveResourceManagerFactory() - Constructor for class org.apache.flink.runtime.resourcemanager.active.ActiveResourceManagerFactory
-
- ActorSystemScheduledExecutorAdapter - Class in org.apache.flink.runtime.concurrent.akka
-
- 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
-
- AdamicAdar() - Constructor for class org.apache.flink.graph.drivers.AdamicAdar
-
- AdamicAdar<K extends CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.similarity
-
http://social.cs.uiuc.edu/class/cs591kgk/friendsadamic.pdf
- AdamicAdar() - Constructor for class org.apache.flink.graph.library.similarity.AdamicAdar
-
- AdamicAdar.Result<T> - Class in org.apache.flink.graph.library.similarity
-
A result for the Adamic-Adar algorithm.
- adaptArguments(TypeInference, CallContext, DataType) - Static method in class org.apache.flink.table.types.inference.TypeInferenceUtil
-
Adapts the call's argument if necessary.
- AdaptedCallContext - Class in org.apache.flink.table.types.inference.utils
-
Helper context that deals with adapted arguments.
- AdaptedCallContext(CallContext, DataType) - Constructor for class org.apache.flink.table.types.inference.utils.AdaptedCallContext
-
- adapterForIterator(Iterator<T>) - Static method in interface org.apache.flink.util.CloseableIterator
-
- adapterForIterator(Iterator<T>, AutoCloseable) - Static method in interface org.apache.flink.util.CloseableIterator
-
- ADAPTIVE_BATCH_SCHEDULER_AVG_DATA_VOLUME_PER_TASK - Static variable in class org.apache.flink.configuration.JobManagerOptions
-
- ADAPTIVE_BATCH_SCHEDULER_DEFAULT_SOURCE_PARALLELISM - Static variable in class org.apache.flink.configuration.JobManagerOptions
-
- ADAPTIVE_BATCH_SCHEDULER_MAX_PARALLELISM - Static variable in class org.apache.flink.configuration.JobManagerOptions
-
- ADAPTIVE_BATCH_SCHEDULER_MIN_PARALLELISM - Static variable in class org.apache.flink.configuration.JobManagerOptions
-
- AdaptiveBatchScheduler - Class in org.apache.flink.runtime.scheduler.adaptivebatch
-
This scheduler decides the parallelism of JobVertex according to the data volume it consumes.
- AdaptiveBatchScheduler(Logger, JobGraph, Executor, Configuration, Consumer<ComponentMainThreadExecutor>, ScheduledExecutor, ClassLoader, CheckpointsCleaner, CheckpointRecoveryFactory, JobManagerJobMetricGroup, SchedulingStrategyFactory, FailoverStrategy.Factory, RestartBackoffTimeStrategy, ExecutionOperations, ExecutionVertexVersioner, ExecutionSlotAllocatorFactory, long, ComponentMainThreadExecutor, JobStatusListener, ExecutionGraphFactory, ShuffleMaster<?>, Time, VertexParallelismDecider, int) - Constructor for class org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler
-
- AdaptiveBatchSchedulerFactory - Class in org.apache.flink.runtime.scheduler.adaptivebatch
-
- AdaptiveBatchSchedulerFactory() - Constructor for class org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchSchedulerFactory
-
- AdaptivePollingRecordPublisher - Class in org.apache.flink.streaming.connectors.kinesis.internals.publisher.polling
-
- 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
-
- add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleCounter
-
- add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleMaximum
-
- add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleMaximum
-
- add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleMinimum
-
- 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
-
- add(int) - Method in class org.apache.flink.api.common.accumulators.IntCounter
-
- add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntMaximum
-
- add(int) - Method in class org.apache.flink.api.common.accumulators.IntMaximum
-
- add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntMinimum
-
- 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
-
- add(long) - Method in class org.apache.flink.api.common.accumulators.LongCounter
-
- add(Long) - Method in class org.apache.flink.api.common.accumulators.LongMaximum
-
- add(long) - Method in class org.apache.flink.api.common.accumulators.LongMaximum
-
- add(Long) - Method in class org.apache.flink.api.common.accumulators.LongMinimum
-
- 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
-
- add(DeleteRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
-
Deprecated.
Add multiple DeleteRequest
to the indexer to prepare for sending requests to
Elasticsearch.
- add(IndexRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
-
Deprecated.
Add multiple IndexRequest
to the indexer to prepare for sending requests to
Elasticsearch.
- add(UpdateRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
-
Deprecated.
Add multiple UpdateRequest
to the indexer to prepare for sending requests to
Elasticsearch.
- add(E) - Method in class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
-
Adds the element to the queue, or fails with an exception, if the queue is closed.
- add(TablePipeline) - Method in class org.apache.flink.table.api.bridge.java.internal.StreamStatementSetImpl
-
- add(TablePipeline) - Method in interface org.apache.flink.table.api.bridge.java.StreamStatementSet
-
- add(T) - Method in class org.apache.flink.table.api.dataview.ListView
-
Adds the given value to the list.
- add(TablePipeline) - Method in class org.apache.flink.table.api.internal.StatementSetImpl
-
- add(TablePipeline) - Method in interface org.apache.flink.table.api.StatementSet
-
- add(TableColumn) - Method in class org.apache.flink.table.api.TableSchema.Builder
-
Deprecated.
- ADD - Static variable in class org.apache.flink.table.codesplit.JavaLexer
-
- ADD - Static variable in class org.apache.flink.table.codesplit.JavaLexer
-
- ADD - Static variable in class org.apache.flink.table.codesplit.JavaParser
-
- ADD - Static variable in class org.apache.flink.table.codesplit.JavaParser
-
- add(DecimalData, DecimalData, int, int) - Static method in class org.apache.flink.table.data.DecimalDataUtils
-
- add(int, String) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTBuilder
-
- add(HiveParserASTBuilder) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTBuilder
-
- add(HiveParserRowResolver, HiveParserRowResolver) - Static method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserRowResolver
-
- add(EE) - Method in class org.apache.flink.table.runtime.dataview.StateListView
-
- add(W, RowData) - Method in class org.apache.flink.table.runtime.operators.window.state.WindowListState
-
Updates the operator state accessible by #get(W)
)} by adding the given value to the
list of values.
- add(byte) - Method in class org.apache.flink.table.runtime.util.collections.ByteHashSet
-
- add(double) - Method in class org.apache.flink.table.runtime.util.collections.DoubleHashSet
-
- add(float) - Method in class org.apache.flink.table.runtime.util.collections.FloatHashSet
-
- add(int) - Method in class org.apache.flink.table.runtime.util.collections.IntHashSet
-
- add(long) - Method in class org.apache.flink.table.runtime.util.collections.LongHashSet
-
- add(T) - Method in class org.apache.flink.table.runtime.util.collections.ObjectHashSet
-
- add(short) - Method in class org.apache.flink.table.runtime.util.collections.ShortHashSet
-
- add(RowData) - Method in class org.apache.flink.table.runtime.util.ResettableExternalBuffer
-
- add(RowData) - Method in interface org.apache.flink.table.runtime.util.ResettableRowBuffer
-
Appends the specified row to the end of this buffer.
- add(T) - Method in class org.apache.flink.testutils.junit.SharedObjects
-
Adds a new object to this SharedObjects
.
- add(T) - Method in class org.apache.flink.testutils.junit.SharedObjectsExtension
-
Adds a new object to this SharedObjects
.
- add(int, V) - Method in class org.apache.flink.types.ListValue
-
- add(V) - Method in class org.apache.flink.types.ListValue
-
- add(Iterator<T>) - Method in class org.apache.flink.util.UnionIterator
-
- ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaLexer
-
- ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaLexer
-
- ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaParser
-
- ADD_ASSIGN - Static variable in class org.apache.flink.table.codesplit.JavaParser
-
- add_escapes(String) - Method in exception org.apache.flink.sql.parser.hive.impl.ParseException
-
Used to convert raw characters to their escaped version
when these raw version cannot be used as part of an ASCII
string literal.
- add_escapes(String) - Method in exception org.apache.flink.sql.parser.impl.ParseException
-
Used to convert raw characters to their escaped version
when these raw version cannot be used as part of an ASCII
string literal.
- add_partition(Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
-
- add_partition(Partition) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- add_partition(Partition, EnvironmentContext) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- add_partitions(List<Partition>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
-
- add_partitions(List<Partition>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- add_partitions(List<Partition>, boolean, boolean) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- add_partitions_pspec(PartitionSpecProxy) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- addAccumulator(String, Accumulator<V, A>) - Method in interface org.apache.flink.api.common.functions.RuntimeContext
-
Add this accumulator.
- addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext
-
- addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.graph.AnalyticHelper
-
Adds an accumulator by prepending the given name with a random string.
- addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.state.api.runtime.SavepointRuntimeContext
-
- addAcknowledgeId(ACKID) - Method in class org.apache.flink.streaming.connectors.gcp.pubsub.common.AcknowledgeOnCheckpoint
-
- addAggregationExprsForClause(String, LinkedHashMap<String, HiveParserASTNode>) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo
-
- addAlias(String) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQB
-
- addAll(AggregatorRegistry) - Method in class org.apache.flink.api.common.aggregators.AggregatorRegistry
-
- addAll(List<T>) - Method in interface org.apache.flink.api.common.state.ListState
-
Updates the operator state accessible by
AppendingState.get()
by adding the given values to
existing list of values.
- addAll(Configuration) - Method in class org.apache.flink.configuration.Configuration
-
- addAll(Configuration, String) - Method in class org.apache.flink.configuration.Configuration
-
Adds all entries from the given configuration into this configuration.
- addAll(Configuration) - Method in class org.apache.flink.configuration.DelegatingConfiguration
-
- addAll(Configuration, String) - Method in class org.apache.flink.configuration.DelegatingConfiguration
-
- addAll(Configuration) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
-
- addAll(Configuration, String) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
-
- addAll(String, Collection<E>) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
-
Add multiple records from the given split ID.
- addAll(SourceSplit, Collection<E>) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
-
Add multiple records from the given source split.
- addAll(Collection<? extends E>) - Method in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet
-
- addAll(ValueArray<ByteValue>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
-
- addAll(ValueArray<CharValue>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
-
- addAll(ValueArray<DoubleValue>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
-
- addAll(ValueArray<FloatValue>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
-
- addAll(ValueArray<IntValue>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
-
- addAll(ValueArray<LongValue>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
-
- addAll(ValueArray<NullValue>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
-
- addAll(ValueArray<ShortValue>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
-
- addAll(ValueArray<StringValue>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
-
- addAll(ValueArray<T>) - Method in interface org.apache.flink.graph.types.valuearray.ValueArray
-
Appends all of the values in the specified array to the end of this array.
- addAll(List<V>) - Method in class org.apache.flink.queryablestate.client.state.ImmutableListState
-
- addAll(Collection<? extends T>) - Method in class org.apache.flink.runtime.checkpoint.StateObjectCollection
-
- addAll(Collection<? extends T>) - Method in class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue
-
- addAll(Collection<? extends T>) - Method in class org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue
-
- addAll(List<T>) - Method in interface org.apache.flink.runtime.state.internal.InternalListState
-
Updates the operator state accessible by
AppendingState.get()
by adding the given values to
existing list of values.
- addAll(Collection<? extends T>) - Method in interface org.apache.flink.runtime.state.InternalPriorityQueue
-
Adds all the given elements to the set.
- addAll(List<S>) - Method in class org.apache.flink.runtime.state.PartitionableListState
-
- addAll(Collection<? extends T>) - Method in class org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue
-
- addAll(List<T>) - Method in class org.apache.flink.streaming.api.operators.util.SimpleVersionedListState
-
- addAll(List<T>) - Method in class org.apache.flink.table.api.dataview.ListView
-
Adds all of the elements of the specified list to this list view.
- addAll(List<EE>) - Method in class org.apache.flink.table.runtime.dataview.StateListView
-
- addAll(Collection<? extends V>) - Method in class org.apache.flink.types.ListValue
-
- addAll(int, Collection<? extends V>) - Method in class org.apache.flink.types.ListValue
-
- addAllFields(Iterable<? extends FlinkFnApi.Schema.Field>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addAllFields(Iterable<? extends FlinkFnApi.TypeInfo.RowTypeInfo.Field>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addAllFieldTypes(Iterable<? extends FlinkFnApi.TypeInfo>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addAllGrouping(Iterable<? extends Integer>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
-
The array of the key indexes.
- addAllInputs(Iterable<? extends FlinkFnApi.Input>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
-
The input arguments of the user-defined function, it could be one of the following:
1.
- addAllInputs(Iterable<? extends FlinkFnApi.Input>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
-
The input arguments of the user-defined function, it could be one of the following:
1.
- addAllJobParameters(Iterable<? extends FlinkFnApi.UserDefinedDataStreamFunction.JobParameter>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
-
repeated .org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter job_parameters = 7;
- addAllNamedProperties(Iterable<? extends FlinkFnApi.GroupWindow.WindowProperty>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
-
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
- addAllNamedPropertiesValue(Iterable<Integer>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
-
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
- addAllocationOnPendingResource(JobID, PendingTaskManagerId, ResourceProfile) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
-
- addAllocationOnRegisteredResource(JobID, InstanceID, ResourceProfile) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
-
- addAllSpecs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
-
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
- addAllStrategies(Iterable<? extends FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
-
repeated .org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry strategies = 2;
- addAllToProperties(Properties) - Method in class org.apache.flink.configuration.Configuration
-
Adds all entries in this
Configuration
to the given
Properties
.
- addAllToProperties(Properties) - Method in class org.apache.flink.configuration.DelegatingConfiguration
-
- addAllToProperties(Properties) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
-
- addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
-
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedFunction>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
-
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
- addAllWindows(Iterable<? extends FlinkFnApi.OverWindow>) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
-
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
- addAndLock(String, T) - Method in class org.apache.flink.kubernetes.highavailability.KubernetesStateHandleStore
-
Creates a state handle, stores it in ConfigMap.
- addAndLock(String, T) - Method in interface org.apache.flink.runtime.persistence.StateHandleStore
-
Persist the state to distributed storage(e.g.
- addAndLock(String, T) - Method in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore
-
Creates a state handle, stores it in ZooKeeper and locks it.
- addAny(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
- addAppConfigurationEntry(String, AppConfigurationEntry...) - Method in class org.apache.flink.runtime.security.DynamicConfiguration
-
Add entries for the given application name.
- addArg(HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserPTFInvocationSpec.PartitionedTableFunctionSpec
-
- addArg(HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserWindowingSpec.WindowFunctionSpec
-
- addArgument(String) - Method in class org.apache.flink.test.util.JobSubmission.JobSubmissionBuilder
-
Adds a program argument.
- addArgument(String, String) - Method in class org.apache.flink.test.util.JobSubmission.JobSubmissionBuilder
-
Convenience method for providing key-value program arguments.
- addArtificialDamCost(EstimateProvider, long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
-
- addArtificialDamCost(EstimateProvider, long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
-
- addAsyncOptionsToBuilder(Properties, AsyncDynamicTableSinkBuilder<?, ?>) - Method in class org.apache.flink.connector.base.table.AsyncDynamicTableSinkFactory
-
- addAsyncOptionsToSinkBuilder(AsyncSinkBaseBuilder<?, RequestEntryT, ?>) - Method in class org.apache.flink.connector.base.table.sink.AsyncDynamicTableSink
-
- addAvroGenericDataArrayRegistration(LinkedHashMap<String, KryoRegistration>) - Method in class org.apache.flink.api.java.typeutils.AvroUtils
-
Registers a special Serializer for GenericData.Array.
- addAvroGenericDataArrayRegistration(LinkedHashMap<String, KryoRegistration>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
-
- addAvroSerializersIfRequired(ExecutionConfig, Class<?>) - Method in class org.apache.flink.api.java.typeutils.AvroUtils
-
Loads the utility class from flink-avro
and adds Avro-specific serializers.
- addAvroSerializersIfRequired(ExecutionConfig, Class<?>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
-
- addBatch() - Method in interface org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatement
-
Adds a set of parameters to this NamedPreparedStatement
object's batch of
commands.
- addBatch() - Method in class org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl
-
- addBinaryLengthConstraint(ExecutionConfigOptions.TypeLengthEnforcer, List<ConstraintEnforcer.FieldInfo>, List<String>, String[]) - Method in class org.apache.flink.table.runtime.operators.sink.ConstraintEnforcer.Builder
-
- addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
-
- addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
-
- AddBoolBeforeReturnRewriter - Class in org.apache.flink.table.codesplit
-
- 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
-
- addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in enum org.apache.flink.runtime.checkpoint.DeactivatedCheckpointCompletedCheckpointStore
-
- addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStore
-
Synchronously writes the new checkpoints to state handle store and asynchronously removes
older ones.
- addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.EmbeddedCompletedCheckpointStore
-
- addCheckpointAndSubsumeOldestOne(CompletedCheckpoint, CheckpointsCleaner, Runnable) - Method in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
-
- addChild(Tree) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTNode
-
- addChildren(List) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserASTNode
-
- addChoices(String...) - Method in class org.apache.flink.graph.drivers.parameter.ChoiceParameter
-
Add additional choices.
- addClasspaths(Collection<URL>) - Method in class org.apache.flink.runtime.jobgraph.JobGraphBuilder
-
- addClosedBranch(OptimizerNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
-
- addClosedBranches(Set<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
-
- addCollectSink(DataStream<T>) - Method in class org.apache.flink.connector.testframe.testsuites.SinkTestSuiteBase
-
- addCollectSink(DataStream<T>) - Method in class org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase
-
Add a collect sink in the job.
- addColumn(String, String, Class<?>) - Method in class org.apache.flink.connector.hbase.util.HBaseTableSchema
-
Adds a column defined by family, qualifier, and type to the table schema.
- addColumn(String, String, DataType) - Method in class org.apache.flink.connector.hbase.util.HBaseTableSchema
-
- addColumn(ExprNodeDesc) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserExprNodeColumnListDesc
-
- addColumnFamilyOptionsToCloseLater(List<ColumnFamilyOptions>, ColumnFamilyHandle) - Static method in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils
-
- addColumns(Expression...) - Method in class org.apache.flink.table.api.internal.TableImpl
-
- addColumns(Expression...) - Method in interface org.apache.flink.table.api.Table
-
Adds additional columns.
- addColumns(boolean, List<Expression>, QueryOperation) - Method in class org.apache.flink.table.operations.utils.OperationTreeBuilder
-
Adds additional columns.
- addComparatorField(int, TypeComparator<?>) - Method in interface org.apache.flink.api.common.typeutils.CompositeType.TypeComparatorBuilder
-
- addConfigAsMainClassArgs(Configuration) - Method in class org.apache.flink.test.util.TestProcessBuilder
-
- addConfiguration(Configuration) - Method in class org.apache.flink.table.api.TableConfig
-
Adds the given key-value configuration to the underlying application-specific configuration.
- addConfiguration(Configuration) - Method in class org.apache.flink.tests.util.flink.FlinkResourceSetup.FlinkResourceSetupBuilder
-
- addConnect(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
- addConsumedPartitionGroup(ConsumedPartitionGroup) - Method in class org.apache.flink.runtime.executiongraph.ExecutionVertex
-
- addConsumer(JobEdge) - Method in class org.apache.flink.runtime.jobgraph.IntermediateDataSet
-
- addConsumers(ConsumerVertexGroup) - Method in class org.apache.flink.runtime.executiongraph.IntermediateResultPartition
-
- addContainedKind(RowKind) - Method in class org.apache.flink.table.connector.ChangelogMode.Builder
-
- addContainedKind(ModifyKind) - Method in class org.apache.flink.table.planner.plan.trait.ModifyKindSet.Builder
-
- addConvertedNonCorrSubqs(Map<SqlNode, RexNode>) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter
-
Adds to the current map of non-correlated converted sub-queries the elements from another map
that contains non-correlated sub-queries that have been converted by another
SqlToRelConverter.
- addCoOperator(Integer, String, String, StreamOperatorFactory<OUT>, TypeInformation<IN1>, TypeInformation<IN2>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
-
- addCopyTranslation(HiveParserASTNode, HiveParserASTNode) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserUnparseTranslator
-
Register a "copy" translation in which a node will be translated into whatever the
translation turns out to be for another node (after previously registered translations have
already been performed).
- addCosts(Costs) - Method in class org.apache.flink.optimizer.costs.Costs
-
Adds the given costs to these costs.
- addCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
-
Adds the given CPU cost to the current CPU cost for this Costs object.
- addCredit(int) - Method in interface org.apache.flink.runtime.io.network.NetworkSequenceViewReader
-
The credits from consumer are added in incremental way.
- addDataSink(GenericDataSinkBase<?>) - Method in class org.apache.flink.api.common.Plan
-
Adds a data sink to the set of sinks in this program.
- addDefaultConstraint(List<SQLDefaultConstraint>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.common.ExecutionConfig
-
Adds a new Kryo default serializer to the Runtime.
- addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.common.ExecutionConfig
-
Adds a new Kryo default serializer to the Runtime.
- addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.java.ExecutionEnvironment
-
Adds a new Kryo default serializer to the Runtime.
- addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.java.ExecutionEnvironment
-
Adds a new Kryo default serializer to the Runtime.
- addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
-
Adds a new Kryo default serializer to the Runtime.
- addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
-
Adds a new Kryo default serializer to the Runtime.
- addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.planner.utils.DummyStreamExecutionEnvironment
-
- addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.table.planner.utils.DummyStreamExecutionEnvironment
-
- addDefaultResource(String) - Static method in class org.apache.hadoop.conf.Configuration
-
Add a default resource.
- addDelete(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
- addDeprecatedKeys(Set<ConfigOption<?>>) - Static method in class org.apache.flink.connector.kinesis.table.util.KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper
-
- addDeprecation(String, String[], String) - Static method in class org.apache.hadoop.conf.Configuration
-
- addDeprecation(String, String, String) - Static method in class org.apache.hadoop.conf.Configuration
-
Adds the deprecated key to the global deprecation map.
- addDeprecation(String, String[]) - Static method in class org.apache.hadoop.conf.Configuration
-
- addDeprecation(String, String) - Static method in class org.apache.hadoop.conf.Configuration
-
Adds the deprecated key to the global deprecation map when no custom message is provided.
- addDeprecations(Configuration.DeprecationDelta[]) - Static method in class org.apache.hadoop.conf.Configuration
-
Adds a set of deprecated keys to the global deprecations.
- addDestToWindowingSpec(String, HiveParserWindowingSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQB
-
- addDimension(long, boolean) - Method in class org.apache.flink.graph.generator.GridGraph
-
Required configuration for each dimension of the graph.
- addDiscoveredPartitions(List<KafkaTopicPartition>) - Method in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher
-
Adds a list of newly discovered partitions to the fetcher for consuming.
- addDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
-
Adds the costs for disk to the current disk costs for this Costs object.
- addDynamicPartitions(long, long, String, String, List<String>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
Deprecated.
- addDynamicPartitions(long, long, String, String, List<String>, DataOperationType) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- addEdge(SharedBufferEdge) - Method in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNode
-
- addEdge(Vertex<K, VV>, Vertex<K, VV>, EV) - Method in class org.apache.flink.graph.Graph
-
Adds the given edge to the graph.
- addEdge(Integer, Integer, int) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
-
- addEdge(Integer, Integer, int, IntermediateDataSetID) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
-
- addEdges(List<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph
-
Adds the given list edges to the graph.
- addElement(T) - Method in interface org.apache.flink.api.common.serialization.BulkWriter
-
Adds an element to the encoder.
- addElement(T) - Method in class org.apache.flink.formats.avro.AvroBulkWriter
-
- addElement(T) - Method in class org.apache.flink.formats.compress.writers.HadoopCompressionBulkWriter
-
- addElement(T) - Method in class org.apache.flink.formats.compress.writers.NoCompressionBulkWriter
-
- addElement(T) - Method in class org.apache.flink.formats.parquet.ParquetBulkWriter
-
- addElement(Tuple2<K, V>) - Method in class org.apache.flink.formats.sequencefile.SequenceFileWriter
-
- addElement(T) - Method in class org.apache.flink.orc.writer.OrcBulkWriter
-
- addElement(RowData, long, RowData) - Method in class org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer
-
- addElement(RowData, long, RowData) - Method in interface org.apache.flink.table.runtime.operators.aggregate.window.buffers.WindowBuffer
-
Adds an element with associated key into the buffer.
- addEntropy(FileSystem, Path) - Static method in class org.apache.flink.core.fs.EntropyInjector
-
Handles entropy injection across regular and entropy-aware file systems.
- addEscapes(String) - Static method in error org.apache.flink.sql.parser.hive.impl.TokenMgrError
-
Replaces unprintable characters by their espaced (or unicode escaped)
equivalents in the given string
- addEscapes(String) - Static method in error org.apache.flink.sql.parser.impl.TokenMgrError
-
Replaces unprintable characters by their espaced (or unicode escaped)
equivalents in the given string
- addExpression(HiveParserPTFInvocationSpec.OrderExpression) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserPTFInvocationSpec.OrderSpec
-
- addExpression(HiveParserPTFInvocationSpec.PartitionExpression) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserPTFInvocationSpec.PartitionSpec
-
- addFeedbackEdge(Transformation<F>) - Method in class org.apache.flink.streaming.api.transformations.CoFeedbackTransformation
-
Adds a feedback edge.
- addFeedbackEdge(Transformation<T>) - Method in class org.apache.flink.streaming.api.transformations.FeedbackTransformation
-
Adds a feedback edge.
- addField(Integer) - Method in class org.apache.flink.api.common.operators.util.FieldList
-
- addField(Integer) - Method in class org.apache.flink.api.common.operators.util.FieldSet
-
- addField(int, boolean, boolean) - Method in class org.apache.flink.table.planner.plan.nodes.exec.spec.SortSpec.SortSpecBuilder
-
- addField(Value) - Method in class org.apache.flink.types.Record
-
- addFields(int...) - Method in class org.apache.flink.api.common.operators.util.FieldList
-
- addFields(FieldSet) - Method in class org.apache.flink.api.common.operators.util.FieldList
-
- addFields(int...) - Method in class org.apache.flink.api.common.operators.util.FieldSet
-
- addFields(FieldSet) - Method in class org.apache.flink.api.common.operators.util.FieldSet
-
- addFields(FlinkFnApi.Schema.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addFields(int, FlinkFnApi.Schema.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addFields(FlinkFnApi.Schema.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addFields(int, FlinkFnApi.Schema.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addFields(FlinkFnApi.TypeInfo.RowTypeInfo.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addFields(int, FlinkFnApi.TypeInfo.RowTypeInfo.Field) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addFields(FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addFields(int, FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addFieldsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addFieldsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
repeated .org.apache.flink.fn_execution.v1.Schema.Field fields = 1;
- addFieldsBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addFieldsBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field fields = 1;
- addFieldTypes(FlinkFnApi.TypeInfo) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addFieldTypes(int, FlinkFnApi.TypeInfo) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addFieldTypes(FlinkFnApi.TypeInfo.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addFieldTypes(int, FlinkFnApi.TypeInfo.Builder) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addFieldTypesBuilder() - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addFieldTypesBuilder(int) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1;
- addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
-
- addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
-
- addFinishedSplit(String) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
-
Mark the split with the given ID as finished.
- addFinishedSplits(Collection<String>) - Method in class org.apache.flink.connector.base.source.reader.RecordsBySplits.Builder
-
Mark multiple splits with the given IDs as finished.
- addFirstInput(Operator<IN1>...) - Method in class org.apache.flink.api.common.operators.DualInputOperator
-
- addFirstInputs(List<Operator<IN1>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
-
- 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
-
- addInput(Operator<IN>...) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
-
- addInput(List<Operator<IN>>) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- addOutputDataFuture(long, ResultSubpartitionInfo, int, CompletableFuture<List<Buffer>>) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter.NoOpChannelStateWriter
-
- addOutputDataFuture(long, ResultSubpartitionInfo, int, CompletableFuture<List<Buffer>>) - Method in class org.apache.flink.runtime.checkpoint.channel.ChannelStateWriterImpl
-
- addOutputFormat(OperatorID, OutputFormat<?>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
-
- addOutputFormat(OperatorID, UserCodeWrapper<? extends OutputFormat<?>>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
-
- addOutputFormat(OperatorID, UserCodeWrapper<? extends OutputFormat<?>>) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.FormatUserCodeTable
-
- addOutputShipStrategy(ShipStrategyType) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
-
- addParameter(Parameter<?>) - Method in class org.apache.flink.graph.drivers.parameter.ParameterizedBase
-
Adds a parameter to the list.
- addParameters(OperatorID, Configuration) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
-
- addParameters(OperatorID, String, String) - Method in class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer
-
- addPartialBuffer(Buffer) - Method in class org.apache.flink.runtime.io.network.buffer.CompositeBuffer
-
- addPartition(String) - Method in interface org.apache.flink.connector.file.table.stream.PartitionCommitTrigger
-
Add a pending partition.
- addPartition(String) - Method in class org.apache.flink.connector.file.table.stream.PartitionTimeCommitTrigger
-
- addPartition(String) - Method in class org.apache.flink.connector.file.table.stream.ProcTimeCommitTrigger
-
- AddPartitionsOperation - Class in org.apache.flink.table.operations.ddl
-
Operation to describe ALTER TABLE ADD PARTITION statement.
- AddPartitionsOperation(ObjectIdentifier, boolean, List<CatalogPartitionSpec>, List<CatalogPartition>) - Constructor for class org.apache.flink.table.operations.ddl.AddPartitionsOperation
-
- addPatch(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
- addPendingTaskManager(PendingTaskManager) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedTaskManagerTracker
-
- addPendingTaskManagerAllocate(PendingTaskManager) - Method in class org.apache.flink.runtime.resourcemanager.slotmanager.ResourceAllocationResult.Builder
-
- addPost(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
- addPostCommitTopology(DataStream<CommittableMessage<CommT>>) - Method in interface org.apache.flink.streaming.api.connector.sink2.WithPostCommitTopology
-
Adds a custom post-commit topology where all committables can be processed.
- addPreCommitTopology(DataStream<CommittableMessage<FileSinkCommittable>>) - Method in class org.apache.flink.connector.file.sink.FileSink
-
- addPreCommitTopology(DataStream<CommittableMessage<CommT>>) - Method in interface org.apache.flink.streaming.api.connector.sink2.WithPreCommitTopology
-
Intercepts and modifies the committables sent on checkpoint or at end of input.
- addPreWriteTopology(DataStream<InputT>) - Method in interface org.apache.flink.streaming.api.connector.sink2.WithPreWriteTopology
-
Adds an arbitrary topology before the writer.
- addPrimaryKey(List<SQLPrimaryKey>) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- addPriorityElement(T) - Method in class org.apache.flink.runtime.io.network.partition.PrioritizedDeque
-
Adds a priority element to this deque, such that it will be polled after all existing
priority elements but before any non-priority element.
- addProceed(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
-
- addProcessedBytes(int) - Method in class org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler
-
- addPTFNodeToSpec(HiveParserASTNode, HiveParserPTFInvocationSpec) - Method in class org.apache.flink.table.planner.delegation.hive.copy.HiveParserQB
-
- addPut(String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
- addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
-
- addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
-
- addRange(long, long) - Method in class org.apache.flink.graph.generator.CirculantGraph
-
Required configuration for each range of offsets in the graph.
- addRangePartitionCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
-
- addRangePartitionCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
-
- addReader(int) - Method in class org.apache.flink.api.connector.source.lib.util.IteratorSourceEnumerator
-
- addReader(int) - Method in interface org.apache.flink.api.connector.source.SplitEnumerator
-
Add a new source reader with the given subtask ID.
- addReader(int) - Method in class org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator
-
- addReader(int) - Method in class org.apache.flink.connector.file.src.impl.ContinuousFileSplitEnumerator
-
- addReader(int) - Method in class org.apache.flink.connector.file.src.impl.DynamicFileSplitEnumerator
-
- addReader(int) - Method in class org.apache.flink.connector.file.src.impl.StaticFileSplitEnumerator
-
- addReader(int) - Method in class org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator
-
- addReader(int) - Method in class org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumerator
-
- addReader(int) - Method in class org.apache.flink.connector.testframe.source.enumerator.NoOpEnumerator
-
- addReader(int) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator
-
- addReadFields(int, FieldSet) - Method in class org.apache.flink.api.common.operators.DualInputSemanticProperties
-
Adds, to the existing information, field(s) that are read in the source record(s) from the
first input.
- addReadFields(FieldSet) - Method in class org.apache.flink.api.common.operators.SingleInputSemanticProperties
-
Adds, to the existing information, field(s) that are read in the source record(s).
- addRecord(T) - Method in class org.apache.flink.runtime.operators.sort.LargeRecordHandler
-
- addRecord(RowData) - Method in interface org.apache.flink.table.runtime.operators.join.stream.state.JoinRecordStateView
-
Add a new record to the state view.
- addRecord(RowData, int) - Method in interface org.apache.flink.table.runtime.operators.join.stream.state.OuterJoinRecordStateView
-
Adds a new record with the number of associations to the state view.
- addRecovered(BufferConsumer) - Method in interface org.apache.flink.runtime.io.network.partition.CheckpointedResultSubpartition
-
- addRecovered(BufferConsumer) - Method in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition
-
- addRelBuilderConfigTransform(UnaryOperator<RelBuilder.Config>) - Method in interface org.apache.calcite.sql2rel.SqlToRelConverter.Config
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RawType.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RowType.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Input.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.BinaryInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.CharInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.DecimalInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Field.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.FieldType.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.LocalZonedTimestampInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.MapInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimeInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimestampInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarBinaryInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarCharInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.ZonedTimestampInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.RocksdbCompactFilterCleanupStrategy.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.AvroTypeInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.MapTypeInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.JobParameter.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction.Builder
-
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
-
- addRequest(R) - Method in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
-
- addResource(String) - Method in class org.apache.hadoop.conf.Configuration
-
Add a configuration resource.
- addResource(String, boolean) - Method in class org.apache.hadoop.conf.Configuration
-
- addResource(URL) - Method in class org.apache.hadoop.conf.Configuration
-
Add a configuration resource.
- addResource(URL, boolean) - Method in class org.apache.hadoop.conf.Configuration
-
- addResource(Path) - Method in class org.apache.hadoop.conf.Configuration
-
Add a configuration resource.
- addResource(Path, boolean) - Method in class org.apache.hadoop.conf.Configuration
-
- addResource(InputStream) - Method in class org.apache.hadoop.conf.Configuration
-
Add a configuration resource.
- addResource(InputStream, boolean) - Method in class org.apache.hadoop.conf.Configuration
-
- addResource(InputStream, String) - Method in class org.apache.hadoop.conf.Configuration
-
Add a configuration resource.
- addResource(InputStream, String, boolean) - Method in class org.apache.hadoop.conf.Configuration
-
- addResource(Configuration) - Method in class org.apache.hadoop.conf.Configuration
-
Add a configuration resource.
- Address - Class in org.apache.flink.avro.generated
-
- Address() - Constructor for class org.apache.flink.avro.generated.Address
-
Default constructor.
- Address(Integer, String, String, String, String, String) - Constructor for class org.apache.flink.avro.generated.Address
-
All-args constructor.
- ADDRESS - Static variable in class org.apache.flink.configuration.JobManagerOptions
-
The config parameter defining the network address to connect to for communication with the
job manager.
- ADDRESS - Static variable in class org.apache.flink.configuration.RestOptions
-
The address that should be used by clients to connect to the server.
- ADDRESS - Static variable in class org.apache.flink.configuration.WebOptions
-
Deprecated.
- address() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerLocation
-
Returns the network address the instance's task manager binds its sockets to.
- address() - Method in class org.apache.flink.streaming.examples.statemachine.event.Alert
-
- ADDRESS - Static variable in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions
-
The address that should be used by clients to connect to the sql gateway server.
- Address.Builder - Class in org.apache.flink.avro.generated
-
RecordBuilder for Address instances.
- ADDRESS_OPTION - Static variable in class org.apache.flink.client.cli.CliFrontendParser
-
- AddressNormalizer() - Constructor for class org.apache.flink.table.examples.java.basics.GettingStartedExample.AddressNormalizer
-
- AddressResolution - Enum in org.apache.flink.runtime.rpc
-
Enum specifying whether address resolution should be tried.
- addressString() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerLocation
-
Gets the IP address where the TaskManager operates.
- addRetrievedShardsToStream(String, List<StreamShardHandle>) - Method in class org.apache.flink.streaming.connectors.kinesis.proxy.GetShardListResult
-
- addRetrievedShardToStream(String, StreamShardHandle) - Method in class org.apache.flink.streaming.connectors.kinesis.proxy.GetShardListResult
-
- addRoute(HttpMethod, String, T) - Method in class org.apache.flink.runtime.rest.handler.router.Router
-
Add route.
- addRunOptions(Options) - Method in class org.apache.flink.client.cli.AbstractCustomCommandLine
-
- addRunOptions(Options) - Method in interface org.apache.flink.client.cli.CustomCommandLine
-
Adds custom options to the existing run options.
- addRunOptions(Options) - Method in class org.apache.flink.client.cli.GenericCLI
-
- addRunOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
-
- addRuntimeStat(RuntimeStat) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- addSchemaVersion(SchemaVersion) - Method in class org.apache.hadoop.hive.metastore.HiveMetaStoreClient
-
- addSecondInput(Operator<IN2>...) - Method in class org.apache.flink.api.common.operators.DualInputOperator
-
- addSecondInputs(List<Operator<IN2>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
-
- 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
OutputTag
s 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
-
- 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
-
- 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
-
- 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
-
- 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