Skip navigation links

Back to Flink Website

$ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z 

$

$greater(A) - Static method in class org.apache.flink.ml.math.distributed.IndexedRow
 
$greater$eq(A) - Static method in class org.apache.flink.ml.math.distributed.IndexedRow
 
$less(A) - Static method in class org.apache.flink.ml.math.distributed.IndexedRow
 
$less$eq(A) - Static method in class org.apache.flink.ml.math.distributed.IndexedRow
 
$minus$greater() - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
$minus$greater() - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
$minus$greater() - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
$minus$greater() - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 

A

A - Variable in class org.apache.flink.graph.generator.RMatGraph
 
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.
abortCheckpointOnBarrier(long, Throwable) - Method in interface org.apache.flink.runtime.jobgraph.tasks.StatefulTask
Aborts a checkpoint as the result of receiving possibly some checkpoint barriers, but at least one CancelCheckpointMarker.
abortCheckpointOnBarrier(long, Throwable) - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
abortDeclined() - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
 
abortError(Throwable) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Aborts the pending checkpoint due to an error.
abortExpired() - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Aborts a checkpoint because it expired (took too long).
abortSubsumed() - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Aborts the pending checkpoint because a newer completed checkpoint subsumed it.
ABS - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
 
abs() - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Calculates the absolute value of given value.
ABS() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ABS() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
Abs - Class in org.apache.flink.table.expressions
 
Abs(Expression) - Constructor for class org.apache.flink.table.expressions.Abs
 
Abs$ - Class in org.apache.flink.table.expressions
 
Abs$() - Constructor for class org.apache.flink.table.expressions.Abs$
 
ABS_DEC() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ABS_DEC() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
absoluteTimeMillis() - Method in class org.apache.flink.runtime.util.clock.Clock
 
absoluteTimeMillis() - Method in class org.apache.flink.runtime.util.clock.SystemClock
 
AbstractAlignedProcessingTimeWindowOperator<KEY,IN,OUT,STATE,F extends Function> - Class in org.apache.flink.streaming.runtime.operators.windowing
Deprecated.
Deprecated in favour of the generic WindowOperator. This was an optimized implementation used for aligned windows.
AbstractAlignedProcessingTimeWindowOperator(F, KeySelector<IN, KEY>, TypeSerializer<KEY>, TypeSerializer<STATE>, long, long) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator
Deprecated.
 
AbstractAsyncIOCallable<V,D extends Closeable> - Class in org.apache.flink.runtime.io.async
The abstract class encapsulates the lifecycle and execution strategy for asynchronous IO operations
AbstractAsyncIOCallable() - Constructor for class org.apache.flink.runtime.io.async.AbstractAsyncIOCallable
 
AbstractAsyncSnapshotIOCallable<H extends StateObject> - Class in org.apache.flink.runtime.checkpoint
Abstract base class for async IO operations of snapshots against a CheckedOutputStream.
AbstractAsyncSnapshotIOCallable(long, long, CheckpointStreamFactory, CloseableRegistry) - Constructor for class org.apache.flink.runtime.checkpoint.AbstractAsyncSnapshotIOCallable
 
AbstractBoltSink - Class in org.apache.flink.storm.util
Implements a sink that write the received data so some external output.
AbstractBoltSink(OutputFormatter) - Constructor for class org.apache.flink.storm.util.AbstractBoltSink
 
AbstractCachedBuildSideJoinDriver<IT1,IT2,OT> - Class in org.apache.flink.runtime.operators
 
AbstractCachedBuildSideJoinDriver(int, int) - Constructor for class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver
 
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.
AbstractCloseableHandle - Class in org.apache.flink.migration.runtime.state
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
AbstractCloseableHandle() - Constructor for class org.apache.flink.migration.runtime.state.AbstractCloseableHandle
Deprecated.
 
AbstractCloseableRegistry<C extends Closeable,T> - Class in org.apache.flink.util
This is the abstract base class for registries that allow to register instances of Closeable, which are all closed if this registry is closed.
AbstractCloseableRegistry(Map<Closeable, T>) - Constructor for class org.apache.flink.util.AbstractCloseableRegistry
 
AbstractDataSetAnalytic<T,R> - Class in org.apache.flink.graph.asm.dataset
Base class for DataSetAnalytic.
AbstractDataSetAnalytic() - Constructor for class org.apache.flink.graph.asm.dataset.AbstractDataSetAnalytic
 
AbstractDeserializationSchema<T> - Class in org.apache.flink.streaming.util.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.streaming.util.serialization.AbstractDeserializationSchema
 
AbstractEvent - Class in org.apache.flink.runtime.event
This type of event can be used to exchange notification messages between different TaskManager objects at runtime using the communication channels.
AbstractEvent() - Constructor for class org.apache.flink.runtime.event.AbstractEvent
 
AbstractExecutionGraphRequestHandler - Class in org.apache.flink.runtime.webmonitor.handlers
Base class for request handlers whose response depends on an ExecutionGraph that can be retrieved via "jobid" parameter.
AbstractExecutionGraphRequestHandler(ExecutionGraphHolder) - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AbstractExecutionGraphRequestHandler
 
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<AssignerWithPeriodicWatermarks<T>>, SerializedValue<AssignerWithPunctuatedWatermarks<T>>, ProcessingTimeService, long, ClassLoader, 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.
AbstractFileStateHandle - Class in org.apache.flink.migration.runtime.state.filesystem
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
AbstractFileStateHandle(Path) - Constructor for class org.apache.flink.migration.runtime.state.filesystem.AbstractFileStateHandle
Deprecated.
Creates a new file state for the given file path.
AbstractFsStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.migration.runtime.state.filesystem
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
AbstractFsStateSnapshot(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, Path) - Constructor for class org.apache.flink.migration.runtime.state.filesystem.AbstractFsStateSnapshot
Deprecated.
 
AbstractGeneratorFactory<T extends org.apache.commons.math3.random.RandomGenerator> - Class in org.apache.flink.graph.generator.random
This base class handles the task of dividing the requested work into the appropriate number of blocks of near-equal size.
AbstractGeneratorFactory() - Constructor for class org.apache.flink.graph.generator.random.AbstractGeneratorFactory
 
AbstractGraphAnalytic<K,VV,EV,T> - Class in org.apache.flink.graph
Base class for GraphAnalytic.
AbstractGraphAnalytic() - Constructor for class org.apache.flink.graph.AbstractGraphAnalytic
 
AbstractGraphGenerator<K,VV,EV> - Class in org.apache.flink.graph.generator
 
AbstractGraphGenerator() - Constructor for class org.apache.flink.graph.generator.AbstractGraphGenerator
 
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
 
AbstractHeapMergingState<K,N,IN,OUT,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.runtime.state.heap
Base class for MergingState (InternalMergingState) that is stored on the heap.
AbstractHeapMergingState(SD, StateTable<K, N, SV>, TypeSerializer<K>, TypeSerializer<N>) - Constructor for class org.apache.flink.runtime.state.heap.AbstractHeapMergingState
Creates a new key/value state for the given hash map of key/value pairs.
AbstractHeapState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.runtime.state.heap
Base class for partitioned ListState implementations that are backed by a regular heap hash map.
AbstractHeapState(SD, StateTable<K, N, SV>, TypeSerializer<K>, TypeSerializer<N>) - Constructor for class org.apache.flink.runtime.state.heap.AbstractHeapState
Creates a new key/value state for the given hash map of key/value pairs.
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.
AbstractInvokable - Class in org.apache.flink.runtime.jobgraph.tasks
This is the abstract base class for every task that can be executed by a TaskManager.
AbstractInvokable() - Constructor for class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
 
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() - Constructor for class org.apache.flink.runtime.iterative.task.AbstractIterativeTask
 
AbstractJobVertexRequestHandler - Class in org.apache.flink.runtime.webmonitor.handlers
Base class for request handlers whose response depends on a specific job vertex (defined via the "vertexid" parameter) in a specific job, defined via (defined voa the "jobid" parameter).
AbstractJobVertexRequestHandler(ExecutionGraphHolder) - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AbstractJobVertexRequestHandler
 
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
 
AbstractJsonRequestHandler - Class in org.apache.flink.runtime.webmonitor.handlers
Base class for most request handlers.
AbstractJsonRequestHandler() - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AbstractJsonRequestHandler
 
AbstractKeyedCEPPatternOperator<IN,KEY,OUT> - Class in org.apache.flink.cep.operator
Abstract CEP pattern operator for a keyed input stream.
AbstractKeyedCEPPatternOperator(TypeSerializer<IN>, boolean, TypeSerializer<KEY>, NFACompiler.NFAFactory<IN>, boolean) - Constructor for class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator
 
AbstractKeyedStateBackend<K> - Class in org.apache.flink.runtime.state
Base implementation of KeyedStateBackend.
AbstractKeyedStateBackend(TaskKvStateRegistry, TypeSerializer<K>, ClassLoader, int, KeyGroupRange, ExecutionConfig) - Constructor for class org.apache.flink.runtime.state.AbstractKeyedStateBackend
 
AbstractKeyedTimePanes<Type,Key,Aggregate,Result> - Class in org.apache.flink.streaming.runtime.operators.windowing
Base class for a multiple key/value maps organized in panes.
AbstractKeyedTimePanes() - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AbstractKeyedTimePanes
 
AbstractLineSpout - Class in org.apache.flink.storm.util
Base class for Spouts that read data line by line from an arbitrary source.
AbstractLineSpout() - Constructor for class org.apache.flink.storm.util.AbstractLineSpout
 
AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.migration.runtime.state.memory
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
AbstractMemStateSnapshot(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, byte[]) - Constructor for class org.apache.flink.migration.runtime.state.memory.AbstractMemStateSnapshot
Deprecated.
Creates a new heap memory state snapshot.
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
 
AbstractMetricsHandler - Class in org.apache.flink.runtime.webmonitor.metrics
Abstract request handler that returns a list of all available metrics or the values for a set of metrics.
AbstractMetricsHandler(MetricFetcher) - Constructor for class org.apache.flink.runtime.webmonitor.metrics.AbstractMetricsHandler
 
AbstractMigrationRestoreStrategy<K,N,S> - Class in org.apache.flink.migration.runtime.state.memory
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
AbstractMigrationRestoreStrategy(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<S>) - Constructor for class org.apache.flink.migration.runtime.state.memory.AbstractMigrationRestoreStrategy
Deprecated.
 
AbstractMultiFSDataInputStream - Class in org.apache.flink.core.fs
Abstract base class for wrappers over multiple FSDataInputStream, which gives a contiguous view on all inner streams and makes them look like a single stream, in which we can read, seek, etc.
AbstractMultiFSDataInputStream() - Constructor for class org.apache.flink.core.fs.AbstractMultiFSDataInputStream
 
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
 
AbstractOperatorBackendStateMetaInfoReader(ClassLoader) - Constructor for class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractOperatorBackendStateMetaInfoReader
 
AbstractOperatorBackendStateMetaInfoWriter(RegisteredOperatorBackendStateMetaInfo.Snapshot<S>) - Constructor for class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractOperatorBackendStateMetaInfoWriter
 
AbstractOperatorDescriptor - Interface in org.apache.flink.optimizer.operators
The root of all descriptions of an operator to the optimizer.
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
 
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
 
AbstractPerWindowStateStore() - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.AbstractPerWindowStateStore
 
AbstractReader - Class in org.apache.flink.runtime.io.network.api.reader
A basic reader implementation, which wraps an input gate and handles events.
AbstractReader(InputGate) - Constructor for class org.apache.flink.runtime.io.network.api.reader.AbstractReader
 
AbstractReporter - Class in org.apache.flink.metrics.reporter
Base interface for custom metric reporters.
AbstractReporter() - Constructor for class org.apache.flink.metrics.reporter.AbstractReporter
 
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,S extends State,SD extends StateDescriptor<S,V>,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>, SD, RocksDBKeyedStateBackend<K>) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Creates a new RocksDB backed state.
AbstractRuntimeUDFContext - Class in org.apache.flink.api.common.functions.util
A standalone implementation of the RuntimeContext, created by runtime UDF operators.
AbstractRuntimeUDFContext(TaskInfo, ClassLoader, ExecutionConfig, Map<String, Accumulator<?, ?>>, Map<String, Future<Path>>, MetricGroup) - Constructor for class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext
 
AbstractSchema<X> - Class in org.apache.flink.optimizer.postpass
 
AbstractSchema() - Constructor for class org.apache.flink.optimizer.postpass.AbstractSchema
 
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
 
AbstractStateBackend - Class in org.apache.flink.migration.runtime.state
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
AbstractStateBackend() - Constructor for class org.apache.flink.migration.runtime.state.AbstractStateBackend
Deprecated.
 
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
 
AbstractStateBackend.DataInputViewHandle - Class in org.apache.flink.migration.runtime.state
Deprecated.
Simple state handle that resolved a DataInputView from a StreamStateHandle.
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
 
AbstractStreamOperator.CountingOutput - Class in org.apache.flink.streaming.api.operators
Wrapping Output that updates metrics on the number of emitted elements.
AbstractStreamOperator.LatencyGauge - Class in org.apache.flink.streaming.api.operators
The gauge uses a HashMap internally to avoid classloading issues when accessing the values using JMX.
AbstractSubtaskAttemptRequestHandler - Class in org.apache.flink.runtime.webmonitor.handlers
Base class for request handlers whose response depends on a specific subtask execution attempt (defined via the "attempt" parameter) of a specific subtask (defined via the "subtasknum" parameter) in a specific job vertex (defined via the "vertexid" parameter) in a specific job, defined via (defined voa the "jobid" parameter).
AbstractSubtaskAttemptRequestHandler(ExecutionGraphHolder) - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AbstractSubtaskAttemptRequestHandler
 
AbstractSubtaskRequestHandler - Class in org.apache.flink.runtime.webmonitor.handlers
Base class for request handlers whose response depends on a specific subtask (defined via the "subtasknum" parameter) in a specific job vertex (defined via the "vertexid" parameter) in a specific job, defined via (defined voa the "jobid" parameter).
AbstractSubtaskRequestHandler(ExecutionGraphHolder) - Constructor for class org.apache.flink.runtime.webmonitor.handlers.AbstractSubtaskRequestHandler
 
AbstractTableInputFormat<T> - Class in org.apache.flink.addons.hbase
Abstract InputFormat to read data from HBase tables.
AbstractTableInputFormat() - Constructor for class org.apache.flink.addons.hbase.AbstractTableInputFormat
 
AbstractTestBase - Class in org.apache.flink.test.util
A base class for tests that run test programs in a Flink mini cluster.
AbstractTestBase(Configuration) - Constructor for class org.apache.flink.test.util.AbstractTestBase
 
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
 
AbstractWindowProperty - Class in org.apache.flink.table.expressions
 
AbstractWindowProperty(Expression) - Constructor for class org.apache.flink.table.expressions.AbstractWindowProperty
 
AbstractYarnClusterDescriptor - Class in org.apache.flink.yarn
The descriptor with deployment information for spawning or resuming a YarnClusterClient.
AbstractYarnClusterDescriptor() - Constructor for class org.apache.flink.yarn.AbstractYarnClusterDescriptor
 
AbstractYarnFlinkApplicationMasterRunner - Class in org.apache.flink.yarn
This class is the executable entry point for the YARN application master.
AbstractYarnFlinkApplicationMasterRunner() - Constructor for class org.apache.flink.yarn.AbstractYarnFlinkApplicationMasterRunner
 
AbstractYarnNonHaServices - Class in org.apache.flink.yarn.highavailability
Abstract base class for the high availability services for Flink YARN applications that support no master fail over.
AbstractYarnNonHaServices(Configuration, Configuration) - Constructor for class org.apache.flink.yarn.highavailability.AbstractYarnNonHaServices
Creates new YARN high-availability services, configuring the file system and recovery data directory based on the working directory in the given Hadoop configuration.
Acc() - Method in class org.apache.flink.table.plan.nodes.datastream.AccMode$
An operator in Acc mode emits change messages as CRow which encode a pair of (Boolean, Row).
Acc() - Static method in class org.apache.flink.table.plan.nodes.datastream.AccMode
An operator in Acc mode emits change messages as CRow which encode a pair of (Boolean, Row).
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(T) - Method in interface org.apache.flink.runtime.concurrent.AcceptFunction
Method which handles the function call.
accept(Parsers) - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
accept(ES, Function1<ES, List<Object>>) - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
accept(String, PartialFunction<Object, U>) - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
accept(RelShuttle) - Method in class org.apache.flink.table.plan.logical.rel.LogicalWindowAggregate
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalAggregate
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalAggregate
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalCalc
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalCalc
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalCorrelate
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalCorrelate
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalIntersect
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalIntersect
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalJoin
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalJoin
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalMinus
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalMinus
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalNativeTableScan
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalNativeTableScan
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalOverWindow
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalOverWindow
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalSort
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalSort
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalTableFunctionScan
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalTableFunctionScan
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalTableSourceScan
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalTableSourceScan
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalUnion
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalUnion
 
accept(RelShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalValues
 
accept(RexShuttle) - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalValues
 
accept(RelShuttle) - Method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalWindowAggregate
 
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) - Static method in class org.apache.flink.table.functions.TimeMaterializationSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall, boolean, SqlBasicVisitor.ArgHandler<R>) - Static method in class org.apache.flink.table.functions.TimeMaterializationSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall) - Static method in class org.apache.flink.table.functions.utils.AggSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall, boolean, SqlBasicVisitor.ArgHandler<R>) - Static method in class org.apache.flink.table.functions.utils.AggSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall) - Static method in class org.apache.flink.table.functions.utils.ScalarSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall, boolean, SqlBasicVisitor.ArgHandler<R>) - Static method in class org.apache.flink.table.functions.utils.ScalarSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall) - Static method in class org.apache.flink.table.functions.utils.TableSqlFunction
 
acceptCall(SqlVisitor<R>, SqlCall, boolean, SqlBasicVisitor.ArgHandler<R>) - Static method in class org.apache.flink.table.functions.utils.TableSqlFunction
 
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
 
AcceptFunction<T> - Interface in org.apache.flink.runtime.concurrent
Function which is called with a single argument and does not return a value.
acceptIf(Function1<Object, Object>, Function1<Object, String>) - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
acceptMatch(String, PartialFunction<Object, U>) - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
AcceptOffers - Class in org.apache.flink.mesos.scheduler.messages
Local message sent by the launch coordinator to the scheduler to accept offers.
AcceptOffers(String, Collection<Protos.OfferID>, Collection<Protos.Offer.Operation>) - Constructor for class org.apache.flink.mesos.scheduler.messages.AcceptOffers
 
AcceptOffers(String, Collection<Protos.OfferID>, Collection<Protos.Offer.Operation>, Protos.Filters) - Constructor for class org.apache.flink.mesos.scheduler.messages.AcceptOffers
 
acceptSeq(ES, Function1<ES, Iterable<Object>>) - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
AccessExecution - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime Execution and {@link ArchivedExecution}.
AccessExecutionGraph - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime ExecutionGraph and ArchivedExecutionGraph.
AccessExecutionJobVertex - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.
AccessExecutionVertex - Interface in org.apache.flink.runtime.executiongraph
Common interface for the runtime ExecutionVertex and ArchivedExecutionVertex.
accessField(Field, Object) - Method in class org.apache.flink.api.java.typeutils.runtime.PojoComparator
This method is handling the IllegalAccess exceptions of Field.get()
AccMode - Class in org.apache.flink.table.plan.nodes.datastream
The AccMode determines how insert, update, and delete changes of tables are encoded by the messeages that an operator emits.
AccMode() - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccMode
 
AccMode$ - Class in org.apache.flink.table.plan.nodes.datastream
The AccMode determines how insert, update, and delete changes of tables are encoded by the messeages that an operator emits.
AccMode$() - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccMode$
 
ACCMODE_INSTANCE() - Method in class org.apache.flink.table.plan.rules.datastream.DataStreamRetractionRules$
Rule instance that assigns the AccMode to DataStreamRel nodes.
ACCMODE_INSTANCE() - Static method in class org.apache.flink.table.plan.rules.datastream.DataStreamRetractionRules
Rule instance that assigns the AccMode to DataStreamRel nodes.
AccModeTrait - Class in org.apache.flink.table.plan.nodes.datastream
Tracks the AccMode of a RelNode.
AccModeTrait() - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccModeTrait
 
AccModeTrait(Enumeration.Value) - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccModeTrait
 
AccModeTrait$ - Class in org.apache.flink.table.plan.nodes.datastream
 
AccModeTrait$() - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccModeTrait$
 
AccModeTraitDef - Class in org.apache.flink.table.plan.nodes.datastream
Definition of the AccModeTrait.
AccModeTraitDef() - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccModeTraitDef
 
AccModeTraitDef$ - Class in org.apache.flink.table.plan.nodes.datastream
 
AccModeTraitDef$() - Constructor for class org.apache.flink.table.plan.nodes.datastream.AccModeTraitDef$
 
AccRetract() - Method in class org.apache.flink.table.plan.nodes.datastream.AccMode$
* An operator in AccRetract mode emits change messages as CRow which encode a pair of (Boolean, Row).
AccRetract() - Static method in class org.apache.flink.table.plan.nodes.datastream.AccMode
* An operator in AccRetract mode emits change messages as CRow which encode a pair of (Boolean, Row).
accumulate(BigIntegralAvgAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.BigIntegralAvgAggFunction
 
accumulate(CountAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.CountAggFunction
 
accumulate(DecimalAvgAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.DecimalAvgAggFunction
 
accumulate(DecimalSumAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.DecimalSumAggFunction
 
accumulate(DecimalSumWithRetractAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.DecimalSumWithRetractAggFunction
 
accumulate(FloatingAvgAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.FloatingAvgAggFunction
 
accumulate(IntegralAvgAccumulator, Object) - Method in class org.apache.flink.table.functions.aggfunctions.IntegralAvgAggFunction
 
accumulate(MaxAccumulator<T>, Object) - Method in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction
 
accumulate(MaxWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction
 
accumulate(MinAccumulator<T>, Object) - Method in class org.apache.flink.table.functions.aggfunctions.MinAggFunction
 
accumulate(MinWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction
 
accumulate(SumAccumulator<T>, Object) - Method in class org.apache.flink.table.functions.aggfunctions.SumAggFunction
 
accumulate(SumWithRetractAccumulator<T>, Object) - Method in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction
 
accumulate(Row, Row) - Method in class org.apache.flink.table.runtime.aggregate.GeneratedAggregations
Accumulates the input values to the accumulators.
AccumulatingKeyedTimePanes<Type,Key,Result> - Class in org.apache.flink.streaming.runtime.operators.windowing
Key/value map organized in panes for accumulating windows (with a window function).
AccumulatingKeyedTimePanes(KeySelector<Type, Key>, InternalWindowFunction<Iterable<Type>, Result, Key, Window>) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes
 
AccumulatingProcessingTimeWindowOperator<KEY,IN,OUT> - Class in org.apache.flink.streaming.runtime.operators.windowing
Deprecated.
Deprecated in favour of the generic WindowOperator. This was an optimized implementation used for aligned windows.
AccumulatingProcessingTimeWindowOperator(InternalWindowFunction<Iterable<IN>, OUT, KEY, TimeWindow>, KeySelector<IN, KEY>, TypeSerializer<KEY>, TypeSerializer<IN>, long, long) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator
Deprecated.
 
Accumulator<V,R extends Serializable> - Interface in org.apache.flink.api.common.accumulators
Accumulators collect distributed statistics or aggregates in a from user functions and operators.
AccumulatorHelper - Class in org.apache.flink.api.common.accumulators
 
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.
AccumulatorMessage - Interface in org.apache.flink.runtime.messages.accumulators
Base trait of all accumulator messages
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
 
AccumulatorResultsErroneous - Class in org.apache.flink.runtime.messages.accumulators
Denotes that the accumulator results for jobID could be obtained from the JobManager because of an exception.
AccumulatorResultsErroneous(JobID, Exception) - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsErroneous
 
AccumulatorResultsErroneous$ - Class in org.apache.flink.runtime.messages.accumulators
 
AccumulatorResultsErroneous$() - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsErroneous$
 
AccumulatorResultsFound - Class in org.apache.flink.runtime.messages.accumulators
Contains the retrieved accumulator results from the job manager.
AccumulatorResultsFound(JobID, Map<String, SerializedValue<Object>>) - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsFound
 
AccumulatorResultsFound$ - Class in org.apache.flink.runtime.messages.accumulators
 
AccumulatorResultsFound$() - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsFound$
 
AccumulatorResultsNotFound - Class in org.apache.flink.runtime.messages.accumulators
Denotes that no accumulator results for jobID could be found at the job manager.
AccumulatorResultsNotFound(JobID) - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsNotFound
 
AccumulatorResultsNotFound$ - Class in org.apache.flink.runtime.messages.accumulators
 
AccumulatorResultsNotFound$() - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsNotFound$
 
AccumulatorResultsResponse - Interface in org.apache.flink.runtime.messages.accumulators
Base trait of responses to RequestAccumulatorResults
AccumulatorResultStringsFound - Class in org.apache.flink.runtime.messages.accumulators
Contains the retrieved accumulator result strings from the job manager.
AccumulatorResultStringsFound(JobID, StringifiedAccumulatorResult[]) - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultStringsFound
 
AccumulatorResultStringsFound$ - Class in org.apache.flink.runtime.messages.accumulators
 
AccumulatorResultStringsFound$() - Constructor for class org.apache.flink.runtime.messages.accumulators.AccumulatorResultStringsFound$
 
accumulators() - Method in class org.apache.flink.runtime.messages.TaskManagerMessages.Heartbeat
 
accumulators() - Method in class org.apache.flink.table.runtime.aggregate.DataSetSlideWindowAggReduceGroupFunction
 
accumulators() - Method in class org.apache.flink.table.runtime.aggregate.DataSetTumbleTimeWindowAggReduceGroupFunction
 
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
 
ack(Object) - Method in class org.apache.flink.storm.util.AbstractLineSpout
 
ack(Object) - Method in class org.apache.flink.storm.util.NullTerminatingSpout
 
Acknowledge - Class in org.apache.flink.runtime.messages
A generic acknowledgement message.
AcknowledgeApplicationClientRegistration$() - Constructor for class org.apache.flink.yarn.YarnMessages.AcknowledgeApplicationClientRegistration$
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, SubtaskState) - 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, SubtaskState) - 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, SubtaskState) - Method in class org.apache.flink.runtime.jobmaster.JobMaster
 
AcknowledgeCheckpoint - Class in org.apache.flink.runtime.messages.checkpoint
This message is sent from the TaskManager to the JobManager to signal that the checkpoint of an individual task is completed.
AcknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, SubtaskState) - 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, SubtaskState) - Method in class org.apache.flink.runtime.taskexecutor.rpc.RpcCheckpointResponder
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, SubtaskState) - Method in class org.apache.flink.runtime.taskmanager.ActorGatewayCheckpointResponder
 
acknowledgeCheckpoint(JobID, ExecutionAttemptID, long, CheckpointMetrics, SubtaskState) - 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, SubtaskState) - Method in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment
 
acknowledgeIDs(long, List<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, List<UId>) - Method in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
Acknowledges the session ids.
AcknowledgeRegistration(InstanceID, int) - Constructor for class org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration
 
AcknowledgeRegistration$() - Constructor for class org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration$
 
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, SubtaskState, CheckpointMetrics) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Acknowledges the task with the given execution attempt id and the given subtask state.
ACOS - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
 
