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 

A

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.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.
abs() - Method in interface org.apache.flink.api.scala.table.ImplicitExpressionOperations
 
Abs - Class in org.apache.flink.api.table.expressions
 
Abs(Expression) - Constructor for class org.apache.flink.api.table.expressions.Abs
 
abs() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
abs() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
Abs$ - Class in org.apache.flink.api.table.expressions
 
Abs$() - Constructor for class org.apache.flink.api.table.expressions.Abs$
 
AbstractAlignedProcessingTimeWindowOperator<KEY,IN,OUT,STATE,F extends Function> - Class in org.apache.flink.streaming.runtime.operators.windowing
 
AbstractAlignedProcessingTimeWindowOperator(F, KeySelector<IN, KEY>, TypeSerializer<KEY>, TypeSerializer<STATE>, long, long) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator
 
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
 
AbstractCEPPatternOperator<IN> - Class in org.apache.flink.cep.operator
Base class for CEP pattern operator.
AbstractCEPPatternOperator(TypeSerializer<IN>, boolean) - Constructor for class org.apache.flink.cep.operator.AbstractCEPPatternOperator
 
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
 
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
 
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.runtime.state.filesystem
Base class for state that is stored in a file.
AbstractFileStateHandle(Path) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFileStateHandle
Creates a new file state for the given file path.
AbstractFlinkYarnClient - Class in org.apache.flink.runtime.yarn
Abstract interface for an implementation of a Flink on YARN client to deploy.
AbstractFlinkYarnClient() - Constructor for class org.apache.flink.runtime.yarn.AbstractFlinkYarnClient
 
AbstractFlinkYarnCluster - Class in org.apache.flink.runtime.yarn
Abstract class for interacting with a running Flink cluster within YARN.
AbstractFlinkYarnCluster() - Constructor for class org.apache.flink.runtime.yarn.AbstractFlinkYarnCluster
 
AbstractFsState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.runtime.state.filesystem
Base class for partitioned ListState implementations that are backed by a regular heap hash map.
AbstractFsState(FsStateBackend, TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFsState
 
AbstractFsState(FsStateBackend, TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, HashMap<N, Map<K, SV>>) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFsState
 
AbstractFsStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.runtime.state.filesystem
A snapshot of a heap key/value state stored in a file.
AbstractFsStateSnapshot(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, Path) - Constructor for class org.apache.flink.runtime.state.filesystem.AbstractFsStateSnapshot
Creates a new state snapshot with data in the file system.
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
 
AbstractHeapState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend> - Class in org.apache.flink.runtime.state
Base class for partitioned ListState implementations that are backed by a regular heap hash map.
AbstractHeapState(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD) - Constructor for class org.apache.flink.runtime.state.AbstractHeapState
Creates a new empty key/value state.
AbstractHeapState(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, HashMap<N, Map<K, SV>>) - Constructor for class org.apache.flink.runtime.state.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
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
 
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
 
AbstractMemState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.runtime.state.memory
Base class for partitioned ListState implementations that are backed by a regular heap hash map.
AbstractMemState(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD) - Constructor for class org.apache.flink.runtime.state.memory.AbstractMemState
 
AbstractMemState(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, HashMap<N, Map<K, SV>>) - Constructor for class org.apache.flink.runtime.state.memory.AbstractMemState
 
AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.runtime.state.memory
A snapshot of a MemValueState for a checkpoint.
AbstractMemStateSnapshot(TypeSerializer<K>, TypeSerializer<N>, TypeSerializer<SV>, SD, byte[]) - Constructor for class org.apache.flink.runtime.state.memory.AbstractMemStateSnapshot
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
 
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
 
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
 
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
 
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
 
AbstractRocksDBSnapshot(File, String, URI, long, TypeSerializer<K>, TypeSerializer<N>, SD) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot
Creates a new snapshot from the given state parameters.
AbstractRocksDBState<K,N,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.contrib.streaming.state
Base class for State implementations that store state in a RocksDB database.
AbstractRocksDBState(TypeSerializer<K>, TypeSerializer<N>, File, String, Options) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Creates a new RocksDB backed state.
AbstractRocksDBState(TypeSerializer<K>, TypeSerializer<N>, File, String, String, Options) - Constructor for class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Creates a new RocksDB backed state and restores from the given backup directory.
AbstractRocksDBState.AbstractRocksDBSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>> - Class in org.apache.flink.contrib.streaming.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>>) - 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.runtime.state
A state backend defines how state is stored and snapshotted during checkpoints.
AbstractStateBackend() - Constructor for class org.apache.flink.runtime.state.AbstractStateBackend
 
AbstractStateBackend.CheckpointStateOutputStream - Class in org.apache.flink.runtime.state
A dedicated output stream that produces a StreamStateHandle when closed.
AbstractStateBackend.CheckpointStateOutputView - Class in org.apache.flink.runtime.state
A dedicated DataOutputView stream that produces a StateHandle<DataInputView> when closed.
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
 
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
 
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
 
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(Visitor<T>) - Method in interface org.apache.flink.util.Visitable
Contains the logic to invoke the visitor and continue the traversal.
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
 
accessField(Field, Object) - Method in class org.apache.flink.api.java.typeutils.runtime.PojoComparator
This method is handling the IllegalAccess exceptions of Field.get()
AccumulatingKeyedTimePanes<Type,Key,Result> - Class in org.apache.flink.streaming.runtime.operators.windowing
 
AccumulatingKeyedTimePanes(KeySelector<Type, Key>, WindowFunction<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
 
AccumulatingProcessingTimeWindowOperator(WindowFunction<IN, OUT, KEY, TimeWindow>, KeySelector<IN, KEY>, TypeSerializer<KEY>, TypeSerializer<IN>, long, long) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator
 
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 internal and user-defined accumulators.
AccumulatorRegistry(JobID, ExecutionAttemptID) - Constructor for class org.apache.flink.runtime.accumulators.AccumulatorRegistry
 
AccumulatorRegistry.Metric - Enum in org.apache.flink.runtime.accumulators
Flink metrics supported
AccumulatorRegistry.Reporter - Interface in org.apache.flink.runtime.accumulators
Interface for Flink's internal accumulators.
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
 
AccumulatorSnapshot - Class in org.apache.flink.runtime.accumulators
This class encapsulates a map of accumulators for a single task.
AccumulatorSnapshot(JobID, ExecutionAttemptID, Map<AccumulatorRegistry.Metric, Accumulator<?, ?>>, 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$() - Constructor for class org.apache.flink.runtime.messages.Messages.Acknowledge$
 
AcknowledgeApplicationClientRegistration$() - Constructor for class org.apache.flink.yarn.YarnMessages.AcknowledgeApplicationClientRegistration$
 
acknowledgeCheckpoint(long) - 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, StateHandle<?>) - 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 - 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) - Constructor for class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint
 
AcknowledgeCheckpoint(JobID, ExecutionAttemptID, long, SerializedValue<StateHandle<?>>, long) - Constructor for class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint
 
acknowledgeCheckpoint(long) - Method in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment
 
acknowledgeCheckpoint(long, StateHandle<?>) - 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, SerializedValue<StateHandle<?>>, long) - Method in class org.apache.flink.runtime.checkpoint.PendingCheckpoint
 
ACTION_INFO - Static variable in class org.apache.flink.client.CliFrontend
 