acos() - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Calculates the arc cosine of a given number.
ACOS() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ACOS() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
Acos - Class in org.apache.flink.table.expressions
 
Acos(Expression) - Constructor for class org.apache.flink.table.expressions.Acos
 
Acos$ - Class in org.apache.flink.table.expressions
 
Acos$() - Constructor for class org.apache.flink.table.expressions.Acos$
 
ACOS_DEC() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ACOS_DEC() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
ActionRequestFailureHandler - Interface in org.apache.flink.streaming.connectors.elasticsearch
An implementation of ActionRequestFailureHandler is provided by the user to define how failed ActionRequests should be handled, e.g.
activate(String) - Method in class org.apache.flink.storm.api.FlinkLocalCluster
 
activate() - Method in class org.apache.flink.storm.util.AbstractLineSpout
 
activate() - Method in class org.apache.flink.storm.util.NullTerminatingSpout
 
ACTIVE - Static variable in class org.apache.flink.streaming.runtime.streamstatus.StreamStatus
 
ACTIVE_STATUS - Static variable in class org.apache.flink.streaming.runtime.streamstatus.StreamStatus
 
actor() - Method in interface org.apache.flink.runtime.instance.ActorGateway
Returns the underlying actor with which is communicated
actor() - Method in class org.apache.flink.runtime.instance.AkkaActorGateway
Returns ActorRef of the target actor
actor() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.ResponseArchive
 
ActorGateway - Interface in org.apache.flink.runtime.instance
Interface to abstract the communication with an actor.
ActorGatewayCheckpointResponder - Class in org.apache.flink.runtime.taskmanager
Implementation using ActorGateway to forward the messages.
ActorGatewayCheckpointResponder(ActorGateway) - Constructor for class org.apache.flink.runtime.taskmanager.ActorGatewayCheckpointResponder
 
ActorGatewayKvStateRegistryListener - Class in org.apache.flink.runtime.taskmanager
This implementation uses ActorGateway to forward key-value state notifications to the job manager.
ActorGatewayKvStateRegistryListener(ActorGateway, KvStateServerAddress) - Constructor for class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener
 
ActorGatewayPartitionProducerStateChecker - Class in org.apache.flink.runtime.taskmanager
This implementation uses ActorGateway to trigger the partition state check at the job manager.
ActorGatewayPartitionProducerStateChecker(ActorGateway, FiniteDuration) - Constructor for class org.apache.flink.runtime.taskmanager.ActorGatewayPartitionProducerStateChecker
 
ActorGatewayResultPartitionConsumableNotifier - Class in org.apache.flink.runtime.taskmanager
This implementation uses ActorGateway to notify the job manager about consumable partitions.
ActorGatewayResultPartitionConsumableNotifier(ExecutionContext, ActorGateway, FiniteDuration) - Constructor for class org.apache.flink.runtime.taskmanager.ActorGatewayResultPartitionConsumableNotifier
 
ActorGatewayTaskExecutionStateListener - Class in org.apache.flink.runtime.taskmanager
Implementation using ActorGateway to forward the messages.
ActorGatewayTaskExecutionStateListener(ActorGateway) - Constructor for class org.apache.flink.runtime.taskmanager.ActorGatewayTaskExecutionStateListener
 
ActorGatewayTaskManagerActions - Class in org.apache.flink.runtime.taskmanager
Implementation using ActorGateway to forward the messages.
ActorGatewayTaskManagerActions(ActorGateway) - Constructor for class org.apache.flink.runtime.taskmanager.ActorGatewayTaskManagerActions
 
actorSystemLoader - Variable in class org.apache.flink.client.program.ClusterClient
The actor system used to communicate with the JobManager.
ActorTaskManagerGateway - Class in org.apache.flink.runtime.jobmanager.slots
Implementation of the TaskManagerGateway for ActorGateway.
ActorTaskManagerGateway(ActorGateway) - Constructor for class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway
 
actualModVersion() - Method in exception org.apache.flink.runtime.executiongraph.GlobalModVersionMismatch
 
AdamicAdar<K extends CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.drivers
Driver for AdamicAdar.
AdamicAdar() - Constructor for class org.apache.flink.graph.drivers.AdamicAdar
 
AdamicAdar<K extends CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.similarity
http://social.cs.uiuc.edu/class/cs591kgk/friendsadamic.pdf
AdamicAdar() - Constructor for class org.apache.flink.graph.library.similarity.AdamicAdar
 
AdamicAdar.Result<T> - Class in org.apache.flink.graph.library.similarity
Wraps Tuple3 to encapsulate results from the Adamic-Adar algorithm.
AdaptiveSpanningRecordDeserializer<T extends IOReadableWritable> - Class in org.apache.flink.runtime.io.network.api.serialization
 
AdaptiveSpanningRecordDeserializer() - Constructor for class org.apache.flink.runtime.io.network.api.serialization.AdaptiveSpanningRecordDeserializer
 
add(V) - Method in interface org.apache.flink.api.common.accumulators.Accumulator
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(double) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(long) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(int) - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleCounter
Consider using DoubleCounter.add(double) instead for primitive double values
add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleCounter
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleMaximum
Consider using DoubleMaximum.add(double) instead for primitive double values
add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleMaximum
 
add(Double) - Method in class org.apache.flink.api.common.accumulators.DoubleMinimum
Consider using DoubleMinimum.add(double) instead for primitive double values
add(double) - Method in class org.apache.flink.api.common.accumulators.DoubleMinimum
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.Histogram
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntCounter
Consider using IntCounter.add(int) instead for primitive int values
add(int) - Method in class org.apache.flink.api.common.accumulators.IntCounter
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntMaximum
Consider using IntMaximum.add(int) instead for primitive integer values
add(int) - Method in class org.apache.flink.api.common.accumulators.IntMaximum
 
add(Integer) - Method in class org.apache.flink.api.common.accumulators.IntMinimum
Consider using IntMinimum.add(int) instead for primitive integer values
add(int) - Method in class org.apache.flink.api.common.accumulators.IntMinimum
 
add(T) - Method in class org.apache.flink.api.common.accumulators.ListAccumulator
 
add(Long) - Method in class org.apache.flink.api.common.accumulators.LongCounter
Consider using LongCounter.add(long) instead for primitive long values
add(long) - Method in class org.apache.flink.api.common.accumulators.LongCounter
 
add(Long) - Method in class org.apache.flink.api.common.accumulators.LongMaximum
Consider using LongMaximum.add(long) instead for primitive long values
add(long) - Method in class org.apache.flink.api.common.accumulators.LongMaximum
 
add(Long) - Method in class org.apache.flink.api.common.accumulators.LongMinimum
Consider using LongMinimum.add(long) instead for primitive long values
add(long) - Method in class org.apache.flink.api.common.accumulators.LongMinimum
 
add(T) - Method in class org.apache.flink.api.common.accumulators.SerializedListAccumulator
 
add(T, TypeSerializer<T>) - Method in class org.apache.flink.api.common.accumulators.SerializedListAccumulator
 
add(IN, ACC) - Method in interface org.apache.flink.api.common.functions.AggregateFunction
Adds the given value to the given accumulator.
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
Add a parameter based on its name.
add(Option) - Method in class org.apache.flink.api.java.utils.RequiredParameters
Add a parameter encapsulated in an Option object.
add(T) - Method in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState
 
add(T) - Method in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState
Deprecated.
 
add(V) - Method in class org.apache.flink.contrib.streaming.state.RocksDBListState
 
add(V) - Method in class org.apache.flink.contrib.streaming.state.RocksDBReducingState
 
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(KMeans.Coordinate) - Method in interface org.apache.flink.examples.scala.clustering.KMeans.Coordinate
 
add(ChecksumHashCode.Checksum) - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
 
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(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(Parameter<T>, T) - Method in class org.apache.flink.ml.common.ParameterMap
Adds a new parameter value to the ParameterMap.
add(DistributedRowMatrix) - Method in class org.apache.flink.ml.math.distributed.DistributedRowMatrix
Adds this matrix to another matrix.
add(int, D) - Method in class org.apache.flink.python.api.util.SetCache
Adds the given DataSet to this cache for the given ID.
add(int, U) - Method in class org.apache.flink.python.api.util.SetCache
Adds the given UnsortedGrouping to this cache for the given ID.
add(int, S) - Method in class org.apache.flink.python.api.util.SetCache
Adds the given SortedGrouping to this cache for the given ID.
add(Buffer, int) - Method in class org.apache.flink.runtime.io.network.partition.ResultPartition
Adds a buffer to the subpartition with the given index.
add(Buffer) - Method in class org.apache.flink.runtime.io.network.partition.ResultSubpartition
 
add(IN) - Method in class org.apache.flink.runtime.state.heap.HeapAggregatingState
 
add(T) - Method in class org.apache.flink.runtime.state.heap.HeapFoldingState
Deprecated.
 
add(V) - Method in class org.apache.flink.runtime.state.heap.HeapListState
 
add(V) - Method in class org.apache.flink.runtime.state.heap.HeapReducingState
 
add(Task) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlot
Add the given task to the task slot.
add(T) - Method in class org.apache.flink.runtime.util.EvictingBoundedList
 
add(int) - Method in class org.apache.flink.runtime.util.IntArrayList
 
add(long) - Method in class org.apache.flink.runtime.util.LongArrayList
 
add(V) - Method in class org.apache.flink.runtime.util.LRUCache
 
add(MetricDump) - Method in class org.apache.flink.runtime.webmonitor.metrics.MetricStore
 
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(ActionRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer
Add multiple ActionRequest to the indexer to prepare for sending requests to Elasticsearch.
add(ActionRequest...) - Method in interface org.apache.flink.streaming.connectors.elasticsearch2.RequestIndexer
Deprecated.
 
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(BufferOrEvent) - Method in class org.apache.flink.streaming.runtime.io.BufferSpiller
Adds a buffer or event to the sequence of spilled buffers and events.
add(CRow, Row) - Method in class org.apache.flink.table.runtime.aggregate.AggregateAggFunction
 
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
 
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.
addAll(AggregatorRegistry) - Method in class org.apache.flink.api.common.aggregators.AggregatorRegistry
 
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(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<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(Collection<? extends V>) - Method in class org.apache.flink.types.ListValue
 
addAll(int, Collection<? extends V>) - Method in class org.apache.flink.types.ListValue
 
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
 
addAndLock(String, T) - Method in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore
Creates a state handle, stores it in ZooKeeper and locks it.
addAppConfigurationEntry(String, AppConfigurationEntry...) - Method in class org.apache.flink.runtime.security.DynamicConfiguration
Add entries for the given application name.
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
 
addBlob(BlobKey) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds the BLOB referenced by the key to the JobGraph's dependencies.
addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addBroadcastConnection(String, DagConnection) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
Adds the broadcast connection identified by the given name to this node.
addBroadcastCost(EstimateProvider, int, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addBroadcastCost(EstimateProvider, int, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addBroadcastInputToGroup(int) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addBroadcastSet(String, DataSet<?>) - Method in class org.apache.flink.graph.pregel.VertexCentricConfiguration
Adds a data set as a broadcast set to the compute function.
addBroadcastSetForApplyFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration
Adds a data set as a broadcast set to the apply function.
addBroadcastSetForGatherFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration
Adds a data set as a broadcast set to the gather function.
addBroadcastSetForGatherFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration
Adds a data set as a broadcast set to the gather function.
addBroadcastSetForScatterFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration
Adds a data set as a broadcast set to the scatter function.
addBroadcastSetForSumFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration
Adds a data set as a broadcast set to the sum function.
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
 
addCheckpoint(CompletedCheckpoint) - Method in interface org.apache.flink.runtime.checkpoint.CompletedCheckpointStore
Adds a CompletedCheckpoint instance to the list of completed checkpoints.
addCheckpoint(CompletedCheckpoint) - Method in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
 
addCheckpoint(CompletedCheckpoint) - Method in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore
Synchronously writes the new checkpoints to ZooKeeper and asynchronously removes older ones.
addChoices(String...) - Method in class org.apache.flink.graph.drivers.parameter.ChoiceParameter
Add additional choices.
addClass(Class<?>) - Method in class org.apache.flink.runtime.util.JarFileCreator
Adds a Class object to the set of classes which shall eventually be included in the jar file.
addClosedBranch(OptimizerNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
addClosedBranches(Set<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
addColumn(String, String, Class<?>) - Method in class org.apache.flink.addons.hbase.HBaseTableSource
Adds a column defined by family, qualifier, and type to the table schema.
addComparatorField(int, TypeComparator<?>) - Method in interface org.apache.flink.api.common.typeutils.CompositeType.TypeComparatorBuilder
 
addConfiguration(Configuration) - Method in class org.apache.flink.runtime.minicluster.MiniClusterConfiguration
 
addConsumer(JobEdge) - Method in class org.apache.flink.runtime.jobgraph.IntermediateDataSet
 
addContainerMapping(String, TaggedValue, ModifiedASMFrame) - Method in class org.apache.flink.api.java.sca.TaggedValue
 
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, TwoInputStreamOperator<IN1, IN2, OUT>, TypeInformation<IN1>, TypeInformation<IN2>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addCosts(Costs) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given costs to these costs.
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.
addDataSink(GenericDataSinkBase<?>) - Method in class org.apache.flink.api.common.Plan
Adds a data sink to the set of sinks in this program.
addDecoRuleSet(RuleSet) - Method in class org.apache.flink.table.calcite.CalciteConfigBuilder
Appends the given decoration rule set to the built-in rule set.
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<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.api.scala.ExecutionEnvironment
Registers a default serializer for the given class and its sub-classes at Kryo.
addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.api.scala.ExecutionEnvironment
Registers a default serializer for the given class and its sub-classes at Kryo.
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.streaming.api.scala.StreamExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
Adds a new Kryo default serializer to the Runtime.
addDimension(long, boolean) - Method in class org.apache.flink.graph.generator.GridGraph
Required configuration for each dimension of the graph.
addDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the costs for disk to the current disk costs for this Costs object.
addEdge(Vertex<K, VV>, Vertex<K, VV>, EV) - Method in class org.apache.flink.graph.Graph
Adds the given edge to the graph.
addEdge(Vertex<K, VV>, Vertex<K, VV>, EV) - Method in class org.apache.flink.graph.scala.Graph
Adds the given edge to the graph.
addEdge(Integer, Integer, int) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addEdges(List<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph
Adds the given list edges to the graph.
addEdges(List<Edge<K, EV>>) - Method in class org.apache.flink.graph.scala.Graph
Adds the given list edges to the graph.
addElementToLatestPane(Type) - Method in class org.apache.flink.streaming.runtime.operators.windowing.AbstractKeyedTimePanes
 
addElementToLatestPane(Type) - Method in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes
 
addElementToLatestPane(Type) - Method in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingKeyedTimePanes
 
addFeedbackEdge(StreamTransformation<F>) - Method in class org.apache.flink.streaming.api.transformations.CoFeedbackTransformation
Adds a feedback edge.
addFeedbackEdge(StreamTransformation<T>) - Method in class org.apache.flink.streaming.api.transformations.FeedbackTransformation
Adds a feedback edge.
addField(Integer) - Method in class org.apache.flink.api.common.operators.util.FieldList
 
addField(Integer) - Method in class org.apache.flink.api.common.operators.util.FieldSet
 
addField(Value) - Method in class org.apache.flink.types.Record
 
addFields(int...) - Method in class org.apache.flink.api.common.operators.util.FieldList
 
addFields(FieldSet) - Method in class org.apache.flink.api.common.operators.util.FieldList
 
addFields(int...) - Method in class org.apache.flink.api.common.operators.util.FieldSet
 
addFields(FieldSet) - Method in class org.apache.flink.api.common.operators.util.FieldSet
 
addFile(File, String) - Method in class org.apache.flink.mesos.util.MesosArtifactServer
Adds a file to the artifact server.
addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addFirstInput(Operator<IN1>...) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addFirstInputs(List<Operator<IN1>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addForwardedField(int, int, int) - Method in class org.apache.flink.api.common.operators.DualInputSemanticProperties
Adds, to the existing information, a field that is forwarded directly from the source record(s) in the first input to the destination record(s).
addForwardedField(int, int) - Method in class org.apache.flink.api.common.operators.SingleInputSemanticProperties
Adds, to the existing information, a field that is forwarded directly from the source record(s) to the destination record(s).
addForwardedField(int, int) - Method in class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties
 
addGarbageCollectorName(String) - Method in class org.apache.flink.runtime.webmonitor.metrics.MetricStore.TaskManagerMetricStore
 
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.yarn.cli.FlinkYarnCLI
 
addGeneralOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
 
addGlobalProperties(RequestedGlobalProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
addGroup(int) - Method in class org.apache.flink.metrics.groups.UnregisteredMetricsGroup
 
addGroup(String) - Method in class org.apache.flink.metrics.groups.UnregisteredMetricsGroup
 
addGroup(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(int) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
 
addGroup(String) - Method in class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
 
addGroup(int) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addGroup(String) - Method in class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup
 
addGroupExpr(SqlNode) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter.AggConverter
 
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
 
addHeuristicCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the given heuristic CPU cost to the current heuristic CPU cost for this Costs object.
addHeuristicDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the heuristic costs for disk to the current heuristic disk costs for this Costs object.
addHeuristicNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the heuristic costs for network to the current heuristic network costs for this Costs object.
addHiddenChoices(String...) - Method in class org.apache.flink.graph.drivers.parameter.ChoiceParameter
Add additional hidden choices.
addHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addId(UId) - Method in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase
Adds an ID to be stored with the current checkpoint.
addIfOpen(E) - Method in class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Tries to add an element to the queue, if the queue is still open.
addIgnore(IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addIgnore(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addInEdge(StreamEdge) - Method in class org.apache.flink.streaming.api.graph.StreamNode
 
addInput(Operator<IN>...) - Method in class org.apache.flink.api.common.operators.GenericDataSinkBase
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInput(Operator<IN>...) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInput(List<Operator<IN>>) - Method in class org.apache.flink.api.common.operators.SingleInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInputs(List<? extends Operator<IN>>) - Method in class org.apache.flink.api.common.operators.GenericDataSinkBase
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addInputToGroup(int) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addInstanceListener(InstanceListener) - Method in class org.apache.flink.runtime.instance.InstanceManager
 
addInterestingProperties(InterestingProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
addIOMetrics(AccessExecution, MetricFetcher, String, String) - Method in class org.apache.flink.runtime.webmonitor.utils.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.
addJob(JobGraph) - Method in class org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup
 
addJob(JobID) - Method in class org.apache.flink.runtime.resourcemanager.JobLeaderIdService
Add a job to be monitored to retrieve the job leader id.
addJob(JobID, String) - Method in class org.apache.flink.runtime.taskexecutor.JobLeaderService
Add the given job to be monitored.
addLibFolderToShipFiles(Collection<File>) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor
 
addList(List<T>) - Method in class org.apache.flink.util.UnionIterator
 
addListener(EventListener<Buffer>) - Method in interface org.apache.flink.runtime.io.network.buffer.BufferProvider
Adds a buffer availability listener to the buffer provider.
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
 
addLogicalOptRuleSet(RuleSet) - Method in class org.apache.flink.table.calcite.CalciteConfigBuilder
Appends the given optimization rule set to the built-in rule set.
AddLongValue() - Constructor for class org.apache.flink.graph.utils.GraphUtils.AddLongValue
 
addMasterHook(MasterTriggerRestoreHook<?>) - Method in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
Adds the given master hook to the checkpoint coordinator.
addMasterState(MasterState) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
Adds a master state (state generated on the checkpoint coordinator) to the pending checkpoint.
addMetric(DMetric) - Method in class org.apache.flink.metrics.datadog.DSeries
 
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.
addNameSpace(Set<String>) - Method in class org.apache.flink.runtime.util.DependencyVisitor
 
addNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs
Adds the costs for network to the current network costs for this Costs object.
addNode(Integer, String, Class<? extends AbstractInvokable>, StreamOperator<?>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addNormRuleSet(RuleSet) - Method in class org.apache.flink.table.calcite.CalciteConfigBuilder
Appends the given normalization rule set to the built-in rule set.
addOffsetStateGauge(MetricGroup) - Method in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher
Add current and committed offsets to metric group
addOperator(String) - Method in class org.apache.flink.runtime.metrics.groups.TaskMetricGroup
 
addOperator(StreamTransformation<?>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds an operator to the list of operators that should be executed when calling StreamExecutionEnvironment.execute().
addOperator(Integer, String, StreamOperator<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
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.
addOutputSelector(Integer, OutputSelector<T>) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addOutputSelector(OutputSelector<?>) - Method in class org.apache.flink.streaming.api.graph.StreamNode
 
addOutputShipStrategy(ShipStrategyType) - Method in class org.apache.flink.runtime.operators.util.TaskConfig
 
addPackage(String) - Method in class org.apache.flink.runtime.util.JarFileCreator
Manually specify the package of the dependencies.
addPackages(String[]) - Method in class org.apache.flink.runtime.util.JarFileCreator
Manually specify the packages of the dependencies.
addParameter(Parameter<?>) - Method in class org.apache.flink.graph.drivers.parameter.ParameterizedBase
Adds a parameter to the list.
addPath(Path, Path) - Method in class org.apache.flink.mesos.util.MesosArtifactServer
Adds a path to the artifact server.
addPhysicalOptRuleSet(RuleSet) - Method in class org.apache.flink.table.calcite.CalciteConfigBuilder
Appends the given optimization rule set to the built-in rule set.
addProceed(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
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
 
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 interface org.apache.flink.runtime.io.network.api.serialization.RecordSerializer
Starts serializing and copying the given record to the target buffer (if available).
addRecord(T) - Method in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer
Serializes the complete record to an intermediate data serialization buffer and starts copying it to the target buffer (if available).
addRecord(T) - Method in class org.apache.flink.runtime.operators.sort.LargeRecordHandler
 
addRequest(R) - Method in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
 
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 - Variable in class org.apache.flink.core.memory.MemorySegment
The address to the data, relative to the heap memory byte array.
address() - Method in class org.apache.flink.runtime.akka.RemoteAddressExtensionImplementation
 
address() - Method in class org.apache.flink.runtime.messages.JobClientMessages.JobManagerLeaderAddress
 
address() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerLocation
Returns the network address the instance's task manager binds its sockets to.
ADDRESS_OPTION - Static variable in class org.apache.flink.client.cli.CliFrontendParser
 
addressLimit - Variable in class org.apache.flink.core.memory.MemorySegment
The address one byte after the last addressable byte.
addressString() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerLocation
Gets the IP address where the TaskManager operates.
addReusableArray(Class<?>, int) - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable array to the member area of the generated Function.
addReusableConstructor(Seq<Class<?>>) - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable constructor statement with the given parameter types.
addReusableDate() - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable date to the beginning of the SAM of the generated Function.
addReusableDecimal(BigDecimal) - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable BigDecimal to the member area of the generated Function.
addReusableFunction(UserDefinedFunction) - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable UserDefinedFunction to the member area of the generated Function.
addReusableLocalTime() - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable local time to the beginning of the SAM of the generated Function.
addReusableLocalTimestamp() - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable local timestamp to the beginning of the SAM of the generated Function.
addReusableOutRecord(TypeInformation<?>) - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable output record to the member area of the generated Function.
addReusablePrivateFieldAccess(Class<?>, String) - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable Field to the member area of the generated Function.
addReusableTime() - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable time to the beginning of the SAM of the generated Function.
addReusableTimestamp() - Method in class org.apache.flink.table.codegen.CodeGenerator
Adds a reusable timestamp to the beginning of the SAM of the generated Function.
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.DefaultCLI
 
addRunOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnCLI
 
addRunOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli
 
AddScoreToVertexValuesMapper() - Constructor for class org.apache.flink.graph.library.CommunityDetection.AddScoreToVertexValuesMapper
 
addSecondInput(Operator<IN2>...) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addSecondInputs(List<Operator<IN2>>) - Method in class org.apache.flink.api.common.operators.DualInputOperator
Deprecated.
This method will be removed in future versions. Use the Union operator instead.
addSemanticPropertiesHints() - Method in class org.apache.flink.api.java.sca.UdfAnalyzer
 
addSharedSlotAndAllocateSubSlot(SharedSlot, Locality, JobVertexID) - Method in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment
 
addSharedSlotAndAllocateSubSlot(SharedSlot, Locality, CoLocationConstraint) - Method in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment
 
addShipFiles(List<File>) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor
 
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, StreamOperator<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addSink(SinkFunction<T>) - Method in class org.apache.flink.streaming.api.scala.DataStream
Adds the given sink to this DataStream.
addSink(Function1<T, BoxedUnit>) - Method in class org.apache.flink.streaming.api.scala.DataStream
Adds the given sink to this DataStream.
addSink(DataStream<IN>) - Static method in class org.apache.flink.streaming.connectors.cassandra.CassandraSink
Writes a DataStream into a Cassandra database.
addSource(SourceFunction<OUT>) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Adds a Data Source to the streaming topology.
addSource(SourceFunction<OUT>, String) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Ads 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, StreamOperator<OUT>, TypeInformation<IN>, TypeInformation<OUT>, String) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
 
addSource(SourceFunction<T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
Create a DataStream using a user defined source function for arbitrary source functionality.
addSource(Function1<SourceFunction.SourceContext<T>, BoxedUnit>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
Create a DataStream using a user defined source function for arbitrary source functionality.
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.
addSqlOperatorTable(SqlOperatorTable) - Method in class org.apache.flink.table.calcite.CalciteConfigBuilder
Appends the given table to the built-in SQL operator table.
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.
addState(State<T>) - Method in class org.apache.flink.cep.nfa.NFA
 
addStates(Collection<State<T>>) - Method in class org.apache.flink.cep.nfa.NFA
 
addStateTransition(StateTransitionAction, State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addStreamedNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addStreamedNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.AmbiguousTableSourceConverterException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.CatalogAlreadyExistException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.CatalogNotExistException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.ExpressionParserException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.ExternalCatalogAlreadyExistException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.ExternalCatalogNotExistException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.NoMatchedTableSourceConverterException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.SqlParserException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.TableAlreadyExistException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.TableException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.TableNotExistException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.UnresolvedException
 
addSuppressed(Throwable) - Static method in exception org.apache.flink.table.api.ValidationException
 
addTake(State<T>, IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addTake(IterativeCondition<T>) - Method in class org.apache.flink.cep.nfa.State
 
addTask(JobVertexID, ExecutionAttemptID, String, int, int) - Method in class org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup
 
addTask(Task) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Add the given task to the slot identified by the task's allocation id.
addTaskForJob(JobID, String, JobVertexID, ExecutionAttemptID, String, int, int) - Method in class org.apache.flink.runtime.metrics.groups.TaskManagerMetricGroup
 
addToDefaults(String, String) - Method in class org.apache.flink.api.java.utils.ParameterTool
 
addToEnvironment(Map<String, String>, String, String) - Static method in class org.apache.flink.yarn.Utils
Copied method from org.apache.hadoop.yarn.util.Apps It was broken by YARN-1824 (2.4.0) and fixed for 2.4.1 by https://issues.apache.org/jira/browse/YARN-1931
addToMessageDigest(MessageDigest) - Method in class org.apache.flink.runtime.blob.BlobKey
Adds the BLOB key to the given MessageDigest.
addType(int, X) - Method in class org.apache.flink.optimizer.postpass.AbstractSchema
 
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.
addVertex(Vertex<K, VV>) - Method in class org.apache.flink.graph.Graph
Adds the input vertex to the graph.
addVertex(Vertex<K, VV>) - Method in class org.apache.flink.graph.scala.Graph
Adds the input vertex to the graph.
addVertex(JobVertex) - Method in class org.apache.flink.runtime.jobgraph.JobGraph
Adds a new task vertex to the job graph if it is not already included.
addVertex(JobVertex) - Method in class org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup
 
addVertexToGroup(JobVertexID) - 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.
addVertices(List<Vertex<K, VV>>) - Method in class org.apache.flink.graph.scala.Graph
Adds the list of vertices, passed as input, to the graph.
addVirtualPartitionNode(Integer, Integer, StreamPartitioner<?>) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Adds a new virtual node that is used to connect a downstream vertex to an input with a certain partitioning.
addVirtualSelectNode(Integer, Integer, List<String>) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Adds a new virtual node that is used to connect a downstream vertex to only the outputs with the selected names.
addVirtualSideOutputNode(Integer, Integer, OutputTag) - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Adds a new virtual node that is used to connect a downstream vertex to only the outputs with the selected side-output OutputTag.
addWindow(W, MergingWindowSet.MergeFunction<W>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.MergingWindowSet
Adds a new Window to the set of in-flight windows.
AdjacencyList(long, long[]) - Constructor for class org.apache.flink.examples.scala.graph.PageRankBasic.AdjacencyList
 
AdjacencyList$() - Constructor for class org.apache.flink.examples.scala.graph.PageRankBasic.AdjacencyList$
 
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.
adjustTop() - Method in class org.apache.flink.runtime.operators.sort.PartialOrderPriorityQueue
Should be called when the Object at top changes values.
adjustType(SqlValidator, SqlCall, RelDataType) - Static method in class org.apache.flink.table.functions.TimeMaterializationSqlFunction
 
adjustType(SqlValidator, SqlCall, RelDataType) - Static method in class org.apache.flink.table.functions.utils.AggSqlFunction
 
adjustType(SqlValidator, SqlCall, RelDataType) - Static method in class org.apache.flink.table.functions.utils.ScalarSqlFunction
 
adjustType(SqlValidator, SqlCall, RelDataType) - Static method in class org.apache.flink.table.functions.utils.TableSqlFunction
 
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.
advanceTime(NFA<IN>, long) - Method in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator
Advances the time for the given NFA to the given timestamp.
advanceTime(NFA<IN>, long) - Method in class org.apache.flink.cep.operator.KeyedCEPPatternOperator
 
advanceTime(NFA<IN>, long) - Method in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator
 
advanceWatermark(long) - Method in class org.apache.flink.streaming.api.operators.HeapInternalTimerService
 
afterTableFunction(SqlToRelConverter.Blackboard, SqlCall, LogicalTableFunctionScan) - Method in class org.apache.calcite.sql2rel.SqlToRelConverter
 
agg() - Method in class org.apache.flink.table.expressions.OverCall
 
agg() - Method in class org.apache.flink.table.expressions.UnresolvedOverCall
 
AggConverter(SqlToRelConverter.Blackboard, SqlSelect) - Constructor for class org.apache.calcite.sql2rel.SqlToRelConverter.AggConverter
Creates an AggConverter.
AggFunctionCall - Class in org.apache.flink.table.expressions
 
AggFunctionCall(AggregateFunction<?, ?>, Seq<Expression>) - Constructor for class org.apache.flink.table.expressions.AggFunctionCall
 
AggFunctionCall$ - Class in org.apache.flink.table.expressions
 
AggFunctionCall$() - Constructor for class org.apache.flink.table.expressions.AggFunctionCall$
 
aggregate(T) - Method in interface org.apache.flink.api.common.aggregators.Aggregator
Aggregates the given element.
aggregate(DoubleValue) - Method in class org.apache.flink.api.common.aggregators.DoubleSumAggregator
 
aggregate(double) - Method in class org.apache.flink.api.common.aggregators.DoubleSumAggregator
Adds the given value to the current aggregate.
aggregate(LongValue) - Method in class org.apache.flink.api.common.aggregators.LongSumAggregator
 
aggregate(long) - Method in class org.apache.flink.api.common.aggregators.LongSumAggregator
Adds the given value to the current aggregate.
aggregate(long) - Method in class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator
 
aggregate(LongValue) - Method in class org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator
 
aggregate(T) - Method in class org.apache.flink.api.java.aggregation.AggregationFunction
 
aggregate(U) - Method in class org.apache.flink.api.java.aggregation.MaxAggregationFunction.ImmutableMaxAgg
 
aggregate(U) - Method in class org.apache.flink.api.java.aggregation.MaxAggregationFunction.MutableMaxAgg
 
aggregate(U) - Method in class org.apache.flink.api.java.aggregation.MinAggregationFunction.ImmutableMinAgg
 
aggregate(U) - Method in class org.apache.flink.api.java.aggregation.MinAggregationFunction.MutableMinAgg
 
aggregate(Byte) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.ByteSumAgg
 
aggregate(ByteValue) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.ByteValueSumAgg
 
aggregate(Double) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.DoubleSumAgg
 
aggregate(DoubleValue) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.DoubleValueSumAgg
 
aggregate(Float) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.FloatSumAgg
 
aggregate(FloatValue) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.FloatValueSumAgg
 
aggregate(Integer) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.IntSumAgg
 
aggregate(IntValue) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.IntValueSumAgg
 
aggregate(Long) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.LongSumAgg
 
aggregate(LongValue) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.LongValueSumAgg
 
aggregate(Short) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.ShortSumAgg
 
aggregate(ShortValue) - Method in class org.apache.flink.api.java.aggregation.SumAggregationFunction.ShortValueSumAgg
 
aggregate(Aggregations, int) - Method in class org.apache.flink.api.java.DataSet
Applies an Aggregate transformation on a non-grouped Tuple DataSet.
Note: Only Tuple DataSets can be aggregated. The transformation applies a built-in Aggregation on a specified field of a Tuple DataSet.
aggregate(Aggregations, int) - Method in class org.apache.flink.api.java.operators.UnsortedGrouping
Applies an Aggregate transformation on a grouped Tuple DataSet.
Note: Only Tuple DataSets can be aggregated. The transformation applies a built-in Aggregation on a specified field of a Tuple group.
aggregate(T) - Method in interface org.apache.flink.api.java.summarize.aggregation.Aggregator
Add a value to the current aggregation
aggregate(Boolean) - Method in class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator
 
aggregate(Double) - Method in class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MaxDoubleAggregator
 
aggregate(Double) - Method in class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.MinDoubleAggregator
 
aggregate(Double) - Method in class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.SumDoubleAggregator
 
aggregate(Float) - Method in class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MaxFloatAggregator
 
aggregate(Float) - Method in class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.MinFloatAggregator
 
aggregate(Float) - Method in class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.SumFloatAggregator
 
aggregate(Integer) - Method in class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MaxIntegerAggregator
 
aggregate(Integer) - Method in class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.MinIntegerAggregator
 
aggregate(Integer) - Method in class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.SumIntegerAggregator
 
aggregate(Long) - Method in class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MaxLongAggregator
 
aggregate(Long) - Method in class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.MinLongAggregator
 
aggregate(Long) - Method in class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.SumLongAggregator
 
aggregate(T) - Method in class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator
Add a value to the current aggregation
aggregate(Object) - Method in class org.apache.flink.api.java.summarize.aggregation.ObjectSummaryAggregator
 
aggregate(Short) - Method in class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MaxShortAggregator
 
aggregate(Short) - Method in class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.MinShortAggregator
 
aggregate(Short) - Method in class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.SumShortAggregator
 
aggregate(String) - Method in class org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregator
 
aggregate(Tuple) - Method in class org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator
 
aggregate(VT) - Method in class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator
 
aggregate(Aggregations, int) - Static method in class org.apache.flink.api.scala.CrossDataSet
 
aggregate(Aggregations, String) - Static method in class org.apache.flink.api.scala.CrossDataSet
 
aggregate(Aggregations, int) - Method in class org.apache.flink.api.scala.DataSet
Creates a new DataSet by aggregating the specified tuple field using the given aggregation function.
aggregate(Aggregations, String) - Method in class org.apache.flink.api.scala.DataSet
Creates a new DataSet by aggregating the specified field using the given aggregation function.
aggregate(Aggregations, String) - Method in class org.apache.flink.api.scala.GroupedDataSet
Creates a new DataSet by aggregating the specified tuple field using the given aggregation function.
aggregate(Aggregations, int) - Method in class org.apache.flink.api.scala.GroupedDataSet
Creates a new DataSet by aggregating the specified field using the given aggregation function.
aggregate(AggregateFunction<T, ACC, R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given AggregateFunction to each window.
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given AggregateFunction to each window.
aggregate(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessAllWindowFunction<V, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessAllWindowFunction<V, R, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregationFunction<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
 
aggregate(AggregateFunction<T, ACC, R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given aggregation function to each window.
aggregate(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessAllWindowFunction<V, R, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, Function3<W, Iterable<V>, Collector<R>, BoxedUnit>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given window function to each window.
aggregate(AggregationFunction.AggregationType, int) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
 
aggregate(AggregateFunction<T, ACC, R>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given aggregation function to each window and key.
aggregate(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, Function4<K, W, Iterable<V>, Collector<R>, BoxedUnit>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given window function to each window.
aggregate(AggregateFunction<T, ACC, V>, ProcessWindowFunction<V, R, K, W>, TypeInformation<ACC>, TypeInformation<V>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given window function to each window.
aggregate(AggregationFunction.AggregationType, int) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
 
aggregate(LogicalWindow, RelBuilder.GroupKey, Seq<FlinkRelBuilder.NamedWindowProperty>, Iterable<RelBuilder.AggCall>) - Method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
Aggregate - Class in org.apache.flink.table.plan.logical
 
Aggregate(Seq<Expression>, Seq<NamedExpression>, LogicalNode) - Constructor for class org.apache.flink.table.plan.logical.Aggregate
 
Aggregate$ - Class in org.apache.flink.table.plan.logical
 
Aggregate$() - Constructor for class org.apache.flink.table.plan.logical.Aggregate$
 
AggregateAggFunction - Class in org.apache.flink.table.runtime.aggregate
Aggregate Function used for the aggregate operator in WindowedStream
AggregateAggFunction(GeneratedAggregationsFunction) - Constructor for class org.apache.flink.table.runtime.aggregate.AggregateAggFunction
 
AggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R> - Class in org.apache.flink.streaming.api.functions.windowing
AggregateApplyAllWindowFunction(AggregateFunction<T, ACC, V>, AllWindowFunction<V, R, W>) - Constructor for class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction
 
AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R> - Class in org.apache.flink.streaming.api.functions.windowing
AggregateApplyWindowFunction(AggregateFunction<T, ACC, V>, WindowFunction<V, R, K, W>) - Constructor for class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction
 
aggregateBuffer() - Method in class org.apache.flink.table.runtime.aggregate.DataSetTumbleTimeWindowAggReduceGroupFunction
 
aggregateCall(SqlAggFunction, boolean, RexNode, String, RexNode[]) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
aggregateCall(SqlAggFunction, boolean, RexNode, String, Iterable<? extends RexNode>) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
AggregateDataSet<T> - Class in org.apache.flink.api.scala
The result of DataSet.aggregate.
AggregateDataSet(ScalaAggregateOperator<T>, ClassTag<T>) - Constructor for class org.apache.flink.api.scala.AggregateDataSet
 
aggregateExpressions() - Method in class org.apache.flink.table.plan.logical.Aggregate
 
aggregateExpressions() - Method in class org.apache.flink.table.plan.logical.WindowAggregate
 
AggregateFunction<IN,ACC,OUT> - Interface in org.apache.flink.api.common.functions
The AggregateFunction is a flexible aggregation function, characterized by the following features: The aggregates may use different types for input values, intermediate aggregates, and result type, to support a wide range of aggregation types. Support for distributive aggregations: Different intermediate aggregates can be merged together, to allow for pre-aggregation/final-aggregation optimizations.
aggregateFunction() - Method in class org.apache.flink.table.expressions.AggFunctionCall
 
aggregateFunction() - Method in class org.apache.flink.table.expressions.UDAGGExpression
 
AggregateFunction<T,ACC> - Class in org.apache.flink.table.functions
Base class for User-Defined Aggregates.
AggregateFunction() - Constructor for class org.apache.flink.table.functions.AggregateFunction
 
AggregateOperator<IN> - Class in org.apache.flink.api.java.operators
This operator represents the application of a "aggregate" operation on a data set, and the result data set produced by the function.
AggregateOperator(DataSet<IN>, Aggregations, int, String) - Constructor for class org.apache.flink.api.java.operators.AggregateOperator
Non grouped aggregation
AggregateOperator(Grouping<IN>, Aggregations, int, String) - Constructor for class org.apache.flink.api.java.operators.AggregateOperator
Grouped aggregation
AggregateOperator.AggregatingUdf<T extends Tuple> - Class in org.apache.flink.api.java.operators
 
aggregateUserAccumulators() - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
Merges all accumulator results from the tasks previously executed in the Executions.
AggregateUtil - Class in org.apache.flink.table.runtime.aggregate
 
AggregateUtil() - Constructor for class org.apache.flink.table.runtime.aggregate.AggregateUtil
 
AggregateUtil$ - Class in org.apache.flink.table.runtime.aggregate
 
AggregateUtil$() - Constructor for class org.apache.flink.table.runtime.aggregate.AggregateUtil$
 
AggregatingKeyedTimePanes<Type,Key> - Class in org.apache.flink.streaming.runtime.operators.windowing
Key/value map organized in panes for aggregating windows (with a reduce function).
AggregatingKeyedTimePanes(KeySelector<Type, Key>, ReduceFunction<Type>) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AggregatingKeyedTimePanes
 
AggregatingProcessingTimeWindowOperator<KEY,IN> - Class in org.apache.flink.streaming.runtime.operators.windowing
Deprecated.
Deprecated in favour of the generic WindowOperator. This was an optimized implementation used for aligned windows.
AggregatingProcessingTimeWindowOperator(ReduceFunction<IN>, KeySelector<IN, KEY>, TypeSerializer<KEY>, TypeSerializer<IN>, long, long) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AggregatingProcessingTimeWindowOperator
Deprecated.
 
aggregatingSelectScope - Variable in class org.apache.calcite.sql2rel.SqlToRelConverter.AggConverter
 
AggregatingState<IN,OUT> - Interface in org.apache.flink.api.common.state
State interface for aggregating state, based on an AggregateFunction.
AggregatingStateDescriptor<IN,ACC,OUT> - Class in org.apache.flink.api.common.state
A StateDescriptor for AggregatingState.
AggregatingStateDescriptor(String, AggregateFunction<IN, ACC, OUT>, Class<ACC>) - Constructor for class org.apache.flink.api.common.state.AggregatingStateDescriptor
Creates a new state descriptor with the given name, function, and type.
AggregatingStateDescriptor(String, AggregateFunction<IN, ACC, OUT>, TypeInformation<ACC>) - Constructor for class org.apache.flink.api.common.state.AggregatingStateDescriptor
Creates a new ReducingStateDescriptor with the given name and default value.
AggregatingStateDescriptor(String, AggregateFunction<IN, ACC, OUT>, TypeSerializer<ACC>) - Constructor for class org.apache.flink.api.common.state.AggregatingStateDescriptor
Creates a new ValueStateDescriptor with the given name and default value.
AggregatingUdf(AggregationFunction<Object>[], int[]) - Constructor for class org.apache.flink.api.java.operators.AggregateOperator.AggregatingUdf
 
AggregatingUdf(TypeInformation<T>, AggregationFunction<Object>[], int[]) - Constructor for class org.apache.flink.api.scala.operators.ScalaAggregateOperator.AggregatingUdf
 
Aggregation - Class in org.apache.flink.table.expressions
 
Aggregation() - Constructor for class org.apache.flink.table.expressions.Aggregation
 
AggregationFunction<T> - Class in org.apache.flink.api.java.aggregation
 
AggregationFunction() - Constructor for class org.apache.flink.api.java.aggregation.AggregationFunction
 
AggregationFunction<T> - Class in org.apache.flink.streaming.api.functions.aggregation
Holder class for aggregation types that can be used on a windowed stream or keyed stream.
AggregationFunction() - Constructor for class org.apache.flink.streaming.api.functions.aggregation.AggregationFunction
 
AggregationFunction.AggregationType - Enum in org.apache.flink.streaming.api.functions.aggregation
Aggregation types that can be used on a windowed stream or keyed stream.
AggregationFunctionFactory - Interface in org.apache.flink.api.java.aggregation
 
Aggregations - Enum in org.apache.flink.api.java.aggregation
 
aggregationToString(RelDataType, int[], RelDataType, Seq<Pair<AggregateCall, String>>, Seq<FlinkRelBuilder.NamedWindowProperty>) - Method in interface org.apache.flink.table.plan.nodes.CommonAggregate
 
aggregationToString(RelDataType, int[], RelDataType, Seq<Pair<AggregateCall, String>>, Seq<FlinkRelBuilder.NamedWindowProperty>) - Static method in class org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate
 
aggregationToString(RelDataType, RelDataType, Seq<Pair<AggregateCall, String>>) - Method in interface org.apache.flink.table.plan.nodes.OverAggregate
 
Aggregator<T extends Value> - Interface in org.apache.flink.api.common.aggregators
Aggregators are a means of aggregating values across parallel instances of a function.
Aggregator<T,R> - Interface in org.apache.flink.api.java.summarize.aggregation
Generic interface for aggregation
AGGREGATOR_NAME - Static variable in class org.apache.flink.runtime.iterative.convergence.WorksetEmptyConvergenceCriterion
 
AggregatorRegistry - Class in org.apache.flink.api.common.aggregators
A registry for iteration Aggregators.
AggregatorRegistry() - Constructor for class org.apache.flink.api.common.aggregators.AggregatorRegistry
 
AggregatorWithName<T extends Value> - Class in org.apache.flink.api.common.aggregators
Simple utility class holding an Aggregator with the name it is registered under.
AggregatorWithName(String, Aggregator<T>) - Constructor for class org.apache.flink.api.common.aggregators.AggregatorWithName
Creates a new instance for the given aggregator and name.
AggSqlFunction - Class in org.apache.flink.table.functions.utils
Calcite wrapper for user-defined aggregate functions.
AggSqlFunction(String, AggregateFunction<?, ?>, TypeInformation<?>, FlinkTypeFactory, boolean) - Constructor for class org.apache.flink.table.functions.utils.AggSqlFunction
 
AggSqlFunction$ - Class in org.apache.flink.table.functions.utils
 
AggSqlFunction$() - Constructor for class org.apache.flink.table.functions.utils.AggSqlFunction$
 
AKKA_ASK_TIMEOUT - Static variable in class org.apache.flink.configuration.AkkaOptions
Timeout for akka ask calls
AKKA_ASK_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Timeout for all blocking calls on the cluster side
AKKA_CLIENT_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Timeout for all blocking calls on the client side
AKKA_DISPATCHER_THROUGHPUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Maximum number of messages until another actor is executed by the same thread
AKKA_FRAMESIZE - Static variable in class org.apache.flink.configuration.ConfigConstants
Maximum framesize of akka messages
AKKA_JVM_EXIT_ON_FATAL_ERROR - Static variable in class org.apache.flink.configuration.ConfigConstants
Exit JVM on fatal Akka errors
AKKA_LOG_LIFECYCLE_EVENTS - Static variable in class org.apache.flink.configuration.ConfigConstants
Log lifecycle events
AKKA_LOOKUP_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Timeout for all blocking calls that look up remote actors
AKKA_SSL_ENABLED - Static variable in class org.apache.flink.configuration.ConfigConstants
Override SSL support for the Akka transport
AKKA_STARTUP_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Timeout for the startup of the actor system
AKKA_TCP_TIMEOUT - Static variable in class org.apache.flink.configuration.AkkaOptions
The Akka tcp connection timeout.
AKKA_TCP_TIMEOUT - Static variable in class org.apache.flink.configuration.ConfigConstants
Akka TCP timeout
AKKA_TRANSPORT_HEARTBEAT_INTERVAL - Static variable in class org.apache.flink.configuration.ConfigConstants
Heartbeat interval of the transport failure detector
AKKA_TRANSPORT_HEARTBEAT_PAUSE - Static variable in class org.apache.flink.configuration.ConfigConstants
Allowed heartbeat pause for the transport failure detector
AKKA_TRANSPORT_THRESHOLD - Static variable in class org.apache.flink.configuration.ConfigConstants
Detection threshold of transport failure detector
AKKA_WATCH_HEARTBEAT_INTERVAL - Static variable in class org.apache.flink.configuration.AkkaOptions
The Akka death watch heartbeat interval.
AKKA_WATCH_HEARTBEAT_INTERVAL - Static variable in class org.apache.flink.configuration.ConfigConstants
Heartbeat interval of watch failure detector
AKKA_WATCH_HEARTBEAT_PAUSE - Static variable in class org.apache.flink.configuration.AkkaOptions
The maximum acceptable Akka death watch heartbeat pause.
AKKA_WATCH_HEARTBEAT_PAUSE - Static variable in class org.apache.flink.configuration.ConfigConstants
Allowed heartbeat pause for the watch failure detector
AKKA_WATCH_THRESHOLD - Static variable in class org.apache.flink.configuration.ConfigConstants
Detection threshold for the phi accrual watch failure detector
AkkaActorGateway - Class in org.apache.flink.runtime.instance
Concrete ActorGateway implementation which uses Akka to communicate with remote actors.
AkkaActorGateway(ActorRef, UUID) - Constructor for class org.apache.flink.runtime.instance.AkkaActorGateway
 
AkkaOptions - Class in org.apache.flink.configuration
Akka configuration options.
AkkaOptions() - Constructor for class org.apache.flink.configuration.AkkaOptions
 
AkkaRpcException - Exception in org.apache.flink.runtime.rpc.akka.exceptions
Base class for Akka RPC related exceptions.
AkkaRpcException(String) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException
 
AkkaRpcException(String, Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException
 
AkkaRpcException(Throwable) - Constructor for exception org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException
 
AkkaRpcService - Class in org.apache.flink.runtime.rpc.akka
Akka based RpcService implementation.
AkkaRpcService(ActorSystem, Time) - Constructor for class org.apache.flink.runtime.rpc.akka.AkkaRpcService
 
AkkaRpcServiceUtils - Class in org.apache.flink.runtime.rpc.akka
These RPC utilities contain helper methods around RPC use, such as starting an RPC service, or constructing RPC addresses.
AkkaRpcServiceUtils.AkkaProtocol - Enum in org.apache.flink.runtime.rpc.akka
 
AkkaUtils - Class in org.apache.flink.runtime.akka
This class contains utility functions for akka.
AkkaUtils() - Constructor for class org.apache.flink.runtime.akka.AkkaUtils
 
AkkaUtils$ - Class in org.apache.flink.runtime.akka
This class contains utility functions for akka.
AkkaUtils$() - Constructor for class org.apache.flink.runtime.akka.AkkaUtils$
 
alias() - Method in class org.apache.flink.table.api.OverWindow
 
alias() - Method in class org.apache.flink.table.api.Window
 
alias(RexNode, String) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
Alias - Class in org.apache.flink.table.expressions
 
Alias(Expression, String, Seq<String>) - Constructor for class org.apache.flink.table.expressions.Alias
 
alias() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
alias() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
alias() - Method in class org.apache.flink.table.expressions.UnresolvedOverCall
 
alias() - Method in class org.apache.flink.table.plan.logical.SessionGroupWindow
 
alias() - Method in class org.apache.flink.table.plan.logical.SlidingGroupWindow
 
alias() - Method in class org.apache.flink.table.plan.logical.TumblingGroupWindow
 
Alias$ - Class in org.apache.flink.table.expressions
 
Alias$() - Constructor for class org.apache.flink.table.expressions.Alias$
 
aliasAttribute() - Method in class org.apache.flink.table.plan.logical.LogicalWindow
 
aliasAttribute() - Static method in class org.apache.flink.table.plan.logical.SessionGroupWindow
 
aliasAttribute() - Static method in class org.apache.flink.table.plan.logical.SlidingGroupWindow
 
aliasAttribute() - Static method in class org.apache.flink.table.plan.logical.TumblingGroupWindow
 
aliasList() - Method in class org.apache.flink.table.plan.logical.AliasNode
 
aliasMapping() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
aliasMapping() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
aliasName() - Method in class org.apache.flink.table.expressions.GetCompositeField
Gives a meaningful alias if possible (e.g.
AliasNode - Class in org.apache.flink.table.plan.logical
 
AliasNode(Seq<Expression>, LogicalNode) - Constructor for class org.apache.flink.table.plan.logical.AliasNode
 
AliasNode$ - Class in org.apache.flink.table.plan.logical
 
AliasNode$() - Constructor for class org.apache.flink.table.plan.logical.AliasNode$
 
AlignmentLimitExceededException - Exception in org.apache.flink.runtime.checkpoint.decline
Exception indicating that a checkpoint was declined because too many bytes were buffered in the alignment phase.
AlignmentLimitExceededException(long) - Constructor for exception org.apache.flink.runtime.checkpoint.decline.AlignmentLimitExceededException
 
all() - Method in class org.apache.flink.table.plan.logical.Intersect
 
all() - Method in class org.apache.flink.table.plan.logical.Minus
 
all() - Method in class org.apache.flink.table.plan.logical.Union
 
AllFieldsForwardedProperties() - Constructor for class org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties
 
AllGroupCombineDriver<IN,OUT> - Class in org.apache.flink.runtime.operators
Non-chained driver for the partial group reduce operator that acts like a combiner with a custom output type OUT.
AllGroupCombineDriver() - Constructor for class org.apache.flink.runtime.operators.AllGroupCombineDriver
 
AllGroupCombineProperties - Class in org.apache.flink.optimizer.operators
 
AllGroupCombineProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupCombineProperties
 
AllGroupReduceDriver<IT,OT> - Class in org.apache.flink.runtime.operators
GroupReduceDriver task which is executed by a Task Manager.
AllGroupReduceDriver() - Constructor for class org.apache.flink.runtime.operators.AllGroupReduceDriver
 
AllGroupReduceProperties - Class in org.apache.flink.optimizer.operators
 
AllGroupReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupReduceProperties
 
AllGroupWithPartialPreGroupProperties - Class in org.apache.flink.optimizer.operators
 
AllGroupWithPartialPreGroupProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties
 
allocate(JobID, AllocationID) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlot
Allocate the task slot for the given job and allocation id.
AllocatedSlot - Class in org.apache.flink.runtime.jobmanager.slots
The AllocatedSlot represents a slot that the JobManager allocated from a TaskManager.
AllocatedSlot(AllocationID, JobID, TaskManagerLocation, int, ResourceProfile, TaskManagerGateway) - Constructor for class org.apache.flink.runtime.jobmanager.slots.AllocatedSlot
 
allocatePages(Object, int) - Method in class org.apache.flink.runtime.memory.MemoryManager
Allocates a set of memory segments from this memory manager.
allocatePages(Object, List<MemorySegment>, int) - Method in class org.apache.flink.runtime.memory.MemoryManager
Allocates a set of memory segments from this memory manager.
allocateResource(ResourceProfile) - Method in interface org.apache.flink.runtime.resourcemanager.ResourceManagerServices
Allocates a resource according to the resource profile.
allocateResource(ResourceProfile) - Method in interface org.apache.flink.runtime.resourcemanager.slotmanager.ResourceManagerActions
 
allocateResourcesForAll(SlotProvider, boolean) - Method in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex
Acquires a slot for all the execution vertices of this ExecutionJobVertex.
allocateSegments(int) - Method in class org.apache.flink.runtime.operators.hash.InMemoryPartition
attempts to allocate specified number of segments and should only be used by compaction partition fails silently if not enough segments are available since next compaction could still succeed
allocateSharedSlot(JobID, SlotSharingGroupAssignment) - Method in class org.apache.flink.runtime.instance.Instance
Allocates a shared slot on this TaskManager instance.
allocateSimpleSlot(JobID) - Method in class org.apache.flink.runtime.instance.Instance
Allocates a simple slot on this TaskManager instance.
allocateSlot(ScheduledUnit, ResourceProfile, Iterable<TaskManagerLocation>) - Method in class org.apache.flink.runtime.instance.SlotPool
 
allocateSlot(ScheduledUnit, ResourceProfile, Iterable<TaskManagerLocation>, Time) - Method in interface org.apache.flink.runtime.instance.SlotPoolGateway
 
allocateSlot(ScheduledUnit, boolean) - Method in interface org.apache.flink.runtime.instance.SlotProvider
Allocating slot with specific requirement.
allocateSlot(ScheduledUnit, boolean) - Method in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler
 
allocateSlot(int, JobID, AllocationID, Time) - Method in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
Allocate the slot with the given index for the given job and allocation id.
allocateSlotForExecution(SlotProvider, boolean) - Method in class org.apache.flink.runtime.executiongraph.Execution
 
allocateUnpooledSegment(int, Object) - Method in class org.apache.flink.core.memory.HeapMemorySegment.HeapMemorySegmentFactory
 
allocateUnpooledSegment(int, Object) - Method in class org.apache.flink.core.memory.HybridMemorySegment.HybridMemorySegmentFactory
 
allocateUnpooledSegment(int) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates some unpooled memory and creates a new memory segment that represents that memory.
allocateUnpooledSegment(int, Object) - Static method in class org.apache.flink.core.memory.MemorySegmentFactory
Allocates some unpooled memory and creates a new memory segment that represents that memory.
allocateUnpooledSegment(int, Object) - Method in interface org.apache.flink.core.memory.MemorySegmentFactory.Factory
Allocates some unpooled memory and creates a new memory segment that represents that memory.
AllocationID - Class in org.apache.flink.runtime.clusterframework.types
Unique identifier for a slot allocated by a JobManager from a TaskManager.
AllocationID() - Constructor for class org.apache.flink.runtime.clusterframework.types.AllocationID
Constructs a new random AllocationID.
AllocationID(long, long) - Constructor for class org.apache.flink.runtime.clusterframework.types.AllocationID
Constructs a new AllocationID with the given parts.
allOutputs - Variable in class org.apache.flink.streaming.api.collector.selector.DirectedOutput
 
allowCombinations() - Method in class org.apache.flink.cep.pattern.Pattern
Applicable only to Quantifier.ONE_OR_MORE(ConsumingStrategy) and Quantifier.TIMES(ConsumingStrategy) patterns, this option allows more flexibility to the matching events.
allowCombinations() - Method in class org.apache.flink.cep.scala.pattern.Pattern
Applicable only to Quantifier.ONE_OR_MORE() and Quantifier.TIMES() patterns, this option allows more flexibility to the matching events.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Sets the time by which elements are allowed to be late.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Sets the time by which elements are allowed to be late.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Sets the allowed lateness to a user-specified value.
allowedLateness(Time) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Sets the allowed lateness to a user-specified value.
allowedLateness - Variable in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator
The allowed lateness for elements.
allowLazyDeployment() - Method in enum org.apache.flink.runtime.jobgraph.ScheduleMode
Returns whether we are allowed to deploy consumers lazily.
allowNonRestoredState() - Method in class org.apache.flink.runtime.jobgraph.SavepointRestoreSettings
Returns whether non restored state is allowed if the savepoint contains state that cannot be mapped back to the job.
allowsFraming() - Static method in class org.apache.flink.table.functions.TimeMaterializationSqlFunction
 
allowsFraming() - Static method in class org.apache.flink.table.functions.utils.AggSqlFunction
 
allowsFraming() - Static method in class org.apache.flink.table.functions.utils.ScalarSqlFunction
 
allowsFraming() - Static method in class org.apache.flink.table.functions.utils.TableSqlFunction
 
AllReduceDriver<T> - Class in org.apache.flink.runtime.operators
Reduce task which is executed by a Task Manager.
AllReduceDriver() - Constructor for class org.apache.flink.runtime.operators.AllReduceDriver
 
AllReduceProperties - Class in org.apache.flink.optimizer.operators
 
AllReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllReduceProperties
 
allStartedWorkers() - Method in class org.apache.flink.runtime.clusterframework.FlinkResourceManager
Gets an iterable for all currently started TaskManagers.
AllWindowedStream<T,W extends Window> - Class in org.apache.flink.streaming.api.datastream
A AllWindowedStream represents a data stream where the stream of elements is split into windows based on a WindowAssigner.
AllWindowedStream(DataStream<T>, WindowAssigner<? super T, W>) - Constructor for class org.apache.flink.streaming.api.datastream.AllWindowedStream
 
AllWindowedStream<T,W extends Window> - Class in org.apache.flink.streaming.api.scala
A AllWindowedStream represents a data stream where the stream of elements is split into windows based on a WindowAssigner.
AllWindowedStream(AllWindowedStream<T, W>) - Constructor for class org.apache.flink.streaming.api.scala.AllWindowedStream
 
AllWindowFunction<IN,OUT,W extends Window> - Interface in org.apache.flink.streaming.api.functions.windowing
Base interface for functions that are evaluated over non-keyed windows.
AllWindowFunction<IN,OUT,W extends Window> - Interface in org.apache.flink.streaming.api.scala.function
Base interface for functions that are evaluated over non-grouped windows, i.e., windows over all stream partitions.
AllWorkersDoneEvent - Class in org.apache.flink.runtime.iterative.event
 
AllWorkersDoneEvent() - Constructor for class org.apache.flink.runtime.iterative.event.AllWorkersDoneEvent
 
AllWorkersDoneEvent(Map<String, Aggregator<?>>) - Constructor for class org.apache.flink.runtime.iterative.event.AllWorkersDoneEvent
 
AlreadyRegistered(InstanceID, int) - Constructor for class org.apache.flink.runtime.messages.RegistrationMessages.AlreadyRegistered
 
AlreadyRegistered$() - Constructor for class org.apache.flink.runtime.messages.RegistrationMessages.AlreadyRegistered$
 
ALS - Class in org.apache.flink.ml.recommendation
Alternating least squares algorithm to calculate a matrix factorization.
ALS() - Constructor for class org.apache.flink.ml.recommendation.ALS
 
ALS$ - Class in org.apache.flink.ml.recommendation
 
ALS$() - Constructor for class org.apache.flink.ml.recommendation.ALS$
 
ALS.BlockedFactorization - Class in org.apache.flink.ml.recommendation
 
ALS.BlockedFactorization$ - Class in org.apache.flink.ml.recommendation
 
ALS.BlockIDGenerator - Class in org.apache.flink.ml.recommendation
 
ALS.BlockIDPartitioner - Class in org.apache.flink.ml.recommendation
 
ALS.BlockRating - Class in org.apache.flink.ml.recommendation
 
ALS.BlockRating$ - Class in org.apache.flink.ml.recommendation
 
ALS.Blocks$ - Class in org.apache.flink.ml.recommendation
 
ALS.Factorization - Class in org.apache.flink.ml.recommendation
 
ALS.Factorization$ - Class in org.apache.flink.ml.recommendation
 
ALS.Factors - Class in org.apache.flink.ml.recommendation
Latent factor model vector
ALS.Factors$ - Class in org.apache.flink.ml.recommendation
 
ALS.InBlockInformation - Class in org.apache.flink.ml.recommendation
 
ALS.InBlockInformation$ - Class in org.apache.flink.ml.recommendation
 
ALS.Iterations$ - Class in org.apache.flink.ml.recommendation
 
ALS.Lambda$ - Class in org.apache.flink.ml.recommendation
 
ALS.NumFactors$ - Class in org.apache.flink.ml.recommendation
 
ALS.OutBlockInformation - Class in org.apache.flink.ml.recommendation
 
ALS.OutBlockInformation$ - Class in org.apache.flink.ml.recommendation
 
ALS.OutLinks - Class in org.apache.flink.ml.recommendation
 
ALS.Rating - Class in org.apache.flink.ml.recommendation
Representation of a user-item rating
ALS.Rating$ - Class in org.apache.flink.ml.recommendation
 
ALS.Seed$ - Class in org.apache.flink.ml.recommendation
 
ALS.TemporaryPath$ - Class in org.apache.flink.ml.recommendation
 
alt(String) - Method in class org.apache.flink.api.java.utils.Option
Define an alternative / short name of the parameter.
alterSubCatalog(String, ExternalCatalog, boolean) - Method in interface org.apache.flink.table.catalog.CrudExternalCatalog
Modifies an existing sub catalog of this catalog.
alterSubCatalog(String, ExternalCatalog, boolean) - Method in class org.apache.flink.table.catalog.InMemoryExternalCatalog
 
alterTable(String, ExternalCatalogTable, boolean) - Method in interface org.apache.flink.table.catalog.CrudExternalCatalog
Modifies an existing table of this catalog.
alterTable(String, ExternalCatalogTable, boolean) - Method in class org.apache.flink.table.catalog.InMemoryExternalCatalog
 
ALWAYS_NULL() - Method in class org.apache.flink.table.codegen.GeneratedExpression$
 
ALWAYS_NULL() - Static method in class org.apache.flink.table.codegen.GeneratedExpression
 
AmbiguousTableSourceConverterException - Exception in org.apache.flink.table.api
Exception for finding more than one TableSourceConverter for a given table type.
AmbiguousTableSourceConverterException(String, Throwable) - Constructor for exception org.apache.flink.table.api.AmbiguousTableSourceConverterException
 
AmbiguousTableSourceConverterException(String) - Constructor for exception org.apache.flink.table.api.AmbiguousTableSourceConverterException
 
AmbiguousTableSourceConverterException$ - Class in org.apache.flink.table.api
 
AmbiguousTableSourceConverterException$() - Constructor for class org.apache.flink.table.api.AmbiguousTableSourceConverterException$
 
amount() - Method in class org.apache.flink.table.examples.scala.StreamSQLExample.Order
 
amount() - Method in class org.apache.flink.table.examples.scala.StreamTableExample.Order
 
AnalyticHelper<T> - Class in org.apache.flink.graph
A GraphAnalytic computes over a DataSet and returns the results via Flink accumulators.
AnalyticHelper() - Constructor for class org.apache.flink.graph.AnalyticHelper
 
analyze() - Method in class org.apache.flink.api.java.sca.NestedMethodAnalyzer
 
analyze() - Method in class org.apache.flink.api.java.sca.UdfAnalyzer
 
analyze(scala.reflect.macros.Context.universe) - Method in class org.apache.flink.api.scala.codegen.TypeAnalyzer.UDTAnalyzerInstance
 
analyzeCondition() - Static method in class org.apache.flink.table.plan.nodes.logical.FlinkLogicalJoin
 
analyzeDualInputUdf(TwoInputUdfOperator<?, ?, ?, ?>, Class<?>, String, Function, Keys<?>, Keys<?>) - Static method in class org.apache.flink.api.java.operators.UdfOperatorUtils
 
analyzePojo(Class<OUT>, ArrayList<Type>, ParameterizedType, TypeInformation<IN1>, TypeInformation<IN2>) - Method in class org.apache.flink.api.java.typeutils.TypeExtractor
 
analyzeSingleInputUdf(SingleInputUdfOperator<?, ?, ?>, Class<?>, String, Function, Keys<?>) - Static method in class org.apache.flink.api.java.operators.UdfOperatorUtils
 
AND - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
Logical AND operator.
and(Aggregations, int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
and(Aggregations, int) - Method in class org.apache.flink.api.scala.AggregateDataSet
Adds the given aggregation on the given field to the previous aggregation operation.
and(Aggregations, String) - Method in class org.apache.flink.api.scala.AggregateDataSet
Adds the given aggregation on the given field to the previous aggregation operation.
and(Aggregations, int) - Method in class org.apache.flink.api.scala.operators.ScalaAggregateOperator
 
and(RexNode[]) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
and(Iterable<? extends RexNode>) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
And - Class in org.apache.flink.table.expressions
 
And(Expression, Expression) - Constructor for class org.apache.flink.table.expressions.And
 
And$ - Class in org.apache.flink.table.expressions
 
And$() - Constructor for class org.apache.flink.table.expressions.And$
 
AndCondition<T> - Class in org.apache.flink.cep.pattern.conditions
A condition which combines two conditions with a logical AND and returns true if both are true.
AndCondition(IterativeCondition<T>, IterativeCondition<T>) - Constructor for class org.apache.flink.cep.pattern.conditions.AndCondition
 
AndFilterFunction<T> - Class in org.apache.flink.cep.pattern
Deprecated.
This is only used when migrating from an older Flink version. Use the AndCondition instead.

A filter function which combines two filter functions with a logical and. Thus, the filter function only returns true, iff both filters return true.

AndFilterFunction(FilterFunction<T>, FilterFunction<T>) - Constructor for class org.apache.flink.cep.pattern.AndFilterFunction
Deprecated.
 
andMax(int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
andMax(int) - Method in class org.apache.flink.api.scala.AggregateDataSet
Syntactic sugar for and with MAX
andMax(String) - Method in class org.apache.flink.api.scala.AggregateDataSet
Syntactic sugar for and with MAX
andMin(int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
andMin(int) - Method in class org.apache.flink.api.scala.AggregateDataSet
Syntactic sugar for and with MIN
andMin(String) - Method in class org.apache.flink.api.scala.AggregateDataSet
Syntactic sugar for and with MIN
andSum(int) - Method in class org.apache.flink.api.java.operators.AggregateOperator
 
andSum(int) - Method in class org.apache.flink.api.scala.AggregateDataSet
Syntactic sugar for and with SUM
andSum(String) - Method in class org.apache.flink.api.scala.AggregateDataSet
Syntactic sugar for and with SUM
AnnotationVisitorImpl(int) - Constructor for class org.apache.flink.runtime.util.DependencyVisitor.AnnotationVisitorImpl
 
AntiJoinVisits() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis.AntiJoinVisits
 
API_KEY - Static variable in class org.apache.flink.metrics.datadog.DatadogHttpReporter
 
APP_MASTER_RPC_ADDRESS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The hostname or address where the application master RPC system is listening.
APP_MASTER_RPC_PORT - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions
The port where the application master RPC system is listening.
append(char) - Method in class org.apache.flink.types.StringValue
 
append(CharSequence) - Method in class org.apache.flink.types.StringValue
 
append(CharSequence, int, int) - Method in class org.apache.flink.types.StringValue
 
append(StringValue) - Method in class org.apache.flink.types.StringValue
 
append(StringValue, int, int) - Method in class org.apache.flink.types.StringValue
 
AppendingState<IN,OUT> - Interface in org.apache.flink.api.common.state
Base interface for partitioned state that supports adding elements and inspecting the current state.
appendKeyExtractor(Operator<T>, Keys.SelectorFunctionKeys<T, K>) - Static method in class org.apache.flink.api.java.operators.KeyFunctions
 
appendKeyExtractor(Operator<T>, Keys.SelectorFunctionKeys<T, K1>, Keys.SelectorFunctionKeys<T, K2>) - Static method in class org.apache.flink.api.java.operators.KeyFunctions
 
appendKeyRemover(Operator<Tuple2<K, T>>, Keys.SelectorFunctionKeys<T, K>) - Static method in class org.apache.flink.api.java.operators.KeyFunctions
 
appendOrdering(Integer, Class<? extends Comparable<?>>, Order) - Method in class org.apache.flink.api.common.operators.Ordering
Extends this ordering by appending an additional order requirement.
appendRecord(T) - Method in class org.apache.flink.runtime.operators.hash.InMemoryPartition
Inserts the given object into the current buffer.
AppendStreamTableSink<T> - Interface in org.apache.flink.table.sinks
Defines an external TableSink to emit streaming Table with only insert changes.
ApplicationClient - Class in org.apache.flink.yarn
Actor which is responsible to repeatedly poll the Yarn cluster status from the ResourceManager.
ApplicationClient(Configuration, LeaderRetrievalService) - Constructor for class org.apache.flink.yarn.ApplicationClient
 
ApplicationClient$ - Class in org.apache.flink.yarn
 
ApplicationClient$() - Constructor for class org.apache.flink.yarn.ApplicationClient$
 
ApplicationMasterStatus(int, int) - Constructor for class org.apache.flink.yarn.YarnMessages.ApplicationMasterStatus
 
ApplicationMasterStatus$() - Constructor for class org.apache.flink.yarn.YarnMessages.ApplicationMasterStatus$
 
ApplicationStatus - Enum in org.apache.flink.runtime.clusterframework
The status of an application.
apply(Function2<Iterator<L>, Iterator<R>, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.CoGroupDataSet
Creates a new DataSet where the result for each pair of co-grouped element lists is the result of the given function.
apply(Function3<Iterator<L>, Iterator<R>, Collector<O>, BoxedUnit>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.CoGroupDataSet
Creates a new DataSet where the result for each pair of co-grouped element lists is the result of the given function.
apply(CoGroupFunction<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.CoGroupDataSet
Creates a new DataSet by passing each pair of co-grouped element lists to the given function.
apply(Function2<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.CrossDataSet
Creates a new DataSet where the result for each pair of elements is the result of the given function.
apply(CrossFunction<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.CrossDataSet
Creates a new DataSet by passing each pair of values to the given function.
apply(Function2<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.JoinDataSet
Creates a new DataSet where the result for each pair of joined elements is the result of the given function.
apply(Function3<L, R, Collector<O>, BoxedUnit>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.JoinDataSet
Creates a new DataSet by passing each pair of joined values to the given function.
apply(FlatJoinFunction<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.JoinDataSet
Creates a new DataSet by passing each pair of joined values to the given function.
apply(JoinFunction<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in class org.apache.flink.api.scala.JoinDataSet
Creates a new DataSet by passing each pair of joined values to the given function.
apply(Function2<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in interface org.apache.flink.api.scala.JoinFunctionAssigner
 
apply(Function3<L, R, Collector<O>, BoxedUnit>, TypeInformation<O>, ClassTag<O>) - Method in interface org.apache.flink.api.scala.JoinFunctionAssigner
 
apply(FlatJoinFunction<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in interface org.apache.flink.api.scala.JoinFunctionAssigner
 
apply(JoinFunction<L, R, O>, TypeInformation<O>, ClassTag<O>) - Method in interface org.apache.flink.api.scala.JoinFunctionAssigner
 
apply(Function0<T>) - Method in class org.apache.flink.api.scala.metrics.ScalaGauge$
 
apply(Function0<T>) - Static method in class org.apache.flink.api.scala.metrics.ScalaGauge
 
apply(Pattern<T, F>) - Method in class org.apache.flink.cep.scala.pattern.Pattern$
Constructs a new Pattern by wrapping a given Java API Pattern
apply(Pattern<T, F>) - Static method in class org.apache.flink.cep.scala.pattern.Pattern
Constructs a new Pattern by wrapping a given Java API Pattern
apply(PatternStream<T>) - Method in class org.apache.flink.cep.scala.PatternStream$
 
apply(PatternStream<T>) - Static method in class org.apache.flink.cep.scala.PatternStream
 
apply(M, VV) - Method in class org.apache.flink.graph.gsa.ApplyFunction
This method is invoked once per superstep, after the SumFunction in a GatherSumApplyIteration.
apply() - Method in class org.apache.flink.ml.classification.SVM$
 
apply() - Static method in class org.apache.flink.ml.classification.SVM
 
apply() - Method in class org.apache.flink.ml.common.ParameterMap$
 
apply(Parameter<T>) - Method in class org.apache.flink.ml.common.ParameterMap
Retrieves a parameter value associated to a given key.
apply(int, int, int[]) - Method in class org.apache.flink.ml.math.DenseMatrix$
 
apply(int, int, Seq<Object>) - Method in class org.apache.flink.ml.math.DenseMatrix$
 
apply(int, int) - Method in class org.apache.flink.ml.math.DenseMatrix
Element wise access function
apply(Seq<Object>) - Method in class org.apache.flink.ml.math.DenseVector$
 
apply(int[]) - Method in class org.apache.flink.ml.math.DenseVector$
 
apply(int) - Method in class org.apache.flink.ml.math.DenseVector
Element wise access function
apply(int, int) - Method in interface org.apache.flink.ml.math.Matrix
Element wise access function
apply(int, int) - Method in class org.apache.flink.ml.math.SparseMatrix
Element wise access function
apply(int) - Method in class org.apache.flink.ml.math.SparseVector
Element wise access function
apply(int) - Method in interface org.apache.flink.ml.math.Vector
Element wise access function
apply() - Method in class org.apache.flink.ml.metrics.distances.ChebyshevDistanceMetric$
 
apply() - Static method in class org.apache.flink.ml.metrics.distances.ChebyshevDistanceMetric
 
apply() - Method in class org.apache.flink.ml.metrics.distances.CosineDistanceMetric$
 
apply() - Static method in class org.apache.flink.ml.metrics.distances.CosineDistanceMetric
 
apply() - Method in class org.apache.flink.ml.metrics.distances.EuclideanDistanceMetric$
 
apply() - Static method in class org.apache.flink.ml.metrics.distances.EuclideanDistanceMetric
 
apply() - Method in class org.apache.flink.ml.metrics.distances.ManhattanDistanceMetric$
 
apply() - Static method in class org.apache.flink.ml.metrics.distances.ManhattanDistanceMetric
 
apply(double) - Method in class org.apache.flink.ml.metrics.distances.MinkowskiDistanceMetric$
 
apply(double) - Static method in class org.apache.flink.ml.metrics.distances.MinkowskiDistanceMetric
 
apply() - Method in class org.apache.flink.ml.metrics.distances.SquaredEuclideanDistanceMetric$
 
apply() - Static method in class org.apache.flink.ml.metrics.distances.SquaredEuclideanDistanceMetric
 
apply() - Method in class org.apache.flink.ml.metrics.distances.TanimotoDistanceMetric$
 
apply() - Static method in class org.apache.flink.ml.metrics.distances.TanimotoDistanceMetric
 
apply() - Method in class org.apache.flink.ml.nn.KNN$
 
apply() - Static method in class org.apache.flink.ml.nn.KNN
 
apply() - Method in class org.apache.flink.ml.optimization.GradientDescent$
 
apply() - Static method in class org.apache.flink.ml.optimization.GradientDescent
 
apply() - Method in class org.apache.flink.ml.outlier.StochasticOutlierSelection$
 
apply() - Static method in class org.apache.flink.ml.outlier.StochasticOutlierSelection
 
apply() - Method in class org.apache.flink.ml.preprocessing.MinMaxScaler$
 
apply() - Static method in class org.apache.flink.ml.preprocessing.MinMaxScaler
 
apply() - Method in class org.apache.flink.ml.preprocessing.PolynomialFeatures$
 
apply() - Static method in class org.apache.flink.ml.preprocessing.PolynomialFeatures
 
apply() - Method in class org.apache.flink.ml.preprocessing.StandardScaler$
 
apply() - Static method in class org.apache.flink.ml.preprocessing.StandardScaler
 
apply() - Method in class org.apache.flink.ml.recommendation.ALS$
 
apply() - Static method in class org.apache.flink.ml.recommendation.ALS
 
apply(long) - Method in class org.apache.flink.ml.recommendation.ALS.BlockIDGenerator
 
apply(int) - Method in class org.apache.flink.ml.recommendation.ALS.BlockRating
 
apply(int) - Method in class org.apache.flink.ml.recommendation.ALS.OutLinks
 
apply() - Method in class org.apache.flink.ml.regression.MultipleLinearRegression$
 
apply() - Static method in class org.apache.flink.ml.regression.MultipleLinearRegression
 
apply(ActorSystem) - Static method in class org.apache.flink.runtime.akka.RemoteAddressExtension
 
apply(V) - Method in interface org.apache.flink.runtime.concurrent.ApplyFunction
Method which handles the function call.
apply(T, U) - Method in interface org.apache.flink.runtime.concurrent.BiFunction
Method which handles the function call.
apply(ActorRef, ListeningBehaviour, long, long) - Method in class org.apache.flink.runtime.jobmanager.JobInfo$
 
apply(ActorRef, ListeningBehaviour, long, long) - Static method in class org.apache.flink.runtime.jobmanager.JobInfo
 
apply(S, T) - Method in interface org.apache.flink.runtime.state.StateTransformationFunction
Binary function that applies a given value to the given old state to compute the new state.
apply(I) - Method in interface org.apache.flink.runtime.util.EvictingBoundedList.Function
Transforms the value.
apply(RetrievableStateHandle<T>) - Method in interface org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore.RemoveCallback
Callback method.
apply(AllWindowFunction<T, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
apply(AllWindowFunction<T, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
apply(ReduceFunction<T>, AllWindowFunction<T, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(ReduceFunction<T>, AllWindowFunction<T, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
apply(CoGroupFunction<T1, T2, T>) - Method in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(CoGroupFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(JoinFunction<T1, T2, T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(FlatJoinFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(FlatJoinFunction<T1, T2, T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(JoinFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.
apply(WindowFunction<T, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
apply(WindowFunction<T, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
apply(ReduceFunction<T>, WindowFunction<T, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(ReduceFunction<T>, WindowFunction<T, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
apply(W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction
 
apply(W, Iterable<IN>, Collector<OUT>) - Method in interface org.apache.flink.streaming.api.functions.windowing.AllWindowFunction
Evaluates the window and outputs none or several elements.
apply(W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction
Deprecated.
 
apply(K, W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.FoldApplyWindowFunction
Deprecated.
 
apply(W, Iterable<T>, Collector<T>) - Method in class org.apache.flink.streaming.api.functions.windowing.PassThroughAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<T>) - Method in class org.apache.flink.streaming.api.functions.windowing.PassThroughWindowFunction
 
apply(W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.ReduceApplyAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<R>) - Method in class org.apache.flink.streaming.api.functions.windowing.ReduceApplyWindowFunction
 
apply(KEY, W, Iterable<IN>, Collector<OUT>) - Method in interface org.apache.flink.streaming.api.functions.windowing.WindowFunction
Evaluates the window and outputs none or several elements.
apply(AllWindowFunction<T, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given window function to each window.
apply(Function3<W, Iterable<T>, Collector<R>, BoxedUnit>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given window function to each window.
apply(ReduceFunction<T>, AllWindowFunction<T, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Deprecated.
Use reduce(ReduceFunction, AllWindowFunction) instead.
apply(Function2<T, T, T>, Function3<W, Iterable<T>, Collector<R>, BoxedUnit>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Deprecated.
Use reduce(ReduceFunction, AllWindowFunction) instead.
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Deprecated.
Use fold(R, FoldFunction, AllWindowFunction) instead.
apply(R, Function2<R, T, R>, Function3<W, Iterable<R>, Collector<R>, BoxedUnit>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Deprecated.
Use fold(R, FoldFunction, AllWindowFunction instead.
apply(Function2<Iterator<T1>, Iterator<T2>, O>, TypeInformation<O>) - Method in class org.apache.flink.streaming.api.scala.CoGroupedStreams.Where.EqualTo.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(Function3<Iterator<T1>, Iterator<T2>, Collector<O>, BoxedUnit>, TypeInformation<O>) - Method in class org.apache.flink.streaming.api.scala.CoGroupedStreams.Where.EqualTo.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(CoGroupFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.scala.CoGroupedStreams.Where.EqualTo.WithWindow
Completes the co-group operation with the user function that is executed for windowed groups.
apply(W, Iterable<IN>, Collector<OUT>) - Method in interface org.apache.flink.streaming.api.scala.function.AllWindowFunction
Evaluates the window and outputs none or several elements.
apply(W, Iterable<IN>, Collector<OUT>) - Method in class org.apache.flink.streaming.api.scala.function.util.ScalaAllWindowFunction
 
apply(W, Iterable<IN>, Collector<OUT>) - Method in class org.apache.flink.streaming.api.scala.function.util.ScalaAllWindowFunctionWrapper
 
apply(KEY, W, Iterable<IN>, Collector<OUT>) - Method in class org.apache.flink.streaming.api.scala.function.util.ScalaWindowFunction
 
apply(KEY, W, Iterable<IN>, Collector<OUT>) - Method in class org.apache.flink.streaming.api.scala.function.util.ScalaWindowFunctionWrapper
 
apply(KEY, W, Iterable<IN>, Collector<OUT>) - Method in interface org.apache.flink.streaming.api.scala.function.WindowFunction
Evaluates the window and outputs none or several elements.
apply(Function2<T1, T2, O>, TypeInformation<O>) - Method in class org.apache.flink.streaming.api.scala.JoinedStreams.Where.EqualTo.WithWindow
Completes the join operation with the user function that is executed for windowed groups.
apply(Function3<T1, T2, Collector<O>, BoxedUnit>, TypeInformation<O>) - Method in class org.apache.flink.streaming.api.scala.JoinedStreams.Where.EqualTo.WithWindow
Completes the join operation with the user function that is executed for windowed groups.
apply(JoinFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.scala.JoinedStreams.Where.EqualTo.WithWindow
Completes the join operation with the user function that is executed for windowed groups.
apply(FlatJoinFunction<T1, T2, T>, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.scala.JoinedStreams.Where.EqualTo.WithWindow
Completes the join operation with the user function that is executed for windowed groups.
apply(String, TypeInformation<T>) - Method in class org.apache.flink.streaming.api.scala.OutputTag$
 
apply(String, TypeInformation<T>) - Static method in class org.apache.flink.streaming.api.scala.OutputTag
 
apply(WindowFunction<T, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given window function to each window.
apply(Function4<K, W, Iterable<T>, Collector<R>, BoxedUnit>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given window function to each window.
apply(ReduceFunction<T>, WindowFunction<T, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Deprecated.
Use reduce(ReduceFunction, WindowFunction) instead.
apply(Function2<T, T, T>, Function4<K, W, Iterable<T>, Collector<R>, BoxedUnit>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Deprecated.
Use reduce(ReduceFunction, WindowFunction) instead.
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Deprecated.
Use fold(R, FoldFunction, WindowFunction) instead.
apply(R, Function2<R, T, R>, Function4<K, W, Iterable<R>, Collector<R>, BoxedUnit>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Deprecated.
Use fold(R, FoldFunction, WindowFunction) instead.
apply(TimeWindow, Iterable<Integer>, Collector<Double[]>) - Method in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.PartialModelBuilder
 
apply(Long, Window, Iterable<Tuple2<Long, Long>>, Collector<Tuple2<Long, Long>>) - Method in class org.apache.flink.streaming.examples.windowing.GroupedProcessingTimeWindowExample.SummingWindowFunction
 
apply(Expression, Seq<Expression>) - Method in class org.apache.flink.table.api.scala.array$
Creates an array of literals.
apply(Expression, Seq<Expression>) - Static method in class org.apache.flink.table.api.scala.array
Creates an array of literals.
apply() - Method in class org.apache.flink.table.api.scala.currentDate$
Returns the current SQL date in UTC time zone.
apply() - Static method in class org.apache.flink.table.api.scala.currentDate
Returns the current SQL date in UTC time zone.
apply() - Method in class org.apache.flink.table.api.scala.currentTime$
Returns the current SQL time in UTC time zone.
apply() - Static method in class org.apache.flink.table.api.scala.currentTime
Returns the current SQL time in UTC time zone.
apply() - Method in class org.apache.flink.table.api.scala.currentTimestamp$
Returns the current SQL timestamp in UTC time zone.
apply() - Static method in class org.apache.flink.table.api.scala.currentTimestamp
Returns the current SQL timestamp in UTC time zone.
apply() - Method in class org.apache.flink.table.api.scala.localTime$
Returns the current SQL time in local time zone.
apply() - Static method in class org.apache.flink.table.api.scala.localTime
Returns the current SQL time in local time zone.
apply() - Method in class org.apache.flink.table.api.scala.localTimestamp$
Returns the current SQL timestamp in local time zone.
apply() - Static method in class org.apache.flink.table.api.scala.localTimestamp
Returns the current SQL timestamp in local time zone.
apply() - Method in class org.apache.flink.table.api.scala.pi$
Returns a value that is closer than any other value to pi.
apply() - Static method in class org.apache.flink.table.api.scala.pi
Returns a value that is closer than any other value to pi.
apply(Seq<Expression>, TypeInformation<T>) - Method in class org.apache.flink.table.api.scala.TableFunctionConversions
Creates a Table from a TableFunction in Scala Table API.
apply(Expression, Expression, Expression, Expression) - Method in class org.apache.flink.table.api.scala.temporalOverlaps$
Determines whether two anchored time intervals overlap.
apply(Expression, Expression, Expression, Expression) - Static method in class org.apache.flink.table.api.scala.temporalOverlaps
Determines whether two anchored time intervals overlap.
apply(String) - Method in class org.apache.flink.table.api.TableException$
 
apply(String) - Static method in exception org.apache.flink.table.api.TableException
 
apply(String) - Method in class org.apache.flink.table.api.ValidationException$
 
apply(String) - Static method in exception org.apache.flink.table.api.ValidationException
 
apply(Object) - Method in class org.apache.flink.table.expressions.Literal$
 
apply(Object) - Static method in class org.apache.flink.table.expressions.Literal
 
apply(int) - Static method in class org.apache.flink.table.expressions.TimeIntervalUnit
 
apply(int) - Static method in class org.apache.flink.table.expressions.TimePointUnit
 
apply(int) - Static method in class org.apache.flink.table.expressions.TrimMode
 
apply(Seq<Expression>) - Method in class org.apache.flink.table.expressions.UDAGGExpression
Creates a call to an AggregateFunction.
apply(Seq<Expression>) - Method in class org.apache.flink.table.functions.ScalarFunction
Creates a call to a ScalarFunction in Scala Table API.
apply(String, AggregateFunction<?, ?>, TypeInformation<?>, FlinkTypeFactory, boolean) - Method in class org.apache.flink.table.functions.utils.AggSqlFunction$
 
apply(String, AggregateFunction<?, ?>, TypeInformation<?>, FlinkTypeFactory, boolean) - Static method in class org.apache.flink.table.functions.utils.AggSqlFunction
 
apply(String, TableFunction<?>, TypeInformation<?>, FlinkTypeFactory, FlinkTableFunctionImpl<?>) - Method in class org.apache.flink.table.functions.utils.TableSqlFunction$
Util function to create a TableSqlFunction.
apply(String, TableFunction<?>, TypeInformation<?>, FlinkTypeFactory, FlinkTableFunctionImpl<?>) - Static method in class org.apache.flink.table.functions.utils.TableSqlFunction
Util function to create a TableSqlFunction.
apply(int) - Static method in class org.apache.flink.table.plan.nodes.datastream.AccMode
 
apply(TimeWindow, Iterable<Row>, Collector<CRow>) - Method in class org.apache.flink.table.runtime.aggregate.IncrementalAggregateAllTimeWindowFunction
 
apply(W, Iterable<Row>, Collector<CRow>) - Method in class org.apache.flink.table.runtime.aggregate.IncrementalAggregateAllWindowFunction
Calculate aggregated values output by aggregate buffer, and set them into output Row based on the mapping relation between intermediate aggregate data and output data.
apply(Tuple, TimeWindow, Iterable<Row>, Collector<CRow>) - Method in class org.apache.flink.table.runtime.aggregate.IncrementalAggregateTimeWindowFunction
 
apply(Tuple, W, Iterable<Row>, Collector<CRow>) - Method in class org.apache.flink.table.runtime.aggregate.IncrementalAggregateWindowFunction
Calculate aggregated values output by aggregate buffer, and set them into output Row based on the mapping relation between intermediate aggregate data and output data.
apply() - Method in class org.apache.flink.table.runtime.types.CRow$
 
apply(Row, boolean) - Method in class org.apache.flink.table.runtime.types.CRow$
 
apply() - Static method in class org.apache.flink.table.runtime.types.CRow
 
apply(Row, boolean) - Static method in class org.apache.flink.table.runtime.types.CRow
 
apply(TypeInformation<Row>) - Method in class org.apache.flink.table.runtime.types.CRowTypeInfo$
 
apply(TypeInformation<Row>) - Static method in class org.apache.flink.table.runtime.types.CRowTypeInfo
 
apply(Statement, Description) - Method in class org.apache.flink.testutils.junit.RetryRule
 
ApplyFunction<K,VV,M> - Class in org.apache.flink.graph.gsa
The base class for the third and last step of a GatherSumApplyIteration.
ApplyFunction() - Constructor for class org.apache.flink.graph.gsa.ApplyFunction
 
ApplyFunction<V,R> - Interface in org.apache.flink.runtime.concurrent
Function which is called with a single argument.
applyIteratorTrueAssumption() - Method in class org.apache.flink.api.java.sca.UdfAnalyzer
 
applyPredicate(List<Expression>) - Method in interface org.apache.flink.table.sources.FilterableTableSource
Check and pick all predicates this table source can support.
applyRegistrations(Kryo, Collection<KryoRegistration>) - Static method in class org.apache.flink.api.java.typeutils.runtime.KryoUtils
Apply a list of KryoRegistration to a Kryo instance.
applyRepartitioner(OperatorStateRepartitioner, List<OperatorStateHandle>, int, int) - Static method in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation
Repartitions the given operator state using the given OperatorStateRepartitioner with respect to the new parallelism.
applyState(FSM.State<S, D>) - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
applyState(FSM.State<S, D>) - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
applyState(FSM.State<S, D>) - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
applyState(FSM.State<S, D>) - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 
applyTo(ParameterTool) - Method in class org.apache.flink.api.java.utils.RequiredParameters
Check for all required parameters defined: - has a value been passed - if not, does the parameter have an associated default value - does the type of the parameter match the one defined in RequiredParameters - does the value provided in the parameterTool adhere to the choices defined in the option If any check fails, a RequiredParametersException is thrown
applyWith(ACC, Function2<ACC, T, ACC>, Function3<K, W, Stream<ACC>, TraversableOnce<R>>, TypeInformation<ACC>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.extensions.impl.acceptPartialFunctions.OnWindowedStream
Applies the given window function to each window.
applyWithState(I, Function2<I, Option<S>, Tuple2<O, Option<S>>>) - Method in interface org.apache.flink.streaming.api.scala.function.StatefulFunction
 
appMasterHostname - Variable in class org.apache.flink.yarn.AbstractYarnFlinkApplicationMasterRunner
The host name passed by env
archive() - Method in interface org.apache.flink.api.common.Archiveable
 
archive() - Method in class org.apache.flink.api.common.ExecutionConfig
 
archive() - Method in class org.apache.flink.runtime.executiongraph.Execution
 
archive() - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
 
archive() - Method in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex
 
archive() - Method in class org.apache.flink.runtime.executiongraph.ExecutionVertex
 
archive() - Method in class org.apache.flink.runtime.jobmanager.JobManager
 
ARCHIVE_DIR - Static variable in class org.apache.flink.configuration.JobManagerOptions
The location where the JobManager stores the archives of completed jobs.
ARCHIVE_NAME - Static variable in class org.apache.flink.runtime.jobmaster.JobMaster
 
Archiveable<T extends Serializable> - Interface in org.apache.flink.api.common
 
ArchivedExecution - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecution(Execution) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecution
 
ArchivedExecution(StringifiedAccumulatorResult[], IOMetrics, ExecutionAttemptID, int, ExecutionState, String, TaskManagerLocation, int, long[]) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecution
 
ArchivedExecutionConfig - Class in org.apache.flink.api.common
Serializable class which is created when archiving the job.
ArchivedExecutionConfig(ExecutionConfig) - Constructor for class org.apache.flink.api.common.ArchivedExecutionConfig
 
ArchivedExecutionConfig(String, String, int, boolean, Map<String, String>) - Constructor for class org.apache.flink.api.common.ArchivedExecutionConfig
 
ArchivedExecutionGraph - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecutionGraph(JobID, String, Map<JobVertexID, ArchivedExecutionJobVertex>, List<ArchivedExecutionJobVertex>, long[], JobStatus, String, String, StringifiedAccumulatorResult[], Map<String, SerializedValue<Object>>, ArchivedExecutionConfig, boolean, JobCheckpointingSettings, CheckpointStatsSnapshot) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph
 
ArchivedExecutionJobVertex - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecutionJobVertex(ExecutionJobVertex) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionJobVertex
 
ArchivedExecutionJobVertex(ArchivedExecutionVertex[], JobVertexID, String, int, int, StringifiedAccumulatorResult[]) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionJobVertex
 
ArchivedExecutionVertex - Class in org.apache.flink.runtime.executiongraph
 
ArchivedExecutionVertex(ExecutionVertex) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionVertex
 
ArchivedExecutionVertex(int, String, ArchivedExecution, EvictingBoundedList<ArchivedExecution>) - Constructor for class org.apache.flink.runtime.executiongraph.ArchivedExecutionVertex
 
ArchivedJob(Option<ArchivedExecutionGraph>) - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob
 
ArchivedJob$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob$
 
ArchivedJobs(Iterable<ArchivedExecutionGraph>) - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs
 
ArchivedJobs$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs$
 
ArchivedJson - Class in org.apache.flink.runtime.webmonitor.history
A simple container for a handler's JSON response and the REST URLs for which the response would've been returned.
ArchivedJson(String, String) - Constructor for class org.apache.flink.runtime.webmonitor.history.ArchivedJson
 
ArchiveExecutionGraph(JobID, ArchivedExecutionGraph) - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph
 
ArchiveExecutionGraph$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph$
 
archiveJob(Path, AccessExecutionGraph) - Static method in class org.apache.flink.runtime.history.FsJobArchivist
Writes the given AccessExecutionGraph to the FileSystem pointed to by JobManagerOptions.ARCHIVE_DIR.
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandler.CheckpointConfigJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsHandler.CheckpointStatsDetailsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler.CheckpointStatsDetailsSubtasksJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsHandler.CheckpointStatsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobsOverviewHandler.CurrentJobsOverviewJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobAccumulatorsHandler.JobAccumulatorsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobConfigHandler.JobConfigJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobDetailsHandler.JobDetailsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobExceptionsHandler.JobExceptionsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobPlanHandler.JobPlanJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobVertexAccumulatorsHandler.JobVertexAccumulatorsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobVertexDetailsHandler.JobVertexDetailsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.JobVertexTaskManagersHandler.JobVertexTaskManagersJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.SubtaskExecutionAttemptAccumulatorsHandler.SubtaskExecutionAttemptAccumulatorsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.SubtaskExecutionAttemptDetailsHandler.SubtaskExecutionAttemptDetailsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.SubtasksAllAccumulatorsHandler.SubtasksAllAccumulatorsJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in class org.apache.flink.runtime.webmonitor.handlers.SubtasksTimesHandler.SubtasksTimesJsonArchivist
 
archiveJsonWithPath(AccessExecutionGraph) - Method in interface org.apache.flink.runtime.webmonitor.history.JsonArchivist
Returns a Collection of ArchivedJsons containing JSON responses and their respective REST URL for a given job.
ArchiveMessages - Class in org.apache.flink.runtime.messages
This object contains the archive specific messages.
ArchiveMessages() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages
 
ArchiveMessages$ - Class in org.apache.flink.runtime.messages
This object contains the archive specific messages.
ArchiveMessages$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages$
 
ArchiveMessages.ArchivedJob - Class in org.apache.flink.runtime.messages
 
ArchiveMessages.ArchivedJob$ - Class in org.apache.flink.runtime.messages
 
ArchiveMessages.ArchivedJobs - Class in org.apache.flink.runtime.messages
Response to RequestArchivedJobs message.
ArchiveMessages.ArchivedJobs$ - Class in org.apache.flink.runtime.messages
 
ArchiveMessages.ArchiveExecutionGraph - Class in org.apache.flink.runtime.messages
 
ArchiveMessages.ArchiveExecutionGraph$ - Class in org.apache.flink.runtime.messages
 
ArchiveMessages.RequestArchivedJob - Class in org.apache.flink.runtime.messages
Reqeuest a specific ExecutionGraph by JobID.
ArchiveMessages.RequestArchivedJob$ - Class in org.apache.flink.runtime.messages
 
ArchiveMessages.RequestArchivedJobs$ - Class in org.apache.flink.runtime.messages
Request the currently archived jobs in the archiver.
ArchiveMessages.RequestJobCounts$ - Class in org.apache.flink.runtime.messages
Requests the number of finished, canceled, and failed jobs
areBranchCompatible(PlanNode, PlanNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode
Checks whether to candidate plans for the sub-plan of this node are comparable.
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor
 
areCompatible(Keys<?>) - Method in class org.apache.flink.api.common.operators.Keys
Check if two sets of keys are compatible to each other (matching types, key counts)
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractJoinDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor
 
areExplicitEnvironmentsAllowed() - Static method in class org.apache.flink.api.java.ExecutionEnvironment
Checks whether it is currently permitted to explicitly instantiate a LocalEnvironment or a RemoteEnvironment.
areFieldsUnique(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties
Checks whether the given set of fields is unique, as specified in these local properties.
ARG_CONVERSION_DURATION - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_CONVERSION_RATE - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_DMAX - Static variable in class org.apache.flink.metrics.ganglia.GangliaReporter
 
ARG_HOST - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_HOST - Static variable in class org.apache.flink.metrics.statsd.StatsDReporter
 
ARG_MODE_ADDRESSING - Static variable in class org.apache.flink.metrics.ganglia.GangliaReporter
 
ARG_PORT - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_PORT - Static variable in class org.apache.flink.metrics.jmx.JMXReporter
 
ARG_PORT - Static variable in class org.apache.flink.metrics.statsd.StatsDReporter
 
ARG_PREFIX - Static variable in class org.apache.flink.dropwizard.ScheduledDropwizardReporter
 
ARG_PROTOCOL - Static variable in class org.apache.flink.metrics.graphite.GraphiteReporter
 
ARG_TMAX - Static variable in class org.apache.flink.metrics.ganglia.GangliaReporter
 
ARG_TTL - Static variable in class org.apache.flink.metrics.ganglia.GangliaReporter
 
args() - Method in class org.apache.flink.table.expressions.AggFunctionCall
 
args() - Method in class org.apache.flink.table.expressions.Call
 
ARGUMENT_ASSIGNMENT - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
ARGUMENT_ASSIGNMENT operator (=<) assigns an argument to a function call to a particular named parameter.
argumentMustBeScalar(int) - Static method in class org.apache.flink.table.functions.TimeMaterializationSqlFunction
 
argumentMustBeScalar(int) - Static method in class org.apache.flink.table.functions.utils.AggSqlFunction
 
argumentMustBeScalar(int) - Static method in class org.apache.flink.table.functions.utils.ScalarSqlFunction
 
argumentMustBeScalar(int) - Static method in class org.apache.flink.table.functions.utils.TableSqlFunction
 
arity - Variable in class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.mesos.scheduler.Tasks
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.runtime.jobmanager.JobManager
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.runtime.taskmanager.TaskManager
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.yarn.ApplicationClient
 
aroundPostRestart(Throwable) - Static method in class org.apache.flink.yarn.YarnTaskManager
 
aroundPostStop() - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
aroundPostStop() - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
aroundPostStop() - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
aroundPostStop() - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
aroundPostStop() - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 
aroundPostStop() - Static method in class org.apache.flink.mesos.scheduler.Tasks
 
aroundPostStop() - Static method in class org.apache.flink.runtime.jobmanager.JobManager
 
aroundPostStop() - Static method in class org.apache.flink.runtime.taskmanager.TaskManager
 
aroundPostStop() - Static method in class org.apache.flink.yarn.ApplicationClient
 
aroundPostStop() - Static method in class org.apache.flink.yarn.YarnTaskManager
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.mesos.scheduler.Tasks
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.runtime.jobmanager.JobManager
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.runtime.taskmanager.TaskManager
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.yarn.ApplicationClient
 
aroundPreRestart(Throwable, Option<Object>) - Static method in class org.apache.flink.yarn.YarnTaskManager
 
aroundPreStart() - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
aroundPreStart() - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
aroundPreStart() - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
aroundPreStart() - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
aroundPreStart() - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 
aroundPreStart() - Static method in class org.apache.flink.mesos.scheduler.Tasks
 
aroundPreStart() - Static method in class org.apache.flink.runtime.jobmanager.JobManager
 
aroundPreStart() - Static method in class org.apache.flink.runtime.taskmanager.TaskManager
 
aroundPreStart() - Static method in class org.apache.flink.yarn.ApplicationClient
 
aroundPreStart() - Static method in class org.apache.flink.yarn.YarnTaskManager
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.mesos.scheduler.ConnectionMonitor
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.mesos.scheduler.LaunchCoordinator
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.mesos.scheduler.ReconciliationCoordinator
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.mesos.scheduler.TaskMonitor
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.mesos.scheduler.Tasks
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.runtime.jobmanager.JobManager
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.runtime.taskmanager.TaskManager
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.yarn.ApplicationClient
 
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Static method in class org.apache.flink.yarn.YarnTaskManager
 
array - Class in org.apache.flink.table.api.scala
Creates an array of literals.
array() - Constructor for class org.apache.flink.table.api.scala.array
 
array() - Method in class org.apache.flink.table.expressions.ArrayCardinality
 
array() - Method in class org.apache.flink.table.expressions.ArrayElement
 
array() - Method in class org.apache.flink.table.expressions.ArrayElementAt
 
array$ - Class in org.apache.flink.table.api.scala
Creates an array of literals.
array$() - Constructor for class org.apache.flink.table.api.scala.array$
 
array2ArrayConstructor(Object) - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionConversions
 
ARRAY_QUERY - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
The ARRAY Query Constructor.
ARRAY_VALUE_CONSTRUCTOR - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
The ARRAY Value Constructor.
arrayAwareToString(Object) - Static method in class org.apache.flink.util.StringUtils
This method calls Object.toString() on the given object, unless the object is an array.
ArrayCardinality - Class in org.apache.flink.table.expressions
 
ArrayCardinality(Expression) - Constructor for class org.apache.flink.table.expressions.ArrayCardinality
 
ArrayCardinality$ - Class in org.apache.flink.table.expressions
 
ArrayCardinality$() - Constructor for class org.apache.flink.table.expressions.ArrayCardinality$
 
ArrayConstructor - Class in org.apache.flink.table.expressions
 
ArrayConstructor(Seq<Expression>) - Constructor for class org.apache.flink.table.expressions.ArrayConstructor
 
ArrayConstructor$ - Class in org.apache.flink.table.expressions
 
ArrayConstructor$() - Constructor for class org.apache.flink.table.expressions.ArrayConstructor$
 
ArrayDescriptor(int, scala.reflect.macros.Context.universe, TypeDescriptors<C>.UDTDescriptor) - Constructor for class org.apache.flink.api.scala.codegen.TypeDescriptors.ArrayDescriptor
 
ArrayElement - Class in org.apache.flink.table.expressions
 
ArrayElement(Expression) - Constructor for class org.apache.flink.table.expressions.ArrayElement
 
ArrayElement$ - Class in org.apache.flink.table.expressions
 
ArrayElement$() - Constructor for class org.apache.flink.table.expressions.ArrayElement$
 
ArrayElementAt - Class in org.apache.flink.table.expressions
 
ArrayElementAt(Expression, Expression) - Constructor for class org.apache.flink.table.expressions.ArrayElementAt
 
ArrayElementAt$ - Class in org.apache.flink.table.expressions
 
ArrayElementAt$() - Constructor for class org.apache.flink.table.expressions.ArrayElementAt$
 
ArrayFromTuple - Class in org.apache.flink.streaming.api.functions.windowing.delta.extractor
Converts a Tuple to an Object-Array.
ArrayFromTuple() - Constructor for class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple
Using this constructor the extractor will convert the whole tuple (all fields in the original order) to an array.
ArrayFromTuple(int...) - Constructor for class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple
Using this constructor the extractor will combine the fields as specified in the indexes parameter in an object array.
ArrayListSerializer<T> - Class in org.apache.flink.runtime.state
 
ArrayListSerializer(TypeSerializer<T>) - Constructor for class org.apache.flink.runtime.state.ArrayListSerializer
 
arrayNext() - Method in class org.apache.flink.api.avro.DataInputDecoder
 
arrayNext() - Method in class org.apache.flink.api.java.typeutils.runtime.DataInputDecoder
 
ArrayRelDataType - Class in org.apache.flink.table.plan.schema
Flink distinguishes between primitive arrays (int[], double[], ...) and object arrays (Integer[], MyPojo[], ...).
ArrayRelDataType(TypeInformation<?>, RelDataType, boolean) - Constructor for class org.apache.flink.table.plan.schema.ArrayRelDataType
 
arrayToMap(String[]) - Static method in class org.apache.flink.runtime.metrics.scope.ScopeFormat
 
arrayToString(Object) - Static method in class org.apache.flink.util.StringUtils
Returns a string representation of the given array.
Artifact(Path, Path, boolean, boolean, boolean) - Constructor for class org.apache.flink.runtime.clusterframework.ContainerSpecification.Artifact
 
AS - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
AS operator associates an expression in the SELECT clause with an alias.
as(String) - Method in class org.apache.flink.table.api.OverWindowWithPreceding
Assigns an alias for this window that the following select() clause can refer to.
as(Expression) - Method in class org.apache.flink.table.api.OverWindowWithPreceding
Assigns an alias for this window that the following select() clause can refer to.
as(Symbol, Seq<Symbol>) - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Specifies a name for an expression i.e.
as(Expression) - Method in class org.apache.flink.table.api.SessionWithGapOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.SessionWithGapOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(Expression) - Method in class org.apache.flink.table.api.SlideWithSizeAndSlideOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.SlideWithSizeAndSlideOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(Seq<Expression>) - Method in class org.apache.flink.table.api.Table
Renames the fields of the expression result.
as(String) - Method in class org.apache.flink.table.api.Table
Renames the fields of the expression result.
as(Expression) - Method in class org.apache.flink.table.api.TumbleWithSizeOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Method in class org.apache.flink.table.api.TumbleWithSizeOnTime
Assigns an alias for this window that the following groupBy() and select() clause can refer to.
as(String) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
AS() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
AS() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
as(Option<Seq<String>>) - Method in class org.apache.flink.table.expressions.TableFunctionCall
Assigns an alias for this table function's returned fields that the following operator can refer to.
asArray(Class<U>) - Static method in class org.apache.flink.api.common.operators.AbstractUdfOperator
Generic utility function that wraps a single class object into an array of that class type.
asBreeze() - Method in class org.apache.flink.ml.math.Breeze.BreezeArrayConverter
 
asBreeze() - Method in class org.apache.flink.ml.math.Breeze.Matrix2BreezeConverter
 
asBreeze() - Method in class org.apache.flink.ml.math.Breeze.Vector2BreezeConverter
 
asc() - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Specifies ascending order of an expression i.e.
Asc - Class in org.apache.flink.table.expressions
 
Asc(Expression) - Constructor for class org.apache.flink.table.expressions.Asc
 
ASC() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
ASC() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
Asc$ - Class in org.apache.flink.table.expressions
 
Asc$() - Constructor for class org.apache.flink.table.expressions.Asc$
 
ascending - Variable in class org.apache.flink.api.common.typeutils.base.array.PrimitiveArrayComparator
 
ascendingComparison - Variable in class org.apache.flink.api.common.typeutils.base.BasicTypeComparator
 
AscendingTimestampExtractor<T> - Class in org.apache.flink.streaming.api.functions
Deprecated.
AscendingTimestampExtractor() - Constructor for class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor
Deprecated.
 
AscendingTimestampExtractor<T> - Class in org.apache.flink.streaming.api.functions.timestamps
A timestamp assigner and watermark generator for streams where timestamps are monotonously ascending.
AscendingTimestampExtractor() - Constructor for class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor
 
AscendingTimestampExtractor.FailingHandler - Class in org.apache.flink.streaming.api.functions.timestamps
Handler that fails the program when timestamp monotony is violated.
AscendingTimestampExtractor.IgnoringHandler - Class in org.apache.flink.streaming.api.functions.timestamps
Handler that does nothing when timestamp monotony is violated.
AscendingTimestampExtractor.LoggingHandler - Class in org.apache.flink.streaming.api.functions.timestamps
Handler that only logs violations of timestamp monotony, on WARN log level.
AscendingTimestampExtractor.MonotonyViolationHandler - Interface in org.apache.flink.streaming.api.functions.timestamps
Interface for handlers that handle violations of the monotonous ascending timestamps property.
asFile(String) - Static method in class org.apache.flink.test.util.TestBaseUtils
 
asFlinkTuples() - Method in class org.apache.flink.hcatalog.HCatInputFormatBase
Specifies that the InputFormat returns Flink tuples instead of HCatRecord.
ASIN - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
 
asin() - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Calculates the arc sine of a given number.
ASIN() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ASIN() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
Asin - Class in org.apache.flink.table.expressions
 
Asin(Expression) - Constructor for class org.apache.flink.table.expressions.Asin
 
Asin$ - Class in org.apache.flink.table.expressions
 
Asin$() - Constructor for class org.apache.flink.table.expressions.Asin$
 
ASIN_DEC() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ASIN_DEC() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
asJavaCollection() - Method in class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs
 
asJavaCollection() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.RegisteredTaskManagers
 
asJavaIterable() - Method in class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs
 
asJavaIterable() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.RegisteredTaskManagers
 
asJavaIterable() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.RunningJobs
 
ask(Object, FiniteDuration) - Method in interface org.apache.flink.runtime.instance.ActorGateway
Sends a message asynchronously and returns its response.
ask(Object, FiniteDuration) - Method in class org.apache.flink.runtime.instance.AkkaActorGateway
Sends a message asynchronously and returns its response.
askTimeout() - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
askTimeout() - Method in class org.apache.flink.runtime.taskmanager.TaskManager
The timeout for all actor ask futures
askTimeout() - Static method in class org.apache.flink.yarn.YarnTaskManager
 
asLatencyMarker() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a LatencyMarker.
asLong(Expression) - Method in class org.apache.flink.table.runtime.aggregate.AggregateUtil$
 
asLong(Expression) - Static method in class org.apache.flink.table.runtime.aggregate.AggregateUtil
 
asQueryableState(String) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Publishes the keyed stream as queryable ValueState instance.
asQueryableState(String, ValueStateDescriptor<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Publishes the keyed stream as a queryable ValueState instance.
asQueryableState(String, FoldingStateDescriptor<T, ACC>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Deprecated.
will be removed in a future version
asQueryableState(String, ReducingStateDescriptor<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
Publishes the keyed stream as a queryable ReducingState instance.
asQueryableState(String) - Method in class org.apache.flink.streaming.api.scala.KeyedStream
Publishes the keyed stream as a queryable ValueState instance.
asQueryableState(String, ValueStateDescriptor<T>) - Method in class org.apache.flink.streaming.api.scala.KeyedStream
Publishes the keyed stream as a queryable ValueState instance.
asQueryableState(String, FoldingStateDescriptor<T, ACC>) - Method in class org.apache.flink.streaming.api.scala.KeyedStream
Deprecated.
will be removed in a future version. Since .
asQueryableState(String, ReducingStateDescriptor<T>) - Method in class org.apache.flink.streaming.api.scala.KeyedStream
Publishes the keyed stream as a queryable ReducingState instance.
asRecord() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a StreamRecord.
asResultCollection() - Method in interface org.apache.flink.streaming.api.operators.async.queue.AsyncResult
Return this async result as a async result collection.
asResultCollection() - Method in class org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry
 
assertNumericExpr(TypeInformation<?>, String) - Method in class org.apache.flink.table.typeutils.TypeCheckUtils$
 
assertNumericExpr(TypeInformation<?>, String) - Static method in class org.apache.flink.table.typeutils.TypeCheckUtils
 
assertOrderableExpr(TypeInformation<?>, String) - Method in class org.apache.flink.table.typeutils.TypeCheckUtils$
 
assertOrderableExpr(TypeInformation<?>, String) - Static method in class org.apache.flink.table.typeutils.TypeCheckUtils
 
Assign(List<Tuple2<TaskRequest, String>>) - Constructor for class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign
 
assign(KafkaTopicPartition, int) - Static method in class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionAssigner
Returns the index of the target subtask that a specific Kafka partition should be assigned to.
Assign$() - Constructor for class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign$
 
assignAscendingTimestamps(Function1<T, Object>) - Method in class org.apache.flink.streaming.api.scala.DataStream
Assigns timestamps to the elements in the data stream and periodically creates watermarks to signal event time progress.
AssignDefaultRetractionRule() - Constructor for class org.apache.flink.table.plan.rules.datastream.DataStreamRetractionRules.AssignDefaultRetractionRule
 
AssignerWithPeriodicWatermarks<T> - Interface in org.apache.flink.streaming.api.functions
The AssignerWithPeriodicWatermarks assigns event time timestamps to elements, and generates low watermarks that signal event time progress within the stream.
AssignerWithPunctuatedWatermarks<T> - Interface in org.apache.flink.streaming.api.functions
The AssignerWithPunctuatedWatermarks assigns event time timestamps to elements, and generates low watermarks that signal event time progress within the stream.
assignKeyToParallelOperator(Object, int, int) - Static method in class org.apache.flink.runtime.state.KeyGroupRangeAssignment
Assigns the given key to a parallel operator index.
assignPartition(int, byte) - Static method in class org.apache.flink.runtime.operators.hash.MutableHashTable
Assigns a partition to a bucket.
assignPartitions(KafkaConsumer<?, ?>, List<TopicPartition>) - Method in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerCallBridge
 
assignPartitions(KafkaConsumer<?, ?>, List<TopicPartition>) - Method in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerCallBridge010
 
AssignRangeIndex<IN> - Class in org.apache.flink.runtime.operators.udf
This mapPartition function require a DataSet with RangeBoundaries as broadcast input, it generate Tuple2 which includes range index and record itself as output.
AssignRangeIndex(TypeComparatorFactory<IN>) - Constructor for class org.apache.flink.runtime.operators.udf.AssignRangeIndex
 
assignStates() - Method in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation
 
assignTimestamps(TimestampExtractor<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
assignTimestamps(TimestampExtractor<T>) - Method in class org.apache.flink.streaming.api.scala.DataStream
Deprecated.
. Since .
assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
Assigns timestamps to the elements in the data stream and periodically creates watermarks to signal event time progress.
assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) - Method in class org.apache.flink.streaming.api.datastream.DataStream
Assigns timestamps to the elements in the data stream and creates watermarks to signal event time progress based on the elements themselves.
assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) - Method in class org.apache.flink.streaming.api.scala.DataStream
Assigns timestamps to the elements in the data stream and periodically creates watermarks to signal event time progress.
assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) - Method in class org.apache.flink.streaming.api.scala.DataStream
Assigns timestamps to the elements in the data stream and periodically creates watermarks to signal event time progress.
assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
Specifies an AssignerWithPunctuatedWatermarks to emit watermarks in a punctuated manner.
assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
Specifies an AssignerWithPunctuatedWatermarks to emit watermarks in a punctuated manner.
assignToKeyGroup(Object, int) - Static method in class org.apache.flink.runtime.state.KeyGroupRangeAssignment
Assigns the given key to a key-group index.
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.BaseAlignedWindowAssigner
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.GlobalWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows
 
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows
 
assignWindows(T, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner
Returns a Collection of windows that should be assigned to the element.
asStreamStatus() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a StreamStatus.
assumeJava8() - Static method in class org.apache.flink.core.testutils.CommonTestUtils
Checks whether this code runs in a Java 8 (Java 1.8) JVM.
asVariable(String) - Static method in class org.apache.flink.runtime.metrics.scope.ScopeFormat
Formats the given string to resemble a scope variable.
asWatermark() - Method in interface org.apache.flink.streaming.api.operators.async.queue.AsyncResult
Return this async result as a async watermark result.
asWatermark() - Method in class org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry
 
asWatermark() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a Watermark.
AsyncCollectionResult<T> - Interface in org.apache.flink.streaming.api.operators.async.queue
AsyncResult sub class for asynchronous result collections.
AsyncCollector<OUT> - Interface in org.apache.flink.streaming.api.functions.async.collector
AsyncCollector collects data / error in user codes while processing async i/o.
AsyncCollector<OUT> - Interface in org.apache.flink.streaming.api.scala.async
The async collector collects data/errors from the user code while processing asynchronous I/O operations.
AsyncDataStream - Class in org.apache.flink.streaming.api.datastream
A helper class to apply AsyncFunction to a data stream.
AsyncDataStream() - Constructor for class org.apache.flink.streaming.api.datastream.AsyncDataStream
 
AsyncDataStream - Class in org.apache.flink.streaming.api.scala
A helper class to apply AsyncFunction to a data stream.
AsyncDataStream() - Constructor for class org.apache.flink.streaming.api.scala.AsyncDataStream
 
AsyncDataStream$ - Class in org.apache.flink.streaming.api.scala
A helper class to apply AsyncFunction to a data stream.
AsyncDataStream$() - Constructor for class org.apache.flink.streaming.api.scala.AsyncDataStream$
 
AsyncDataStream.OutputMode - Enum in org.apache.flink.streaming.api.datastream
Output mode for asynchronous operations.
AsyncDoneCallback - Interface in org.apache.flink.runtime.io.async
Callback for an asynchronous operation that is called on termination
asyncException - Variable in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase
Errors encountered in the async producer are stored here
AsyncExceptionHandler - Interface in org.apache.flink.streaming.runtime.tasks
An interface marking a task as capable of handling exceptions thrown by different threads, other than the one executing the task itself.
AsyncFunction<IN,OUT> - Interface in org.apache.flink.streaming.api.functions.async
A function to trigger Async I/O operation.
AsyncFunction<IN,OUT> - Interface in org.apache.flink.streaming.api.scala.async
A function to trigger async I/O operations.
AsynchronousBlockReader - Class in org.apache.flink.runtime.io.disk.iomanager
A reader that reads data in blocks from a file channel.
AsynchronousBlockReader(FileIOChannel.ID, RequestQueue<ReadRequest>, LinkedBlockingQueue<MemorySegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBlockReader
Creates a new block channel reader for the given channel.
AsynchronousBlockWriter - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBlockWriter(FileIOChannel.ID, RequestQueue<WriteRequest>, LinkedBlockingQueue<MemorySegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBlockWriter
Creates a new block channel writer for the given channel.
AsynchronousBlockWriterWithCallback - Class in org.apache.flink.runtime.io.disk.iomanager
An asynchronous implementation of the BlockChannelWriterWithCallback that queues I/O requests and calls a callback once they have been handled.
AsynchronousBlockWriterWithCallback(FileIOChannel.ID, RequestQueue<WriteRequest>, RequestDoneCallback<MemorySegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBlockWriterWithCallback
Creates a new asynchronous block writer for the given channel.
AsynchronousBufferFileReader - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBufferFileReader(FileIOChannel.ID, RequestQueue<ReadRequest>, RequestDoneCallback<Buffer>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileReader
 
AsynchronousBufferFileSegmentReader - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBufferFileSegmentReader(FileIOChannel.ID, RequestQueue<ReadRequest>, RequestDoneCallback<FileSegment>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileSegmentReader
 
AsynchronousBufferFileWriter - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBufferFileWriter(FileIOChannel.ID, RequestQueue<WriteRequest>) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileWriter
 
AsynchronousBulkBlockReader - Class in org.apache.flink.runtime.io.disk.iomanager
 
AsynchronousBulkBlockReader(FileIOChannel.ID, RequestQueue<ReadRequest>, List<MemorySegment>, int) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousBulkBlockReader
 
AsynchronousException - Exception in org.apache.flink.streaming.runtime.tasks
An exception for wrapping exceptions that are thrown by an operator in threads other than the main compute thread of that operator.
AsynchronousException(Throwable) - Constructor for exception org.apache.flink.streaming.runtime.tasks.AsynchronousException
 
AsynchronousException(String, Throwable) - Constructor for exception org.apache.flink.streaming.runtime.tasks.AsynchronousException
 
AsynchronousFileIOChannel<T,R extends org.apache.flink.runtime.io.disk.iomanager.IORequest> - Class in org.apache.flink.runtime.io.disk.iomanager
A base class for readers and writers that accept read or write requests for whole blocks.
AsynchronousFileIOChannel(FileIOChannel.ID, RequestQueue<R>, RequestDoneCallback<T>, boolean) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
Creates a new channel access to the path indicated by the given ID.
asyncInvoke(IN, AsyncCollector<OUT>) - Method in interface org.apache.flink.streaming.api.functions.async.AsyncFunction
Trigger async operation for each stream input.
asyncInvoke(IN, AsyncCollector<OUT>) - Method in class org.apache.flink.streaming.api.functions.async.RichAsyncFunction
 
asyncInvoke(IN, AsyncCollector<OUT>) - Method in interface org.apache.flink.streaming.api.scala.async.AsyncFunction
Trigger the async operation for each stream input
AsyncIOExample - Class in org.apache.flink.streaming.examples.async
Example to illustrates how to use AsyncFunction
AsyncIOExample() - Constructor for class org.apache.flink.streaming.examples.async.AsyncIOExample
 
AsyncIOExample - Class in org.apache.flink.streaming.scala.examples.async
 
AsyncIOExample() - Constructor for class org.apache.flink.streaming.scala.examples.async.AsyncIOExample
 
AsyncIOExample$ - Class in org.apache.flink.streaming.scala.examples.async
 
AsyncIOExample$() - Constructor for class org.apache.flink.streaming.scala.examples.async.AsyncIOExample$
 
AsyncResult - Interface in org.apache.flink.streaming.api.operators.async.queue
Asynchronous result returned by the StreamElementQueue.
AsyncStoppable - Interface in org.apache.flink.runtime.io.async
An asynchronous operation that can be stopped.
AsyncStoppableTaskWithCallback<V> - Class in org.apache.flink.runtime.io.async
 
AsyncStoppableTaskWithCallback(StoppableCallbackCallable<V>) - Constructor for class org.apache.flink.runtime.io.async.AsyncStoppableTaskWithCallback
 
AsyncWaitOperator<IN,OUT> - Class in org.apache.flink.streaming.api.operators.async
The AsyncWaitOperator allows to asynchronously process incoming stream records.
AsyncWaitOperator(AsyncFunction<IN, OUT>, long, int, AsyncDataStream.OutputMode) - Constructor for class org.apache.flink.streaming.api.operators.async.AsyncWaitOperator
 
AsyncWatermarkResult - Interface in org.apache.flink.streaming.api.operators.async.queue
AsyncResult subclass for asynchronous result Watermark.
at(Expression) - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Accesses the element of an array based on an index (starting at 1).
ATAN - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
 
atan() - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Calculates the arc tangent of a given number.
ATAN() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ATAN() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
Atan - Class in org.apache.flink.table.expressions
 
Atan(Expression) - Constructor for class org.apache.flink.table.expressions.Atan
 
Atan$ - Class in org.apache.flink.table.expressions
 
Atan$() - Constructor for class org.apache.flink.table.expressions.Atan$
 
ATAN2 - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
 
ATAN_DEC() - Method in class org.apache.flink.table.codegen.calls.BuiltInMethods$
 
ATAN_DEC() - Static method in class org.apache.flink.table.codegen.calls.BuiltInMethods
 
atom() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
atom() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
AtomicDisposableReferenceCounter - Class in org.apache.flink.runtime.util
Atomic reference counter, which enters a "disposed" state after it reaches a configurable reference count (default 0).
AtomicDisposableReferenceCounter() - Constructor for class org.apache.flink.runtime.util.AtomicDisposableReferenceCounter
 
AtomicDisposableReferenceCounter(int) - Constructor for class org.apache.flink.runtime.util.AtomicDisposableReferenceCounter
 
AtomicKvStateRequestStats - Class in org.apache.flink.runtime.query.netty
Atomic KvStateRequestStats implementation.
AtomicKvStateRequestStats() - Constructor for class org.apache.flink.runtime.query.netty.AtomicKvStateRequestStats
 
AtomicType<T> - Interface in org.apache.flink.api.common.typeinfo
An atomic type is a type that is treated as one indivisible unit and where the entire type acts as a key.
attachJobGraph(List<JobVertex>) - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
 
AttachToJobAndWait(JobID) - Constructor for class org.apache.flink.runtime.messages.JobClientMessages.AttachToJobAndWait
 
AttachToJobAndWait$() - Constructor for class org.apache.flink.runtime.messages.JobClientMessages.AttachToJobAndWait$
 
attachToRunningJob(JobID, ActorGateway, Configuration, ActorSystem, HighAvailabilityServices, FiniteDuration, boolean) - Static method in class org.apache.flink.runtime.client.JobClient
Attaches to a running Job using the JobID.
attempt() - Method in class org.apache.flink.runtime.messages.RegistrationMessages.TriggerTaskManagerRegistration
 
attemptID() - Method in class org.apache.flink.runtime.messages.TaskMessages.CancelTask
 
attemptID() - Method in class org.apache.flink.runtime.messages.TaskMessages.StopTask
 
attemptNumber() - Method in class org.apache.flink.runtime.metrics.groups.TaskMetricGroup
 
Attribute - Class in org.apache.flink.table.expressions
 
Attribute() - Constructor for class org.apache.flink.table.expressions.Attribute
 
ATTRIBUTE_COUNT - Static variable in class org.apache.flink.storm.wordcount.operators.BoltCounter
 
ATTRIBUTE_COUNT - Static variable in class org.apache.flink.storm.wordcount.operators.BoltCounterByName
 
ATTRIBUTE_COUNT - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizer
 
ATTRIBUTE_COUNT - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizerByName
 
ATTRIBUTE_COUNT_INDEX - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizer
 
ATTRIBUTE_COUNT_INDEX - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizerByName
 
ATTRIBUTE_LINE - Static variable in class org.apache.flink.storm.util.AbstractLineSpout
 
ATTRIBUTE_WORD - Static variable in class org.apache.flink.storm.wordcount.operators.BoltCounter
 
ATTRIBUTE_WORD - Static variable in class org.apache.flink.storm.wordcount.operators.BoltCounterByName
 
ATTRIBUTE_WORD - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizer
 
ATTRIBUTE_WORD - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizerByName
 
ATTRIBUTE_WORD_INDEX - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizer
 
ATTRIBUTE_WORD_INDEX - Static variable in class org.apache.flink.storm.wordcount.operators.BoltTokenizerByName
 
Attributes - Class in org.apache.flink.contrib.tweetinputformat.model.places
 
Attributes() - Constructor for class org.apache.flink.contrib.tweetinputformat.model.places.Attributes
 
attrNameCntr() - Method in class org.apache.flink.table.api.TableEnvironment
 
autoAck - Variable in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
AuxiliaryConverter - Interface in org.apache.calcite.sql2rel
Converts an expression for a group window function (e.g.
AuxiliaryConverter.Impl - Class in org.apache.calcite.sql2rel
Simple implementation of AuxiliaryConverter.
auxiliaryToGroup(SqlKind) - Static method in class org.apache.calcite.sql.fun.SqlStdOperatorTable
Returns the group function for which a given kind is an auxiliary function, or null if it is not an auxiliary function.
available() - Method in class org.apache.flink.core.fs.FSDataInputStreamWrapper
 
available() - Method in class org.apache.flink.core.fs.local.LocalDataInputStream
 
available() - Method in class org.apache.flink.core.memory.ByteArrayInputStreamWithPos
 
available() - Method in class org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream
 
available() - Method in class org.apache.flink.runtime.state.BoundedInputStream
 
available() - Method in class org.apache.flink.runtime.util.DataInputDeserializer
 
available() - Method in class org.apache.flink.runtime.util.NonClosingStreamDecorator
 
availableMemory - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
The free memory segments currently available to the hash join.
AverageAccumulator - Class in org.apache.flink.api.common.accumulators
An accumulator that computes the average value.
AverageAccumulator() - Constructor for class org.apache.flink.api.common.accumulators.AverageAccumulator
 
AverageClusteringCoefficient<K extends Comparable<K> & CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.directed
The average clustering coefficient measures the mean connectedness of a graph.
AverageClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient
 
AverageClusteringCoefficient<K extends Comparable<K> & CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.undirected
The average clustering coefficient measures the mean connectedness of a graph.
AverageClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient
 
AverageClusteringCoefficient.Result - Class in org.apache.flink.graph.library.clustering.directed
Wraps global clustering coefficient metrics.
AverageClusteringCoefficient.Result - Class in org.apache.flink.graph.library.clustering.undirected
Wraps global clustering coefficient metrics.
AVG - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
AVG aggregate function.
avg() - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionOperations
Returns the average (arithmetic mean) of the numeric field across all input values.
avg(boolean, String, RexNode) - Static method in class org.apache.flink.table.calcite.FlinkRelBuilder
 
Avg - Class in org.apache.flink.table.expressions
 
Avg(Expression) - Constructor for class org.apache.flink.table.expressions.Avg
 
Avg$ - Class in org.apache.flink.table.expressions
 
Avg$() - Constructor for class org.apache.flink.table.expressions.Avg$
 
AVG_RECORD_BYTES_UNKNOWN - Static variable in interface org.apache.flink.api.common.io.statistics.BaseStatistics
Constant indicating that average record width is unknown.
avgBytesPerRecord - Variable in class org.apache.flink.api.common.io.FileInputFormat.FileBaseStatistics
 
avgLen() - Method in class org.apache.flink.table.plan.stats.ColumnStats
 
AvroInputFormat<E> - Class in org.apache.flink.api.java.io
Provides a FileInputFormat for Avro records.
AvroInputFormat(Path, Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroInputFormat
 
AvroKeyValue(GenericRecord) - Constructor for class org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter.AvroKeyValue
Wraps a GenericRecord that is a key value pair.
AvroKeyValueSinkWriter<K,V> - Class in org.apache.flink.streaming.connectors.fs
Implementation of AvroKeyValue writer that can be used in Sink.
AvroKeyValueSinkWriter(Map<String, String>) - Constructor for class org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter
C'tor for the writer
AvroKeyValueSinkWriter.AvroKeyValue<K,V> - Class in org.apache.flink.streaming.connectors.fs
 
AvroOutputFormat<E> - Class in org.apache.flink.api.java.io
 
AvroOutputFormat(Path, Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroOutputFormat
 
AvroOutputFormat(Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroOutputFormat
 
AvroOutputFormat.Codec - Enum in org.apache.flink.api.java.io
Wrapper which encapsulates the supported codec and a related serialization byte.
AvroRowDeserializationSchema - Class in org.apache.flink.streaming.util.serialization
Deserialization schema from Avro bytes over SpecificRecord to Row.
AvroRowDeserializationSchema(Class<? extends SpecificRecord>) - Constructor for class org.apache.flink.streaming.util.serialization.AvroRowDeserializationSchema
Creates a Avro deserialization schema for the given record.
AvroRowSerializationSchema - Class in org.apache.flink.streaming.util.serialization
Serialization schema that serializes Row over SpecificRecord into a Avro bytes.
AvroRowSerializationSchema(Class<? extends SpecificRecord>) - Constructor for class org.apache.flink.streaming.util.serialization.AvroRowSerializationSchema
Creates a Avro serialization schema for the given schema.
AvroSchemaSerializer() - Constructor for class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.AvroSchemaSerializer
 
AvroSerializer<T> - Class in org.apache.flink.api.java.typeutils.runtime
General purpose serialization.
AvroSerializer(Class<T>) - Constructor for class org.apache.flink.api.java.typeutils.runtime.AvroSerializer
 
AvroSerializer(Class<T>, Class<? extends T>) - Constructor for class org.apache.flink.api.java.typeutils.runtime.AvroSerializer
 
AvroSerializer.AvroSerializerConfigSnapshot<T> - Class in org.apache.flink.api.java.typeutils.runtime
 
AvroSerializerConfigSnapshot() - Constructor for class org.apache.flink.api.java.typeutils.runtime.AvroSerializer.AvroSerializerConfigSnapshot
 
AvroSerializerConfigSnapshot(Class<T>, Class<? extends T>, LinkedHashMap<String, KryoRegistration>) - Constructor for class org.apache.flink.api.java.typeutils.runtime.AvroSerializer.AvroSerializerConfigSnapshot
 
AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> - Class in org.apache.flink.api.java.typeutils
Special type information to generate a special AvroTypeInfo for Avro POJOs (implementing SpecificRecordBase, the typed Avro POJOs) Proceeding: It uses a regular pojo type analysis and replaces all GenericType<CharSequence> with a GenericType<avro.Utf8>.
AvroTypeInfo(Class<T>) - Constructor for class org.apache.flink.api.java.typeutils.AvroTypeInfo
 
await() - Method in class org.apache.flink.core.testutils.MultiShotLatch
Waits until MultiShotLatch.trigger() is called.
await() - Method in class org.apache.flink.core.testutils.OneShotLatch
Waits until OneShotLatch.trigger() is called.
await(long, TimeUnit) - Method in class org.apache.flink.core.testutils.OneShotLatch
Waits until OneShotLatch.trigger() is called.
awaitJobManagerGatewayAndWebPort() - Method in class org.apache.flink.runtime.webmonitor.JobManagerRetriever
Awaits the leading job manager gateway and its web monitor port.
awaitJobResult(JobListeningContext) - Static method in class org.apache.flink.runtime.client.JobClient
Given a JobListeningContext, awaits the result of the job execution that this context is bound to
awaitStartOfSuperstepOrTermination(int) - Method in class org.apache.flink.runtime.iterative.concurrent.SuperstepKickoffLatch
 
awaitTermination() - Method in class org.apache.flink.runtime.minicluster.FlinkMiniCluster
 
axpy(double, Vector, Vector) - Method in class org.apache.flink.ml.math.BLAS$
y += a * x
axpy(double, Vector, Vector) - Static method in class org.apache.flink.ml.math.BLAS
y += a * x

B

B - Variable in class org.apache.flink.graph.generator.RMatGraph
 
back() - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable.UnmatchedBuildIterator
 
backend - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Backend that holds the actual RocksDB instance where we store state
BackPressureStatsTracker - Class in org.apache.flink.runtime.webmonitor
Back pressure statistics tracker.
BackPressureStatsTracker(StackTraceSampleCoordinator, int, int, Time) - Constructor for class org.apache.flink.runtime.webmonitor.BackPressureStatsTracker
Creates a back pressure statistics tracker.
BarrierBuffer - Class in org.apache.flink.streaming.runtime.io
The barrier buffer is CheckpointBarrierHandler that blocks inputs with barriers until all inputs have received the barrier for a given checkpoint.
BarrierBuffer(InputGate, IOManager) - Constructor for class org.apache.flink.streaming.runtime.io.BarrierBuffer
Creates a new checkpoint stream aligner.
BarrierBuffer(InputGate, IOManager, long) - Constructor for class org.apache.flink.streaming.runtime.io.BarrierBuffer
Creates a new checkpoint stream aligner.
BarrierTracker - Class in org.apache.flink.streaming.runtime.io
The BarrierTracker keeps track of what checkpoint barriers have been received from which input channels.
BarrierTracker(InputGate) - Constructor for class org.apache.flink.streaming.runtime.io.BarrierTracker
 
BaseAlignedWindowAssigner - Class in org.apache.flink.streaming.api.windowing.assigners
BaseAlignedWindowAssigner(long) - Constructor for class org.apache.flink.streaming.api.windowing.assigners.BaseAlignedWindowAssigner
 
BasePathBucketer<T> - Class in org.apache.flink.streaming.connectors.fs.bucketing
A Bucketer that does not perform any bucketing of files.
BasePathBucketer() - Constructor for class org.apache.flink.streaming.connectors.fs.bucketing.BasePathBucketer
 
BaseStatistics - Interface in org.apache.flink.api.common.io.statistics
Interface describing the basic statistics that can be obtained from the input.
baseType() - Method in class org.apache.flink.api.scala.codegen.TypeDescriptors.FactoryTypeDescriptor
 
baseURL() - Method in class org.apache.flink.mesos.util.MesosArtifactServer
 
BasicArrayTypeInfo<T,C> - Class in org.apache.flink.api.common.typeinfo
 
BasicOperatorTable - Class in org.apache.flink.table.validate
 
BasicOperatorTable() - Constructor for class org.apache.flink.table.validate.BasicOperatorTable
 
BasicTypeComparator<T extends Comparable<T>> - Class in org.apache.flink.api.common.typeutils.base
 
BasicTypeComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.BasicTypeComparator
 
BasicTypeInfo<T> - Class in org.apache.flink.api.common.typeinfo
Type information for primitive types (int, long, double, byte, ...), String, Date, Void, BigInteger, and BigDecimal.
BasicTypeInfo(Class<T>, Class<?>[], TypeSerializer<T>, Class<? extends TypeComparator<T>>) - Constructor for class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
BatchQueryConfig - Class in org.apache.flink.table.api
The BatchQueryConfig holds parameters to configure the behavior of batch queries.
BatchQueryConfig() - Constructor for class org.apache.flink.table.api.BatchQueryConfig
 
BatchScan - Interface in org.apache.flink.table.plan.nodes.dataset
 
BatchTableEnvironment - Class in org.apache.flink.table.api
The abstract base class for batch TableEnvironments.
BatchTableEnvironment(ExecutionEnvironment, TableConfig) - Constructor for class org.apache.flink.table.api.BatchTableEnvironment
 
BatchTableEnvironment - Class in org.apache.flink.table.api.java
The TableEnvironment for a Java batch DataSet ExecutionEnvironment.
BatchTableEnvironment(ExecutionEnvironment, TableConfig) - Constructor for class org.apache.flink.table.api.java.BatchTableEnvironment
 
BatchTableEnvironment - Class in org.apache.flink.table.api.scala
The TableEnvironment for a Scala batch DataSet ExecutionEnvironment.
BatchTableEnvironment(ExecutionEnvironment, TableConfig) - Constructor for class org.apache.flink.table.api.scala.BatchTableEnvironment
 
BatchTableSink<T> - Interface in org.apache.flink.table.sinks
Defines an external TableSink to emit a batch Table.
BatchTableSource<T> - Interface in org.apache.flink.table.sources
Defines an external batch table and provides access to its data.
BatchTableSourceScan - Class in org.apache.flink.table.plan.nodes.dataset
Flink RelNode to read data from an external source defined by a BatchTableSource.
BatchTableSourceScan(RelOptCluster, RelTraitSet, RelOptTable, BatchTableSource<?>) - Constructor for class org.apache.flink.table.plan.nodes.dataset.BatchTableSourceScan
 
BatchTableSourceScanRule - Class in org.apache.flink.table.plan.rules.dataSet
 
BatchTableSourceScanRule() - Constructor for class org.apache.flink.table.plan.rules.dataSet.BatchTableSourceScanRule
 
BatchTableSourceScanRule$ - Class in org.apache.flink.table.plan.rules.dataSet
 
BatchTableSourceScanRule$() - Constructor for class org.apache.flink.table.plan.rules.dataSet.BatchTableSourceScanRule$
 
BatchTask<S extends Function,OT> - Class in org.apache.flink.runtime.operators
The base class for all batch tasks.
BatchTask() - Constructor for class org.apache.flink.runtime.operators.BatchTask
 
bcVarManager() - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManager
 
bcVarManager() - Method in class org.apache.flink.runtime.taskmanager.TaskManager
Handler for shared broadcast variables (shared between multiple Tasks)
bcVarManager() - Static method in class org.apache.flink.yarn.YarnTaskManager
 
begin(String) - Static method in class org.apache.flink.cep.pattern.Pattern
Starts a new pattern sequence.
begin(String) - Method in class org.apache.flink.cep.scala.pattern.Pattern$
Starts a new pattern sequence.
begin(String) - Static method in class org.apache.flink.cep.scala.pattern.Pattern
Starts a new pattern sequence.
begin() - Method in class org.apache.flink.table.expressions.Substring
 
BernoulliSampler<T> - Class in org.apache.flink.api.java.sampling
A sampler implementation built upon a Bernoulli trail.
BernoulliSampler(double) - Constructor for class org.apache.flink.api.java.sampling.BernoulliSampler
Create a Bernoulli sampler with sample fraction and default random number generator.
BernoulliSampler(double, long) - Constructor for class org.apache.flink.api.java.sampling.BernoulliSampler
Create a Bernoulli sampler with sample fraction and random number generator seed.
BernoulliSampler(double, Random) - Constructor for class org.apache.flink.api.java.sampling.BernoulliSampler
Create a Bernoulli sampler with sample fraction and random number generator.
bestEffortDiscardAllStateObjects(Iterable<? extends StateObject>) - Static method in class org.apache.flink.runtime.state.StateUtil
Iterates through the passed state handles and calls discardState() on each handle that is not null.
bestEffortGetNumOfUsedBuffers() - Method in interface org.apache.flink.runtime.io.network.buffer.BufferPool
Returns the number of used buffers of this buffer pool.
BETWEEN - Static variable in class org.apache.calcite.sql.fun.SqlStdOperatorTable
 
BiFunction<T,U,R> - Interface in org.apache.flink.runtime.concurrent
Function which is called with two arguments and returns a value.
BIG_DEC_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
BIG_INT_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
BigDecComparator - Class in org.apache.flink.api.common.typeutils.base
Comparator for comparing BigDecimal values.
BigDecComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.BigDecComparator
 
BigDecParser - Class in org.apache.flink.types.parser
Parses a text field into a BigDecimal.
BigDecParser() - Constructor for class org.apache.flink.types.parser.BigDecParser
 
BigDecSerializer - Class in org.apache.flink.api.common.typeutils.base
Serializer for serializing/deserializing BigDecimal values including null values.
BigDecSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.BigDecSerializer
 
BigIntComparator - Class in org.apache.flink.api.common.typeutils.base
Comparator for comparing BigInteger values.
BigIntComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.BigIntComparator
 
BigIntegralAvgAccumulator - Class in org.apache.flink.table.functions.aggfunctions
The initial accumulator for Big Integral Avg aggregate function
BigIntegralAvgAccumulator() - Constructor for class org.apache.flink.table.functions.aggfunctions.BigIntegralAvgAccumulator
 
BigIntegralAvgAggFunction<T> - Class in org.apache.flink.table.functions.aggfunctions
Base Class for Built-in Big Integral Avg aggregate function
BigIntegralAvgAggFunction() - Constructor for class org.apache.flink.table.functions.aggfunctions.BigIntegralAvgAggFunction
 
BigIntParser - Class in org.apache.flink.types.parser
Parses a text field into a BigInteger.
BigIntParser() - Constructor for class org.apache.flink.types.parser.BigIntParser
 
BigIntSerializer - Class in org.apache.flink.api.common.typeutils.base
Serializer for serializing/deserializing BigInteger values including null values.
BigIntSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.BigIntSerializer
 
BinaryArithmetic - Class in org.apache.flink.table.expressions
 
BinaryArithmetic() - Constructor for class org.apache.flink.table.expressions.BinaryArithmetic
 
BinaryComparison - Class in org.apache.flink.table.expressions
 
BinaryComparison() - Constructor for class org.apache.flink.table.expressions.BinaryComparison
 
BinaryExpression - Class in org.apache.flink.table.expressions
 
BinaryExpression() - Constructor for class org.apache.flink.table.expressions.BinaryExpression
 
BinaryInputFormat<T> - Class in org.apache.flink.api.common.io
Base class for all input formats that use blocks of fixed size.
BinaryInputFormat() - Constructor for class org.apache.flink.api.common.io.BinaryInputFormat
 
BinaryInputFormat.BlockBasedInput - Class in org.apache.flink.api.common.io
Reads the content of a block of data.
BinaryNode - Class in org.apache.flink.table.plan.logical
 
BinaryNode() - Constructor for class org.apache.flink.table.plan.logical.BinaryNode
 
binaryOperation(AbstractInsnNode, BasicValue, BasicValue) - Method in class org.apache.flink.api.java.sca.NestedMethodAnalyzer
 
BinaryOperatorInformation<IN1,IN2,OUT> - Class in org.apache.flink.api.common.operators
A class for holding information about a single input operator, such as input/output TypeInformation.
BinaryOperatorInformation(TypeInformation<IN1>, TypeInformation<IN2>, TypeInformation<OUT>) - Constructor for class org.apache.flink.api.common.operators.BinaryOperatorInformation
 
BinaryOutputFormat<T> - Class in org.apache.flink.api.common.io
 
BinaryOutputFormat() - Constructor for class org.apache.flink.api.common.io.BinaryOutputFormat
 
BinaryOutputFormat.BlockBasedOutput - Class in org.apache.flink.api.common.io
Writes a block info at the end of the blocks.
Current implementation uses only int and not long.
BinaryPredicate - Class in org.apache.flink.table.expressions
 
BinaryPredicate() - Constructor for class org.apache.flink.table.expressions.BinaryPredicate
 
BinaryResult<T> - Interface in org.apache.flink.graph.asm.result
A GraphAlgorithm result for a pair vertices.
binarySearch(Vector<Object>, double, int, double, double, double, double, int) - Method in class org.apache.flink.ml.outlier.StochasticOutlierSelection$
Performs a binary search to get affinities in such a way that each conditional Gaussian has the same perplexity.
binarySearch(Vector<Object>, double, int, double, double, double, double, int) - Static method in class org.apache.flink.ml.outlier.StochasticOutlierSelection
Performs a binary search to get affinities in such a way that each conditional Gaussian has the same perplexity.
BinaryUnionNode - Class in org.apache.flink.optimizer.dag
The Optimizer representation of a binary Union.
BinaryUnionNode(Union<?>) - Constructor for class org.apache.flink.optimizer.dag.BinaryUnionNode
 
BinaryUnionNode.UnionSemanticProperties - Class in org.apache.flink.optimizer.dag
 
BinaryUnionOpDescriptor - Class in org.apache.flink.optimizer.operators
 
BinaryUnionOpDescriptor() - Constructor for class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor
 
BinaryUnionPlanNode - Class in org.apache.flink.optimizer.plan
A special subclass for the union to make it identifiable.
BinaryUnionPlanNode(BinaryUnionNode, Channel, Channel) - Constructor for class org.apache.flink.optimizer.plan.BinaryUnionPlanNode
 
BinaryUnionPlanNode(BinaryUnionPlanNode) - Constructor for class org.apache.flink.optimizer.plan.BinaryUnionPlanNode
 
BinaryUnionReplacer - Class in org.apache.flink.optimizer.traversals
A traversal that collects cascading binary unions into a single n-ary union operator.
BinaryUnionReplacer() - Constructor for class org.apache.flink.optimizer.traversals.BinaryUnionReplacer
 
bind(StateBinder) - Method in class org.apache.flink.api.common.state.AggregatingStateDescriptor
 
bind(StateBinder) - Method in class org.apache.flink.api.common.state.FoldingStateDescriptor
Deprecated.
 
bind(StateBinder) - Method in class org.apache.flink.api.common.state.ListStateDescriptor
 
bind(StateBinder) - Method in class org.apache.flink.api.common.state.MapStateDescriptor
 
bind(StateBinder) - Method in class org.apache.flink.api.common.state.ReducingStateDescriptor
 
bind(StateBinder) - Method in class org.apache.flink.api.common.state.StateDescriptor
Creates a new State on the given StateBinder.
bind(StateBinder) - Method in class org.apache.flink.api.common.state.ValueStateDescriptor
 
bind(StateBinder) - Method in class org.apache.flink.migration.api.common.state.ListStateDescriptor
Deprecated.
 
bindVariables(String[], String[]) - Method in class org.apache.flink.runtime.metrics.scope.ScopeFormat
 
BipartiteEdge<KT,KB,EV> - Class in org.apache.flink.graph.bipartite
A BipartiteEdge represents a link between top and bottom vertices in a BipartiteGraph.
BipartiteEdge() - Constructor for class org.apache.flink.graph.bipartite.BipartiteEdge
 
BipartiteEdge(KT, KB, EV) - Constructor for class org.apache.flink.graph.bipartite.BipartiteEdge
 
BipartiteGraph<KT,KB,VVT,VVB,EV> - Class in org.apache.flink.graph.bipartite
The vertices of a bipartite graph are divided into two disjoint sets, referenced by the names "top" and "bottom".
bitMix(int) - Static method in class org.apache.flink.util.MathUtils
Bit-mixing for pseudo-randomization of integers (e.g., to guard against bad hash functions).
BitSet - Class in org.apache.flink.runtime.operators.util
 
BitSet(int) - Constructor for class org.apache.flink.runtime.operators.util.BitSet
 
bitSet - Variable in class org.apache.flink.runtime.operators.util.BloomFilter
 
BitSet(int) - Constructor for class org.apache.flink.runtime.operators.util.BloomFilter.BitSet
 
bitSize() - Method in class org.apache.flink.runtime.operators.util.BitSet
Number of bits
bitSize() - Method in class org.apache.flink.runtime.operators.util.BloomFilter.BitSet
Number of bits
Blackboard(SqlValidatorScope, Map<String, RexNode>, boolean) - Constructor for class org.apache.calcite.sql2rel.SqlToRelConverter.Blackboard
Creates a Blackboard.
BLAS - Class in org.apache.flink.ml.math
BLAS routines for vectors and matrices.
BLAS() - Constructor for class org.apache.flink.ml.math.BLAS
 
BLAS$ - Class in org.apache.flink.ml.math
BLAS routines for vectors and matrices.
BLAS$() - Constructor for class org.apache.flink.ml.math.BLAS$
 
BLOB_FETCH_BACKLOG_KEY - Static variable in class org.apache.flink.configuration.ConfigConstants
The config parameter defining the backlog of BLOB fetches on the JobManager
BLOB_FETCH_CONCURRENT_KEY - Static variable in class org.apache.flink.configuration.ConfigConstants
The config parameter defining the maximum number of concurrent BLOB fetches that the JobManager serves.
BLOB_FETCH_RETRIES_KEY - Static variable in class org.apache.flink.configuration.ConfigConstants
The config parameter defining number of retires for failed BLOB fetches.
BLOB_SERVER_PORT - Static variable in class org.apache.flink.configuration.ConfigConstants
The config parameter defining the server port of the blob service.
BLOB_SERVICE_SSL_ENABLED - Static variable in class org.apache.flink.configuration.ConfigConstants
Flag to override ssl support for the blob service transport
BLOB_STORAGE_DIRECTORY_KEY - Static variable in class org.apache.flink.configuration.ConfigConstants
The config parameter defining the storage directory to be used by the blob server.
BlobCache - Class in org.apache.flink.runtime.blob
The BLOB cache implements a local cache for content-addressable BLOBs.
BlobCache(InetSocketAddress, Configuration, BlobView) - Constructor for class org.apache.flink.runtime.blob.BlobCache
Instantiates a new BLOB cache.
BlobClient - Class in org.apache.flink.runtime.blob
The BLOB client can communicate with the BLOB server and either upload (PUT), download (GET), or delete (DELETE) BLOBs.
BlobClient(InetSocketAddress, Configuration) - Constructor for class org.apache.flink.runtime.blob.BlobClient
Instantiates a new BLOB client.
BlobKey - Class in org.apache.flink.runtime.blob
A BLOB key uniquely identifies a BLOB.
BlobKey() - Constructor for class org.apache.flink.runtime.blob.BlobKey
Constructs a new BLOB key.
BlobLibraryCacheManager - Class in org.apache.flink.runtime.execution.librarycache
For each job graph that is submitted to the system the library cache manager maintains a set of libraries (typically JAR files) which the job requires to run.
BlobLibraryCacheManager(BlobService, long) - Constructor for class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager
 
blobManagerPort() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.ClassloadingProps
 
blobPort() - Method in class org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration
 
blobPort() - Method in class org.apache.flink.runtime.messages.RegistrationMessages.AlreadyRegistered
 
BlobServer - Class in org.apache.flink.runtime.blob
This class implements the BLOB server.
BlobServer(Configuration, BlobStore) - Constructor for class org.apache.flink.runtime.blob.BlobServer
Instantiates a new BLOB server and binds it to a free network port.
BlobServerProtocol - Class in org.apache.flink.runtime.blob
 
BlobService - Interface in org.apache.flink.runtime.blob
A simple store and retrieve binary large objects (BLOBs).
BlobStore - Interface in org.apache.flink.runtime.blob
A blob store.
BlobStoreService - Interface in org.apache.flink.runtime.blob
Service interface for the BlobStore which allows to close and clean up its data.
blobStoreService - Variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices
Blob store service to be used for the BlobServer and BlobCache
BlobUtils - Class in org.apache.flink.runtime.blob
Utility class to work with blob data.
BlobView - Interface in org.apache.flink.runtime.blob
View on blobs stored in a BlobStore.
Block<T> - Class in org.apache.flink.ml.common
Base class for blocks of elements.
Block(int, Vector<T>) - Constructor for class org.apache.flink.ml.common.Block
 
block(DataSet<T>, int, Option<Partitioner<Object>>, TypeInformation<T>, ClassTag<T>) - Method in class org.apache.flink.ml.common.FlinkMLTools$
Groups the DataSet input into numBlocks blocks.
block(DataSet<T>, int, Option<Partitioner<Object>>, TypeInformation<T>, ClassTag<T>) - Static method in class org.apache.flink.ml.common.FlinkMLTools
Groups the DataSet input into numBlocks blocks.
Block$ - Class in org.apache.flink.ml.common
 
Block$() - Constructor for class org.apache.flink.ml.common.Block$
 
BLOCK_SIZE_PARAMETER_KEY - Static variable in class org.apache.flink.api.common.io.BinaryInputFormat
The config parameter which defines the fixed length of a record.
BLOCK_SIZE_PARAMETER_KEY - Static variable in class org.apache.flink.api.common.io.BinaryOutputFormat
The config parameter which defines the fixed length of a record.
BlockBasedInput(FSDataInputStream, int) - Constructor for class org.apache.flink.api.common.io.BinaryInputFormat.BlockBasedInput
 
BlockBasedInput(FSDataInputStream, int, long) - Constructor for class org.apache.flink.api.common.io.BinaryInputFormat.BlockBasedInput
 
BlockBasedOutput(OutputStream, int) - Constructor for class org.apache.flink.api.common.io.BinaryOutputFormat.BlockBasedOutput
 
BlockChannelReader<T> - Interface in org.apache.flink.runtime.io.disk.iomanager
A reader that reads data in blocks from a file channel.
BlockChannelWriter<T> - Interface in org.apache.flink.runtime.io.disk.iomanager
A writer that writes data in blocks to a file channel.
BlockChannelWriterWithCallback<T> - Interface in org.apache.flink.runtime.io.disk.iomanager
 
BlockedFactorization(DataSet<Tuple2<Object, double[][]>>, DataSet<Tuple2<Object, double[][]>>) - Constructor for class org.apache.flink.ml.recommendation.ALS.BlockedFactorization
 
BlockedFactorization$() - Constructor for class org.apache.flink.ml.recommendation.ALS.BlockedFactorization$
 
blockForeverNonInterruptibly() - Static method in class org.apache.flink.core.testutils.CommonTestUtils
Permanently blocks the current thread.
blockHeadCopy - Variable in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator
 
BlockIDGenerator(int) - Constructor for class org.apache.flink.ml.recommendation.ALS.BlockIDGenerator
 
BlockIDPartitioner() - Constructor for class org.apache.flink.ml.recommendation.ALS.BlockIDPartitioner
 
BlockInfo - Class in org.apache.flink.api.common.io
A block of 24 bytes written at the end of a block in a binary file, and containing i) the number of records in the block, ii) the accumulated number of records, and iii) the offset of the first record in the block.
BlockInfo() - Constructor for class org.apache.flink.api.common.io.BlockInfo
 
BlockInfo<T extends org.apache.commons.math3.random.RandomGenerator> - Class in org.apache.flink.graph.generator.random
Defines a source of randomness and a unit of work.
BlockInfo(RandomGenerable<T>, int, int, long, long) - Constructor for class org.apache.flink.graph.generator.random.BlockInfo
 
BlockingBackChannel - Class in org.apache.flink.runtime.iterative.concurrent
A concurrent datastructure that establishes a backchannel buffer between an iteration head and an iteration tail.
BlockingBackChannel(SerializedUpdateBuffer) - Constructor for class org.apache.flink.runtime.iterative.concurrent.BlockingBackChannel
 
BlockingBackChannelBroker - Class in org.apache.flink.runtime.iterative.concurrent
Singleton class for the threadsafe handover of BlockingBackChannels from iteration heads to iteration tails
BlockingQueueBroker - Class in org.apache.flink.streaming.runtime.io
Broker for the BlockingQueue used in StreamIterationHead and StreamIterationTail for implementing feedback streams.
BlockLocation - Interface in org.apache.flink.core.fs
A BlockLocation lists hosts, offset and length of block.
BlockRating(Tuple2<int[], double[]>[]) - Constructor for class org.apache.flink.ml.recommendation.ALS.BlockRating
 
BlockRating$() - Constructor for class org.apache.flink.ml.recommendation.ALS.BlockRating$
 
BlockResettableMutableObjectIterator<T> - Class in org.apache.flink.runtime.operators.resettable
Implementation of an iterator that fetches a block of data into main memory and offers resettable access to the data in that block.
BlockResettableMutableObjectIterator(MemoryManager, MutableObjectIterator<T>, TypeSerializer<T>, int, AbstractInvokable) - Constructor for class org.apache.flink.runtime.operators.resettable.BlockResettableMutableObjectIterator
 
Blocks$() - Constructor for class org.apache.flink.ml.classification.SVM.Blocks$
 
Blocks$() - Constructor for class org.apache.flink.ml.nn.KNN.Blocks$
 
Blocks$() - Constructor for class org.apache.flink.ml.recommendation.ALS.Blocks$
 
BloomFilter - Class in org.apache.flink.runtime.operators.util
BloomFilter is a probabilistic data structure for set membership check.
BloomFilter(int, int) - Constructor for class org.apache.flink.runtime.operators.util.BloomFilter
 
BloomFilter.BitSet - Class in org.apache.flink.runtime.operators.util
Bare metal bit set implementation.
body - Variable in class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail
 
bolt - Variable in class org.apache.flink.storm.wrappers.BoltWrapper
The wrapped Storm bolt.
BoltCounter - Class in org.apache.flink.storm.wordcount.operators
Implements the word counter that counts the occurrence of each unique word.
BoltCounter() - Constructor for class org.apache.flink.storm.wordcount.operators.BoltCounter
 
BoltCounterByName - Class in org.apache.flink.storm.wordcount.operators
Implements the word counter that counts the occurrence of each unique word.
BoltCounterByName() - Constructor for class org.apache.flink.storm.wordcount.operators.BoltCounterByName
 
BoltFileSink - Class in org.apache.flink.storm.util
Implements a sink that write the received data to the given file (as a result of Object.toString() for each attribute).
BoltFileSink(String) - Constructor for class org.apache.flink.storm.util.BoltFileSink
 
BoltFileSink(String, OutputFormatter) - Constructor for class org.apache.flink.storm.util.BoltFileSink
 
BoltPrintSink - Class in org.apache.flink.storm.util
Implements a sink that prints the received data to stdout.
BoltPrintSink(OutputFormatter) - Constructor for class org.apache.flink.storm.util.BoltPrintSink
 
BoltTokenizer - Class in org.apache.flink.storm.wordcount.operators
Implements the string tokenizer that splits sentences into words as a bolt.
BoltTokenizer() - Constructor for class org.apache.flink.storm.wordcount.operators.BoltTokenizer
 
BoltTokenizerByName - Class in org.apache.flink.storm.wordcount.operators
Implements the string tokenizer that splits sentences into words as a bolt.
BoltTokenizerByName() - Constructor for class org.apache.flink.storm.wordcount.operators.BoltTokenizerByName
 
BoltTokenizerWordCount - Class in org.apache.flink.storm.wordcount
Implements the "WordCount" program that computes a simple word occurrence histogram over text files in a streaming fashion.
BoltTokenizerWordCount() - Constructor for class org.apache.flink.storm.wordcount.BoltTokenizerWordCount
 
BoltTokenizerWordCountPojo - Class in org.apache.flink.storm.wordcount
Implements the "WordCount" program that computes a simple word occurrence histogram over text files in a streaming fashion.
BoltTokenizerWordCountPojo() - Constructor for class org.apache.flink.storm.wordcount.BoltTokenizerWordCountPojo
 
BoltTokenizerWordCountWithNames - Class in org.apache.flink.storm.wordcount
Implements the "WordCount" program that computes a simple word occurrence histogram over text files in a streaming fashion.
BoltTokenizerWordCountWithNames() - Constructor for class org.apache.flink.storm.wordcount.BoltTokenizerWordCountWithNames
 
BoltWrapper<IN,OUT> - Class in org.apache.flink.storm.wrappers
A BoltWrapper wraps an IRichBolt in order to execute the Storm bolt within a Flink Streaming program.
BoltWrapper(IRichBolt) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BoltWrapper(IRichBolt, Fields) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BoltWrapper(IRichBolt, String[]) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BoltWrapper(IRichBolt, Collection<String>) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BoltWrapper(IRichBolt, Fields, String[]) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BoltWrapper(IRichBolt, Fields, Collection<String>) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BoltWrapper(IRichBolt, String, String, String, Fields, Collection<String>) - Constructor for class org.apache.flink.storm.wrappers.BoltWrapper
Instantiates a new BoltWrapper that wraps the given Storm bolt such that it can be used within a Flink streaming program.
BOOLEAN - Static variable in class org.apache.flink.api.common.typeinfo.Types
 
BOOLEAN() - Method in class org.apache.flink.table.api.Types$
 
BOOLEAN() - Static method in class org.apache.flink.table.api.Types
 
BOOLEAN() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
BOOLEAN() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
boolean2Literal(boolean) - Method in interface org.apache.flink.table.api.scala.ImplicitExpressionConversions
 
BOOLEAN_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo
 
BOOLEAN_PRIMITIVE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo
 
BOOLEAN_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
BOOLEAN_VALUE_TYPE_INFO - Static variable in class org.apache.flink.api.java.typeutils.ValueTypeInfo
 
BooleanColumnSummary - Class in org.apache.flink.api.java.summarize
Summary for a column of booleans
BooleanColumnSummary(long, long, long) - Constructor for class org.apache.flink.api.java.summarize.BooleanColumnSummary
 
BooleanComparator - Class in org.apache.flink.api.common.typeutils.base
 
BooleanComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.BooleanComparator
 
BooleanConditions - Class in org.apache.flink.cep.pattern.conditions
Utility class containing an IterativeCondition that always returns true and one that always returns false.
BooleanConditions() - Constructor for class org.apache.flink.cep.pattern.conditions.BooleanConditions
 
BooleanExplodeTableFunc - Class in org.apache.flink.table.plan.util
 
BooleanExplodeTableFunc() - Constructor for class org.apache.flink.table.plan.util.BooleanExplodeTableFunc
 
BooleanMaxAggFunction - Class in org.apache.flink.table.functions.aggfunctions
Built-in Boolean Max aggregate function
BooleanMaxAggFunction() - Constructor for class org.apache.flink.table.functions.aggfunctions.BooleanMaxAggFunction
 
BooleanMaxWithRetractAggFunction - Class in org.apache.flink.table.functions.aggfunctions
Built-in Boolean Max with retraction aggregate function
BooleanMaxWithRetractAggFunction() - Constructor for class org.apache.flink.table.functions.aggfunctions.BooleanMaxWithRetractAggFunction
 
BooleanMinAggFunction - Class in org.apache.flink.table.functions.aggfunctions
Built-in Boolean Min aggregate function
BooleanMinAggFunction() - Constructor for class org.apache.flink.table.functions.aggfunctions.BooleanMinAggFunction
 
BooleanMinWithRetractAggFunction - Class in org.apache.flink.table.functions.aggfunctions
Built-in Boolean Min with retraction aggregate function
BooleanMinWithRetractAggFunction() - Constructor for class org.apache.flink.table.functions.aggfunctions.BooleanMinWithRetractAggFunction
 
BooleanParameter - Class in org.apache.flink.graph.drivers.parameter
A Parameter storing a Boolean.
BooleanParameter(ParameterizedBase, String) - Constructor for class org.apache.flink.graph.drivers.parameter.BooleanParameter
Set the parameter name and add this parameter to the list of parameters stored by owner.
BooleanParser - Class in org.apache.flink.types.parser
 
BooleanParser() - Constructor for class org.apache.flink.types.parser.BooleanParser
 
BooleanPrimitiveArrayComparator - Class in org.apache.flink.api.common.typeutils.base.array
 
BooleanPrimitiveArrayComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArrayComparator
 
BooleanPrimitiveArraySerializer - Class in org.apache.flink.api.common.typeutils.base.array
A serializer for boolean arrays.
BooleanPrimitiveArraySerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArraySerializer
 
BooleanSerializer - Class in org.apache.flink.api.common.typeutils.base
 
BooleanSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.BooleanSerializer
 
BooleanSerializer() - Constructor for class org.apache.flink.python.api.streaming.util.SerializationUtils.BooleanSerializer
 
BooleanSummaryAggregator - Class in org.apache.flink.api.java.summarize.aggregation
 
BooleanSummaryAggregator() - Constructor for class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator
 
BooleanValue - Class in org.apache.flink.types
Boxed serializable and comparable boolean type, representing the primitive type boolean.
BooleanValue() - Constructor for class org.apache.flink.types.BooleanValue
 
BooleanValue(boolean) - Constructor for class org.apache.flink.types.BooleanValue
 
BooleanValueComparator - Class in org.apache.flink.api.common.typeutils.base
Specialized comparator for BooleanValue based on CopyableValueComparator.
BooleanValueComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.BooleanValueComparator
 
BooleanValueParser - Class in org.apache.flink.types.parser
 
BooleanValueParser() - Constructor for class org.apache.flink.types.parser.BooleanValueParser
 
BooleanValueSerializer - Class in org.apache.flink.api.common.typeutils.base
 
BooleanValueSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.BooleanValueSerializer
 
BooleanValueSummaryAggregator() - Constructor for class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.BooleanValueSummaryAggregator
 
boolLiteral() - Method in class org.apache.flink.table.expressions.ExpressionParser$
 
boolLiteral() - Static method in class org.apache.flink.table.expressions.ExpressionParser
 
bootstrapCommand() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters
Get the bootstrap command.
BootstrapTools - Class in org.apache.flink.runtime.clusterframework
Tools for starting JobManager and TaskManager processes, including the Actor Systems used to run the JobManager and TaskManager actors.
BOTH() - Method in class org.apache.flink.table.expressions.TrimMode$
 
BOTH() - Static method in class org.apache.flink.table.expressions.TrimMode
 
Bottou(double) - Constructor for class org.apache.flink.ml.optimization.LearningRateMethod.Bottou
 
Bottou$() - Constructor for class org.apache.flink.ml.optimization.LearningRateMethod.Bottou$
 
BoundedInputStream - Class in org.apache.flink.runtime.state
Wrapper around a FSDataInputStream to limit the maximum read offset.
BoundedInputStream(FSDataInputStream, long) - Constructor for class org.apache.flink.runtime.state.BoundedInputStream
 
BoundedOutOfOrdernessTimestampExtractor<T> - Class in org.apache.flink.streaming.api.functions.timestamps
This is a AssignerWithPeriodicWatermarks used to emit Watermarks that lag behind the element with the maximum timestamp (in event time) seen so far by a fixed amount of time, t_late.
BoundedOutOfOrdernessTimestampExtractor(Time) - Constructor fo