ACTION_RUN - Static variable in class org.apache.flink.client.CliFrontend
 
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
 
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.
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(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(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(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) - Method in interface org.apache.flink.api.common.state.MergingState
Updates the operator state accessible by MergingState.get() by adding the given value to the list of values.
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(Object) - Method in class org.apache.flink.contrib.operatorstatistics.OperatorStatisticsAccumulator
 
add(T) - Method in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState
 
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(Parameter<T>, T) - Method in class org.apache.flink.ml.common.ParameterMap
Adds a new parameter value to the ParameterMap.
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(T) - Method in class org.apache.flink.runtime.state.filesystem.FsFoldingState
 
add(V) - Method in class org.apache.flink.runtime.state.filesystem.FsListState
 
add(V) - Method in class org.apache.flink.runtime.state.filesystem.FsReducingState
 
add(T) - Method in class org.apache.flink.runtime.state.GenericFoldingState
 
add(T) - Method in class org.apache.flink.runtime.state.GenericListState
 
add(T) - Method in class org.apache.flink.runtime.state.GenericReducingState
 
add(T) - Method in class org.apache.flink.runtime.state.memory.MemFoldingState
 
add(V) - Method in class org.apache.flink.runtime.state.memory.MemListState
 
add(V) - Method in class org.apache.flink.runtime.state.memory.MemReducingState
 
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(String, T) - Method in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore
Creates a state handle and stores it in ZooKeeper with create mode CreateMode.PERSISTENT.
add(String, T, CreateMode) - Method in class org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore
Creates a state handle and stores it in ZooKeeper.
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction.ByteSum
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction.DoubleSum
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction.FloatSum
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction.IntSum
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction.LongSum
 
add(Object, Object) - Method in class org.apache.flink.streaming.api.functions.aggregation.SumFunction.ShortSum
 
add(Extractor<TO, OUT>) - Method in class org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtract
 
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(Void) - Method in class org.apache.flink.streaming.connectors.kafka.internals.metrics.DefaultKafkaMetricAccumulator
 
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(int, V) - Method in class org.apache.flink.types.ListValue
 
add(V) - Method in class org.apache.flink.types.ListValue
 
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
 
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.UnmodifiableConfiguration
 
addAll(Configuration, String) - Method in class org.apache.flink.configuration.UnmodifiableConfiguration
 
addAll(Configuration) - Method in class org.apache.flink.runtime.operators.util.TaskConfig.DelegatingConfiguration
 
addAll(Configuration, String) - Method in class org.apache.flink.runtime.operators.util.TaskConfig.DelegatingConfiguration
 
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
 
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
 
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.
addBroadcastSetForMessagingFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration
Adds a data set as a broadcast set to the messaging 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.
addBroadcastSetForUpdateFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration
Adds a data set as a broadcast set to the vertex update 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.ZooKeeperCompletedCheckpointStore
Synchronously writes the new checkpoints to ZooKeeper and asynchronously removes older ones.
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
 
addComparatorField(int, TypeComparator<?>) - Method in interface org.apache.flink.api.common.typeutils.CompositeType.TypeComparatorBuilder
 
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
 
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.
addDateFormatter() - Method in class org.apache.flink.api.table.codegen.ExpressionCodeGenerator
 
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.
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
 
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
 
addGlobalProperties(RequestedGlobalProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
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.
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.
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
 
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.
addList(List<T>) - Method in class org.apache.flink.runtime.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
 
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
 
addObject(Object) - Method in class org.apache.flink.contrib.operatorstatistics.heavyhitters.CountMinHeavyHitter
 
addObject(Object) - Method in interface org.apache.flink.contrib.operatorstatistics.heavyhitters.HeavyHitter
 
addObject(Object) - Method in class org.apache.flink.contrib.operatorstatistics.heavyhitters.LossyCounting
 
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.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.
addPostParameter(String, String) - Method in class org.apache.flink.streaming.connectors.twitter.TwitterFilterSource
This function sets a post parameter.
addPostParameters(Map<String, String>) - Method in class org.apache.flink.streaming.connectors.twitter.TwitterFilterSource
This function sets post parameters.
addQueryParameter(String, String) - Method in class org.apache.flink.streaming.connectors.twitter.TwitterFilterSource
This function sets a query parameter.
addQueryParameters(Map<String, String>) - Method in class org.apache.flink.streaming.connectors.twitter.TwitterFilterSource
This function sets query parameters.
addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator
 
addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator
 
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
 
addRecord(T) - Method in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer
 
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 - 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.instance.InstanceConnectionInfo
Returns the network address the instance's task manager binds its sockets to.
address() - Method in class org.apache.flink.runtime.messages.JobClientMessages.JobManagerLeaderAddress
 
addressLimit - Variable in class org.apache.flink.core.memory.MemorySegment
The address one byte after the last addressable byte.
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
 
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.
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.
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(StateTransition<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
 
addTimeFormatter() - Method in class org.apache.flink.api.table.codegen.ExpressionCodeGenerator
 
addTimestampFormatter() - Method in class org.apache.flink.api.table.codegen.ExpressionCodeGenerator
 
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
 
addType(int, Class<? extends Key<?>>) - Method in class org.apache.flink.optimizer.postpass.SparseKeySchema
 
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.
AdjacencyList(long, long[]) - Constructor for class org.apache.flink.examples.scala.graph.PageRankBasic.AdjacencyList
 
AdjacencyList(long, long[]) - Constructor for class org.apache.flink.examples.scala.PageRankTable.AdjacencyList
 
AdjacencyList$() - Constructor for class org.apache.flink.examples.scala.graph.PageRankBasic.AdjacencyList$
 
AdjacencyList$() - Constructor for class org.apache.flink.examples.scala.PageRankTable.AdjacencyList$
 
adjustGlobalPropertiesForFullParallelismChange() - Method in class org.apache.flink.optimizer.plan.Channel
 
adjustTop() - Method in class org.apache.flink.runtime.operators.sort.PartialOrderPriorityQueue
Should be called when the Object at top changes values.
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.
agg - Variable in class org.apache.flink.python.api.PythonOperationInfo.AggregationEntry
 
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(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 - Class in org.apache.flink.api.table.plan
Internal operation.
Aggregate(PlanNode, Seq<Tuple2<String, Aggregations>>) - Constructor for class org.apache.flink.api.table.plan.Aggregate
 
aggregate(AggregationFunction<T>) - Method in class org.apache.flink.streaming.api.datastream.KeyedStream
 
aggregate(AggregationFunction.AggregationType, int) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
 
aggregate(AggregationFunction.AggregationType, int) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
 
Aggregate$ - Class in org.apache.flink.api.table.plan
 
Aggregate$() - Constructor for class org.apache.flink.api.table.plan.Aggregate$
 
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
 
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
 
aggregates - Variable in class org.apache.flink.python.api.PythonOperationInfo
 
aggregateUserAccumulators() - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
Merges all accumulator results from the tasks previously executed in the Executions.
AggregatingKeyedTimePanes<Type,Key> - Class in org.apache.flink.streaming.runtime.operators.windowing
 
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
 
AggregatingProcessingTimeWindowOperator(ReduceFunction<IN>, KeySelector<IN, KEY>, TypeSerializer<KEY>, TypeSerializer<IN>, long, long) - Constructor for class org.apache.flink.streaming.runtime.operators.windowing.AggregatingProcessingTimeWindowOperator
 
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.api.table.expressions
 
Aggregation() - Constructor for class org.apache.flink.api.table.expressions.Aggregation
 
AggregationEntry(int, int) - Constructor for class org.apache.flink.python.api.PythonOperationInfo.AggregationEntry
 
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
 
AggregationFunction() - Constructor for class org.apache.flink.streaming.api.functions.aggregation.AggregationFunction
 
AggregationFunction.AggregationType - Enum in org.apache.flink.streaming.api.functions.aggregation
 
AggregationFunctionFactory - Interface in org.apache.flink.api.java.aggregation
 
Aggregations - Enum in org.apache.flink.api.java.aggregation
 
aggregations() - Method in class org.apache.flink.api.table.plan.Aggregate
 
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_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.
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_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.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.ConfigConstants
Heartbeat interval of watch failure detector
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
 
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.api.table.parser.ExpressionParser$
 
alias() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
allBufferPools - Variable in class org.apache.flink.runtime.io.network.buffer.NetworkBufferPool
 
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
 
allocatedContainersList() - Method in class org.apache.flink.yarn.YarnJobManager
 
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(int[], int) - Static method in class org.apache.flink.yarn.FlinkYarnClientBase
 
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.
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.
AllReduceDriver<T> - Class in org.apache.flink.runtime.operators
Reduce task which is executed by a Task Manager.
AllReduceDriver() - Constructor for class org.apache.flink.runtime.operators.AllReduceDriver
 
AllReduceProperties - Class in org.apache.flink.optimizer.operators
 
AllReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllReduceProperties
 
AllWindowedStream<T,W extends Window> - Class in org.apache.flink.streaming.api.datastream
A AllWindowedStream represents a data stream where the stream of elements is split into windows based on a WindowAssigner.
AllWindowedStream(DataStream<T>, WindowAssigner<? super T, W>) - Constructor for class org.apache.flink.streaming.api.datastream.AllWindowedStream
 
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.
AMRMClientAsyncHandler() - Method in class org.apache.flink.yarn.YarnJobManager
 
AMRMClientAsyncHandler() - Constructor for class org.apache.flink.yarn.YarnJobManager.AMRMClientAsyncHandler
Heartbeats with the resource manager and informs of container updates.
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
 
analyze(A) - Method in class org.apache.flink.api.table.trees.Analyzer
 
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
 
Analyzer<A extends TreeNode<A>> - Class in org.apache.flink.api.table.trees
Base class for tree analyzers/transformers.
Analyzer() - Constructor for class org.apache.flink.api.table.trees.Analyzer
 
analyzeSingleInputUdf(SingleInputUdfOperator<?, ?, ?>, Class<?>, String, Function, Keys<?>) - Static method in class org.apache.flink.api.java.operators.UdfOperatorUtils
 
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 - Class in org.apache.flink.api.table.expressions
 
And(Expression, Expression) - Constructor for class org.apache.flink.api.table.expressions.And
 
And$ - Class in org.apache.flink.api.table.expressions
 
And$() - Constructor for class org.apache.flink.api.table.expressions.And$
 
AndFilterFunction<T> - Class in org.apache.flink.cep.pattern
A filter function which combines two filter functions with a logical and.
AndFilterFunction(FilterFunction<T>, FilterFunction<T>) - Constructor for class org.apache.flink.cep.pattern.AndFilterFunction
 
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
 
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
 
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 Key<?>>, 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.
ApplicationClient - Class in org.apache.flink.yarn
Actor which is responsible to repeatedly poll the Yarn cluster status from the JobManager.
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$
 
ApplicationMaster - Class in org.apache.flink.yarn
Default implementation of the ApplicationMasterBase which starts a YarnJobManager and a MemoryArchivist.
ApplicationMaster() - Constructor for class org.apache.flink.yarn.ApplicationMaster
 
ApplicationMaster$ - Class in org.apache.flink.yarn
 
ApplicationMaster$() - Constructor for class org.apache.flink.yarn.ApplicationMaster$
 
ApplicationMasterBase - Class in org.apache.flink.yarn
Base class for all application masters.
ApplicationMasterBase() - Constructor for class org.apache.flink.yarn.ApplicationMasterBase
 
ApplicationMasterBase$ - Class in org.apache.flink.yarn
 
ApplicationMasterBase$() - Constructor for class org.apache.flink.yarn.ApplicationMasterBase$
 
ApplicationMasterStatus(int, int) - Constructor for class org.apache.flink.yarn.YarnMessages.ApplicationMasterStatus
 
ApplicationMasterStatus$() - Constructor for class org.apache.flink.yarn.YarnMessages.ApplicationMasterStatus$
 
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(CompositeType<?>, CompositeType<?>, Expression) - Method in class org.apache.flink.api.table.expressions.analysis.ExtractEquiJoinFields$
 
apply(CompositeType<?>, CompositeType<?>, Expression) - Static method in class org.apache.flink.api.table.expressions.analysis.ExtractEquiJoinFields
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.GroupByAnalyzer.CheckGroupExpression
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.InsertAutoCasts
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.ResolveFieldReferences
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.TypeCheck
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.VerifyBoolean
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.VerifyNoAggregates
 
apply(Expression) - Method in class org.apache.flink.api.table.expressions.analysis.VerifyNoNestedAggregates
 
apply(Object) - Method in class org.apache.flink.api.table.expressions.Literal$
 
apply(Object) - Static method in class org.apache.flink.api.table.expressions.Literal
 
apply(Select) - Method in class org.apache.flink.api.table.plan.ExpandAggregations$
 
apply(Select) - Static method in class org.apache.flink.api.table.plan.ExpandAggregations
 
apply(A) - Method in class org.apache.flink.api.table.trees.Rule
 
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.optimization.GradientDescentL1$
 
apply() - Static method in class org.apache.flink.ml.optimization.GradientDescentL1
 
apply() - Method in class org.apache.flink.ml.optimization.GradientDescentL2$
 
apply() - Static method in class org.apache.flink.ml.optimization.GradientDescentL2
 
apply() - Method in class org.apache.flink.ml.optimization.SimpleGradientDescent$
 
apply() - Static method in class org.apache.flink.ml.optimization.SimpleGradientDescent
 
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(int) - 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(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(AllWindowFunction<T, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies a window function to the 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
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.datastream.AllWindowedStream
Applies the given window function to each window.
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.AllWindowedStream
Applies the given window function to each window.
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
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.datastream.WindowedStream
Applies the given window function to each window.
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.datastream.WindowedStream
Applies the given window function to each window.
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<ACC>) - Method in class org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<ACC>) - Method in class org.apache.flink.streaming.api.functions.windowing.FoldApplyWindowFunction
 
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(W, Iterable<T>, Collector<T>) - Method in class org.apache.flink.streaming.api.functions.windowing.ReduceIterableAllWindowFunction
 
apply(K, W, Iterable<T>, Collector<T>) - Method in class org.apache.flink.streaming.api.functions.windowing.ReduceIterableWindowFunction
 
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
Applies the given window function to each window.
apply(Function2<T, T, T>, 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(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Applies the given window function to each window.
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
Applies the given window function to each window.
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(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
Applies the given window function to each window.
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
Applies the given window function to each window.
apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Applies the given window function to each window.
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
Applies the given window function to each window.
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(KEY, W, Iterable<IN>, Collector<OUT>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableWindowFunction
 
apply(KEY, W, IN, Collector<OUT>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueWindowFunction
 
apply(KEY, W, IN, Collector<OUT>) - Method in class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalWindowFunction
Evaluates the window and outputs none or several elements.
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
 
applyIteratorTrueAssumption() - Method in class org.apache.flink.api.java.sca.UdfAnalyzer
 
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
applyWithState(I, Function2<I, Option<S>, Tuple2<O, Option<S>>>) - Method in interface org.apache.flink.streaming.api.scala.function.StatefulFunction
 
archive() - Method in class org.apache.flink.runtime.jobmanager.JobManager
 
ARCHIVE_NAME() - Method in class org.apache.flink.runtime.jobmanager.JobManager$
Name of the archive actor
ARCHIVE_NAME() - Static method in class org.apache.flink.runtime.jobmanager.JobManager
Name of the archive actor
ArchivedJob(Option<ExecutionGraph>) - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob
 
ArchivedJob$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob$
 
ArchivedJobs(Iterable<ExecutionGraph>) - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs
 
ArchivedJobs$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs$
 
ArchiveExecutionGraph(JobID, ExecutionGraph) - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph
 
ArchiveExecutionGraph$() - Constructor for class org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph$
 
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.
ARGUMENT_PYTHON_2 - Static variable in class org.apache.flink.python.api.PythonPlanBinder
 
ARGUMENT_PYTHON_3 - Static variable in class org.apache.flink.python.api.PythonPlanBinder
 
arguments - Static variable in class org.apache.flink.python.api.PythonPlanBinder
 
arity - Variable in class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase
 
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.
ArrayDescriptor(int, scala.reflect.macros.Context.universe, TypeDescriptors<C>.UDTDescriptor) - Constructor for class org.apache.flink.api.scala.codegen.TypeDescriptors.ArrayDescriptor
 
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
 
arrayToString(Object) - Static method in class org.apache.flink.util.StringUtils
Returns a string representation of the given array.
as(Seq<Expression>) - Method in class org.apache.flink.api.scala.table.DataSetConversions
Converts the DataSet to a Table.
as(Seq<Expression>) - Method in class org.apache.flink.api.scala.table.DataStreamConversions
Converts the DataStream to a Table.
as(Symbol) - Method in interface org.apache.flink.api.scala.table.ImplicitExpressionOperations
 
AS() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
as() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
AS() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
as() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
As - Class in org.apache.flink.api.table.plan
Operation that gives new names to fields.
As(PlanNode, Seq<String>) - Constructor for class org.apache.flink.api.table.plan.As
 
as(Seq<Expression>) - Method in class org.apache.flink.api.table.Table
Renames the fields of the expression result.
as(String) - Method in class org.apache.flink.api.table.Table
Renames the fields of the expression result.
As$ - Class in org.apache.flink.api.table.plan
 
As$() - Constructor for class org.apache.flink.api.table.plan.As$
 
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
 
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
A timestamp assigner and watermark generator for streams where timestamps are monotonously ascending.
AscendingTimestampExtractor() - Constructor for class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor
 
AscendingTimestampExtractor.FailingHandler - Class in org.apache.flink.streaming.api.functions
Handler that fails the program when timestamp monotony is violated.
AscendingTimestampExtractor.IgnoringHandler - Class in org.apache.flink.streaming.api.functions
Handler that does nothing when timestamp monotony is violated.
AscendingTimestampExtractor.LoggingHandler - Class in org.apache.flink.streaming.api.functions
Handler that only logs violations of timestamp monotony, on WARN log level.
AscendingTimestampExtractor.MonotonyViolationHandler - Interface in org.apache.flink.streaming.api.functions
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.
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() - Method in class org.apache.flink.runtime.taskmanager.TaskManager
The timeout for all actor ask futures
asRecord() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a StreamRecord.
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.
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.
assignPartition(int, byte) - Static method in class org.apache.flink.runtime.operators.hash.MutableHashTable
Assigns a partition to a bucket.
assignPartitions(List<T>, int, int) - Static method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
 
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
 
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
Extracts a timestamp from an element and assigns it as the internal timestamp of that element.
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 periodically creates watermarks to signal event time progress.
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.
assignWindows(Object, long) - Method in class org.apache.flink.streaming.api.windowing.assigners.GlobalWindows
 
assignWindows(Object, long) - Method in class org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
 
assignWindows(Object, long) - Method in class org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows
 
assignWindows(Object, long) - Method in class org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows
 
assignWindows(Object, long) - Method in class org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows
 
assignWindows(T, long) - Method in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner
Returns a Collection of windows that should be assigned to the element.
associateWithTaskManagerAndJobManager(ActorGateway, ActorGateway) - Method in class org.apache.flink.runtime.io.network.NetworkEnvironment
This associates the network environment with a TaskManager and JobManager.
asWatermark() - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamElement
Casts this element into a Watermark.
asyncException - Variable in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase
Errors encountered in the async producer are stored here
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
RuntimeException for wrapping exceptions that are thrown in Threads that are not the main compute Thread.
AsynchronousException(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.
AsynchronousKvStateSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend> - Class in org.apache.flink.runtime.state
KvStateSnapshot that asynchronously materializes the state that it represents.
AsynchronousKvStateSnapshot() - Constructor for class org.apache.flink.runtime.state.AsynchronousKvStateSnapshot
 
AsynchronousStateHandle<T> - Class in org.apache.flink.runtime.state
StateHandle that can asynchronously materialize the state that it represents.
AsynchronousStateHandle() - Constructor for class org.apache.flink.runtime.state.AsynchronousStateHandle
 
atom() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
atom() - Static method in class org.apache.flink.api.table.parser.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
 
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
 
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
 
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
 
authenticate() - Method in class org.apache.flink.streaming.connectors.twitter.TwitterSource
 
autoAck - Variable in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
AutomaticWatermarkContext(StreamSource<?, ?>, Object, Output<StreamRecord<T>>, long) - Constructor for class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext
 
available() - Method in class org.apache.flink.core.fs.local.LocalDataInputStream
 
available() - Method in class org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream
 
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
 
avg() - Method in interface org.apache.flink.api.scala.table.ImplicitExpressionOperations
 
Avg - Class in org.apache.flink.api.table.expressions
 
Avg(Expression) - Constructor for class org.apache.flink.api.table.expressions.Avg
 
AVG() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
avg() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
AVG() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
avg() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
Avg$ - Class in org.apache.flink.api.table.expressions
 
Avg$() - Constructor for class org.apache.flink.api.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
 
AvgKafkaMetricAccumulator - Class in org.apache.flink.streaming.connectors.kafka.internals.metrics
 
AvgKafkaMetricAccumulator(KafkaMetric) - Constructor for class org.apache.flink.streaming.connectors.kafka.internals.metrics.AvgKafkaMetricAccumulator
 
AvroInputFormat<E> - Class in org.apache.flink.api.java.io
 
AvroInputFormat(Path, Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroInputFormat
 
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
 
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
 
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
 
awaitJobManagerGatewayAndWebPort() - Method in class org.apache.flink.runtime.webmonitor.JobManagerRetriever
Awaits the leading job manager gateway and its web monitor port.
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

back() - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable.UnmatchedBuildIterator
 
BackPressureStatsTracker - Class in org.apache.flink.runtime.webmonitor
Back pressure statistics tracker.
BackPressureStatsTracker(StackTraceSampleCoordinator, int, int, FiniteDuration) - Constructor for class org.apache.flink.runtime.webmonitor.BackPressureStatsTracker
Creates a back pressure statistics tracker.
backupUri - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot
 
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
 
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
 
basePath - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot
Store it so that we can clean up in dispose()
basePath - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
Store it so that we can clean up in dispose()
BaseStatistics - Interface in org.apache.flink.api.common.io.statistics
Interface describing the basic statistics that can be obtained from the input.
BasicArrayTypeInfo<T,C> - Class in org.apache.flink.api.common.typeinfo
 
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, and Void.
BasicTypeInfo(Class<T>, Class<?>[], TypeSerializer<T>, Class<? extends TypeComparator<T>>) - Constructor for class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
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() - Method in class org.apache.flink.runtime.taskmanager.TaskManager
Handler for shared broadcast variables (shared between multiple Tasks)
begin(String) - Static method in class org.apache.flink.cep.pattern.Pattern
Starts a new pattern with the initial pattern operator whose name is provided.
beginIndex() - Method in class org.apache.flink.api.table.expressions.Substring
 
BEGINNING_STATE_NAME - Static variable in class org.apache.flink.cep.nfa.compiler.NFACompiler
 
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.
BinaryArithmetic - Class in org.apache.flink.api.table.expressions
 
BinaryArithmetic() - Constructor for class org.apache.flink.api.table.expressions.BinaryArithmetic
 
binaryBitwise() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
binaryBitwise() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
BinaryComparison - Class in org.apache.flink.api.table.expressions
 
BinaryComparison() - Constructor for class org.apache.flink.api.table.expressions.BinaryComparison
 
BinaryExpression - Class in org.apache.flink.api.table.expressions
 
BinaryExpression() - Constructor for class org.apache.flink.api.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
Writes a block info at the end of the blocks.
Current implementation uses only int and not long.
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.api.table.expressions
 
BinaryPredicate() - Constructor for class org.apache.flink.api.table.expressions.BinaryPredicate
 
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(StateBackend) - Method in class org.apache.flink.api.common.state.FoldingStateDescriptor
 
bind(StateBackend) - Method in class org.apache.flink.api.common.state.ListStateDescriptor
 
bind(StateBackend) - Method in class org.apache.flink.api.common.state.ReducingStateDescriptor
 
bind(StateBackend) - Method in class org.apache.flink.api.common.state.StateDescriptor
Creates a new State on the given StateBackend.
bind(StateBackend) - Method in class org.apache.flink.api.common.state.ValueStateDescriptor
 
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
BitwiseAnd - Class in org.apache.flink.api.table.expressions
 
BitwiseAnd(Expression, Expression) - Constructor for class org.apache.flink.api.table.expressions.BitwiseAnd
 
BitwiseAnd$ - Class in org.apache.flink.api.table.expressions
 
BitwiseAnd$() - Constructor for class org.apache.flink.api.table.expressions.BitwiseAnd$
 
BitwiseBinaryArithmetic - Class in org.apache.flink.api.table.expressions
 
BitwiseBinaryArithmetic() - Constructor for class org.apache.flink.api.table.expressions.BitwiseBinaryArithmetic
 
BitwiseNot - Class in org.apache.flink.api.table.expressions
 
BitwiseNot(Expression) - Constructor for class org.apache.flink.api.table.expressions.BitwiseNot
 
BitwiseNot$ - Class in org.apache.flink.api.table.expressions
 
BitwiseNot$() - Constructor for class org.apache.flink.api.table.expressions.BitwiseNot$
 
BitwiseOr - Class in org.apache.flink.api.table.expressions
 
BitwiseOr(Expression, Expression) - Constructor for class org.apache.flink.api.table.expressions.BitwiseOr
 
BitwiseOr$ - Class in org.apache.flink.api.table.expressions
 
BitwiseOr$() - Constructor for class org.apache.flink.api.table.expressions.BitwiseOr$
 
BitwiseXor - Class in org.apache.flink.api.table.expressions
 
BitwiseXor(Expression, Expression) - Constructor for class org.apache.flink.api.table.expressions.BitwiseXor
 
BitwiseXor$ - Class in org.apache.flink.api.table.expressions
 
BitwiseXor$() - Constructor for class org.apache.flink.api.table.expressions.BitwiseXor$
 
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_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) - Constructor for class org.apache.flink.runtime.blob.BlobCache
 
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) - 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
 
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) - 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).
BlobUtils - Class in org.apache.flink.runtime.blob
Utility class to work with blob data.
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
 
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$
 
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
 
BlockInfo() - Constructor for class org.apache.flink.api.common.io.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
 
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.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.
boolean2Literal(boolean) - Method in interface org.apache.flink.api.scala.table.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
 
BooleanComparator - Class in org.apache.flink.api.common.typeutils.base
 
BooleanComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.BooleanComparator
 
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
 
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
 
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
 
boolLiteral() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
boolLiteral() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
Bottou(double) - Constructor for class org.apache.flink.ml.optimization.LearningRateMethod.Bottou
 
Bottou$() - Constructor for class org.apache.flink.ml.optimization.LearningRateMethod.Bottou$
 
boundaries - Variable in class org.apache.flink.api.common.distributions.SimpleDistribution
 
BoundingBox - Class in org.apache.flink.contrib.tweetinputformat.model.places
A series of longitude and latitude points, defining a box which will contain the Place entity this bounding box is related to.
BoundingBox() - Constructor for class org.apache.flink.contrib.tweetinputformat.model.places.BoundingBox
 
BoundingBox(List<double[]>) - Constructor for class org.apache.flink.contrib.tweetinputformat.model.places.BoundingBox
 
box() - Method in class org.apache.flink.api.scala.codegen.TypeDescriptors.BoxedPrimitiveDescriptor
 
BoxedPrimitiveDescriptor(int, scala.reflect.macros.Context.universe, scala.reflect.macros.Context.universe, scala.reflect.macros.Context.universe, Function1<Universe.TreeContextApi, Universe.TreeContextApi>, Function1<Universe.TreeContextApi, Universe.TreeContextApi>) - Constructor for class org.apache.flink.api.scala.codegen.TypeDescriptors.BoxedPrimitiveDescriptor
 
boxedPrimitives() - Method in interface org.apache.flink.api.scala.codegen.TypeAnalyzer
 
BranchesVisitor - Class in org.apache.flink.optimizer.traversals
This traversal of the optimizer DAG computes the information needed to track branches and joins in the data flow.
BranchesVisitor() - Constructor for class org.apache.flink.optimizer.traversals.BranchesVisitor
 
branchingNode - Variable in class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor
 
branchPlan - Variable in class org.apache.flink.optimizer.plan.PlanNode
 
breaksPipeline() - Method in enum org.apache.flink.optimizer.dag.TempMode
 
Breeze - Class in org.apache.flink.ml.math
This class contains convenience function to wrap a matrix/vector into a breeze matrix/vector and to unwrap it again.
Breeze() - Constructor for class org.apache.flink.ml.math.Breeze
 
Breeze$ - Class in org.apache.flink.ml.math
This class contains convenience function to wrap a matrix/vector into a breeze matrix/vector and to unwrap it again.
Breeze$() - Constructor for class org.apache.flink.ml.math.Breeze$
 
Breeze.Breeze2MatrixConverter - Class in org.apache.flink.ml.math
 
Breeze.Breeze2VectorConverter - Class in org.apache.flink.ml.math
 
Breeze.BreezeArrayConverter<T> - Class in org.apache.flink.ml.math
 
Breeze.Matrix2BreezeConverter - Class in org.apache.flink.ml.math
 
Breeze.Vector2BreezeConverter - Class in org.apache.flink.ml.math
 
Breeze2MatrixConverter(Matrix<Object>) - Constructor for class org.apache.flink.ml.math.Breeze.Breeze2MatrixConverter
 
Breeze2VectorConverter(Vector<Object>) - Constructor for class org.apache.flink.ml.math.Breeze.Breeze2VectorConverter
 
BreezeArrayConverter(Object) - Constructor for class org.apache.flink.ml.math.Breeze.BreezeArrayConverter
 
BreezeVectorConverter<T extends Vector> - Interface in org.apache.flink.ml.math
Type class which allows the conversion from Breeze vectors to Flink vectors
broadcast() - Method in class org.apache.flink.streaming.api.datastream.DataStream
Sets the partitioning of the DataStream so that the output elements are broadcasted to every parallel instance of the next operation.
broadcast() - Method in class org.apache.flink.streaming.api.scala.DataStream
Sets the partitioning of the DataStream so that the output tuples are broad casted to every parallel instance of the next component.
broadcastCheckpointBarrier(long, long) - Method in class org.apache.flink.streaming.runtime.tasks.OperatorChain
 
broadcastEmit(T) - Method in class org.apache.flink.runtime.io.network.api.writer.RecordWriter
This is used to broadcast Streaming Watermarks in-band with records.
broadcastEmit(T) - Method in class org.apache.flink.streaming.runtime.io.StreamRecordWriter
 
broadcastEvent(AbstractEvent) - Method in class org.apache.flink.runtime.io.network.api.writer.RecordWriter
 
broadcastEvent(AbstractEvent) - Method in class org.apache.flink.streaming.runtime.io.RecordWriterOutput
 
broadcastInputReaders - Variable in class org.apache.flink.runtime.operators.BatchTask
The input readers for the configured broadcast variables for this task.
broadcastInputs - Variable in class org.apache.flink.api.common.operators.AbstractUdfOperator
The extra inputs which parameterize the user function.
broadcastInputSerializers - Variable in class org.apache.flink.runtime.operators.BatchTask
The serializers for the broadcast input data types.
BroadcastPartitioner<T> - Class in org.apache.flink.streaming.runtime.partitioner
Partitioner that selects all the output channels.
BroadcastPartitioner() - Constructor for class org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner
 
BroadcastVariableInitializer<T,O> - Interface in org.apache.flink.api.common.functions
A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.
BroadcastVariableKey - Class in org.apache.flink.runtime.broadcast
 
BroadcastVariableKey(JobVertexID, String, int) - Constructor for class org.apache.flink.runtime.broadcast.BroadcastVariableKey
 
BroadcastVariableManager - Class in org.apache.flink.runtime.broadcast
 
BroadcastVariableManager() - Constructor for class org.apache.flink.runtime.broadcast.BroadcastVariableManager
 
BroadcastVariableMaterialization<T,C> - Class in org.apache.flink.runtime.broadcast
 
BroadcastVariableMaterialization(BroadcastVariableKey) - Constructor for class org.apache.flink.runtime.broadcast.BroadcastVariableMaterialization
 
Broker<V> - Class in org.apache.flink.runtime.iterative.concurrent
A concurrent data structure that allows the hand-over of an object between a pair of threads
Broker() - Constructor for class org.apache.flink.runtime.iterative.concurrent.Broker
 
brokerKey() - Method in class org.apache.flink.runtime.iterative.task.AbstractIterativeTask
 
Bucketer - Interface in org.apache.flink.streaming.connectors.fs
A bucketer is used with a RollingSink to put emitted elements into rolling files.
buckets - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
The array of memory segments that contain the buckets which form the actual hash-table of hash-codes and pointers to the elements.
bucketsPerSegmentBits - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
The number of bits that describe the position of a bucket in a memory segment.
bucketsPerSegmentMask - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
The number of hash table buckets in a single memory segment - 1.
Buffer - Class in org.apache.flink.runtime.io.network.buffer
Wrapper for pooled MemorySegment instances.
Buffer(MemorySegment, BufferRecycler) - Constructor for class org.apache.flink.runtime.io.network.buffer.Buffer
 
Buffer(MemorySegment, BufferRecycler, boolean) - Constructor for class org.apache.flink.runtime.io.network.buffer.Buffer
 
buffer() - Method in class org.apache.flink.runtime.io.network.netty.NettyBufferPool
 
buffer(int) - Method in class org.apache.flink.runtime.io.network.netty.NettyBufferPool
 
buffer(int, int) - Method in class org.apache.flink.runtime.io.network.netty.NettyBufferPool
 
buffer - Variable in class org.apache.flink.runtime.operators.resettable.SpillingResettableIterator
 
buffer - Variable in class org.apache.flink.runtime.operators.resettable.SpillingResettableMutableObjectIterator
 
bufferedReader() - Method in class org.apache.flink.api.scala.FlinkShell$
 
bufferedReader() - Static method in class org.apache.flink.api.scala.FlinkShell
 
BufferFileReader - Interface in org.apache.flink.runtime.io.disk.iomanager
 
BufferFileSegmentReader - Interface in org.apache.flink.runtime.io.disk.iomanager
 
BufferFileWriter - Interface in org.apache.flink.runtime.io.disk.iomanager
 
BufferOrEvent - Class in org.apache.flink.runtime.io.network.partition.consumer
Either type for Buffer or AbstractEvent instances tagged with the channel index, from which they were received.
BufferOrEvent(Buffer, int) - Constructor for class org.apache.flink.runtime.io.network.partition.consumer.BufferOrEvent
 
BufferOrEvent(AbstractEvent, int) - Constructor for class org.apache.flink.runtime.io.network.partition.consumer.BufferOrEvent
 
BufferPool - Interface in org.apache.flink.runtime.io.network.buffer
A dynamically sized buffer pool.
BufferPoolFactory - Interface in org.apache.flink.runtime.io.network.buffer
A factory for buffer pools.
BufferPoolOwner - Interface in org.apache.flink.runtime.io.network.buffer
 
BufferProvider - Interface in org.apache.flink.runtime.io.network.buffer
A buffer provider to request buffers from in a synchronous or asynchronous fashion.
BufferReader - Class in org.apache.flink.runtime.io.network.api.reader
A buffer-oriented reader.
BufferReader(InputGate) - Constructor for class org.apache.flink.runtime.io.network.api.reader.BufferReader
 
BufferRecycler - Interface in org.apache.flink.runtime.io.network.buffer
 
BufferReorderingException(int, int) - Constructor for exception org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.BufferReorderingException
 
BufferSpiller - Class in org.apache.flink.streaming.runtime.io
The buffer spiller takes the buffers and events from a data stream and adds them to a spill file.
BufferSpiller(IOManager, int) - Constructor for class org.apache.flink.streaming.runtime.io.BufferSpiller
Creates a new buffer spiller, spilling to one of the I/O manager's temp directories.
BufferSpiller.SpilledBufferOrEventSequence - Class in org.apache.flink.streaming.runtime.io
This class represents a sequence of spilled buffers and events, created by the BufferSpiller.
bufferTimeout - Variable in class org.apache.flink.streaming.api.transformations.StreamTransformation
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple0Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple10Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple11Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple12Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple13Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple14Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple15Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple16Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple17Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple18Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple19Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple1Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple20Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple21Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple22Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple23Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple24Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple25Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple2Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple3Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple4Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple5Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple6Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple7Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple8Builder
 
build() - Method in class org.apache.flink.api.java.tuple.builder.Tuple9Builder
 
build(List<Object>) - Method in interface org.apache.flink.ml.math.VectorBuilder
Builds a Vector of type T from a List[Double]
buildBloomFilterForBucketsInPartition(int, HashPartition<BT, PT>) - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable
 
BuildFirstCachedJoinDriver<IT1,IT2,OT> - Class in org.apache.flink.runtime.operators
 
BuildFirstCachedJoinDriver() - Constructor for class org.apache.flink.runtime.operators.BuildFirstCachedJoinDriver
 
buildFlinkTuple(T, HCatRecord) - Method in class org.apache.flink.hcatalog.HCatInputFormatBase
 
buildFlinkTuple(T, HCatRecord) - Method in class org.apache.flink.hcatalog.java.HCatInputFormat
 
buildFlinkTuple(T, HCatRecord) - Method in class org.apache.flink.hcatalog.scala.HCatInputFormat
 
buildInitialTable(MutableObjectIterator<BT>) - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable
Creates the initial hash table.
buildJDBCInputFormat() - Static method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat
A builder used to set parameters to the output format's configuration in a fluent way.
buildJDBCOutputFormat() - Static method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat
 
BuildOutgoingEdgeList() - Constructor for class org.apache.flink.examples.java.graph.PageRank.BuildOutgoingEdgeList
 
buildPartialModel(Iterable<Integer>) - Method in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.PartialModelBuilder
 
buildProgram(ProgramOptions) - Method in class org.apache.flink.client.CliFrontend
Creates a Packaged program from the given command line options.
BuildSecondCachedJoinDriver<IT1,IT2,OT> - Class in org.apache.flink.runtime.operators
 
BuildSecondCachedJoinDriver() - Constructor for class org.apache.flink.runtime.operators.BuildSecondCachedJoinDriver
 
buildSideComparator - Variable in class org.apache.flink.runtime.operators.hash.AbstractMutableHashTable
The utilities to hash and compare the build side data types.
buildSideComparator - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
The utilities to hash and compare the build side data types.
buildSideSerializer - Variable in class org.apache.flink.runtime.operators.hash.AbstractMutableHashTable
The utilities to serialize the build side data types.
buildSideSerializer - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
The utilities to serialize the build side data types.
buildTableFromSpilledPartition(HashPartition<BT, PT>) - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable
 
buildTableWithUniqueKey(MutableObjectIterator<T>) - Method in class org.apache.flink.runtime.operators.hash.CompactingHashTable
 
buildTopology() - Static method in class org.apache.flink.storm.exclamation.ExclamationTopology
 
buildTopology() - Static method in class org.apache.flink.storm.wordcount.WordCountTopology
 
buildTopology(boolean) - Static method in class org.apache.flink.storm.wordcount.WordCountTopology
 
buildUserCodeClassLoader(List<URL>, List<URL>, ClassLoader) - Static method in class org.apache.flink.client.program.JobWithJars
 
BulkBlockChannelReader - Interface in org.apache.flink.runtime.io.disk.iomanager
 
BulkIterationBase<T> - Class in org.apache.flink.api.common.operators.base
 
BulkIterationBase(UnaryOperatorInformation<T, T>) - Constructor for class org.apache.flink.api.common.operators.base.BulkIterationBase
 
BulkIterationBase(UnaryOperatorInformation<T, T>, String) - Constructor for class org.apache.flink.api.common.operators.base.BulkIterationBase
 
BulkIterationBase.PartialSolutionPlaceHolder<OT> - Class in org.apache.flink.api.common.operators.base
Specialized operator to use as a recognizable place-holder for the input to the step function when composing the nested data flow.
BulkIterationBase.TerminationCriterionAggregationConvergence - Class in org.apache.flink.api.common.operators.base
Convergence for the termination criterion is reached if no tuple is output at current iteration for the termination criterion branch
BulkIterationBase.TerminationCriterionAggregator - Class in org.apache.flink.api.common.operators.base
Aggregator that basically only adds 1 for every output tuple of the termination criterion branch
BulkIterationBase.TerminationCriterionMapper<X> - Class in org.apache.flink.api.common.operators.base
Special Mapper that is added before a termination criterion and is only a container for an special aggregator
BulkIterationNode - Class in org.apache.flink.optimizer.dag
A node in the optimizer's program representation for a bulk iteration.
BulkIterationNode(BulkIterationBase<?>) - Constructor for class org.apache.flink.optimizer.dag.BulkIterationNode
Creates a new node for the bulk iteration.
BulkIterationPlanNode - Class in org.apache.flink.optimizer.plan
 
BulkIterationPlanNode(BulkIterationNode, String, Channel, BulkPartialSolutionPlanNode, PlanNode) - Constructor for class org.apache.flink.optimizer.plan.BulkIterationPlanNode
 
BulkIterationPlanNode(BulkIterationNode, String, Channel, BulkPartialSolutionPlanNode, PlanNode, PlanNode) - Constructor for class org.apache.flink.optimizer.plan.BulkIterationPlanNode
 
BulkIterationResultSet<T> - Class in org.apache.flink.api.java.operators
 
BulkPartialSolutionNode - Class in org.apache.flink.optimizer.dag
The optimizer's internal representation of the partial solution that is input to a bulk iteration.
BulkPartialSolutionNode(BulkIterationBase.PartialSolutionPlaceHolder<?>, BulkIterationNode) - Constructor for class org.apache.flink.optimizer.dag.BulkPartialSolutionNode
 
BulkPartialSolutionPlanNode - Class in org.apache.flink.optimizer.plan
Plan candidate node for partial solution of a bulk iteration.
BulkPartialSolutionPlanNode(BulkPartialSolutionNode, String, GlobalProperties, LocalProperties, Channel) - Constructor for class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode
 
BYTE_ARRAY_BASE_OFFSET - Static variable in class org.apache.flink.core.memory.MemorySegment
The beginning of the byte array contents, relative to the byte array object
BYTE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo
 
BYTE_PRIMITIVE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo
 
BYTE_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
BYTE_VALUE_TYPE_INFO - Static variable in class org.apache.flink.api.java.typeutils.ValueTypeInfo
 
ByteComparator - Class in org.apache.flink.api.common.typeutils.base
 
ByteComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.ByteComparator
 
ByteParser - Class in org.apache.flink.types.parser
 
ByteParser() - Constructor for class org.apache.flink.types.parser.ByteParser
 
BytePrimitiveArrayComparator - Class in org.apache.flink.api.common.typeutils.base.array
 
BytePrimitiveArrayComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArrayComparator
 
BytePrimitiveArraySerializer - Class in org.apache.flink.api.common.typeutils.base.array
A serializer for byte arrays.
BytePrimitiveArraySerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArraySerializer
 
BYTES_COPIED_CNT_NAME - Static variable in class org.apache.flink.examples.java.distcp.DistCp
 
ByteSerializer - Class in org.apache.flink.api.common.typeutils.base
 
ByteSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.ByteSerializer
 
ByteSerializer() - Constructor for class org.apache.flink.python.api.streaming.util.SerializationUtils.ByteSerializer
 
BytesSerializer() - Constructor for class org.apache.flink.python.api.streaming.util.SerializationUtils.BytesSerializer
 
ByteStreamStateHandle - Class in org.apache.flink.runtime.state.memory
A state handle that contains stream state in a byte array.
ByteStreamStateHandle(byte[]) - Constructor for class org.apache.flink.runtime.state.memory.ByteStreamStateHandle
Creates a new ByteStreamStateHandle containing the given data.
ByteSum() - Constructor for class org.apache.flink.streaming.api.functions.aggregation.SumFunction.ByteSum
 
ByteSumAgg() - Constructor for class org.apache.flink.api.java.aggregation.SumAggregationFunction.ByteSumAgg
 
byteToHexString(byte[], int, int) - Static method in class org.apache.flink.util.StringUtils
Given an array of bytes it will convert the bytes to a hex string representation of the bytes.
byteToHexString(byte[]) - Static method in class org.apache.flink.util.StringUtils
Given an array of bytes it will convert the bytes to a hex string representation of the bytes.
ByteValue - Class in org.apache.flink.types
Boxed serializable and comparable byte type, representing the primitive type byte (signed 8 bit integer).
ByteValue() - Constructor for class org.apache.flink.types.ByteValue
Initializes the encapsulated byte with 0.
ByteValue(byte) - Constructor for class org.apache.flink.types.ByteValue
Initializes the encapsulated byte with the provided value.
ByteValueParser - Class in org.apache.flink.types.parser
Parses a decimal text field into a ByteValue.
ByteValueParser() - Constructor for class org.apache.flink.types.parser.ByteValueParser
 
ByteValueSerializer - Class in org.apache.flink.api.common.typeutils.base
 
ByteValueSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.ByteValueSerializer
 
ByteValueSumAgg() - Constructor for class org.apache.flink.api.java.aggregation.SumAggregationFunction.ByteValueSumAgg
 

C

c() - Method in class org.apache.flink.api.scala.codegen.MacroContextHolder
 
cacheBaseStatistics(BaseStatistics, String) - Method in class org.apache.flink.optimizer.DataStatistics
Caches the given statistics.
cachedPlans - Variable in class org.apache.flink.optimizer.dag.OptimizerNode
 
cacheFile - Variable in class org.apache.flink.api.common.Plan
Hash map for files in the distributed cache: registered name to cache entry.
cachePartitionInfo(PartialInputChannelDeploymentDescriptor) - Method in class org.apache.flink.runtime.executiongraph.ExecutionVertex
 
calculateHeapSize(int, Configuration) - Static method in class org.apache.flink.yarn.Utils
See documentation
calculateLearningRate(double, int, double) - Method in class org.apache.flink.ml.optimization.LearningRateMethod.Bottou
 
calculateLearningRate(double, int, double) - Method in class org.apache.flink.ml.optimization.LearningRateMethod.Constant$
 
calculateLearningRate(double, int, double) - Method in class org.apache.flink.ml.optimization.LearningRateMethod.Default$
 
calculateLearningRate(double, int, double) - Method in class org.apache.flink.ml.optimization.LearningRateMethod.InvScaling
 
calculateLearningRate(double, int, double) - Method in interface org.apache.flink.ml.optimization.LearningRateMethod.LearningRateMethodTrait
 
calculateLearningRate(double, int, double) - Method in class org.apache.flink.ml.optimization.LearningRateMethod.Xu
 
callback - Variable in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase
The callback than handles error propagation or logging callbacks
callWithNextKey(FlatJoinFunction<V1, V2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashJoinIterator
 
callWithNextKey(FlatJoinFunction<V1, V2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator
 
callWithNextKey(FlatJoinFunction<V1, V2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashJoinIterator
 
callWithNextKey(FlatJoinFunction<V1, V2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashJoinIterator
 
callWithNextKey(FlatJoinFunction<T1, T2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.sort.AbstractMergeInnerJoinIterator
Calls the JoinFunction#join() method for all two key-value pairs that share the same key and come from different inputs.
callWithNextKey(FlatJoinFunction<T1, T2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator
Calls the JoinFunction#join() method for all two key-value pairs that share the same key and come from different inputs.
callWithNextKey(FlatJoinFunction<T1, T2, O>, Collector<O>) - Method in class org.apache.flink.runtime.operators.sort.AbstractMergeOuterJoinIterator
Calls the JoinFunction#join() method for all two key-value pairs that share the same key and come from different inputs.
callWithNextKey(FlatJoinFunction<V1, V2, O>, Collector<O>) - Method in interface org.apache.flink.runtime.operators.util.JoinTaskIterator
Moves the internal pointer to the next key that both inputs share.
cancel(String[]) - Method in class org.apache.flink.client.CliFrontend
Executes the CANCEL action.
cancel(JobID) - Method in class org.apache.flink.client.program.Client
Cancels a job identified by the job id.
cancel() - Method in class org.apache.flink.runtime.executiongraph.Execution
 
cancel() - Method in class org.apache.flink.runtime.executiongraph.ExecutionGraph
 
cancel() - Method in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex
 
cancel() - Method in class org.apache.flink.runtime.executiongraph.ExecutionVertex
 
cancel() - Method in class org.apache.flink.runtime.iterative.task.AbstractIterativeTask
 
cancel() - Method in class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
This method is called when a task is canceled either as a result of a user abort or an execution failure.
cancel() - Method in class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.AbstractOuterJoinDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.AllGroupCombineDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.AllGroupReduceDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.AllReduceDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.BatchTask
 
cancel() - Method in class org.apache.flink.runtime.operators.CoGroupDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.CoGroupRawDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.CoGroupWithSolutionSetFirstDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.CoGroupWithSolutionSetSecondDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.CrossDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.DataSinkTask
 
cancel() - Method in class org.apache.flink.runtime.operators.DataSourceTask
 
cancel() - Method in interface org.apache.flink.runtime.operators.Driver
This method is invoked when the driver must aborted in mid processing.
cancel() - Method in class org.apache.flink.runtime.operators.FlatMapDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.GroupReduceCombineDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.GroupReduceDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.JoinDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.JoinWithSolutionSetFirstDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.JoinWithSolutionSetSecondDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.MapDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.MapPartitionDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.NoOpDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.ReduceCombineDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.ReduceDriver
 
cancel() - Method in class org.apache.flink.runtime.operators.UnionWithTempOperator
 
cancel() - Method in class org.apache.flink.storm.wrappers.SpoutWrapper
Cancels the source.
cancel() - Method in class org.apache.flink.streaming.api.functions.source.FileMonitoringFunction
 
cancel() - Method in class org.apache.flink.streaming.api.functions.source.FileSourceFunction
 
cancel() - Method in class org.apache.flink.streaming.api.functions.source.FromElementsFunction
 
cancel() - Method in class org.apache.flink.streaming.api.functions.source.FromIteratorFunction
 
cancel() - Method in class org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction
 
cancel() - Method in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction
 
cancel() - Method in interface org.apache.flink.streaming.api.functions.source.SourceFunction
Cancels the source.
cancel() - Method in class org.apache.flink.streaming.api.functions.source.StatefulSequenceSource
 
cancel() - Method in class org.apache.flink.streaming.api.operators.StreamSource
 
cancel() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08
 
cancel() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09
 
cancel() - Method in class org.apache.flink.streaming.connectors.nifi.NiFiSource
 
cancel() - Method in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
cancel() - Method in class org.apache.flink.streaming.connectors.twitter.TwitterSource
 
cancel() - Method in class org.apache.flink.streaming.connectors.wikiedits.WikipediaEditsSource
 
cancel() - Method in class org.apache.flink.streaming.examples.join.WindowJoin.GradeSource
 
cancel() - Method in class org.apache.flink.streaming.examples.join.WindowJoin.SalarySource
 
cancel() - Method in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.FiniteNewDataSource
 
cancel() - Method in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.FiniteTrainingDataSource
 
cancel() - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
cancelAndReleaseAllSlots() - Method in class org.apache.flink.runtime.instance.Instance
 
cancelChainedTasks(List<ChainedDriver<?, ?>>) - Static method in class org.apache.flink.runtime.operators.BatchTask
Cancels all tasks via their ChainedDriver.cancelTask() method.
cancelExecution() - Method in class org.apache.flink.runtime.taskmanager.Task
Cancels the task execution.
CancelJob(JobID) - Constructor for class org.apache.flink.runtime.messages.JobManagerMessages.CancelJob
 
CancelJob$() - Constructor for class org.apache.flink.runtime.messages.JobManagerMessages.CancelJob$
 
CancellationFailure(JobID, Throwable) - Constructor for class org.apache.flink.runtime.messages.JobManagerMessages.CancellationFailure
 
CancellationFailure$() - Constructor for class org.apache.flink.runtime.messages.JobManagerMessages.CancellationFailure$
 
CancellationSuccess(JobID) - Constructor for class org.apache.flink.runtime.messages.JobManagerMessages.CancellationSuccess
 
CancellationSuccess$() - Constructor for class org.apache.flink.runtime.messages.JobManagerMessages.CancellationSuccess$
 
CancelOptions - Class in org.apache.flink.client.cli
Command line options for the CANCEL command
CancelOptions(CommandLine) - Constructor for class org.apache.flink.client.cli.CancelOptions
 
cancelStackTraceSample(int, Exception) - Method in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinator
Cancels a pending sample.
CancelTask(ExecutionAttemptID) - Constructor for class org.apache.flink.runtime.messages.TaskMessages.CancelTask
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedMapDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedTerminationCriterionDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.GroupCombineChainedDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver
 
cancelTask() - Method in class org.apache.flink.runtime.operators.NoOpChainedDriver
 
cancelTask() - Method in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTask
 
cancelTask() - Method in class org.apache.flink.streaming.runtime.tasks.SourceStreamTask
 
cancelTask() - Method in class org.apache.flink.streaming.runtime.tasks.StreamIterationHead
 
cancelTask() - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
cancelTask() - Method in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask
 
CancelTask$() - Constructor for class org.apache.flink.runtime.messages.TaskMessages.CancelTask$
 
CancelTaskException - Exception in org.apache.flink.runtime.execution
Thrown to trigger a canceling of the executing task.
CancelTaskException(Throwable) - Constructor for exception org.apache.flink.runtime.execution.CancelTaskException
 
CancelTaskException(String) - Constructor for exception org.apache.flink.runtime.execution.CancelTaskException
 
CancelTaskException() - Constructor for exception org.apache.flink.runtime.execution.CancelTaskException
 
canContainFields() - Method in class org.apache.flink.api.java.sca.TaggedValue
 
canContainInput() - Method in class org.apache.flink.api.java.sca.TaggedValue
 
canEqual(Object) - Method in class org.apache.flink.api.common.ExecutionConfig
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeinfo.NothingTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeinfo.TypeInformation
Returns true if the given object can be equaled with this object.
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.BooleanPrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.BytePrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.DoublePrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.FloatPrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.IntPrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.LongPrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.ShortPrimitiveArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.array.StringArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.BooleanSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.BooleanValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.ByteSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.ByteValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.CharSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.CharValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.DateSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.DoubleSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.DoubleValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.EnumSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.FloatSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.FloatValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.GenericArraySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.IntSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.IntValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.LongSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.LongValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.ShortSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.ShortValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.StringSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.StringValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.base.VoidSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.CompositeType
 
canEqual(Object) - Method in class org.apache.flink.api.common.typeutils.TypeSerializer
Returns true if the given object can be equaled with this object.
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.EitherTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.EnumTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.GenericTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.MissingTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.PojoField
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.PojoTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.AvroSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.EitherSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.Tuple0Serializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.ValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.TupleTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.TupleTypeInfoBase
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.ValueTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.CaseClassTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.EitherSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.EitherTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.EnumValueSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.EnumValueTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.NothingSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.OptionSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.OptionTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.ScalaNothingTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.TraversableSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.TraversableTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.TrySerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.TryTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.UnitSerializer
 
canEqual(Object) - Method in class org.apache.flink.api.scala.typeutils.UnitTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.table.Row
 
canEqual(Object) - Method in class org.apache.flink.api.table.typeinfo.RenamingProxyTypeInfo
 
canEqual(Object) - Method in class org.apache.flink.api.table.typeinfo.RowSerializer
 
canEqual(Object) - Method in class org.apache.flink.cep.NonDuplicatingTypeSerializer
 
canEqual(Object) - Method in class org.apache.flink.runtime.state.ArrayListSerializer
 
canEqual(Object) - Method in class org.apache.flink.streaming.api.windowing.windows.GlobalWindow.Serializer
 
canEqual(Object) - Method in class org.apache.flink.streaming.api.windowing.windows.TimeWindow.Serializer
 
canEqual(Object) - Method in class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer
 
canEqual(Object) - Method in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer
 
canNotContainInput() - Method in class org.apache.flink.api.java.sca.TaggedValue
 
canReadInt() - Method in class org.apache.flink.api.java.typeutils.runtime.NoFetchingInput
 
canReadLong() - Method in class org.apache.flink.api.java.typeutils.runtime.NoFetchingInput
 
canRestart() - Method in class org.apache.flink.runtime.executiongraph.restart.FixedDelayRestartStrategy
 
canRestart() - Method in class org.apache.flink.runtime.executiongraph.restart.NoRestartStrategy
 
canRestart() - Method in interface org.apache.flink.runtime.executiongraph.restart.RestartStrategy
True if the restart strategy can be applied to restart the ExecutionGraph.
CAR_DATA - Static variable in class org.apache.flink.streaming.examples.windowing.util.TopSpeedWindowingExampleData
 
CarEvent(int, int, double, long) - Constructor for class org.apache.flink.examples.scala.StreamingTableFilter.CarEvent
 
CarEvent(int, int, double, long) - Constructor for class org.apache.flink.streaming.scala.examples.windowing.TopSpeedWindowing.CarEvent
 
CarEvent$() - Constructor for class org.apache.flink.examples.scala.StreamingTableFilter.CarEvent$
 
CarEvent$() - Constructor for class org.apache.flink.streaming.scala.examples.windowing.TopSpeedWindowing.CarEvent$
 
carId() - Method in class org.apache.flink.examples.scala.StreamingTableFilter.CarEvent
 
carId() - Method in class org.apache.flink.streaming.scala.examples.windowing.TopSpeedWindowing.CarEvent
 
CartesianProductDescriptor - Class in org.apache.flink.optimizer.operators
 
CartesianProductDescriptor(boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.CartesianProductDescriptor
 
CaseClassComparator<T extends scala.Product> - Class in org.apache.flink.api.scala.typeutils
Comparator for Case Classes.
CaseClassComparator(int[], TypeComparator<?>[], TypeSerializer<?>[]) - Constructor for class org.apache.flink.api.scala.typeutils.CaseClassComparator
 
CaseClassDescriptor(int, scala.reflect.macros.Context.universe, boolean, scala.reflect.macros.Context.universe, Seq<org.apache.flink.api.scala.codegen.TypeDescriptors.FieldDescriptor>) - Constructor for class org.apache.flink.api.scala.codegen.TypeDescriptors.CaseClassDescriptor
 
CaseClassSerializer<T extends scala.Product> - Class in org.apache.flink.api.scala.typeutils
Serializer for Case Classes.
CaseClassSerializer(Class<T>, TypeSerializer<?>[]) - Constructor for class org.apache.flink.api.scala.typeutils.CaseClassSerializer
 
CaseClassTypeInfo<T extends scala.Product> - Class in org.apache.flink.api.scala.typeutils
TypeInformation for Case Classes.
CaseClassTypeInfo(Class<T>, TypeInformation<?>[], Seq<TypeInformation<?>>, Seq<String>) - Constructor for class org.apache.flink.api.scala.typeutils.CaseClassTypeInfo
 
cast(TypeInformation<?>) - Method in interface org.apache.flink.api.scala.table.ImplicitExpressionOperations
 
Cast - Class in org.apache.flink.api.table.expressions
 
Cast(Expression, TypeInformation<?>) - Constructor for class org.apache.flink.api.table.expressions.Cast
 
cast() - Method in class org.apache.flink.api.table.parser.ExpressionParser$
 
cast() - Static method in class org.apache.flink.api.table.parser.ExpressionParser
 
Cast$ - Class in org.apache.flink.api.table.expressions
 
Cast$() - Constructor for class org.apache.flink.api.table.expressions.Cast$
 
cause() - Method in class org.apache.flink.runtime.messages.accumulators.AccumulatorResultsErroneous
 
cause() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.CancellationFailure
 
cause() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.DisposeSavepointFailure
 
cause() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.JobResultFailure
 
cause() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.StoppingFailure
 
cause() - Method in class org.apache.flink.runtime.messages.JobManagerMessages.TriggerSavepointFailure
 
cause() - Method in class org.apache.flink.runtime.messages.StackTraceSampleMessages.ResponseStackTraceSampleFailure
 
cause() - Method in class org.apache.flink.runtime.messages.TaskManagerMessages.FatalError
 
cause() - Method in class org.apache.flink.runtime.messages.TaskMessages.FailTask
 
cbf() - Method in class org.apache.flink.api.scala.typeutils.TraversableSerializer
 
CCMessenger() - Constructor for class org.apache.flink.graph.library.ConnectedComponents.CCMessenger
 
CCUpdater() - Constructor for class org.apache.flink.graph.library.ConnectedComponents.CCUpdater
 
CENTERS_2D_AFTER_20_ITERATIONS_DOUBLE_DIGIT - Static variable in class org.apache.flink.test.testdata.KMeansData
 
CENTERS_2D_AFTER_SINGLE_ITERATION_DOUBLE_DIGIT - Static variable in class org.apache.flink.test.testdata.KMeansData
 
CENTERS_AFTER_20_ITERATIONS_DOUBLE_DIGIT - Static variable in class org.apache.flink.test.testdata.KMeansData
 
CENTERS_AFTER_20_ITERATIONS_SINGLE_DIGIT - Static variable in class org.apache.flink.test.testdata.KMeansData
 
CENTERS_AFTER_ONE_STEP - Static variable in class org.apache.flink.test.testdata.KMeansData
 
CENTERS_AFTER_ONE_STEP_SINGLE_DIGIT - Static variable in class org.apache.flink.test.testdata.KMeansData
 
Centroid() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Centroid
 
Centroid(int, double, double) - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Centroid
 
Centroid(int, KMeans.Point) - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Centroid
 
Centroid(int, double, double) - Constructor for class org.apache.flink.examples.scala.clustering.KMeans.Centroid
 
Centroid(int, KMeans.Point) - Constructor for class org.apache.flink.examples.scala.clustering.KMeans.Centroid
 
Centroid$() - Constructor for class org.apache.flink.examples.scala.clustering.KMeans.Centroid$
 
CentroidAccumulator() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.CentroidAccumulator
 
CentroidAverager() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.CentroidAverager
 
CENTROIDS - Static variable in class org.apache.flink.examples.java.clustering.util.KMeansData
 
CEP - Class in org.apache.flink.cep
Utility class for complex event processing.
CEP() - Constructor for class org.apache.flink.cep.CEP
 
CEPPatternOperator<IN> - Class in org.apache.flink.cep.operator
CEP pattern operator implementation which is used for non keyed streams.
CEPPatternOperator(TypeSerializer<IN>, boolean, NFACompiler.NFAFactory<IN>) - Constructor for class org.apache.flink.cep.operator.CEPPatternOperator
 
ChainedAllReduceDriver<IT> - Class in org.apache.flink.runtime.operators.chaining
 
ChainedAllReduceDriver() - Constructor for class org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver
 
ChainedDriver<IT,OT> - Class in org.apache.flink.runtime.operators.chaining
The interface to be implemented by drivers that do not run in an own task context, but are chained to other tasks.
ChainedDriver() - Constructor for class org.apache.flink.runtime.operators.chaining.ChainedDriver
 
chainedEvaluationOperation(TransformDataSetOperation<T, Testing, Intermediate>, EvaluateDataSetOperation<P, Intermediate, PredictionValue>, TypeInformation<Testing>, TypeInformation<PredictionValue>) - Method in class org.apache.flink.ml.pipeline.ChainedPredictor$
 
chainedEvaluationOperation(TransformDataSetOperation<T, Testing, Intermediate>, EvaluateDataSetOperation<P, Intermediate, PredictionValue>, TypeInformation<Testing>, TypeInformation<PredictionValue>) - Static method in class org.apache.flink.ml.pipeline.ChainedPredictor
 
chainedFitOperation(FitOperation<L, I>, TransformDataSetOperation<L, I, T>, FitOperation<R, T>) - Method in class org.apache.flink.ml.pipeline.ChainedPredictor$
chainedFitOperation(FitOperation<L, I>, TransformDataSetOperation<L, I, T>, FitOperation<R, T>) - Static method in class org.apache.flink.ml.pipeline.ChainedPredictor
chainedFitOperation(FitOperation<L, I>, TransformDataSetOperation<L, I, T>, FitOperation<R, T>) - Method in class org.apache.flink.ml.pipeline.ChainedTransformer$
FitOperation implementation for ChainedTransformer.
chainedFitOperation(FitOperation<L, I>, TransformDataSetOperation<L, I, T>, FitOperation<R, T>) - Static method in class org.apache.flink.ml.pipeline.ChainedTransformer
FitOperation implementation for ChainedTransformer.
ChainedFlatMapDriver<IT,OT> - Class in org.apache.flink.runtime.operators.chaining
 
ChainedFlatMapDriver() - Constructor for class org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver
 
ChainedMapDriver<IT,OT> - Class in org.apache.flink.runtime.operators.chaining
 
ChainedMapDriver() - Constructor for class org.apache.flink.runtime.operators.chaining.ChainedMapDriver
 
chainedPredictOperation(TransformDataSetOperation<T, Testing, Intermediate>, PredictDataSetOperation<P, Intermediate, Prediction>) - Method in class org.apache.flink.ml.pipeline.ChainedPredictor$
chainedPredictOperation(TransformDataSetOperation<T, Testing, Intermediate>, PredictDataSetOperation<P, Intermediate, Prediction>) - Static method in class org.apache.flink.ml.pipeline.ChainedPredictor
ChainedPredictor<T extends Transformer<T>,P extends Predictor<P>> - Class in org.apache.flink.ml.pipeline
Predictor which represents a pipeline of possibly multiple Transformer and a trailing Predictor.
ChainedPredictor(T, P) - Constructor for class org.apache.flink.ml.pipeline.ChainedPredictor
 
ChainedPredictor$ - Class in org.apache.flink.ml.pipeline
 
ChainedPredictor$() - Constructor for class org.apache.flink.ml.pipeline.ChainedPredictor$
 
chainedTasks - Variable in class org.apache.flink.runtime.operators.BatchTask
A list of chained drivers, if there are any.
ChainedTerminationCriterionDriver<IT,OT> - Class in org.apache.flink.runtime.operators.chaining
 
ChainedTerminationCriterionDriver() - Constructor for class org.apache.flink.runtime.operators.chaining.ChainedTerminationCriterionDriver
 
ChainedTransformer<L extends Transformer<L>,R extends Transformer<R>> - Class in org.apache.flink.ml.pipeline
Transformer which represents the chaining of two Transformer.
ChainedTransformer(L, R) - Constructor for class org.apache.flink.ml.pipeline.ChainedTransformer
 
ChainedTransformer$ - Class in org.apache.flink.ml.pipeline
 
ChainedTransformer$() - Constructor for class org.apache.flink.ml.pipeline.ChainedTransformer$
 
chainedTransformOperation(TransformDataSetOperation<L, I, T>, TransformDataSetOperation<R, T, O>) - Method in class org.apache.flink.ml.pipeline.ChainedTransformer$
chainedTransformOperation(TransformDataSetOperation<L, I, T>, TransformDataSetOperation<R, T, O>) - Static method in class org.apache.flink.ml.pipeline.ChainedTransformer
chainingStrategy - Variable in class org.apache.flink.streaming.api.operators.AbstractStreamOperator
 
ChainingStrategy - Enum in org.apache.flink.streaming.api.operators
Defines the chaining scheme for the operator.
chainPredictor(P) - Method in interface org.apache.flink.ml.pipeline.Transformer
Chains a Transformer with a Predictor to form a ChainedPredictor.
chainTransformer(T) - Method in interface org.apache.flink.ml.pipeline.Transformer
Chains two Transformer to form a ChainedTransformer.
Channel - Class in org.apache.flink.optimizer.plan
A Channel represents the result produced by an operator and the data exchange before the consumption by the target operator.
Channel(PlanNode) - Constructor for class org.apache.flink.optimizer.plan.Channel
 
Channel(PlanNode, TempMode) - Constructor for class org.apache.flink.optimizer.plan.Channel
 
channel - Variable in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
channelIndex - Variable in class org.apache.flink.runtime.io.network.partition.consumer.InputChannel
 
channelRead0(ChannelHandlerContext, Routed) - Method in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler
 
channelRead0(ChannelHandlerContext, Routed) - Method in class org.apache.flink.runtime.webmonitor.handlers.ConstantTextHandler
 
channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.apache.flink.runtime.webmonitor.HttpRequestHandler
 
channelRead0(ChannelHandlerContext, Object) - Method in class org.apache.flink.runtime.webmonitor.PipelineErrorHandler
 
channelRead0(ChannelHandlerContext, Routed) - Method in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler
 
ChannelReaderInputView - Class in org.apache.flink.runtime.io.disk.iomanager
A DataInputView that is backed by a BlockChannelReader, making it effectively a data input stream.
ChannelReaderInputView(BlockChannelReader<MemorySegment>, List<MemorySegment>, boolean) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.ChannelReaderInputView
Creates a new channel reader that reads from the given channel until the last block (as marked by a ChannelWriterOutputView) is found.
ChannelReaderInputView(BlockChannelReader<MemorySegment>, List<MemorySegment>, int, boolean) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.ChannelReaderInputView
Creates a new channel reader that reads from the given channel, expecting a specified number of blocks in the channel.
ChannelReaderInputViewIterator<E> - Class in org.apache.flink.runtime.io.disk
A simple iterator over the input read though an I/O channel.
ChannelReaderInputViewIterator(IOManager, FileIOChannel.ID, List<MemorySegment>, List<MemorySegment>, TypeSerializer<E>, int) - Constructor for class org.apache.flink.runtime.io.disk.ChannelReaderInputViewIterator
 
ChannelReaderInputViewIterator(IOManager, FileIOChannel.ID, LinkedBlockingQueue<MemorySegment>, List<MemorySegment>, List<MemorySegment>, TypeSerializer<E>, int) - Constructor for class org.apache.flink.runtime.io.disk.ChannelReaderInputViewIterator
 
ChannelReaderInputViewIterator(BlockChannelReader<MemorySegment>, LinkedBlockingQueue<MemorySegment>, List<MemorySegment>, List<MemorySegment>, TypeSerializer<E>, int) - Constructor for class org.apache.flink.runtime.io.disk.ChannelReaderInputViewIterator
 
ChannelReaderInputViewIterator(ChannelReaderInputView, List<MemorySegment>, TypeSerializer<E>) - Constructor for class org.apache.flink.runtime.io.disk.ChannelReaderInputViewIterator
 
ChannelSelector<T extends IOReadableWritable> - Interface in org.apache.flink.runtime.io.network.api.writer
The ChannelSelector determines to which logical channels a record should be written to.
channelUnregistered(ChannelHandlerContext) - Method in class org.apache.flink.runtime.webmonitor.HttpRequestHandler
 
ChannelWithBlockCount(FileIOChannel.ID, int) - Constructor for class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.ChannelWithBlockCount
 
ChannelWriterOutputView - Class in org.apache.flink.runtime.io.disk.iomanager
A DataOutputView that is backed by a BlockChannelWriter, making it effectively a data output stream.
ChannelWriterOutputView(BlockChannelWriter<MemorySegment>, List<MemorySegment>, int) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.ChannelWriterOutputView
Creates an new ChannelWriterOutputView that writes to the given channel and buffers data in the given memory segments.
ChannelWriterOutputView(BlockChannelWriter<MemorySegment>, int) - Constructor for class org.apache.flink.runtime.io.disk.iomanager.ChannelWriterOutputView
Creates an new ChannelWriterOutputView that writes to the given channel.
CHAR_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo
 
CHAR_PRIMITIVE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo
 
CHAR_TYPE_INFO - Static variable in class org.apache.flink.api.common.typeinfo.BasicTypeInfo
 
CHAR_VALUE_TYPE_INFO - Static variable in class org.apache.flink.api.java.typeutils.ValueTypeInfo
 
charAt(int) - Method in class org.apache.flink.types.StringValue
 
CharComparator - Class in org.apache.flink.api.common.typeutils.base
 
CharComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.CharComparator
 
CharPrimitiveArrayComparator - Class in org.apache.flink.api.common.typeutils.base.array
 
CharPrimitiveArrayComparator(boolean) - Constructor for class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArrayComparator
 
CharPrimitiveArraySerializer - Class in org.apache.flink.api.common.typeutils.base.array
A serializer for char arrays.
CharPrimitiveArraySerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.array.CharPrimitiveArraySerializer
 
CharSerializer - Class in org.apache.flink.api.common.typeutils.base
 
CharSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.CharSerializer
 
CharValue - Class in org.apache.flink.types
Boxed serializable and comparable character type, representing the primitive type char.
CharValue() - Constructor for class org.apache.flink.types.CharValue
Initializes the encapsulated char with 0.
CharValue(char) - Constructor for class org.apache.flink.types.CharValue
Initializes the encapsulated char with the provided value.
CharValueSerializer - Class in org.apache.flink.api.common.typeutils.base
 
CharValueSerializer() - Constructor for class org.apache.flink.api.common.typeutils.base.CharValueSerializer
 
ChebyshevDistanceMetric - Class in org.apache.flink.ml.metrics.distances
This class implements a Chebyshev distance metric.
ChebyshevDistanceMetric() - Constructor for class org.apache.flink.ml.metrics.distances.ChebyshevDistanceMetric
 
ChebyshevDistanceMetric$ - Class in org.apache.flink.ml.metrics.distances
 
ChebyshevDistanceMetric$() - Constructor for class org.apache.flink.ml.metrics.distances.ChebyshevDistanceMetric$
 
checkAndCoSort(int[], Class<?>[]) - Static method in class org.apache.flink.api.common.io.GenericCsvInputFormat
 
checkAndExtractLambdaMethod(Function) - Static method in class org.apache.flink.api.common.functions.util.FunctionUtils
 
checkAndGetNextWatermark(T, long) - Method in interface org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
Asks this implementation if it wants to emit a watermark.
checkAndGetNextWatermark(Integer, long) - Method in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp
 
checkArgument(boolean) - Static method in class org.apache.flink.streaming.connectors.kafka.util.KafkaUtils
 
checkCollection(Collection<X>, Class<X>) - Static method in class org.apache.flink.api.java.io.CollectionInputFormat
 
checkCollection(Collection<OUT>, Class<OUT>) - Static method in class org.apache.flink.streaming.api.functions.source.FromElementsFunction
Verifies that all elements in the collection are non-null, and are of the given class, or a subclass thereof.
checkedDownCast(long) - Static method in class org.apache.flink.runtime.util.MathUtils
Casts the given value to a 32 bit integer, if it can be safely done.
checkEquivalentFieldPositionsInKeyFields(FieldList, FieldList) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
checkEquivalentFieldPositionsInKeyFields(FieldList, FieldList, int) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
checkErroneous() - Method in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
Checks the exception state of this channel.
checkErroneous() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase
 
checkError() - Method in class org.apache.flink.runtime.io.network.partition.consumer.InputChannel
Checks for an error and rethrows it if one was reported.
checkForInstantiation(Class<?>) - Static method in class org.apache.flink.util.InstantiationUtil
Performs a standard check whether the class can be instantiated by Class#newInstance().
checkForInstantiationError(Class<?>) - Static method in class org.apache.flink.util.InstantiationUtil
 
checkForMonotonousOrder(int[], Class<?>[]) - Static method in class org.apache.flink.api.common.io.GenericCsvInputFormat
 
CheckForUserCommand$() - Constructor for class org.apache.flink.yarn.YarnMessages.CheckForUserCommand$
 
CheckGroupExpression() - Method in class org.apache.flink.api.table.expressions.analysis.GroupByAnalyzer
 
CheckGroupExpression() - Constructor for class org.apache.flink.api.table.expressions.analysis.GroupByAnalyzer.CheckGroupExpression
 
checkJarFile(URL) - Static method in class org.apache.flink.client.program.JobWithJars
 
checkJoinKeyFields(int[]) - Method in class org.apache.flink.api.java.operators.DeltaIteration.SolutionSetPlaceHolder
 
checkLinesAgainstRegexp(String, String) - Static method in class org.apache.flink.test.util.TestBaseUtils
 
checkOddEvenResult(BufferedReader) - Static method in class org.apache.flink.test.testdata.ConnectedComponentsData
 
checkOddEvenResult(List<Tuple2<Long, Long>>) - Static method in class org.apache.flink.test.testdata.ConnectedComponentsData
 
checkOddEvenResult(BufferedReader) - Static method in class org.apache.flink.test.testdata.TransitiveClosureData
 
checkPartialSolutionPropertiesMet(PlanNode, GlobalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.plan.PlanNode
 
CHECKPOINT_DIRECTORY_URI_CONF_KEY - Static variable in class org.apache.flink.runtime.state.filesystem.FsStateBackendFactory
The key under which the config stores the directory where checkpoints should be stored
CheckpointBarrier - Class in org.apache.flink.runtime.io.network.api
Checkpoint barriers are used to align checkpoints throughout the streaming topology.
CheckpointBarrier() - Constructor for class org.apache.flink.runtime.io.network.api.CheckpointBarrier
 
CheckpointBarrier(long, long) - Constructor for class org.apache.flink.runtime.io.network.api.CheckpointBarrier
 
CheckpointBarrierHandler - Interface in org.apache.flink.streaming.runtime.io
The CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input channels.
CheckpointConfig - Class in org.apache.flink.streaming.api.environment
Configuration that captures all checkpointing related settings.
CheckpointConfig() - Constructor for class org.apache.flink.streaming.api.environment.CheckpointConfig
 
CheckpointCoordinator - Class in org.apache.flink.runtime.checkpoint
The checkpoint coordinator coordinates the distributed snapshots of operators and state.
CheckpointCoordinator(JobID, long, long, ExecutionVertex[], ExecutionVertex[], ExecutionVertex[], ClassLoader, CheckpointIDCounter, CompletedCheckpointStore, RecoveryMode) - Constructor for class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
 
CheckpointCoordinator(JobID, long, long, long, int, ExecutionVertex[], ExecutionVertex[], ExecutionVertex[], ClassLoader, CheckpointIDCounter, CompletedCheckpointStore, RecoveryMode, CheckpointStatsTracker) - Constructor for class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
 
CheckpointCoordinatorDeActivator - Class in org.apache.flink.runtime.checkpoint
This actor listens to changes in the JobStatus and activates or deactivates the periodic checkpoint scheduler.
CheckpointCoordinatorDeActivator(CheckpointCoordinator, UUID) - Constructor for class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator
 
Checkpointed<T extends Serializable> - Interface in org.apache.flink.streaming.api.checkpoint
This method must be implemented by functions that have state that needs to be checkpointed.
CheckpointedAsynchronously<T extends Serializable> - Interface in org.apache.flink.streaming.api.checkpoint
This interface marks a function/operator as asynchronously checkpointed.
checkpointId - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot
 
checkpointIdCounter - Variable in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator
Checkpoint ID counter to ensure ascending IDs.
CheckpointIDCounter - Interface in org.apache.flink.runtime.checkpoint
A checkpoint ID counter.
CheckpointingMode - Enum in org.apache.flink.streaming.api
The checkpointing mode defines what consistency guarantees the system gives in the presence of failures.
CheckpointListener - Interface in org.apache.flink.runtime.state
This interface must be implemented by functions/operations that want to receive a commit notification once a checkpoint has been completely acknowledged by all participants.
checkpointPath - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot
Where we should put RocksDB backups
checkpointPath - Variable in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
FileSystem path where checkpoints are stored
CheckpointRecoveryFactory - Interface in org.apache.flink.runtime.checkpoint
A factory for per Job checkpoint recovery components.
checkpointRecoveryFactory() - Method in class org.apache.flink.runtime.jobmanager.JobManager
 
CheckpointStateOutputStream() - Constructor for class org.apache.flink.runtime.state.AbstractStateBackend.CheckpointStateOutputStream
 
CheckpointStateOutputView(AbstractStateBackend.CheckpointStateOutputStream) - Constructor for class org.apache.flink.runtime.state.AbstractStateBackend.CheckpointStateOutputView
 
checkpointStateSerializable(S, long, long) - Method in class org.apache.flink.contrib.streaming.state.DbStateBackend
 
checkpointStateSerializable(S, long, long) - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
checkpointStateSerializable(S, long, long) - Method in class org.apache.flink.runtime.state.AbstractStateBackend
Writes the given state into the checkpoint, and returns a handle that can retrieve the state back.
checkpointStateSerializable(S, long, long) - Method in class org.apache.flink.runtime.state.filesystem.FsStateBackend
 
checkpointStateSerializable(S, long, long) - Method in class org.apache.flink.runtime.state.memory.MemoryStateBackend
Serialized the given state into bytes using Java serialization and creates a state handle that can re-create that state.
CheckpointStats - Class in org.apache.flink.runtime.checkpoint.stats
Statistics for a specific checkpoint.
CheckpointStats(long, long, long, long) - Constructor for class org.apache.flink.runtime.checkpoint.stats.CheckpointStats
Creates a checkpoint statistic.
CheckpointStatsTracker - Interface in org.apache.flink.runtime.checkpoint.stats
A tracker for checkpoint statistics.
checkResultsWithDelta(String, List<String>, double) - Static method in class org.apache.flink.test.testdata.KMeansData
 
checkSameExecutionContext(DataSet<?>, DataSet<?>) - Static method in class org.apache.flink.api.java.DataSet
 
checkSameOrdering(LocalProperties, LocalProperties, int) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual
 
ChecksumHashCode() - Constructor for class org.apache.flink.api.java.Utils.ChecksumHashCode
 
ChecksumHashCode(long, long) - Constructor for class org.apache.flink.api.java.Utils.ChecksumHashCode
 
checksumHashCode(DataSet<T>) - Static method in class org.apache.flink.api.java.utils.DataSetUtils
Convenience method to get the count (number of elements) of a DataSet as well as the checksum (sum over element hashes).
checksumHashCode(Graph) - Static method in class org.apache.flink.graph.utils.GraphUtils
Computes the checksum over the Graph
ChecksumHashCodeHelper(String) - Constructor for class org.apache.flink.api.java.Utils.ChecksumHashCodeHelper
 
checkTimerException() - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
checkValidArguments(Vector, Vector) - Method in interface org.apache.flink.ml.metrics.distances.DistanceMetric
 
child() - Method in class org.apache.flink.api.table.expressions.Abs
 
child() - Method in class org.apache.flink.api.table.expressions.Avg
 
child() - Method in class org.apache.flink.api.table.expressions.BitwiseNot
 
child() - Method in class org.apache.flink.api.table.expressions.Cast
 
child() - Method in class org.apache.flink.api.table.expressions.Count
 
child() - Method in class org.apache.flink.api.table.expressions.IsNotNull
 
child() - Method in class org.apache.flink.api.table.expressions.IsNull
 
child() - Method in class org.apache.flink.api.table.expressions.Max
 
child() - Method in class org.apache.flink.api.table.expressions.Min
 
child() - Method in class org.apache.flink.api.table.expressions.Naming
 
child() - Method in class org.apache.flink.api.table.expressions.Not
 
child() - Method in class org.apache.flink.api.table.expressions.Sum
 
child() - Method in class org.apache.flink.api.table.expressions.UnaryExpression
 
child() - Method in class org.apache.flink.api.table.expressions.UnaryMinus
 
children() - Method in class org.apache.flink.api.table.expressions.BinaryExpression
 
children() - Method in class org.apache.flink.api.table.expressions.LeafExpression
 
children() - Method in class org.apache.flink.api.table.expressions.Substring
 
children() - Method in class org.apache.flink.api.table.expressions.UnaryExpression
 
children() - Method in class org.apache.flink.api.table.plan.Aggregate
 
children() - Method in class org.apache.flink.api.table.plan.As
 
children() - Method in class org.apache.flink.api.table.plan.Filter
 
children() - Method in class org.apache.flink.api.table.plan.GroupBy
 
children() - Method in class org.apache.flink.api.table.plan.Join
 
children() - Method in class org.apache.flink.api.table.plan.Root
 
children() - Method in class org.apache.flink.api.table.plan.Select
 
children() - Method in class org.apache.flink.api.table.plan.UnionAll
 
children() - Method in class org.apache.flink.api.table.trees.TreeNode
List of child nodes that should be considered when doing transformations.
choices(String...) - Method in class org.apache.flink.api.java.utils.Option
Restrict the list of possible values of the parameter.
CircularElement() - Constructor for class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.CircularElement
 
CircularElement(int, InMemorySorter<E>, List<MemorySegment>) - Constructor for class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.CircularElement
 
CircularQueues() - Constructor for class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.CircularQueues
 
CircularQueues(int) - Constructor for class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.CircularQueues
 
CLASS_OPTION - Static variable in class org.apache.flink.client.cli.CliFrontendParser
 
ClassLoaderObjectInputStream(InputStream, ClassLoader) - Constructor for class org.apache.flink.util.InstantiationUtil.ClassLoaderObjectInputStream
 
ClassLoaderUtil - Class in org.apache.flink.runtime.util
Utilities for information with respect to class loaders, specifically class loaders for the dynamic loading of user defined classes.
classpathsToAttach - Variable in class org.apache.flink.client.program.ContextEnvironment
 
clazz() - Method in class org.apache.flink.api.scala.typeutils.EitherTypeInfo
 
clazz() - Method in class org.apache.flink.api.scala.typeutils.EnumValueTypeInfo
 
clazz() - Method in class org.apache.flink.api.scala.typeutils.TraversableTypeInfo
 
clean(Object, boolean) - Static method in class org.apache.flink.api.java.ClosureCleaner
 
clean(F) - Method in class org.apache.flink.api.java.DataSet
 
clean(Object, boolean) - Method in class org.apache.flink.api.scala.ClosureCleaner$
 
clean(Object, boolean) - Static method in class org.apache.flink.api.scala.ClosureCleaner
 
clean(F, boolean) - Method in class org.apache.flink.api.scala.DataSet
Clean a closure to make it ready to serialized and send to tasks (removes unreferenced variables in $outer's, updates REPL variables) If checkSerializable is set, clean will also proactively check to see if f is serializable and throw a SparkException if not.
clean(F, boolean) - Method in class org.apache.flink.graph.scala.Graph
 
clean(F) - Method in class org.apache.flink.streaming.api.datastream.DataStream
Invokes the ClosureCleaner on the given function if closure cleaning is enabled in the ExecutionConfig.
clean(F) - Method in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Returns a "closure-cleaned" version of the given function.
clean(F) - Method in class org.apache.flink.streaming.api.scala.AllWindowedStream
Returns a "closure-cleaned" version of the given function.
clean(F) - Method in class org.apache.flink.streaming.api.scala.CoGroupedStreams
Returns a "closure-cleaned" version of the given function.
clean(F) - Method in class org.apache.flink.streaming.api.scala.ConnectedStreams
Returns a "closure-cleaned" version of the given function.
clean(F) - Method in class org.apache.flink.streaming.api.scala.DataStream
Returns a "closure-cleaned" version of the given function.
clean(F) - Method in class org.apache.flink.streaming.api.scala.JoinedStreams
Returns a "closure-cleaned" version of the given function.
clean(F) - Method in class org.apache.flink.streaming.api.scala.WindowedStream
Returns a "closure-cleaned" version of the given function.
cleanFile(String) - Method in class org.apache.flink.streaming.api.functions.sink.WriteSinkFunction
Creates target file if it does not exist, cleans it if it exists.
cleanup() - Method in class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.AbstractOuterJoinDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.AllGroupCombineDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.AllGroupReduceDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.AllReduceDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.CoGroupDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.CoGroupRawDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.CoGroupWithSolutionSetFirstDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.CoGroupWithSolutionSetSecondDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.CrossDriver
 
cleanup() - Method in interface org.apache.flink.runtime.operators.Driver
This method is invoked in any case (clean termination and exception) at the end of the tasks operation.
cleanup() - Method in class org.apache.flink.runtime.operators.FlatMapDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.GroupReduceCombineDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.GroupReduceDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.JoinDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.JoinWithSolutionSetFirstDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.JoinWithSolutionSetSecondDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.MapDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.MapPartitionDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.NoOpDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.ReduceCombineDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.ReduceDriver
 
cleanup() - Method in class org.apache.flink.runtime.operators.UnionWithTempOperator
 
cleanup(Logger, Closeable...) - Static method in class org.apache.flink.runtime.util.IOUtils
Close the Closeable objects and ignore any IOException or null pointers.
cleanup() - Method in class org.apache.flink.storm.exclamation.operators.ExclamationBolt
 
cleanup() - Method in class org.apache.flink.storm.util.AbstractBoltSink
 
cleanup() - Method in class org.apache.flink.storm.util.BoltFileSink
 
cleanup() - Method in class org.apache.flink.storm.wordcount.operators.BoltCounter
 
cleanup() - Method in class org.apache.flink.storm.wordcount.operators.BoltCounterByName
 
cleanup() - Method in class org.apache.flink.storm.wordcount.operators.BoltTokenizer
 
cleanup() - Method in class org.apache.flink.storm.wordcount.operators.BoltTokenizerByName
 
cleanup() - Method in class org.apache.flink.streaming.runtime.io.BarrierBuffer
 
cleanup() - Method in class org.apache.flink.streaming.runtime.io.BarrierTracker
 
cleanup() - Method in class org.apache.flink.streaming.runtime.io.BufferSpiller.SpilledBufferOrEventSequence
Cleans up all file resources held by this spilled sequence.
cleanup() - Method in interface org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler
Cleans up all internally held resources.
cleanup() - Method in interface org.apache.flink.streaming.runtime.io.StreamingReader
 
cleanup() - Method in class org.apache.flink.streaming.runtime.io.StreamInputProcessor
 
cleanup() - Method in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor
 
cleanup() - Method in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTask
 
cleanup() - Method in class org.apache.flink.streaming.runtime.tasks.SourceStreamTask
 
cleanup() - Method in class org.apache.flink.streaming.runtime.tasks.StreamIterationHead
 
cleanup() - Method in class org.apache.flink.streaming.runtime.tasks.StreamTask
 
cleanup() - Method in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask
 
cleanupFailedCheckpoints(String, Connection, long, long) - Method in interface org.apache.flink.contrib.streaming.state.DbAdapter
Clean up states between the checkpoint and recovery timestamp.
cleanupFailedCheckpoints(String, Connection, long, long) - Method in class org.apache.flink.contrib.streaming.state.MySqlAdapter
 
cleanupInterval() - Method in class org.apache.flink.runtime.taskmanager.TaskManagerConfiguration
 
cleanUpOperatorStatsCache() - Method in class org.apache.flink.runtime.webmonitor.BackPressureStatsTracker
Cleans up the operator stats cache if it contains timed out entries.
CleanupWhenUnsuccessful - Interface in org.apache.flink.api.common.io
OutputFormats may implement this interface to run a cleanup hook when the execution is not successful.
clear() - Method in interface org.apache.flink.api.common.state.State
Removes the value mapped under the current key.
clear() - Method in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState
 
clear() - Method in class org.apache.flink.contrib.streaming.state.LazyDbValueState
 
clear() - Method in class org.apache.flink.examples.java.clustering.KMeans.Point
 
clear() - Method in interface org.apache.flink.examples.scala.clustering.KMeans.Coordinate
 
clear() - Method in class org.apache.flink.runtime.io.network.api.serialization.AdaptiveSpanningRecordDeserializer
 
clear() - Method in interface org.apache.flink.runtime.io.network.api.serialization.RecordDeserializer
 
clear() - Method in interface org.apache.flink.runtime.io.network.api.serialization.RecordSerializer
 
clear() - Method in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer
 
clear() - Method in class org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer
 
clear() - Method in class org.apache.flink.runtime.jobmanager.scheduler.SetQueue
 
clear() - Method in class org.apache.flink.runtime.memory.AbstractPagedInputView
Clears the internal state of the view.
clear() - Method in class org.apache.flink.runtime.memory.AbstractPagedOutputView
Clears the internal state.
clear() - Method in class org.apache.flink.runtime.operators.sort.PartialOrderPriorityQueue
Removes all entries from the PriorityQueue.
clear() - Method in class org.apache.flink.runtime.operators.util.BitSet
Clear the bit set.
clear() - Method in class org.apache.flink.runtime.operators.util.BloomFilter.BitSet
Clear the bit set.
clear() - Method in class org.apache.flink.runtime.state.AbstractHeapState
 
clear() - Method in class org.apache.flink.runtime.state.GenericFoldingState
 
clear() - Method in class org.apache.flink.runtime.state.GenericListState
 
clear() - Method in class org.apache.flink.runtime.state.GenericReducingState
 
clear() - Method in class org.apache.flink.runtime.util.DataOutputSerializer
 
clear() - Method in class org.apache.flink.runtime.util.IntArrayList
 
clear() - Method in class org.apache.flink.runtime.util.LongArrayList
 
clear() - Method in class org.apache.flink.runtime.util.UnionIterator
 
clear() - Method in class org.apache.flink.storm.util.StormConfig
 
clear() - Method in class org.apache.flink.streaming.api.graph.StreamGraph
Remove all registered nodes etc.
clear(W, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger
 
clear(W, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger
 
clear(W, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.CountTrigger
 
clear(W, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.DeltaTrigger
 
clear(TimeWindow, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.EventTimeTrigger
 
clear(TimeWindow, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.ProcessingTimeTrigger
 
clear(W, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.PurgingTrigger
 
clear(W, Trigger.TriggerContext) - Method in class org.apache.flink.streaming.api.windowing.triggers.Trigger
Clears any state that the trigger might still hold for the given window.
clear() - Method in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context
 
clear() - Method in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Context
 
clear() - Method in class org.apache.flink.types.ListValue
 
clear() - Method in class org.apache.flink.types.MapValue
 
clear() - Method in class org.apache.flink.types.Record
Clears the record.
clearAll() - Method in class org.apache.flink.runtime.io.network.TaskEventDispatcher
 
clearAllBroadcastVariables() - Method in class org.apache.flink.api.common.functions.util.RuntimeUDFContext
 
clearAllBroadcastVariables() - Method in class org.apache.flink.runtime.operators.util.DistributedRuntimeUDFContext
 
clearAllMemory(List<MemorySegment>) - Method in class org.apache.flink.runtime.operators.hash.HashPartition
 
clearAllMemory(List<MemorySegment>) - Method in class org.apache.flink.runtime.operators.hash.InMemoryPartition
releases all of the partition's segments (pages and overflow buckets)
clearAllMemory(List<MemorySegment>) - Method in class org.apache.flink.runtime.operators.hash.ReOpenableHashPartition
 
clearBroadcastVariable(String) - Method in class org.apache.flink.api.common.functions.util.RuntimeUDFContext
 
clearBroadcastVariable(String) - Method in class org.apache.flink.runtime.operators.util.DistributedRuntimeUDFContext
 
clearBuffers() - Method in interface org.apache.flink.runtime.io.network.api.reader.MutableReader
 
clearBuffers() - Method in class org.apache.flink.runtime.io.network.api.reader.MutableRecordReader
 
clearBuffers() - Method in interface org.apache.flink.runtime.io.network.api.reader.Reader
 
clearBuffers() - Method in class org.apache.flink.runtime.io.network.api.reader.RecordReader
 
clearBuffers() - Method in class org.apache.flink.runtime.io.network.api.writer.RecordWriter
 
clearBuffers() - Method in class org.apache.flink.streaming.runtime.io.RecordWriterOutput
 
clearContainerMappingMarkedFields() - Method in class org.apache.flink.api.java.sca.TaggedValue
 
clearCurrentBuffer() - Method in interface org.apache.flink.runtime.io.network.api.serialization.RecordSerializer
 
clearCurrentBuffer() - Method in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer
 
clearFirstInput() - Method in class org.apache.flink.api.common.operators.DualInputOperator
Clears this operator's first input.
clearInputs() - Method in class org.apache.flink.api.common.operators.SingleInputOperator
Removes all inputs.
clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode
 
clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.DagConnection
 
clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.OptimizerNode
 
clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode
 
clearLeader() - Method in class org.apache.flink.runtime.minicluster.FlinkMiniCluster
 
clearPartitions() - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable
This method clears all partitions currently residing (partially) in memory.
clearReaders(MutableReader<?>[]) - Static method in class org.apache.flink.runtime.operators.BatchTask
 
clearReferences() - Method in class org.apache.flink.cep.NonDuplicatingTypeSerializer
Clears the data structures containing the already serialized/deserialized objects.
clearSecondInput() - Method in class org.apache.flink.api.common.operators.DualInputOperator
Clears this operator's second input.
clearTaskAssignment() - Method in class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup
 
clearUniqueFieldCombinations() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties
 
clearUniqueFields() - Method in class org.apache.flink.api.common.operators.CompilerHints
 
clearUniqueFieldSets() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties
 
clearWriters(List<RecordWriter<?>>) - Static method in class org.apache.flink.runtime.operators.BatchTask
 
CliArgsException - Exception in org.apache.flink.client.cli
Special exception that is thrown when the command line parsing fails.
CliArgsException(String) - Constructor for exception org.apache.flink.client.cli.CliArgsException
 
Client - Class in org.apache.flink.client.program
Encapsulates the functionality necessary to submit a program to a remote cluster.
Client(Configuration) - Constructor for class org.apache.flink.client.program.Client
Creates a instance that submits the programs to the JobManager defined in the configuration.
Client(Configuration, int) - Constructor for class org.apache.flink.client.program.Client
Creates a new instance of the class that submits the jobs to a job-manager.
client - Variable in class org.apache.flink.client.program.ContextEnvironment
 
client() - Method in class org.apache.flink.runtime.jobmanager.JobInfo
 
CLIENT_CONNECT_TIMEOUT_SECONDS - Static variable in class org.apache.flink.runtime.io.network.netty.NettyConfig
 
ClientShutdownHook() - Constructor for class org.apache.flink.yarn.FlinkYarnCluster.ClientShutdownHook
 
CliFrontend - Class in org.apache.flink.client
Implementation of a simple command line frontend for executing programs.
CliFrontend() - Constructor for class org.apache.flink.client.CliFrontend
 
CliFrontend(String) - Constructor for class org.apache.flink.client.CliFrontend
 
CliFrontendParser - Class in org.apache.flink.client.cli
A simple command line parser (based on Apache Commons CLI) that extracts command line options.
CliFrontendParser() - Constructor for class org.apache.flink.client.cli.CliFrontendParser
 
Clock - Interface in org.apache.flink.streaming.connectors.fs
A clock that can provide the current time.
clone() - Method in interface org.apache.flink.api.common.accumulators.Accumulator
Duplicates the accumulator.
clone() - Method in class org.apache.flink.api.common.accumulators.AverageAccumulator
 
clone() - Method in class org.apache.flink.api.common.accumulators.DoubleCounter
 
clone() - Method in class org.apache.flink.api.common.accumulators.Histogram
 
clone() - Method in class org.apache.flink.api.common.accumulators.IntCounter
 
clone() - Method in class org.apache.flink.api.common.accumulators.ListAccumulator
 
clone() - Method in class org.apache.flink.api.common.accumulators.LongCounter
 
clone() - Method in class org.apache.flink.api.common.accumulators.SerializedListAccumulator
 
clone() - Method in class org.apache.flink.api.common.operators.Ordering
 
clone() - Method in class org.apache.flink.api.common.operators.util.FieldSet
Since instances of FieldSet are strictly immutable, this method does not actually clone, but it only returns the original instance.
clone() - Method in class org.apache.flink.api.java.Utils.ChecksumHashCode
 
clone() - Method in class org.apache.flink.api.java.utils.ParameterTool
 
clone() - Method in class org.apache.flink.api.scala.typeutils.CaseClassSerializer
 
clone() - Method in class org.apache.flink.configuration.Configuration
 
clone() - Method in class org.apache.flink.contrib.operatorstatistics.OperatorStatistics
 
clone() - Method in class org.apache.flink.contrib.operatorstatistics.OperatorStatisticsAccumulator
 
clone() - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator
 
clone() - Method in class org.apache.flink.optimizer.costs.Costs
 
clone() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties
 
clone() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties
 
clone() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties
 
clone() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties
 
clone() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties
 
clone() - Method in class org.apache.flink.optimizer.plan.Channel
 
clone() - Method in class org.apache.flink.streaming.connectors.kafka.internals.metrics.AvgKafkaMetricAccumulator
 
clone() - Method in class org.apache.flink.streaming.connectors.kafka.internals.metrics.DefaultKafkaMetricAccumulator
 
clone() - Method in class org.apache.flink.streaming.connectors.kafka.internals.metrics.MaxKafkaMetricAccumulator
 
clone() - Method in class org.apache.flink.streaming.connectors.kafka.internals.metrics.MinKafkaMetricAccumulator
 
clone(T) - Static method in class org.apache.flink.util.InstantiationUtil
Clones the given serializable object using Java serialization.
clone(T, ClassLoader) - Static method in class org.apache.flink.util.InstantiationUtil
Clones the given serializable object using Java serialization, using the given classloader to resolve the cloned classes.
ClosableBlockingQueue<E> - Class in org.apache.flink.streaming.connectors.kafka.internals
A special form of blocking queue with two additions: The queue can be closed atomically when empty.
ClosableBlockingQueue() - Constructor for class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Creates a new empty queue.
ClosableBlockingQueue(int) - Constructor for class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Creates a new empty queue, reserving space for at least the specified number of elements.
ClosableBlockingQueue(Collection<? extends E>) - Constructor for class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Creates a new queue that contains the given elements.
close() - Method in class org.apache.flink.addons.hbase.TableInputFormat
 
close() - Method in class org.apache.flink.api.avro.FSDataInputStreamWrapper
 
close() - Method in class org.apache.flink.api.common.functions.AbstractRichFunction
 
close() - Method in interface org.apache.flink.api.common.functions.RichFunction
Tear-down method for the user code.
close() - Method in class org.apache.flink.api.common.functions.util.CopyingListCollector
 
close() - Method in class org.apache.flink.api.common.functions.util.ListCollector
 
close() - Method in class org.apache.flink.api.common.io.BinaryOutputFormat.BlockBasedOutput
 
close() - Method in class org.apache.flink.api.common.io.BinaryOutputFormat
 
close() - Method in class org.apache.flink.api.common.io.DelimitedInputFormat
Closes the input by releasing all buffers and closing the file input stream.
close() - Method in class org.apache.flink.api.common.io.FileInputFormat
Closes the file input stream of the input format.
close() - Method in class org.apache.flink.api.common.io.FileOutputFormat
 
close() - Method in class org.apache.flink.api.common.io.GenericCsvInputFormat
 
close() - Method in class org.apache.flink.api.common.io.GenericInputFormat
 
close() - Method in interface org.apache.flink.api.common.io.InputFormat
Method that marks the end of the life-cycle of an input split.
close() - Method in interface org.apache.flink.api.common.io.OutputFormat
Method that marks the end of the life-cycle of parallel output instance.
close() - Method in class org.apache.flink.api.common.io.ReplicatingInputFormat
 
close() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
 
close() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
commit the task by moving the output file out from the temporary directory.
close() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
 
close() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
commit the task by moving the output file out from the temporary directory.
close() - Method in class org.apache.flink.api.java.io.AvroOutputFormat
 
close() - Method in class org.apache.flink.api.java.io.CsvOutputFormat
 
close() - Method in class org.apache.flink.api.java.io.DiscardingOutputFormat
 
close() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat
Closes all resources used.
close() - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat
Executes prepared statement and closes all resources of this instance.
close() - Method in class org.apache.flink.api.java.io.LocalCollectionOutputFormat
 
close() - Method in class org.apache.flink.api.java.io.PrintingOutputFormat
 
close() - Method in class org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector
 
close() - Method in class org.apache.flink.api.java.operators.translation.TupleWrappingCollector
 
close() - Method in class org.apache.flink.api.java.operators.translation.WrappingFunction
 
close() - Method in class org.apache.flink.api.java.Utils.ChecksumHashCodeHelper
 
close() - Method in class org.apache.flink.api.java.Utils.CollectHelper
 
close() - Method in class org.apache.flink.api.java.Utils.CountHelper
 
close() - Method in class org.apache.flink.api.scala.operators.ScalaCsvOutputFormat
 
close() - Method in class org.apache.flink.contrib.streaming.state.DbStateBackend
 
close() - Method in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend
 
close() - Method in class org.apache.flink.contrib.streaming.state.ShardedConnection
 
close() - Method in class org.apache.flink.contrib.streaming.state.ShardedConnection.ShardedStatement
 
close() - Method in class org.apache.flink.core.fs.local.LocalDataInputStream
 
close() - Method in class org.apache.flink.core.fs.local.LocalDataOutputStream
 
close() - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat
 
close() - Method in class org.apache.flink.graph.examples.utils.ExampleUtils.PrintingOutputFormatWithMessage
 
close() - Method in class org.apache.flink.hcatalog.HCatInputFormatBase
 
close() - Method in class org.apache.flink.python.api.functions.PythonCoGroup
Closes this function.
close() - Method in class org.apache.flink.python.api.functions.PythonMapPartition
Closes this function.
close() - Method in class org.apache.flink.python.api.streaming.data.PythonReceiver
 
close() - Method in class org.apache.flink.python.api.streaming.data.PythonSender
 
close() - Method in class org.apache.flink.python.api.streaming.data.PythonStreamer
Closes this streamer.
close() - Method in class org.apache.flink.python.api.streaming.plan.PythonPlanStreamer
 
close() - Method in class org.apache.flink.runtime.blob.BlobClient
 
close() - Method in class org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream
 
close() - Method in class org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream
 
close() - Method in class org.apache.flink.runtime.io.disk.FileChannelInputView
 
close() - Method in class org.apache.flink.runtime.io.disk.FileChannelOutputView
Closes this output, writing pending data and releasing the memory.
close() - Method in class org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel
 
close() - Method in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
Closes the channel and waits until all pending asynchronous requests are processed.
close() - Method in class org.apache.flink.runtime.io.disk.iomanager.ChannelReaderInputView
Closes this InputView, closing the underlying reader and returning all memory segments.
close() - Method in class org.apache.flink.runtime.io.disk.iomanager.ChannelWriterOutputView
Closes this OutputView, closing the underlying writer and returning all memory segments.
close() - Method in interface org.apache.flink.runtime.io.disk.iomanager.FileIOChannel
Closes the channel.
close() - Method in class org.apache.flink.runtime.io.disk.iomanager.RequestQueue
Closes this request queue.
close() - Method in class org.apache.flink.runtime.io.disk.iomanager.SynchronousFileIOChannel
 
close() - Method in class org.apache.flink.runtime.io.disk.SeekableFileChannelInputView
 
close() - Method in class org.apache.flink.runtime.io.disk.SpillingBuffer
 
close(RemoteInputChannel) - Method in class org.apache.flink.runtime.io.network.netty.PartitionRequestClient
 
close() - Method in class org.apache.flink.runtime.iterative.io.SerializedUpdateBuffer
 
close() - Method in class org.apache.flink.runtime.iterative.io.SolutionSetFastUpdateOutputCollector
 
close() - Method in class org.apache.flink.runtime.iterative.io.SolutionSetObjectsUpdateOutputCollector
 
close() - Method in class org.apache.flink.runtime.iterative.io.SolutionSetUpdateOutputCollector
 
close() - Method in class org.apache.flink.runtime.iterative.io.WorksetUpdateOutputCollector
 
close() - Method in class org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver
 
close() - Method in class org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver
 
close() - Method in class org.apache.flink.runtime.operators.chaining.ChainedMapDriver
 
close() - Method in class org.apache.flink.runtime.operators.chaining.ChainedTerminationCriterionDriver
 
close() - Method in class org.apache.flink.runtime.operators.chaining.GroupCombineChainedDriver
 
close() - Method in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver
 
close() - Method in class org.apache.flink.runtime.operators.hash.AbstractMutableHashTable
 
close() - Method in class org.apache.flink.runtime.operators.hash.CompactingHashTable
Closes the hash table.
close() - Method in class org.apache.flink.runtime.operators.hash.MutableHashTable
Closes the hash table.
close() - Method in class org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashJoinIterator
 
close() - Method in class org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator
 
close() - Method in class org.apache.flink.runtime.operators.hash.ReOpenableMutableHashTable
 
close() - Method in class org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashJoinIterator
 
close() - Method in class org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashJoinIterator
 
close() - Method in class org.apache.flink.runtime.operators.NoOpChainedDriver
 
close() - Method in class org.apache.flink.runtime.operators.resettable.BlockResettableMutableObjectIterator
 
close() - Method in class org.apache.flink.runtime.operators.resettable.NonReusingBlockResettableIterator
 
close() - Method in class org.apache.flink.runtime.operators.resettable.SpillingResettableIterator
 
close() - Method in class org.apache.flink.runtime.operators.resettable.SpillingResettableMutableObjectIterator
 
close() - Method in class org.apache.flink.runtime.operators.shipping.OutputCollector
 
close() - Method in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator
 
close() - Method in class org.apache.flink.runtime.operators.sort.LargeRecordHandler
Closes all structures and deletes all temporary files.
close() - Method in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIterator
 
close() - Method in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIterator
 
close() - Method in class org.apache.flink.runtime.operators.sort.UnilateralSortMerger
Shuts down all the threads initiated by this sort/merger.
close() - Method in class org.apache.flink.runtime.operators.TempBarrier
 
close() - Method in interface org.apache.flink.runtime.operators.util.CoGroupTaskIterator
General-purpose close method.
close() - Method in interface org.apache.flink.runtime.operators.util.JoinTaskIterator
General-purpose close method.
close() - Method in class org.apache.flink.runtime.operators.util.SimpleCloseableInputProvider
 
close() - Method in class org.apache.flink.runtime.state.AbstractStateBackend.CheckpointStateOutputView
 
close() - Method in class org.apache.flink.runtime.state.AbstractStateBackend
Closes the state backend, releasing all internal resources, but does not delete any persistent checkpoint data.
close() - Method in class org.apache.flink.runtime.state.filesystem.FsStateBackend
 
close() - Method in class org.apache.flink.runtime.state.filesystem.FsStateBackend.FsCheckpointStateOutputStream
If the stream is only closed, we remove the produced file (cleanup through the auto close feature, for example).
close() - Method in class org.apache.flink.runtime.state.memory.MemoryStateBackend
 
close() - Method in class org.apache.flink.runtime.state.memory.MemoryStateBackend.MemoryCheckpointOutputStream
 
close() - Method in class org.apache.flink.storm.util.AbstractLineSpout
 
close() - Method in class org.apache.flink.storm.util.FileSpout
 
close() - Method in class org.apache.flink.storm.util.NullTerminatingSpout
 
close() - Method in class org.apache.flink.storm.wrappers.SpoutWrapper
 
close() - Method in class org.apache.flink.streaming.api.collector.selector.DirectedOutput
 
close() - Method in class org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction
 
close() - Method in class org.apache.flink.streaming.api.functions.sink.PrintSinkFunction
 
close() - Method in class org.apache.flink.streaming.api.functions.sink.SocketClientSink
Closes the connection with the Socket server.
close() - Method in class org.apache.flink.streaming.api.functions.source.FileSourceFunction
 
close() - Method in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase
 
close() - Method in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
 
close() - Method in interface org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
This method is called by the system to shut down the context.
close() - Method in class org.apache.flink.streaming.api.operators.AbstractStreamOperator
close() - Method in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
 
close() - Method in interface org.apache.flink.streaming.api.operators.StreamOperator
close() - Method in class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext
 
close() - Method in class org.apache.flink.streaming.api.operators.StreamSource.ManualWatermarkContext
 
close() - Method in class org.apache.flink.streaming.api.operators.StreamSource.NonTimestampContext
 
close() - Method in class org.apache.flink.streaming.api.operators.TimestampedCollector
 
close() - Method in class org.apache.flink.streaming.api.scala.function.util.ScalaAllWindowFunctionWrapper
 
close() - Method in class org.apache.flink.streaming.api.scala.function.util.ScalaWindowFunctionWrapper
 
close() - Method in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink
 
close() - Method in class org.apache.flink.streaming.connectors.flume.FlumeSink
 
close() - Method in class org.apache.flink.streaming.connectors.fs.RollingSink
 
close() - Method in class org.apache.flink.streaming.connectors.fs.SequenceFileWriter
 
close() - Method in class org.apache.flink.streaming.connectors.fs.StringWriter
 
close() - Method in interface org.apache.flink.streaming.connectors.fs.Writer
Closes the Writer.
close() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08
 
close() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09
 
close() - Method in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase
 
close() - Method in class org.apache.flink.streaming.connectors.kafka.internals.ClosableBlockingQueue
Tries to close the queue.
close() - Method in interface org.apache.flink.streaming.connectors.kafka.internals.Fetcher
Closes the fetcher.
close() - Method in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher
 
close() - Method in interface org.apache.flink.streaming.connectors.kafka.internals.OffsetHandler
Closes the offset handler, releasing all resources.
close() - Method in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler
 
close() - Method in class org.apache.flink.streaming.connectors.nifi.NiFiSink
 
close() - Method in class org.apache.flink.streaming.connectors.nifi.NiFiSource
 
close() - Method in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink
 
close() - Method in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource
 
close() - Method in class org.apache.flink.streaming.connectors.twitter.TwitterSource
 
close() - Method in class org.apache.flink.streaming.connectors.wikiedits.WikipediaEditsSource
 
close() - Method in class org.apache.flink.streaming.runtime.io.BufferSpiller
Cleans up the current spilling channel and file.
close() - Method in class org.apache.flink.streaming.runtime.io.RecordWriterOutput
 
close() - Method in class org.apache.flink.streaming.runtime.io.StreamRecordWriter
Closes the writer.
close() - Method in class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator
 
close() - Method in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator
 
close() - Method in class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableWindowFunction
 
close() - Method in class org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueWindowFunction
 
close() - Method in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator
 
close() - Method in interface org.apache.flink.util.Collector
Closes the collector.
CLOSE_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
 
CLOSE_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
 
CloseableInputProvider<E> - Interface in org.apache.flink.runtime.operators.util
Utility interface for a provider of an input that can be closed.
closeAndDelete() - Method in class org.apache.flink.runtime.io.disk.FileChannelInputView
 
closeAndDelete() - Method in class org.apache.flink.runtime.io.disk.FileChannelOutputView
Closes this output, writing pending data and releasing the memory.
closeAndDelete() - Method in class org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel
 
closeAndDelete() - Method in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
This method waits for all pending asynchronous requests to return.
closeAndDelete() - Method in interface org.apache.flink.runtime.io.disk.iomanager.FileIOChannel
Closes the channel and deletes the underlying file.
closeAndDelete() - Method in class org.apache.flink.runtime.io.disk.SeekableFileChannelInputView
 
closeAndGetBytes() - Method in class org.apache.flink.runtime.state.memory.MemoryStateBackend.MemoryCheckpointOutputStream
Closes the stream and returns the byte array containing the stream's data.
closeAndGetHandle() - Method in class org.apache.flink.runtime.state.AbstractStateBackend.CheckpointStateOutputStream
Closes the stream and gets a state handle that can create an input stream producing the data written to this stream.
closeAndGetHandle() - Method in class org.apache.flink.runtime.state.AbstractStateBackend.CheckpointStateOutputView
Closes the stream and gets a state handle that can create a DataInputView.
closeAndGetHandle() - Method in class org.apache.flink.runtime.state.filesystem.FsStateBackend.FsCheckpointStateOutputStream
 
closeAndGetHandle() - Method in class org.apache.flink.runtime.state.memory.MemoryStateBackend.MemoryCheckpointOutputStream
 
closeAndGetPath() - Method in class org.apache.flink.runtime.state.filesystem.FsStateBackend.FsCheckpointStateOutputStream
Closes the stream and returns the path to the file that contains the stream's data.
closeChainedTasks(List<ChainedDriver<?, ?>>, AbstractInvokable) - Static method in class org.apache.flink.runtime.operators.BatchTask
Closes all chained tasks, in the order as they are stored in the array.
closed - Variable in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
Flag marking this channel as closed
closed - Variable in class org.apache.flink.runtime.operators.hash.MutableHashTable
Flag indicating that the closing logic has been invoked.
closed - Variable in class org.apache.flink.runtime.operators.sort.UnilateralSortMerger
Flag indicating that the sorter was closed.
closedBranchingNodes - Variable in class org.apache.flink.optimizer.dag.OptimizerNode
 
closeFunction(Function) - Static method in class org.apache.flink.api.common.functions.util.FunctionUtils
 
closeLocalStrategiesAndCaches() - Method in class org.apache.flink.runtime.iterative.task.AbstractIterativeTask
 
closeLocalStrategiesAndCaches() - Method in class org.apache.flink.runtime.operators.BatchTask
 
closeLock - Variable in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel
The lock that is used during closing to synchronize the thread that waits for all requests to be handled with the asynchronous I/O thread.
closeOpenChannelConnections(ConnectionID) - Method in interface org.apache.flink.runtime.io.network.ConnectionManager
Closes opened ChannelConnections in case of a resource release
closeOpenChannelConnections(ConnectionID) - Method in class org.apache.flink.runtime.io.network.LocalConnectionManager
 
closeOpenChannelConnections(ConnectionID) - Method in class org.apache.flink.runtime.io.network.netty.NettyConnectionManager
 
closeSocket(Socket) - Static method in class org.apache.flink.runtime.util.IOUtils
Closes the socket ignoring IOException.
closeStream(Closeable) - Static method in class org.apache.flink.runtime.util.IOUtils
Closes the stream ignoring IOException.
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedMapDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.ChainedTerminationCriterionDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.GroupCombineChainedDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver
 
closeTask() - Method in class org.apache.flink.runtime.operators.NoOpChainedDriver
 
closeUserCode(Function) - Static method in class org.apache.flink.runtime.operators.BatchTask
Closes the given stub using its RichFunction.close() method.
closeWith(DataSet<ST>, DataSet<WT>) - Method in class org.apache.flink.api.java.operators.DeltaIteration
Closes the delta iteration.
closeWith(DataSet<T>) - Method in class org.apache.flink.api.java.operators.IterativeDataSet
Closes the iteration.
closeWith(DataSet<T>, DataSet<?>) - Method in class org.apache.flink.api.java.operators.IterativeDataSet
Closes the iteration and specifies a termination criterion.
closeWith(DataStream<T>) - Method in class org.apache.flink.streaming.api.datastream.IterativeStream
Closes the iteration.
closeWith(DataStream<F>) - Method in class org.apache.flink.streaming.api.datastream.IterativeStream.ConnectedIterativeStreams
Closes the iteration.
ClosureCleaner - Class in org.apache.flink.api.java
 
ClosureCleaner() - Constructor for class org.apache.flink.api.java.ClosureCleaner
 
ClosureCleaner - Class in org.apache.flink.api.scala
 
ClosureCleaner() - Constructor for class org.apache.flink.api.scala.ClosureCleaner
 
ClosureCleaner$ - Class in org.apache.flink.api.scala
 
ClosureCleaner$() - Constructor for class org.apache.flink.api.scala.ClosureCleaner$
 
cluster() - Method in interface org.apache.flink.test.util.FlinkTestBase
 
cluster - Static variable in class org.apache.flink.test.util.MultipleProgramsTestBase
 
ClusterOverviewHandler - Class in org.apache.flink.runtime.webmonitor.handlers
Responder that returns the status of the Flink cluster, such as how many TaskManagers are currently connected, and how many jobs are running.
ClusterOverviewHandler(FiniteDuration) - Constructor for class org.apache.flink.runtime.webmonitor.handlers.ClusterOverviewHandler
 
CMHeavyHitterMergeException(String) - Constructor for exception org.apache.flink.contrib.operatorstatistics.heavyhitters.CountMinHeavyHitter.CMHeavyHitterMergeException
 
code() - Method in class org.apache.flink.api.table.codegen.ExpressionCodeGenerator.GeneratedExpression
 
CodeAnalysisMode - Enum in org.apache.flink.api.common
Specifies to which extent user-defined functions are analyzed in order to give the Flink optimizer an insight of UDF internals and inform the user about common implementation mistakes.
CodeAnalyzerException - Exception in org.apache.flink.api.java.sca
Exception that is thrown if code analysis could not run properly.
CodeAnalyzerException() - Constructor for exception org.apache.flink.api.java.sca.CodeAnalyzerException
 
CodeAnalyzerException(String, Throwable) - Constructor for exception org.apache.flink.api.java.sca.CodeAnalyzerException
 
CodeAnalyzerException(String) - Constructor for exception org.apache.flink.api.java.sca.CodeAnalyzerException
 
CodeAnalyzerException(Throwable) - Constructor for exception org.apache.flink.api.java.sca.CodeAnalyzerException
 
CodeErrorException - Exception in org.apache.flink.api.java.sca
Exception that is thrown if code er