Index (Flink ML 2.0-SNAPSHOT API)

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

A

abort(long) - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
AbstractAllRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>> - Class in org.apache.flink.iteration.operator.allround: The base class for the all-round wrapper operators.
AbstractAllRoundWrapperOperator(StreamOperatorParameters<IterationRecord<T>>, StreamOperatorFactory<T>) - Constructor for class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
AbstractBroadcastWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>> - Class in org.apache.flink.ml.common.broadcast.operator: Base class for the broadcast wrapper operators.
AbstractPerRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>> - Class in org.apache.flink.iteration.operator.perround: The base class for all the per-round wrapper operators.
AbstractPerRoundWrapperOperator(StreamOperatorParameters<IterationRecord<T>>, StreamOperatorFactory<T>) - Constructor for class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
AbstractWrapperOperator<T> - Class in org.apache.flink.iteration.operator: The base class of all the wrapper operators.
AbstractWrapperOperator(StreamOperatorParameters<IterationRecord<T>>, StreamOperatorFactory<T>) - Constructor for class org.apache.flink.iteration.operator.AbstractWrapperOperator
addAlgoOperator(AlgoOperator<?>, TableId...) - Method in class org.apache.flink.ml.builder.GraphBuilder: Adds an AlgoOperator in the graph.
addDraftSource(DataStream<?>, TypeInformation<T>) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment
addEstimator(Estimator<?, ?>, TableId...) - Method in class org.apache.flink.ml.builder.GraphBuilder: Adds an Estimator in the graph.
addEstimator(Estimator<?, ?>, TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Adds an Estimator in the graph.
addOperator(Transformation<?>) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment
addOperatorIfNotExists(Transformation<?>) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment
addRecord(T) - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
advanceWatermark(Watermark) - Method in class org.apache.flink.iteration.proxy.state.ProxyInternalTimeServiceManager
AlgoOperator<T extends AlgoOperator<T>> - Interface in org.apache.flink.ml.api: An AlgoOperator takes a list of tables as inputs and produces a list of tables as results.
algoOpInputIds - Variable in class org.apache.flink.ml.builder.GraphNode
ALIGN_NOTIFY_OUTPUT_TAG - Static variable in class org.apache.flink.iteration.operator.HeadOperator
allReduceSum(DataStream<double[]>) - Static method in class org.apache.flink.ml.common.datastream.DataStreamUtils: Applies allReduceSum on the input data stream.
AllRoundOperatorWrapper<T> - Class in org.apache.flink.iteration.operator.allround: The operator wrapper implementation for all-round wrappers.
AllRoundOperatorWrapper() - Constructor for class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
alwaysTrue() - Static method in class org.apache.flink.ml.param.ParamValidators
andNotReplay(DataStream<?>...) - Method in class org.apache.flink.iteration.ReplayableDataStreamList.ReplayedDataStreamList
append(T) - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
applyToAllKeys(N, TypeSerializer<N>, StateDescriptor<S, T>, KeyedStateFunction<K, S>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
areBroadcastVariablesReady() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: checks whether all of broadcast variables are ready.
assignWindows(Object, long, WindowAssigner.WindowAssignerContext) - Method in class org.apache.flink.ml.common.datastream.EndOfStreamWindows
asum(DenseVector) - Static method in class org.apache.flink.ml.linalg.BLAS: \sum_i |x_i| .
axpy(double, DenseVector, DenseVector) - Static method in class org.apache.flink.ml.linalg.BLAS: y += a * x .

B

BLAS - Class in org.apache.flink.ml.linalg: A utility class that provides BLAS routines over matrices and vectors.
BLAS() - Constructor for class org.apache.flink.ml.linalg.BLAS
BooleanParam - Class in org.apache.flink.ml.param: Class for the boolean parameter.
BooleanParam(String, String, Boolean, ParamValidator<Boolean>) - Constructor for class org.apache.flink.ml.param.BooleanParam
BooleanParam(String, String, Boolean) - Constructor for class org.apache.flink.ml.param.BooleanParam
BroadcastContext - Class in org.apache.flink.ml.common.broadcast: Context to hold the broadcast variables and provides some utility function for accessing broadcast variables.
BroadcastContext() - Constructor for class org.apache.flink.ml.common.broadcast.BroadcastContext
broadcastEmit(StreamRecord<OUT>) - Method in interface org.apache.flink.iteration.broadcast.BroadcastOutput: Broadcasts the record to all the downstream operators.
broadcastEmit(StreamRecord<OUT>) - Method in class org.apache.flink.iteration.broadcast.ChainingBroadcastOutput
broadcastEmit(StreamRecord<OUT>) - Method in class org.apache.flink.iteration.broadcast.CountingBroadcastOutput
broadcastEmit(StreamRecord<OUT>) - Method in class org.apache.flink.iteration.broadcast.RecordWriterBroadcastOutput
BroadcastOutput<OUT> - Interface in org.apache.flink.iteration.broadcast: Wrapper output that broadcasts the records to all the downstream operators.
broadcastOutput(StreamRecord<IterationRecord<?>>) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
BroadcastOutputFactory - Class in org.apache.flink.iteration.broadcast: Factory that creates the corresponding BroadcastOutput from the Output.
BroadcastOutputFactory() - Constructor for class org.apache.flink.iteration.broadcast.BroadcastOutputFactory
BroadcastStateTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the BroadcastStateTransformation.
BroadcastStateTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.BroadcastStateTransformationTranslator
BroadcastStreamingRuntimeContext - Class in org.apache.flink.ml.common.broadcast: An subclass of StreamingRuntimeContext that provides accessibility of broadcast variables.
BroadcastStreamingRuntimeContext(Environment, Map<String, Accumulator<?, ?>>, OperatorMetricGroup, OperatorID, ProcessingTimeService, KeyedStateStore, ExternalResourceInfoProvider) - Constructor for class org.apache.flink.ml.common.broadcast.BroadcastStreamingRuntimeContext
broadcastStreamNames - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: variables specific for withBroadcast functionality.
BroadcastUtils - Class in org.apache.flink.ml.common.broadcast: Utility class to support withBroadcast in DataStream.
BroadcastUtils() - Constructor for class org.apache.flink.ml.common.broadcast.BroadcastUtils
BroadcastVariableReceiverOperator<OUT> - Class in org.apache.flink.ml.common.broadcast.operator: The operator that process all broadcast inputs and stores them in BroadcastContext.
BroadcastVariableReceiverOperatorFactory<OUT> - Class in org.apache.flink.ml.common.broadcast.operator: Factory class for BroadcastVariableReceiverOperator.
BroadcastVariableReceiverOperatorFactory(String[], TypeInformation<?>[]) - Constructor for class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperatorFactory
broadcastVariablesReady - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: whether all broadcast variables of this operator are ready.
BroadcastWrapper<T> - Class in org.apache.flink.ml.common.broadcast.operator: The operator wrapper for AbstractBroadcastWrapperOperator.
BroadcastWrapper(String[], TypeInformation<?>[]) - Constructor for class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
BroadcastWrapper(String[], TypeInformation<?>[], boolean[]) - Constructor for class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
build() - Method in class org.apache.flink.iteration.IterationConfig.IterationConfigBuilder
buildAlgoOperator(TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Wraps nodes of the graph into an AlgoOperator.
buildEstimator(TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Wraps nodes of the graph into an Estimator.
buildEstimator(TableId[], TableId[], TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Wraps nodes of the graph into an Estimator.
buildEstimator(TableId[], TableId[], TableId[], TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Wraps nodes of the graph into an Estimator.
buildModel(TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Wraps nodes of the graph into a Model.
buildModel(TableId[], TableId[], TableId[], TableId[]) - Method in class org.apache.flink.ml.builder.GraphBuilder: Wraps nodes of the graph into a Model.

C

CacheElement<T> - Class in org.apache.flink.ml.common.broadcast.typeinfo: The wrapper class for possible cached elements used in AbstractBroadcastWrapperOperator.
CacheElement(T, long, CacheElement.Type) - Constructor for class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
CacheElement.Type - Enum in org.apache.flink.ml.common.broadcast.typeinfo: The type of cached elements.
CacheElementSerializer<T> - Class in org.apache.flink.ml.common.broadcast.typeinfo: TypeSerializer for CacheElement.
CacheElementSerializer(TypeSerializer<T>) - Constructor for class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
CacheElementTypeInfo<T> - Class in org.apache.flink.ml.common.broadcast.typeinfo: TypeInformation for CacheElement.
CacheElementTypeInfo(TypeInformation<T>) - Constructor for class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
callMethod(Object, Class<?>, String) - Static method in class org.apache.flink.iteration.utils.ReflectionUtils
callMethod(Object, Class<?>, String, List<Class<?>>, List<Object>) - Static method in class org.apache.flink.iteration.utils.ReflectionUtils
cancel() - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment.EmptySource
canEqual(Object) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
canEqual(Object) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
canEqual(Object) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
canEqual(Object) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
canEqual(Object) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
centroids - Variable in class org.apache.flink.ml.clustering.kmeans.KMeansModelData
ChainingBroadcastOutput<OUT> - Class in org.apache.flink.iteration.broadcast: The broadcast output corresponding to a chained output.
checkpointCoordinator(long, CompletableFuture<byte[]>) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
Checkpoints<T> - Class in org.apache.flink.iteration.checkpoint: Maintains the pending checkpoints.
Checkpoints(TypeSerializer<T>, FileSystem, SupplierWithException<Path, IOException>) - Constructor for class org.apache.flink.iteration.checkpoint.Checkpoints
CheckpointsBroker - Class in org.apache.flink.iteration.checkpoint: Hand offs the Checkpoints from the head operator to the tail operator so that the tail operator could decrease the reference count of the raw state when checkpoints are aborted.
CheckpointsBroker() - Constructor for class org.apache.flink.iteration.checkpoint.CheckpointsBroker
clazz - Variable in class org.apache.flink.ml.param.Param
cleanup() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
clearIterationContextRound() - Method in class org.apache.flink.iteration.operator.AbstractWrapperOperator
clone() - Method in class org.apache.flink.iteration.IterationRecord
close() - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
close() - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
close() - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
close() - Method in class org.apache.flink.iteration.operator.HeadOperator
close() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
close() - Method in class org.apache.flink.iteration.operator.TailOperator
close() - Method in class org.apache.flink.iteration.proxy.ProxyOutput
close() - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
close() - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
close() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
closeStreamOperator(S, int, int) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
closeStreamOperator(MultipleInputStreamOperator<OUT>, int, int) - Method in class org.apache.flink.iteration.operator.perround.MultipleInputPerRoundWrapperOperator
coefficient - Variable in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData
collect(OutputTag<X>, StreamRecord<X>) - Method in class org.apache.flink.iteration.proxy.ProxyOutput
collect(StreamRecord<T>) - Method in class org.apache.flink.iteration.proxy.ProxyOutput
commitCheckpointsUntil(long) - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
computeGradient(List<LabeledPointWithWeight>, DenseVector, DenseVector) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticGradient: Computes gradient on a set of samples.
computeLoss(List<LabeledPointWithWeight>, DenseVector) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticGradient: Computes weight sum and loss sum on a set of samples.
containingTask - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
containingTask - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
CoordinatorCheckpointEvent - Class in org.apache.flink.iteration.operator.event: Coordinator received the request of checkpoints.
CoordinatorCheckpointEvent(long) - Constructor for class org.apache.flink.iteration.operator.event.CoordinatorCheckpointEvent
copy() - Method in class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
copy(IterationRecord<T>) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
copy(IterationRecord<T>, IterationRecord<T>) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
copy(CacheElement<T>) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
copy(CacheElement<T>, CacheElement<T>) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
copy(DenseMatrix) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
copy(DenseMatrix, DenseMatrix) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
copy(DenseVector) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
copy(DenseVector, DenseVector) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
copy(SparseVector) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
copy(SparseVector, SparseVector) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
copyProperties(Transformation<?>, Transformation<?>) - Method in interface org.apache.flink.iteration.compile.DraftTransformationTranslator.Context
copyToActualEnvironment() - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment
CountingBroadcastOutput<OUT> - Class in org.apache.flink.iteration.broadcast: The intermediate broadcast output that wrappers a list of internal outputs.
CountingBroadcastOutput(Counter, List<BroadcastOutput<OUT>>) - Constructor for class org.apache.flink.iteration.broadcast.CountingBroadcastOutput
create(OperatorCoordinator.Context) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator.HeadOperatorCoordinatorProvider
create(StreamConfig, StreamTask<?, ?>, OperatorEpochWatermarkTrackerListener) - Static method in class org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTrackerFactory
create(String, TypeSerializer<T>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
createBroadcastOutput(Output<StreamRecord<OUT>>, Counter) - Static method in class org.apache.flink.iteration.broadcast.BroadcastOutputFactory: Creates the wrapper broadcast output from output.
createDataCacheFileGenerator(Path, String, OperatorID) - Static method in class org.apache.flink.iteration.operator.OperatorUtils
createFeedbackKey(IterationID, int) - Static method in class org.apache.flink.iteration.operator.OperatorUtils: Creates FeedbackKey from the iterationId and feedbackIndex.
createInstance() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
createInstance() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
createInstance() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
createInstance() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
createInstance() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
createInternalState(TypeSerializer<N>, StateDescriptor<S, SV>, StateSnapshotTransformer.StateSnapshotTransformFactory<SEV>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
createNewDescriptor(StateDescriptor<S, T>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
createReader(Configuration, FSDataInputStream) - Method in class org.apache.flink.ml.classification.knn.KnnModelData.ModelDataDecoder
createReader(Configuration, FSDataInputStream) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData.ModelDataDecoder
createReader(Configuration, FSDataInputStream) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData.ModelDataDecoder
createReader(Configuration, FSDataInputStream) - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModelData.ModelDataDecoder
createReader(Configuration, FSDataInputStream) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData.ModelDataStreamFormat
createSerializer(ExecutionConfig) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
createSerializer(ExecutionConfig) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
createSerializer(ExecutionConfig) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
createSerializer(ExecutionConfig) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
createSerializer(ExecutionConfig) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
createStreamOperator(StreamOperatorParameters<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.HeadOperatorFactory
createStreamOperator(StreamOperatorParameters<IterationRecord<OUT>>) - Method in class org.apache.flink.iteration.operator.WrapperOperatorFactory
createStreamOperator(StreamOperatorParameters<OUT>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperatorFactory
createTableId() - Method in class org.apache.flink.ml.builder.GraphBuilder: Creates a TableId associated with this GraphBuilder.
createTypeInfo(Type, Map<String, TypeInformation<?>>) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfoFactory
createTypeInfo(Type, Map<String, TypeInformation<?>>) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfoFactory
createTypeInfo(Type, Map<String, TypeInformation<?>>) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfoFactory
createWrappedOperatorConfig(StreamConfig) - Static method in class org.apache.flink.iteration.operator.OperatorUtils

D

DATA_CACHE_PATH - Static variable in class org.apache.flink.iteration.config.IterationOptions
DataCacheReader<T> - Class in org.apache.flink.iteration.datacache.nonkeyed: Reads the cached data from a list of paths.
DataCacheReader(TypeSerializer<T>, FileSystem, List<Segment>) - Constructor for class org.apache.flink.iteration.datacache.nonkeyed.DataCacheReader
DataCacheReader(TypeSerializer<T>, FileSystem, List<Segment>, Tuple2<Integer, Integer>) - Constructor for class org.apache.flink.iteration.datacache.nonkeyed.DataCacheReader
DataCacheSnapshot - Class in org.apache.flink.iteration.datacache.nonkeyed: The snapshot of a data cache.
DataCacheSnapshot(FileSystem, Tuple2<Integer, Integer>, List<Segment>) - Constructor for class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot
DataCacheWriter<T> - Class in org.apache.flink.iteration.datacache.nonkeyed: Records the data received and replayed them on required.
DataCacheWriter(TypeSerializer<T>, FileSystem, SupplierWithException<Path, IOException>) - Constructor for class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
DataCacheWriter(TypeSerializer<T>, FileSystem, SupplierWithException<Path, IOException>, List<Segment>) - Constructor for class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
dataCacheWriters - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: DataCacheWriter for each input.
DataStreamList - Class in org.apache.flink.iteration: A utility class to maintain a list of DataStream, which might have different types.
DataStreamList(List<DataStream<?>>) - Constructor for class org.apache.flink.iteration.DataStreamList
DataStreamUtils - Class in org.apache.flink.ml.common.datastream: Provides utility functions for DataStream.
DataStreamUtils() - Constructor for class org.apache.flink.ml.common.datastream.DataStreamUtils
defaultValue - Variable in class org.apache.flink.ml.param.Param
dense(double...) - Static method in class org.apache.flink.ml.linalg.Vectors: Creates a dense vector from its values.
DenseMatrix - Class in org.apache.flink.ml.linalg: Column-major dense matrix.
DenseMatrix(int, int) - Constructor for class org.apache.flink.ml.linalg.DenseMatrix: Constructs an m-by-n matrix of zeros.
DenseMatrix(int, int, double[]) - Constructor for class org.apache.flink.ml.linalg.DenseMatrix: Constructs a matrix from a 1-D array.
DenseMatrixSerializer - Class in org.apache.flink.ml.linalg.typeinfo: Specialized serializer for DenseMatrix.
DenseMatrixSerializer() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
DenseMatrixSerializer.DenseMatrixSerializerSnapshot - Class in org.apache.flink.ml.linalg.typeinfo: Serializer configuration snapshot for compatibility and format evolution.
DenseMatrixSerializerSnapshot() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer.DenseMatrixSerializerSnapshot
DenseMatrixTypeInfo - Class in org.apache.flink.ml.linalg.typeinfo: A TypeInformation for the DenseMatrix type.
DenseMatrixTypeInfo() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
DenseMatrixTypeInfoFactory - Class in org.apache.flink.ml.linalg.typeinfo: Used by TypeExtractor to create a TypeInformation for implementations of DenseMatrix.
DenseMatrixTypeInfoFactory() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfoFactory
DenseVector - Class in org.apache.flink.ml.linalg: A dense vector of double values.
DenseVector(double[]) - Constructor for class org.apache.flink.ml.linalg.DenseVector
DenseVector(int) - Constructor for class org.apache.flink.ml.linalg.DenseVector
DenseVectorSerializer - Class in org.apache.flink.ml.linalg.typeinfo: Specialized serializer for DenseVector.
DenseVectorSerializer() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
DenseVectorSerializer.DenseVectorSerializerSnapshot - Class in org.apache.flink.ml.linalg.typeinfo: Serializer configuration snapshot for compatibility and format evolution.
DenseVectorSerializerSnapshot() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer.DenseVectorSerializerSnapshot
DenseVectorTypeInfo - Class in org.apache.flink.ml.linalg.typeinfo: A TypeInformation for the DenseVector type.
DenseVectorTypeInfo() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
DenseVectorTypeInfoFactory - Class in org.apache.flink.ml.linalg.typeinfo: Used by TypeExtractor to create a TypeInformation for implementations of DenseVector.
DenseVectorTypeInfoFactory() - Constructor for class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfoFactory
deregisterKeySelectionListener(KeyedStateBackend.KeySelectionListener<K>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
description - Variable in class org.apache.flink.ml.param.Param
deserialize(DataInputView) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
deserialize(IterationRecord<T>, DataInputView) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
deserialize(DataInputView) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
deserialize(CacheElement<T>, DataInputView) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
deserialize(DataInputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
deserialize(DenseMatrix, DataInputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
deserialize(DataInputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
deserialize(DenseVector, DataInputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
deserialize(DataInputView) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
deserialize(SparseVector, DataInputView) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
deserializeNumber(DataInputView) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
dispose() - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
dispose() - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
distance(Vector, Vector) - Method in interface org.apache.flink.ml.common.distance.DistanceMeasure: Measures the distance between two vectors.
distance(Vector, Vector) - Method in class org.apache.flink.ml.common.distance.EuclideanDistanceMeasure
DISTANCE_MEASURE - Static variable in interface org.apache.flink.ml.common.param.HasDistanceMeasure
DistanceMeasure - Interface in org.apache.flink.ml.common.distance: Interface for measuring distance between two vectors.
dot(DenseVector, DenseVector) - Static method in class org.apache.flink.ml.linalg.BLAS: x \cdot y .
DoubleArrayParam - Class in org.apache.flink.ml.param: Class for the double array parameter.
DoubleArrayParam(String, String, Double[], ParamValidator<Double[]>) - Constructor for class org.apache.flink.ml.param.DoubleArrayParam
DoubleArrayParam(String, String, Double[]) - Constructor for class org.apache.flink.ml.param.DoubleArrayParam
DoubleParam - Class in org.apache.flink.ml.param: Class for the double parameter.
DoubleParam(String, String, Double, ParamValidator<Double>) - Constructor for class org.apache.flink.ml.param.DoubleParam
DoubleParam(String, String, Double) - Constructor for class org.apache.flink.ml.param.DoubleParam
DraftExecutionEnvironment - Class in org.apache.flink.iteration.compile: A specialized stream execution environment that allows users to first construct a subgraph and later copy the transformations into the actual environment.
DraftExecutionEnvironment(StreamExecutionEnvironment, OperatorWrapper<?, ?>) - Constructor for class org.apache.flink.iteration.compile.DraftExecutionEnvironment
DraftExecutionEnvironment.EmptySource<T> - Class in org.apache.flink.iteration.compile: A special source that emits no data.
DraftTransformationTranslator<TF extends org.apache.flink.api.dag.Transformation<?>> - Interface in org.apache.flink.iteration.compile: Creates the actual transformation according to the draft transformation.
DraftTransformationTranslator.Context - Interface in org.apache.flink.iteration.compile: The context for DraftTransformationTranslator.
DROP_LAST - Static variable in interface org.apache.flink.ml.feature.onehotencoder.OneHotEncoderParams
duplicate() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
duplicate() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer

E

emitLatencyMarker(LatencyMarker) - Method in class org.apache.flink.iteration.proxy.ProxyOutput
emitWatermark(Watermark) - Method in class org.apache.flink.iteration.proxy.ProxyOutput
emitWatermarkStatus(WatermarkStatus) - Method in class org.apache.flink.iteration.proxy.ProxyOutput
EmptySource() - Constructor for class org.apache.flink.iteration.compile.DraftExecutionEnvironment.EmptySource
encode(KnnModelData, OutputStream) - Method in class org.apache.flink.ml.classification.knn.KnnModelData.ModelDataEncoder
encode(LogisticRegressionModelData, OutputStream) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData.ModelDataEncoder
encode(NaiveBayesModelData, OutputStream) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData.ModelDataEncoder
encode(KMeansModelData, OutputStream) - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModelData.ModelDataEncoder
encode(Tuple2<Integer, Integer>, OutputStream) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData.ModelDataEncoder
endInput(int) - Method in class org.apache.flink.iteration.operator.AbstractWrapperOperator
endInput(int) - Method in class org.apache.flink.iteration.operator.allround.MultipleInputAllRoundWrapperOperator
endInput() - Method in class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
endInput(int) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
endInput() - Method in class org.apache.flink.iteration.operator.HeadOperator
endInput(int) - Method in class org.apache.flink.iteration.operator.ReplayOperator
endInput(int) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperator
endInput() - Method in class org.apache.flink.ml.common.broadcast.operator.OneInputBroadcastWrapperOperator
endInput(int) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
endInputAndEmitMaxWatermark(S, int, int) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
endInputAndEmitMaxWatermark(MultipleInputStreamOperator<OUT>, int, int) - Method in class org.apache.flink.iteration.operator.perround.MultipleInputPerRoundWrapperOperator
endInputAndEmitMaxWatermark(OneInputStreamOperator<IN, OUT>, int, int) - Method in class org.apache.flink.iteration.operator.perround.OneInputPerRoundWrapperOperator
endInputAndEmitMaxWatermark(TwoInputStreamOperator<IN1, IN2, OUT>, int, int) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
endInputX(int, ThrowingConsumer<StreamRecord, Exception>, ThrowingConsumer<Watermark, Exception>) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: extracts common processing logic in subclasses' endInput(...).
EndOfStreamWindows - Class in org.apache.flink.ml.common.datastream: A WindowAssigner that assigns all elements of a bounded input stream into one window pane.
EpochAware - Interface in org.apache.flink.iteration.operator.allround: Operators or UDF implements this method would be provided with an supplier that provides the current rounds of the current element.
EpochAwareAllRoundProcessFunction<I,O> - Class in org.apache.flink.iteration.functions: A specialized ProcessFunction that also provide the attach epoch with each record.
EpochAwareAllRoundProcessFunction() - Constructor for class org.apache.flink.iteration.functions.EpochAwareAllRoundProcessFunction
EpochAwareCoProcessFunction<I1,I2,O> - Class in org.apache.flink.iteration.functions: A specialized CoProcessFunction that also provide the attach epoch with each record.
EpochAwareCoProcessFunction() - Constructor for class org.apache.flink.iteration.functions.EpochAwareCoProcessFunction
epochWatermarkSupplier - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
epochWatermarkTracker - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
equals(Object) - Method in class org.apache.flink.iteration.datacache.nonkeyed.Segment
equals(Object) - Method in class org.apache.flink.iteration.IterationRecord
equals(Object) - Method in class org.apache.flink.iteration.operator.event.CoordinatorCheckpointEvent
equals(Object) - Method in class org.apache.flink.iteration.operator.event.GloballyAlignedEvent
equals(Object) - Method in class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
equals(Object) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
equals(Object) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
equals(Object) - Method in class org.apache.flink.ml.builder.GraphNode
equals(Object) - Method in class org.apache.flink.ml.builder.TableId
equals(Object) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
equals(Object) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
equals(Object) - Method in class org.apache.flink.ml.linalg.DenseVector
equals(Object) - Method in class org.apache.flink.ml.linalg.SparseVector
equals(Object) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
equals(Object) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
equals(Object) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
equals(Object) - Method in class org.apache.flink.ml.param.Param
ERROR_INVALID - Static variable in interface org.apache.flink.ml.common.param.HasHandleInvalid
Estimator<E extends Estimator<E,M>,M extends Model<M>> - Interface in org.apache.flink.ml.api: Estimators are responsible for training and generating Models.
estimatorInputIds - Variable in class org.apache.flink.ml.builder.GraphData
estimatorInputIds - Variable in class org.apache.flink.ml.builder.GraphNode
EuclideanDistanceMeasure - Class in org.apache.flink.ml.common.distance: Interface for measuring the Euclidean distance between two vectors.
eventBroadcastOutput - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
execute(StreamGraph) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment

F

featureNormSquares - Variable in class org.apache.flink.ml.classification.knn.KnnModelData
FEATURES_COL - Static variable in interface org.apache.flink.ml.common.param.HasFeaturesCol
finish() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
finish() - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
finish() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
finish(int) - Method in class org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTracker
finish() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
finishCurrentSegment() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
FINISHED_STATE - Static variable in class org.apache.flink.iteration.operator.headprocessor.HeadOperatorState
fit(Table...) - Method in interface org.apache.flink.ml.api.Estimator: Trains on the given inputs and produces a Model.
fit(Table...) - Method in class org.apache.flink.ml.builder.Graph
fit(Table...) - Method in class org.apache.flink.ml.builder.Pipeline: Trains the pipeline to fit on the given tables.
fit(Table...) - Method in class org.apache.flink.ml.classification.knn.Knn
fit(Table...) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegression
fit(Table...) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayes
fit(Table...) - Method in class org.apache.flink.ml.clustering.kmeans.KMeans
fit(Table...) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoder
flatMap(T, Collector<T>) - Method in class org.apache.flink.ml.common.iteration.ForwardInputsOfLastRound
flatMap(T, Collector<Integer>) - Method in class org.apache.flink.ml.common.iteration.TerminateOnMaxIter
flatMap(Double, Collector<Integer>) - Method in class org.apache.flink.ml.common.iteration.TerminateOnMaxIterOrTol
FloatArrayParam - Class in org.apache.flink.ml.param: Class for the float array parameter.
FloatArrayParam(String, String, Float[], ParamValidator<Float[]>) - Constructor for class org.apache.flink.ml.param.FloatArrayParam
FloatArrayParam(String, String, Float[]) - Constructor for class org.apache.flink.ml.param.FloatArrayParam
FloatParam - Class in org.apache.flink.ml.param: Class for the float parameter.
FloatParam(String, String, Float, ParamValidator<Float>) - Constructor for class org.apache.flink.ml.param.FloatParam
FloatParam(String, String, Float) - Constructor for class org.apache.flink.ml.param.FloatParam
forEachRound(DataStreamList, IterationBody.PerRoundSubBody) - Static method in interface org.apache.flink.iteration.IterationBody
ForwardInputsOfLastRound<T> - Class in org.apache.flink.ml.common.iteration: A FlatMapFunction which forwards input values in the last round of the iteration to the output.
ForwardInputsOfLastRound() - Constructor for class org.apache.flink.ml.common.iteration.ForwardInputsOfLastRound
fromList(List<Integer>) - Static method in class org.apache.flink.ml.builder.TableId
fromMap(Map<String, Object>) - Static method in class org.apache.flink.ml.builder.GraphData
fromMap(Map<String, Object>) - Static method in class org.apache.flink.ml.builder.GraphNode

G

gemv(double, DenseMatrix, boolean, DenseVector, double, DenseVector) - Static method in class org.apache.flink.ml.linalg.BLAS: y = alpha * matrix * x + beta * y or y = alpha * (matrix^T) * x + beta * y.
get() - Static method in class org.apache.flink.iteration.checkpoint.CheckpointsBroker
get(int) - Method in class org.apache.flink.iteration.DataStreamList: Returns the data stream at the given index in this list.
get() - Static method in class org.apache.flink.ml.common.datastream.EndOfStreamWindows
get(int, int) - Method in class org.apache.flink.ml.linalg.DenseMatrix
get(int) - Method in class org.apache.flink.ml.linalg.DenseVector
get(int, int) - Method in interface org.apache.flink.ml.linalg.Matrix: Gets value of the (i,j) element.
get(int) - Method in class org.apache.flink.ml.linalg.SparseVector
get(int) - Method in interface org.apache.flink.ml.linalg.Vector: Gets the value of the ith element.
get(Param<V>) - Method in interface org.apache.flink.ml.param.WithParams: Gets the value of the parameter.
getActualStream(int) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment
getActualTransformation(int) - Method in interface org.apache.flink.iteration.compile.DraftTransformationTranslator.Context
getArity() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
getArity() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
getArity() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
getArity() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
getArity() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
getBroadcastingInternalOutputs(Object) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
getBroadcastState(MapStateDescriptor<K, V>) - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
getBroadcastVariable(String) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastContext
getBroadcastVariable(String) - Method in class org.apache.flink.ml.common.broadcast.BroadcastStreamingRuntimeContext
getBroadcastVariableWithInitializer(String, BroadcastVariableInitializer<T, C>) - Method in class org.apache.flink.ml.common.broadcast.BroadcastStreamingRuntimeContext
getChainingOutputTag(Object) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
getChainingStrategy() - Method in class org.apache.flink.iteration.operator.HeadOperatorFactory
getCheckpointId() - Method in class org.apache.flink.iteration.IterationRecord
getCheckpointId() - Method in class org.apache.flink.iteration.operator.event.CoordinatorCheckpointEvent
getCheckpointId() - Method in class org.apache.flink.iteration.proxy.state.ProxyStateSnapshotContext
getCheckpoints(SubtaskFeedbackKey<V>) - Method in class org.apache.flink.iteration.checkpoint.CheckpointsBroker
getCheckpointTimestamp() - Method in class org.apache.flink.iteration.proxy.state.ProxyStateSnapshotContext
getClassField(Class<?>, String) - Static method in class org.apache.flink.iteration.utils.ReflectionUtils
getCoordinatorProvider(String, OperatorID) - Method in class org.apache.flink.iteration.operator.HeadOperatorFactory
getCount() - Method in class org.apache.flink.iteration.datacache.nonkeyed.Segment
getCurrentKey() - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
getCurrentKey() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
getCurrentKey() - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getCurrentKey() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
getDataCachePath(Configuration, String[]) - Static method in class org.apache.flink.iteration.operator.OperatorUtils
getDataStreams() - Method in class org.apache.flink.iteration.DataStreamList: Returns all the data streams as a native list.
getDefaultTrigger(StreamExecutionEnvironment) - Method in class org.apache.flink.ml.common.datastream.EndOfStreamWindows
getDistanceMeasure() - Method in interface org.apache.flink.ml.common.param.HasDistanceMeasure
getDownstreamSubtaskStateMapper() - Method in class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
getDropLast() - Method in interface org.apache.flink.ml.feature.onehotencoder.OneHotEncoderParams
getEpoch() - Method in class org.apache.flink.iteration.IterationRecord
getEpoch() - Method in class org.apache.flink.iteration.operator.event.GloballyAlignedEvent
getEpoch() - Method in class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
getExecutionConfig() - Method in interface org.apache.flink.iteration.compile.DraftTransformationTranslator.Context
getFeatures() - Method in class org.apache.flink.ml.common.feature.LabeledPointWithWeight
getFeaturesCol() - Method in interface org.apache.flink.ml.common.param.HasFeaturesCol
getFeedbackVariableStreams() - Method in class org.apache.flink.iteration.IterationBodyResult
getFieldValue(Object, Field) - Static method in class org.apache.flink.iteration.utils.ReflectionUtils
getFieldValue(Object, Class<?>, String) - Static method in class org.apache.flink.iteration.utils.ReflectionUtils
getFileSystem() - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
getFileSystem() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot
getFileSystem() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
getFinishSegments() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheWriter
getGlobalBatchSize() - Method in interface org.apache.flink.ml.common.param.HasGlobalBatchSize
getHandleInvalid() - Method in interface org.apache.flink.ml.common.param.HasHandleInvalid
getInitMode() - Method in interface org.apache.flink.ml.clustering.kmeans.KMeansParams
getInnerSerializer() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
getInnerTypeInfo() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
getInputCols() - Method in interface org.apache.flink.ml.common.param.HasInputCols
getInputs() - Method in class org.apache.flink.iteration.operator.allround.MultipleInputAllRoundWrapperOperator
getInputs() - Method in class org.apache.flink.iteration.operator.perround.MultipleInputPerRoundWrapperOperator
getInputs() - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperator
getInstance(String) - Static method in interface org.apache.flink.ml.common.distance.DistanceMeasure
getInstance() - Static method in class org.apache.flink.ml.common.distance.EuclideanDistanceMeasure
getInternalTimerService(String, TypeSerializer<K>, TypeSerializer<N>, Triggerable<K, N>) - Method in class org.apache.flink.iteration.proxy.state.ProxyInternalTimeServiceManager
getK() - Method in interface org.apache.flink.ml.classification.knn.KnnModelParams
getK() - Method in interface org.apache.flink.ml.clustering.kmeans.KMeansModelParams
getKey(IterationRecord<T>) - Method in class org.apache.flink.iteration.proxy.ProxyKeySelector
getKeyGroupRange() - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getKeys(String, N) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getKeysAndNamespaces(String) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getKeySerializer() - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getLabel() - Method in class org.apache.flink.ml.common.feature.LabeledPointWithWeight
getLabelCol() - Method in interface org.apache.flink.ml.common.param.HasLabelCol
getLatestRoundAligned() - Method in class org.apache.flink.iteration.operator.headprocessor.HeadOperatorState
getLatestRoundAligned() - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
getLatestRoundGloballyAligned() - Method in class org.apache.flink.iteration.operator.headprocessor.HeadOperatorState
getLatestRoundGloballyAligned() - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
getLearningRate() - Method in interface org.apache.flink.ml.common.param.HasLearningRate
getLength() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
getLength() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
getLength() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
getLength() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
getLength() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
getListState(ListStateDescriptor<S>) - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
getMaxIter() - Method in interface org.apache.flink.ml.common.param.HasMaxIter
getMetricGroup() - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
getMetricGroup() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
getMetricGroup() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
getModelData() - Method in interface org.apache.flink.ml.api.Model: Gets a list of tables representing the model data.
getModelData() - Method in class org.apache.flink.ml.builder.GraphModel
getModelData() - Method in class org.apache.flink.ml.classification.knn.KnnModel
getModelData() - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
getModelData() - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
getModelData() - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModel
getModelData() - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
getModelDataFromEstimator(Estimator<?, ?>) - Method in class org.apache.flink.ml.builder.GraphBuilder: When the graph runs as Estimator, it first generates a GraphModel that contains the Model fitted by the given Estimator.
getModelDataFromModel(Model<?>) - Method in class org.apache.flink.ml.builder.GraphBuilder: When the graph runs as Estimator, the getModelData() of the given Model would be invoked.
getModelDataStream(Table) - Static method in class org.apache.flink.ml.classification.knn.KnnModelData: Converts the table model to a data stream.
getModelDataStream(Table) - Static method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData: Converts the table model to a data stream.
getModelDataStream(Table) - Static method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData: Converts the table model to a data stream.
getModelDataStream(Table) - Static method in class org.apache.flink.ml.clustering.kmeans.KMeansModelData: Converts the table model to a data stream.
getModelDataStream(Table) - Static method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData: Converts the table model to a data stream.
getModelType() - Method in interface org.apache.flink.ml.classification.naivebayes.NaiveBayesModelParams
getMultiClass() - Method in interface org.apache.flink.ml.common.param.HasMultiClass
getNamePrefix() - Method in class org.apache.flink.iteration.proxy.state.StateNamePrefix
getNumFeedbackRecordsEachRound() - Method in class org.apache.flink.iteration.operator.headprocessor.HeadOperatorState
getNumFeedbackRecordsPerEpoch() - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
getNumRecordsThisRound() - Method in class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
getOperatorEventGateway() - Method in class org.apache.flink.iteration.operator.HeadOperator
getOperatorFactory() - Method in class org.apache.flink.iteration.operator.WrapperOperatorFactory
getOperatorID() - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
getOperatorId() - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator.HeadOperatorCoordinatorProvider
getOperatorID() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
getOperatorID() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
getOperatorLifeCycle() - Method in class org.apache.flink.iteration.IterationConfig
getOrCreate(IterationID, int, OperatorCoordinator.Context, Supplier<Executor>) - Static method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
getOrCreateKeyedState(TypeSerializer<N>, StateDescriptor<S, T>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getOutputCols() - Method in interface org.apache.flink.ml.common.param.HasOutputCols
getOutputStreams() - Method in class org.apache.flink.iteration.IterationBodyResult
getParam(String) - Method in interface org.apache.flink.ml.param.WithParams: Gets the parameter by its name.
getParamMap() - Method in class org.apache.flink.ml.builder.Graph
getParamMap() - Method in class org.apache.flink.ml.builder.GraphModel
getParamMap() - Method in class org.apache.flink.ml.builder.Pipeline
getParamMap() - Method in class org.apache.flink.ml.builder.PipelineModel
getParamMap() - Method in class org.apache.flink.ml.classification.knn.Knn
getParamMap() - Method in class org.apache.flink.ml.classification.knn.KnnModel
getParamMap() - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegression
getParamMap() - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
getParamMap() - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayes
getParamMap() - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
getParamMap() - Method in class org.apache.flink.ml.clustering.kmeans.KMeans
getParamMap() - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModel
getParamMap() - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoder
getParamMap() - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
getParamMap() - Method in interface org.apache.flink.ml.param.WithParams: Returns a map which should contain value for every parameter that meets one of the following conditions.
getPartitionedState(N, TypeSerializer<N>, StateDescriptor<S, ?>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
getPath() - Method in class org.apache.flink.iteration.datacache.nonkeyed.Segment
getPathSupplier() - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
getPosition() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheReader
getPredictionCol() - Method in interface org.apache.flink.ml.common.param.HasPredictionCol
getProducedType() - Method in class org.apache.flink.ml.classification.knn.KnnModelData.ModelDataDecoder
getProducedType() - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData.ModelDataDecoder
getProducedType() - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData.ModelDataDecoder
getProducedType() - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModelData.ModelDataDecoder
getProducedType() - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData.ModelDataStreamFormat
getPublicFinalParamFields(Object) - Static method in class org.apache.flink.ml.util.ParamUtils: Finds all public final fields of the Param class type of the given object, including those fields inherited from its interfaces and super-classes, and returns those Param instances as a list.
getRawKeyedOperatorStateOutput() - Method in class org.apache.flink.iteration.proxy.state.ProxyStateSnapshotContext
getRawOperatorStateOutput() - Method in class org.apache.flink.iteration.proxy.state.ProxyStateSnapshotContext
getRawPredictionCol() - Method in interface org.apache.flink.ml.common.param.HasRawPredictionCol
getReaderPosition() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot
getRecord() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
getRecordWriter(Object) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
getRecordWriterTypeSerializer(Object) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
getReg() - Method in interface org.apache.flink.ml.common.param.HasReg
getRegisteredBroadcastStateNames() - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
getRegisteredStateNames() - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
getRestoredCheckpointId() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
getRowTypeInfo(ResolvedSchema) - Static method in class org.apache.flink.ml.common.datastream.TableUtils
getSeed() - Method in interface org.apache.flink.ml.common.param.HasSeed
getSegments() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot
getSender() - Method in class org.apache.flink.iteration.IterationRecord
getSize() - Method in class org.apache.flink.iteration.datacache.nonkeyed.Segment
getSmoothing() - Method in interface org.apache.flink.ml.classification.naivebayes.NaiveBayesParams
getStatus() - Method in class org.apache.flink.iteration.operator.HeadOperator
getStreamConfig() - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
getStreamOperatorClass(ClassLoader, StreamOperatorFactory<T>) - Method in class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
getStreamOperatorClass(ClassLoader) - Method in class org.apache.flink.iteration.operator.HeadOperatorFactory
getStreamOperatorClass(ClassLoader, StreamOperatorFactory<T>) - Method in interface org.apache.flink.iteration.operator.OperatorWrapper
getStreamOperatorClass(ClassLoader, StreamOperatorFactory<T>) - Method in class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
getStreamOperatorClass(ClassLoader) - Method in class org.apache.flink.iteration.operator.WrapperOperatorFactory
getStreamOperatorClass(ClassLoader) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperatorFactory
getStreamOperatorClass(ClassLoader, StreamOperatorFactory<T>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
getTaskInfo() - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
getTerminationCriteria() - Method in class org.apache.flink.iteration.IterationBodyResult
getTol() - Method in interface org.apache.flink.ml.common.param.HasTol
getTotalFields() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
getTotalFields() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
getTotalFields() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
getTotalFields() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
getTotalFields() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
getType() - Method in class org.apache.flink.iteration.IterationRecord
getType() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
getTypeClass() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
getTypeClass() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
getTypeClass() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
getTypeClass() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
getTypeClass() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
getTypeSerializer() - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
getUnionListState(ListStateDescriptor<S>) - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
getUniqueElement(ListState<T>, String) - Static method in class org.apache.flink.iteration.operator.OperatorStateUtils
getUniqueSenderId(OperatorID, int) - Static method in class org.apache.flink.iteration.operator.OperatorUtils: Returns the unique id for the specified operator.
getValue() - Method in class org.apache.flink.iteration.IterationRecord
getWatermark() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
getWeight() - Method in class org.apache.flink.ml.common.feature.LabeledPointWithWeight
getWeightCol() - Method in interface org.apache.flink.ml.common.param.HasWeightCol
getWindowSerializer(ExecutionConfig) - Method in class org.apache.flink.ml.common.datastream.EndOfStreamWindows
getWrappedKeySelector() - Method in class org.apache.flink.iteration.proxy.ProxyKeySelector
getWrappedOperator(int) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
getWrappedOperator(int) - Method in class org.apache.flink.iteration.operator.perround.MultipleInputPerRoundWrapperOperator
getWrappedOperators() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
getWrappedTypeInfo(TypeInformation<T>) - Method in class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
getWrappedTypeInfo(TypeInformation<T>) - Method in interface org.apache.flink.iteration.operator.OperatorWrapper
getWrappedTypeInfo(TypeInformation<T>) - Method in class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
getWrappedTypeInfo(TypeInformation<T>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
getWrapper() - Method in class org.apache.flink.iteration.operator.WrapperOperatorFactory
GLOBAL_BATCH_SIZE - Static variable in interface org.apache.flink.ml.common.param.HasGlobalBatchSize
GloballyAlignedEvent - Class in org.apache.flink.iteration.operator.event: The event sent from HeadOperatorCoordinator to HeadOperator to notify a round is globally aligned and whether the iteration should terminate.
GloballyAlignedEvent(int, boolean) - Constructor for class org.apache.flink.iteration.operator.event.GloballyAlignedEvent
Graph - Class in org.apache.flink.ml.builder: A Graph acts as an Estimator.
Graph(List<GraphNode>, TableId[], TableId[], TableId[], TableId[], TableId[]) - Constructor for class org.apache.flink.ml.builder.Graph
GraphBuilder - Class in org.apache.flink.ml.builder: A GraphBuilder provides APIs to build Estimator/Model/AlgoOperator from a DAG of stages, each of which could be an Estimator, Model, Transformer or AlgoOperator.
GraphBuilder() - Constructor for class org.apache.flink.ml.builder.GraphBuilder
GraphData - Class in org.apache.flink.ml.builder: This class contains fields that can be used to re-construct Graph and GraphModel.
GraphData(List<GraphNode>, TableId[], TableId[], TableId[], TableId[], TableId[]) - Constructor for class org.apache.flink.ml.builder.GraphData
GraphModel - Class in org.apache.flink.ml.builder: A GraphModel acts as a Model.
GraphModel(List<GraphNode>, TableId[], TableId[], TableId[], TableId[]) - Constructor for class org.apache.flink.ml.builder.GraphModel
GraphNode - Class in org.apache.flink.ml.builder: The Graph node class.
GraphNode(int, Stage<?>, GraphNode.StageType, TableId[], TableId[], TableId[], TableId[], TableId[]) - Constructor for class org.apache.flink.ml.builder.GraphNode
GraphNode.StageType - Enum in org.apache.flink.ml.builder: This class specifies whether a node should be used as Estimator or AlgoOperator.
gt(double) - Static method in class org.apache.flink.ml.param.ParamValidators
gtEq(double) - Static method in class org.apache.flink.ml.param.ParamValidators

H

HANDLE_INVALID - Static variable in interface org.apache.flink.ml.common.param.HasHandleInvalid
handleEventFromOperator(int, OperatorEvent) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
handleOperatorEvent(OperatorEvent) - Method in class org.apache.flink.iteration.operator.HeadOperator
hasBroadcastVariable(String) - Method in class org.apache.flink.ml.common.broadcast.BroadcastStreamingRuntimeContext
HasDistanceMeasure<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared distanceMeasure param.
HasFeaturesCol<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared featuresCol param.
HasGlobalBatchSize<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared global batch size param.
HasHandleInvalid<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared handleInvalid param.
hashCode() - Method in class org.apache.flink.iteration.datacache.nonkeyed.Segment
hashCode() - Method in class org.apache.flink.iteration.IterationRecord
hashCode() - Method in class org.apache.flink.iteration.operator.event.CoordinatorCheckpointEvent
hashCode() - Method in class org.apache.flink.iteration.operator.event.GloballyAlignedEvent
hashCode() - Method in class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
hashCode() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
hashCode() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
hashCode() - Method in class org.apache.flink.ml.builder.GraphNode
hashCode() - Method in class org.apache.flink.ml.builder.TableId
hashCode() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
hashCode() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
hashCode() - Method in class org.apache.flink.ml.linalg.DenseVector
hashCode() - Method in class org.apache.flink.ml.linalg.SparseVector
hashCode() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
hashCode() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
hashCode() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
hashCode() - Method in class org.apache.flink.ml.param.Param
HasInputCols<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared inputCols param.
HasLabelCol<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared label column param.
HasLearningRate<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared learning rate param.
HasMaxIter<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared maxIter param.
HasMultiClass<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared multi-class param.
hasNext() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheReader
HasOutputCols<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared outputCols param.
hasPendingElements - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: whether each input has pending elements.
HasPredictionCol<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared prediction column param.
HasRawPredictionCol<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared raw prediction column param.
HasReg<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared regularization param.
HasSeed<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared seed param.
HasTol<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared tolerance param.
HasWeightCol<T> - Interface in org.apache.flink.ml.common.param: Interface for the shared weight column param.
HeadOperator - Class in org.apache.flink.iteration.operator: The head operator unions the initialized variable stream and the feedback stream, synchronize the epoch watermark (round) and taking care of the checkpoints.
HeadOperator(IterationID, int, boolean, MailboxExecutor, OperatorEventGateway, ProcessingTimeService) - Constructor for class org.apache.flink.iteration.operator.HeadOperator
HeadOperatorCoordinator - Class in org.apache.flink.iteration.operator.coordinator: The OperatorCoordinator of the HeadOperator, it notifies the SharedProgressAligner when received aligned event from the operator, and emit the globally aligned event back after one round is globally aligned.
HeadOperatorCoordinator(OperatorCoordinator.Context, SharedProgressAligner) - Constructor for class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
HeadOperatorCoordinator.HeadOperatorCoordinatorProvider - Class in org.apache.flink.iteration.operator.coordinator: The factory of HeadOperatorCoordinator.
HeadOperatorCoordinatorProvider(OperatorID, IterationID, int) - Constructor for class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator.HeadOperatorCoordinatorProvider
HeadOperatorFactory - Class in org.apache.flink.iteration.operator: The Factory for the HeadOperator.
HeadOperatorFactory(IterationID, int, boolean, int) - Constructor for class org.apache.flink.iteration.operator.HeadOperatorFactory
HeadOperatorRecordProcessor - Interface in org.apache.flink.iteration.operator.headprocessor: The component to actually deal with the event received in the HeadOperator.
HeadOperatorRecordProcessor.Context - Interface in org.apache.flink.iteration.operator.headprocessor: The context for HeadOperatorRecordProcessor.
HeadOperatorState - Class in org.apache.flink.iteration.operator.headprocessor: The state entry for the head operator.
HeadOperatorState(Map<Integer, Long>, int, int) - Constructor for class org.apache.flink.iteration.operator.headprocessor.HeadOperatorState

I

id - Variable in class org.apache.flink.ml.builder.TableId
inArray(T...) - Static method in class org.apache.flink.ml.param.ParamValidators
incrementEpoch() - Method in class org.apache.flink.iteration.IterationRecord
indexOfSubtask - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: index of this subtask.
indices - Variable in class org.apache.flink.ml.linalg.SparseVector
INIT_MODE - Static variable in interface org.apache.flink.ml.clustering.kmeans.KMeansParams
initializeMapWithDefaultValues(Map<Param<?>, Object>, WithParams<?>) - Static method in class org.apache.flink.ml.util.ParamUtils: Updates the paramMap with default values of all public final Param-typed fields of the given instance.
initializeState(StreamTaskStateInitializer) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
initializeState(StateInitializationContext) - Method in class org.apache.flink.iteration.operator.HeadOperator
initializeState(HeadOperatorState, Iterable<StatePartitionStreamProvider>) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor
initializeState(HeadOperatorState, Iterable<StatePartitionStreamProvider>) - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
initializeState(HeadOperatorState, Iterable<StatePartitionStreamProvider>) - Method in class org.apache.flink.iteration.operator.headprocessor.TerminatingHeadOperatorRecordProcessor
initializeState(StreamTaskStateInitializer) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
initializeState(StateInitializationContext) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
initializeState(StateInitializationContext) - Method in class org.apache.flink.iteration.operator.ReplayOperator
initializeState(StreamTaskStateInitializer) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
initializeState(StateInitializationContext) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
initializeState(StateInitializationContext) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperator
INPUT_COLS - Static variable in interface org.apache.flink.ml.common.param.HasInputCols
inputModelDataIds - Variable in class org.apache.flink.ml.builder.GraphData
inputModelDataIds - Variable in class org.apache.flink.ml.builder.GraphNode
InputOperator<T> - Class in org.apache.flink.iteration.operator: Input operator that wraps the user record into IterationRecord.
InputOperator() - Constructor for class org.apache.flink.iteration.operator.InputOperator
inRange(double, double, boolean, boolean) - Static method in class org.apache.flink.ml.param.ParamValidators: Check if the parameter value is in the range from lowerBound to upperBound.
inRange(double, double) - Static method in class org.apache.flink.ml.param.ParamValidators
INSTANCE - Static variable in class org.apache.flink.iteration.operator.event.TerminatingOnInitializeEvent
INSTANCE - Static variable in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
INSTANCE - Static variable in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
INSTANCE - Static variable in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
INSTANCE - Static variable in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
INSTANCE - Static variable in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
INSTANCE - Static variable in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
instances - Static variable in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
IntArrayParam - Class in org.apache.flink.ml.param: Class for the integer array parameter.
IntArrayParam(String, String, Integer[], ParamValidator<Integer[]>) - Constructor for class org.apache.flink.ml.param.IntArrayParam
IntArrayParam(String, String, Integer[]) - Constructor for class org.apache.flink.ml.param.IntArrayParam
internalTimerServiceManager() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
IntParam - Class in org.apache.flink.ml.param: Class for the integer parameter.
IntParam(String, String, Integer, ParamValidator<Integer>) - Constructor for class org.apache.flink.ml.param.IntParam
IntParam(String, String, Integer) - Constructor for class org.apache.flink.ml.param.IntParam
inTypes - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: type information of each input.
isBasicType() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
isBasicType() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
isBasicType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
isBasicType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
isBasicType() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
isBlocked - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: whether each input is blocked.
isBroadcastingOutput(Output<?>) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
isCacheFinished(String) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastContext
isChainingOutput(Output<?>) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
isCriteriaStream() - Method in class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
isEventTime() - Method in class org.apache.flink.ml.common.datastream.EndOfStreamWindows
isImmutableType() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
isImmutableType() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
isImmutableType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
isImmutableType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
isImmutableType() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
isKeyType() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
isKeyType() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
isKeyType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
isKeyType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
isKeyType() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
isPointwise() - Method in class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
isRecordWriterOutput(Output<?>) - Method in class org.apache.flink.iteration.broadcast.OutputReflectionContext
isRestored() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
isTerminated() - Method in class org.apache.flink.iteration.operator.event.GloballyAlignedEvent
isTupleType() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
isTupleType() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
isTupleType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
isTupleType() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
isTupleType() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
isUsingCustomRawKeyedState() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
iterateBoundedStreamsUntilTermination(DataStreamList, ReplayableDataStreamList, IterationConfig, IterationBody) - Static method in class org.apache.flink.iteration.Iterations: This method uses an iteration body to process records in some bounded data streams iteratively until no more records are iterating or the given terminating criteria stream is empty in one round.
iterateUnboundedStreams(DataStreamList, DataStreamList, IterationBody) - Static method in class org.apache.flink.iteration.Iterations: This method uses an iteration body to process records in possibly unbounded data streams.
IterationBody - Interface in org.apache.flink.iteration: The builder of the subgraph that will be executed inside the iteration.
IterationBody.PerRoundSubBody - Interface in org.apache.flink.iteration: The sub-graph inside the iteration body that should be executed as per-round.
IterationBodyResult - Class in org.apache.flink.iteration: The result of an iteration, specifying the feedbacks and the outputs.
IterationBodyResult(DataStreamList, DataStreamList) - Constructor for class org.apache.flink.iteration.IterationBodyResult
IterationBodyResult(DataStreamList, DataStreamList, DataStream<?>) - Constructor for class org.apache.flink.iteration.IterationBodyResult
IterationConfig - Class in org.apache.flink.iteration: The config for an iteration.
IterationConfig(IterationConfig.OperatorLifeCycle) - Constructor for class org.apache.flink.iteration.IterationConfig
IterationConfig.IterationConfigBuilder - Class in org.apache.flink.iteration: The builder of the IterationConfig.
IterationConfig.OperatorLifeCycle - Enum in org.apache.flink.iteration: LifeCycles of the operator inside the iteration.
iterationContext - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
IterationID - Class in org.apache.flink.iteration: The id of a single iteration instance in the job graph.
IterationID(byte[]) - Constructor for class org.apache.flink.iteration.IterationID
IterationID() - Constructor for class org.apache.flink.iteration.IterationID
IterationListener<T> - Interface in org.apache.flink.iteration: The callbacks which will be invoked if the operator or UDF inside iteration implement this interface.
IterationListener.Context - Interface in org.apache.flink.iteration: Information available in an invocation of the callbacks defined in the IterationProgressListener.
IterationOptions - Class in org.apache.flink.iteration.config: The options for the iteration.
IterationOptions() - Constructor for class org.apache.flink.iteration.config.IterationOptions
IterationRecord<T> - Class in org.apache.flink.iteration: The wrapper for the records in iterative stream.
IterationRecord.Type - Enum in org.apache.flink.iteration: The type of iteration records.
IterationRecordSerializer<T> - Class in org.apache.flink.iteration.typeinfo: The type serializer for IterationRecord.
IterationRecordSerializer(TypeSerializer<T>) - Constructor for class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
IterationRecordTypeInfo<T> - Class in org.apache.flink.iteration.typeinfo: The type information for IterationRecord.
IterationRecordTypeInfo(TypeInformation<T>) - Constructor for class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
Iterations - Class in org.apache.flink.iteration: A helper class to create iterations.
Iterations() - Constructor for class org.apache.flink.iteration.Iterations

J

jsonDecode(String) - Method in class org.apache.flink.ml.param.Param: Decodes the given string into an object of class type T.
jsonEncode(T) - Method in class org.apache.flink.ml.param.Param: Encodes the given object into a json-formatted string.

K

K - Static variable in interface org.apache.flink.ml.classification.knn.KnnModelParams
K - Static variable in interface org.apache.flink.ml.clustering.kmeans.KMeansModelParams
KeyedBroadcastStateTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the KeyedBroadcastStateTransformation.
KeyedBroadcastStateTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.KeyedBroadcastStateTransformationTranslator
KeyedMultipleInputTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the KeyedMultipleInputTransformation.
KeyedMultipleInputTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.KeyedMultipleInputTransformationTranslator
keyedStateBackend() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
KMeans - Class in org.apache.flink.ml.clustering.kmeans: An Estimator which implements the k-means clustering algorithm.
KMeans() - Constructor for class org.apache.flink.ml.clustering.kmeans.KMeans
KMeansModel - Class in org.apache.flink.ml.clustering.kmeans: A Model which clusters data into k clusters using the model data computed by KMeans.
KMeansModel() - Constructor for class org.apache.flink.ml.clustering.kmeans.KMeansModel
KMeansModelData - Class in org.apache.flink.ml.clustering.kmeans: Model data of KMeansModel.
KMeansModelData(DenseVector[]) - Constructor for class org.apache.flink.ml.clustering.kmeans.KMeansModelData
KMeansModelData() - Constructor for class org.apache.flink.ml.clustering.kmeans.KMeansModelData
KMeansModelData.ModelDataDecoder - Class in org.apache.flink.ml.clustering.kmeans: Data decoder for KMeansModelData.
KMeansModelData.ModelDataEncoder - Class in org.apache.flink.ml.clustering.kmeans: Data encoder for KMeansModelData.
KMeansModelParams<T> - Interface in org.apache.flink.ml.clustering.kmeans: Params of KMeansModel.
KMeansParams<T> - Interface in org.apache.flink.ml.clustering.kmeans: Params of KMeans.
Knn - Class in org.apache.flink.ml.classification.knn: An Estimator which implements the KNN algorithm.
Knn() - Constructor for class org.apache.flink.ml.classification.knn.Knn
KnnModel - Class in org.apache.flink.ml.classification.knn: A Model which classifies data using the model data computed by Knn.
KnnModel() - Constructor for class org.apache.flink.ml.classification.knn.KnnModel
KnnModelData - Class in org.apache.flink.ml.classification.knn: Model data of KnnModel.
KnnModelData() - Constructor for class org.apache.flink.ml.classification.knn.KnnModelData
KnnModelData(DenseMatrix, DenseVector, DenseVector) - Constructor for class org.apache.flink.ml.classification.knn.KnnModelData
KnnModelData.ModelDataDecoder - Class in org.apache.flink.ml.classification.knn: Decoder for KnnModelData.
KnnModelData.ModelDataEncoder - Class in org.apache.flink.ml.classification.knn: Encoder for KnnModelData.
KnnModelParams<T> - Interface in org.apache.flink.ml.classification.knn: Params for KnnModel.
KnnParams<T> - Interface in org.apache.flink.ml.classification.knn: Params for Knn.

L

LABEL_COL - Static variable in interface org.apache.flink.ml.common.param.HasLabelCol
LabeledPointWithWeight - Class in org.apache.flink.ml.common.feature: Utility class to represent a data point that contains features, label and weight.
LabeledPointWithWeight(DenseVector, double, double) - Constructor for class org.apache.flink.ml.common.feature.LabeledPointWithWeight
LabeledPointWithWeight() - Constructor for class org.apache.flink.ml.common.feature.LabeledPointWithWeight
labels - Variable in class org.apache.flink.ml.classification.knn.KnnModelData
labels - Variable in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData: Value of labels.
latencyStats - Variable in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
LEARNING_RATE - Static variable in interface org.apache.flink.ml.common.param.HasLearningRate
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.builder.Graph
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.builder.GraphModel
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.builder.Pipeline
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.builder.PipelineModel
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.classification.knn.Knn
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.classification.knn.KnnModel: Loads model data from path.
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.classification.logisticregression.LogisticRegression
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.classification.naivebayes.NaiveBayes
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.clustering.kmeans.KMeans
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.clustering.kmeans.KMeansModel
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoder
load(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
loadGraph(StreamExecutionEnvironment, String, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Loads a Graph or GraphModel from the given path.
loadMetadata(String, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Loads the metadata from the metadata file under the given path.
loadModelData(StreamExecutionEnvironment, String, SimpleStreamFormat<T>) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Loads the model data from the given path using the model decoder.
loadPipeline(StreamExecutionEnvironment, String, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Loads the stages of a Pipeline or PipelineModel from the given path.
loadStage(StreamExecutionEnvironment, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Loads the stage from the given path by invoking the static load() method of the stage.
loadStageParam(String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Loads the stage with the saved parameters from the given path.
LOG - Static variable in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
LogisticGradient - Class in org.apache.flink.ml.classification.logisticregression: Utility class to compute gradient and loss for logistic loss function.
LogisticGradient(double) - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticGradient
LogisticRegression - Class in org.apache.flink.ml.classification.logisticregression: An Estimator which implements the logistic regression algorithm.
LogisticRegression() - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticRegression
LogisticRegressionModel - Class in org.apache.flink.ml.classification.logisticregression: A Model which classifies data using the model data computed by LogisticRegression.
LogisticRegressionModel() - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
LogisticRegressionModelData - Class in org.apache.flink.ml.classification.logisticregression: Model data of LogisticRegressionModel.
LogisticRegressionModelData(DenseVector) - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData
LogisticRegressionModelData() - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData
LogisticRegressionModelData.ModelDataDecoder - Class in org.apache.flink.ml.classification.logisticregression: Data decoder for LogisticRegressionModel.
LogisticRegressionModelData.ModelDataEncoder - Class in org.apache.flink.ml.classification.logisticregression: Data encoder for LogisticRegressionModel.
LogisticRegressionModelParams<T> - Interface in org.apache.flink.ml.classification.logisticregression: Params for LogisticRegressionModel.
LogisticRegressionParams<T> - Interface in org.apache.flink.ml.classification.logisticregression: Params for LogisticRegression.
LongArrayParam - Class in org.apache.flink.ml.param: Class for the long array parameter.
LongArrayParam(String, String, Long[], ParamValidator<Long[]>) - Constructor for class org.apache.flink.ml.param.LongArrayParam
LongArrayParam(String, String, Long[]) - Constructor for class org.apache.flink.ml.param.LongArrayParam
LongParam - Class in org.apache.flink.ml.param: Class for the long parameter.
LongParam(String, String, Long, ParamValidator<Long>) - Constructor for class org.apache.flink.ml.param.LongParam
LongParam(String, String, Long) - Constructor for class org.apache.flink.ml.param.LongParam
lt(double) - Static method in class org.apache.flink.ml.param.ParamValidators
ltEq(double) - Static method in class org.apache.flink.ml.param.ParamValidators

M

mailboxExecutor - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
mapPartition(DataStream<IN>, MapPartitionFunction<IN, OUT>) - Static method in class org.apache.flink.ml.common.datastream.DataStreamUtils: Applies a MapPartitionFunction on a bounded data stream.
Matrix - Interface in org.apache.flink.ml.linalg: A matrix of double values.
MAX_ITER - Static variable in interface org.apache.flink.ml.common.param.HasMaxIter
metrics - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator: Metric group for the operator.
metrics - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
Model<T extends Model<T>> - Interface in org.apache.flink.ml.api: A Model is typically generated by invoking Estimator.fit(Table...).
MODEL_TYPE - Static variable in interface org.apache.flink.ml.classification.naivebayes.NaiveBayesModelParams
ModelDataDecoder() - Constructor for class org.apache.flink.ml.classification.knn.KnnModelData.ModelDataDecoder
ModelDataDecoder() - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData.ModelDataDecoder
ModelDataDecoder() - Constructor for class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData.ModelDataDecoder
ModelDataDecoder() - Constructor for class org.apache.flink.ml.clustering.kmeans.KMeansModelData.ModelDataDecoder
ModelDataEncoder() - Constructor for class org.apache.flink.ml.classification.knn.KnnModelData.ModelDataEncoder
ModelDataEncoder() - Constructor for class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModelData.ModelDataEncoder
ModelDataEncoder() - Constructor for class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData.ModelDataEncoder
ModelDataEncoder() - Constructor for class org.apache.flink.ml.clustering.kmeans.KMeansModelData.ModelDataEncoder
ModelDataEncoder() - Constructor for class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData.ModelDataEncoder
ModelDataStreamFormat() - Constructor for class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData.ModelDataStreamFormat
modelInputIds - Variable in class org.apache.flink.ml.builder.GraphData
MULTI_CLASS - Static variable in interface org.apache.flink.ml.common.param.HasMultiClass
MultipleInputAllRoundWrapperOperator<OUT> - Class in org.apache.flink.iteration.operator.allround: All-round wrapper for the multiple-inputs operator.
MultipleInputAllRoundWrapperOperator(StreamOperatorParameters<IterationRecord<OUT>>, StreamOperatorFactory<OUT>) - Constructor for class org.apache.flink.iteration.operator.allround.MultipleInputAllRoundWrapperOperator
MultipleInputPerRoundWrapperOperator<OUT> - Class in org.apache.flink.iteration.operator.perround: Per-round wrapper for the multiple-inputs operator.
MultipleInputPerRoundWrapperOperator(StreamOperatorParameters<IterationRecord<OUT>>, StreamOperatorFactory<OUT>) - Constructor for class org.apache.flink.iteration.operator.perround.MultipleInputPerRoundWrapperOperator
MultipleInputTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the MultipleInputTransformation.
MultipleInputTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.MultipleInputTransformationTranslator

N

n - Variable in class org.apache.flink.ml.linalg.SparseVector
NaiveBayes - Class in org.apache.flink.ml.classification.naivebayes: An Estimator which implements the naive bayes classification algorithm.
NaiveBayes() - Constructor for class org.apache.flink.ml.classification.naivebayes.NaiveBayes
NaiveBayesModel - Class in org.apache.flink.ml.classification.naivebayes: A Model which classifies data using the model data computed by NaiveBayes.
NaiveBayesModel() - Constructor for class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
NaiveBayesModelData - Class in org.apache.flink.ml.classification.naivebayes: Model data of NaiveBayesModel.
NaiveBayesModelData(Map<Double, Double>[][], DenseVector, DenseVector) - Constructor for class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData
NaiveBayesModelData() - Constructor for class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData
NaiveBayesModelData.ModelDataDecoder - Class in org.apache.flink.ml.classification.naivebayes: Data decoder for the NaiveBayesModelData.
NaiveBayesModelData.ModelDataEncoder - Class in org.apache.flink.ml.classification.naivebayes: Data encoder for the NaiveBayesModelData.
NaiveBayesModelParams<T> - Interface in org.apache.flink.ml.classification.naivebayes: Params of NaiveBayesModel.
NaiveBayesParams<T> - Interface in org.apache.flink.ml.classification.naivebayes: Params of NaiveBayes.
NAME - Static variable in class org.apache.flink.ml.common.distance.EuclideanDistanceMeasure
name - Variable in class org.apache.flink.ml.param.Param
newBarrier(long) - Static method in class org.apache.flink.iteration.IterationRecord
newBuilder() - Static method in class org.apache.flink.iteration.IterationConfig
newEpochWatermark(int, String) - Static method in class org.apache.flink.iteration.IterationRecord
newRecord(T, int) - Static method in class org.apache.flink.iteration.IterationRecord
newRecord(T) - Static method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
newWatermark(long) - Static method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
next() - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheReader
nodeId - Variable in class org.apache.flink.ml.builder.GraphNode
nodes - Variable in class org.apache.flink.ml.builder.GraphData
nonEmptyArray() - Static method in class org.apache.flink.ml.param.ParamValidators
NonReplayedDataStreamList(List<DataStream<?>>) - Constructor for class org.apache.flink.iteration.ReplayableDataStreamList.NonReplayedDataStreamList
norm2(DenseVector) - Static method in class org.apache.flink.ml.linalg.BLAS: \sqrt(\sum_i x_i * x_i) .
notifyCacheFinished(String) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastContext
notifyCheckpointAborted(long) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
notifyCheckpointAborted(long) - Method in class org.apache.flink.iteration.operator.HeadOperator
notifyCheckpointAborted(long) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
notifyCheckpointAborted(long) - Method in class org.apache.flink.iteration.operator.TailOperator
notifyCheckpointAborted(long) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
notifyCheckpointComplete(long) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
notifyCheckpointComplete(long) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
notifyCheckpointComplete(long) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
notifyCheckpointComplete(long) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
notifyEpochWatermarkIncrement(IterationListener<?>, int) - Method in class org.apache.flink.iteration.operator.AbstractWrapperOperator
notifyGloballyTerminating() - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
notifyTerminatingOnInitialize() - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
notNull() - Static method in class org.apache.flink.ml.param.ParamValidators
notReplay(DataStream<?>...) - Static method in class org.apache.flink.iteration.ReplayableDataStreamList
numCols() - Method in class org.apache.flink.ml.linalg.DenseMatrix
numCols() - Method in interface org.apache.flink.ml.linalg.Matrix: Gets number of columns.
numInputs - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: number of the inputs of this operator.
numRows() - Method in class org.apache.flink.ml.linalg.DenseMatrix
numRows() - Method in interface org.apache.flink.ml.linalg.Matrix: Gets number of rows.

O

OBJECT_MAPPER - Static variable in class org.apache.flink.ml.util.ReadWriteUtils
of(DataStream<?>...) - Static method in class org.apache.flink.iteration.DataStreamList
onAligned(GloballyAlignedEvent) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
onAligned(GloballyAlignedEvent) - Method in interface org.apache.flink.iteration.operator.coordinator.SharedProgressAlignerListener
onCheckpointAligned(CoordinatorCheckpointEvent) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
onCheckpointAligned(CoordinatorCheckpointEvent) - Method in interface org.apache.flink.iteration.operator.coordinator.SharedProgressAlignerListener
OneHotEncoder - Class in org.apache.flink.ml.feature.onehotencoder: An Estimator which implements the one-hot encoding algorithm.
OneHotEncoder() - Constructor for class org.apache.flink.ml.feature.onehotencoder.OneHotEncoder
OneHotEncoderModel - Class in org.apache.flink.ml.feature.onehotencoder: A Model which encodes data into one-hot format using the model data computed by OneHotEncoder.
OneHotEncoderModel() - Constructor for class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
OneHotEncoderModelData - Class in org.apache.flink.ml.feature.onehotencoder: Model data of OneHotEncoderModel.
OneHotEncoderModelData() - Constructor for class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModelData
OneHotEncoderModelData.ModelDataEncoder - Class in org.apache.flink.ml.feature.onehotencoder: Data encoder for the OneHotEncoder model data.
OneHotEncoderModelData.ModelDataStreamFormat - Class in org.apache.flink.ml.feature.onehotencoder: Data decoder for the OneHotEncoder model data.
OneHotEncoderParams<T> - Interface in org.apache.flink.ml.feature.onehotencoder: Params of OneHotEncoderModel.
OneInputAllRoundWrapperOperator<IN,OUT> - Class in org.apache.flink.iteration.operator.allround: All-round wrapper for the one-input operator.
OneInputAllRoundWrapperOperator(StreamOperatorParameters<IterationRecord<OUT>>, StreamOperatorFactory<OUT>) - Constructor for class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
OneInputBroadcastWrapperOperator<IN,OUT> - Class in org.apache.flink.ml.common.broadcast.operator: Wrapper for OneInputStreamOperator.
OneInputPerRoundWrapperOperator<IN,OUT> - Class in org.apache.flink.iteration.operator.perround: Per-round wrapper operator for the one-input operator.
OneInputPerRoundWrapperOperator(StreamOperatorParameters<IterationRecord<OUT>>, StreamOperatorFactory<OUT>) - Constructor for class org.apache.flink.iteration.operator.perround.OneInputPerRoundWrapperOperator
OneInputTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the OneInputTransformation.
OneInputTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.OneInputTransformationTranslator
onEpochWatermark(int, String, int) - Method in class org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTracker
onEpochWatermarkEvent(int, IterationRecord<?>) - Method in class org.apache.flink.iteration.operator.AbstractWrapperOperator
onEpochWatermarkIncrement(int) - Method in class org.apache.flink.iteration.operator.AbstractWrapperOperator
onEpochWatermarkIncrement(int) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
onEpochWatermarkIncrement(int) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
onEpochWatermarkIncrement(int) - Method in class org.apache.flink.iteration.operator.ReplayOperator
onEpochWatermarkIncrement(int) - Method in interface org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTrackerListener: Notifies a new round is aligned to a new epoch watermark.
onEpochWatermarkIncremented(int, IterationListener.Context, Collector<T>) - Method in interface org.apache.flink.iteration.IterationListener: This callback is invoked every time the epoch watermark of this operator increments.
onEpochWatermarkIncremented(int, IterationListener.Context, Collector<T>) - Method in class org.apache.flink.ml.common.iteration.ForwardInputsOfLastRound
onEpochWatermarkIncremented(int, IterationListener.Context, Collector<Integer>) - Method in class org.apache.flink.ml.common.iteration.TerminateOnMaxIter
onEpochWatermarkIncremented(int, IterationListener.Context, Collector<Integer>) - Method in class org.apache.flink.ml.common.iteration.TerminateOnMaxIterOrTol
onGloballyAligned(GloballyAlignedEvent) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor
onGloballyAligned(GloballyAlignedEvent) - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
onGloballyAligned(GloballyAlignedEvent) - Method in class org.apache.flink.iteration.operator.headprocessor.TerminatingHeadOperatorRecordProcessor
onIterationTerminated(IterationListener.Context, Collector<T>) - Method in interface org.apache.flink.iteration.IterationListener: This callback is invoked after the execution of the iteration body has terminated.
onIterationTerminated(IterationListener.Context, Collector<T>) - Method in class org.apache.flink.ml.common.iteration.ForwardInputsOfLastRound
onIterationTerminated(IterationListener.Context, Collector<Integer>) - Method in class org.apache.flink.ml.common.iteration.TerminateOnMaxIter
onIterationTerminated(IterationListener.Context, Collector<Integer>) - Method in class org.apache.flink.ml.common.iteration.TerminateOnMaxIterOrTol
open() - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
open() - Method in class org.apache.flink.iteration.operator.InputOperator
open() - Method in class org.apache.flink.iteration.operator.OutputOperator
open() - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
open() - Method in class org.apache.flink.iteration.operator.TailOperator
open() - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
OperatorEpochWatermarkTracker - Class in org.apache.flink.iteration.progresstrack: Tracks the epoch watermark from each input.
OperatorEpochWatermarkTrackerFactory - Class in org.apache.flink.iteration.progresstrack: The factory of OperatorEpochWatermarkTracker.
OperatorEpochWatermarkTrackerFactory() - Constructor for class org.apache.flink.iteration.progresstrack.OperatorEpochWatermarkTrackerFactory
OperatorEpochWatermarkTrackerListener - Interface in org.apache.flink.iteration.progresstrack: The listener of alignment.
operatorFactory - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
operatorFactory - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
operatorStateBackend() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
OperatorStateUtils - Class in org.apache.flink.iteration.operator: Utility to deal with the states inside the operator.
OperatorStateUtils() - Constructor for class org.apache.flink.iteration.operator.OperatorStateUtils
OperatorUtils - Class in org.apache.flink.iteration.operator: Utility class for operators.
OperatorUtils() - Constructor for class org.apache.flink.iteration.operator.OperatorUtils
OperatorWrapper<T,R> - Interface in org.apache.flink.iteration.operator: Wrappers for the given operator factory.
org.apache.flink.iteration - package org.apache.flink.iteration
org.apache.flink.iteration.broadcast - package org.apache.flink.iteration.broadcast
org.apache.flink.iteration.checkpoint - package org.apache.flink.iteration.checkpoint
org.apache.flink.iteration.compile - package org.apache.flink.iteration.compile
org.apache.flink.iteration.compile.translator - package org.apache.flink.iteration.compile.translator
org.apache.flink.iteration.config - package org.apache.flink.iteration.config
org.apache.flink.iteration.datacache.nonkeyed - package org.apache.flink.iteration.datacache.nonkeyed
org.apache.flink.iteration.functions - package org.apache.flink.iteration.functions
org.apache.flink.iteration.operator - package org.apache.flink.iteration.operator
org.apache.flink.iteration.operator.allround - package org.apache.flink.iteration.operator.allround
org.apache.flink.iteration.operator.coordinator - package org.apache.flink.iteration.operator.coordinator
org.apache.flink.iteration.operator.event - package org.apache.flink.iteration.operator.event
org.apache.flink.iteration.operator.headprocessor - package org.apache.flink.iteration.operator.headprocessor
org.apache.flink.iteration.operator.perround - package org.apache.flink.iteration.operator.perround
org.apache.flink.iteration.progresstrack - package org.apache.flink.iteration.progresstrack
org.apache.flink.iteration.proxy - package org.apache.flink.iteration.proxy
org.apache.flink.iteration.proxy.state - package org.apache.flink.iteration.proxy.state
org.apache.flink.iteration.typeinfo - package org.apache.flink.iteration.typeinfo
org.apache.flink.iteration.utils - package org.apache.flink.iteration.utils
org.apache.flink.ml.api - package org.apache.flink.ml.api
org.apache.flink.ml.builder - package org.apache.flink.ml.builder
org.apache.flink.ml.classification.knn - package org.apache.flink.ml.classification.knn
org.apache.flink.ml.classification.logisticregression - package org.apache.flink.ml.classification.logisticregression
org.apache.flink.ml.classification.naivebayes - package org.apache.flink.ml.classification.naivebayes
org.apache.flink.ml.clustering.kmeans - package org.apache.flink.ml.clustering.kmeans
org.apache.flink.ml.common.broadcast - package org.apache.flink.ml.common.broadcast
org.apache.flink.ml.common.broadcast.operator - package org.apache.flink.ml.common.broadcast.operator
org.apache.flink.ml.common.broadcast.typeinfo - package org.apache.flink.ml.common.broadcast.typeinfo
org.apache.flink.ml.common.datastream - package org.apache.flink.ml.common.datastream
org.apache.flink.ml.common.distance - package org.apache.flink.ml.common.distance
org.apache.flink.ml.common.feature - package org.apache.flink.ml.common.feature
org.apache.flink.ml.common.iteration - package org.apache.flink.ml.common.iteration
org.apache.flink.ml.common.param - package org.apache.flink.ml.common.param
org.apache.flink.ml.feature.onehotencoder - package org.apache.flink.ml.feature.onehotencoder
org.apache.flink.ml.linalg - package org.apache.flink.ml.linalg
org.apache.flink.ml.linalg.typeinfo - package org.apache.flink.ml.linalg.typeinfo
org.apache.flink.ml.param - package org.apache.flink.ml.param
org.apache.flink.ml.util - package org.apache.flink.ml.util
output(OutputTag<X>, X) - Method in interface org.apache.flink.iteration.IterationListener.Context: Emits a record to the side output identified by the OutputTag.
output - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
output(StreamRecord<IterationRecord<?>>) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
output(OutputTag<IterationRecord<?>>, StreamRecord<IterationRecord<?>>) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
output - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
OUTPUT_COLS - Static variable in interface org.apache.flink.ml.common.param.HasOutputCols
outputIds - Variable in class org.apache.flink.ml.builder.GraphData
outputIds - Variable in class org.apache.flink.ml.builder.GraphNode
outputModelDataIds - Variable in class org.apache.flink.ml.builder.GraphData
outputModelDataIds - Variable in class org.apache.flink.ml.builder.GraphNode
OutputOperator<T> - Class in org.apache.flink.iteration.operator: Output operator that unwraps IterationRecord into user record, and desert all the event records.
OutputOperator() - Constructor for class org.apache.flink.iteration.operator.OutputOperator
OutputReflectionContext - Class in org.apache.flink.iteration.broadcast: The reflection utilities to parse the output and create the broadcast output.
OutputReflectionContext() - Constructor for class org.apache.flink.iteration.broadcast.OutputReflectionContext

P

packedFeatures - Variable in class org.apache.flink.ml.classification.knn.KnnModelData
Param<T> - Class in org.apache.flink.ml.param: Definition of a parameter, including name, class, description, default value and the validator.
Param(String, Class<T>, String, T, ParamValidator<T>) - Constructor for class org.apache.flink.ml.param.Param
parameters - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
parameters - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
ParamUtils - Class in org.apache.flink.ml.util: Utility methods for reading and writing stages.
ParamUtils() - Constructor for class org.apache.flink.ml.util.ParamUtils
ParamValidator<T> - Interface in org.apache.flink.ml.param: An interface to validate that a parameter value is valid.
ParamValidators - Class in org.apache.flink.ml.param: Factory methods for common validation functions on numerical values.
ParamValidators() - Constructor for class org.apache.flink.ml.param.ParamValidators
PartitionTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the PartitionTransformation.
PartitionTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.PartitionTransformationTranslator
PerRoundOperatorWrapper<T> - Class in org.apache.flink.iteration.operator.perround: The operator wrapper implementation for per-round wrappers.
PerRoundOperatorWrapper() - Constructor for class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
piArray - Variable in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData: Log of class priors, whose dimension is C (number of classes).
Pipeline - Class in org.apache.flink.ml.builder: A Pipeline acts as an Estimator.
Pipeline(List<Stage<?>>) - Constructor for class org.apache.flink.ml.builder.Pipeline
PipelineModel - Class in org.apache.flink.ml.builder: A PipelineModel acts as a Model.
PipelineModel(List<Stage<?>>) - Constructor for class org.apache.flink.ml.builder.PipelineModel
PREDICTION_COL - Static variable in interface org.apache.flink.ml.common.param.HasPredictionCol
prefix(String) - Method in class org.apache.flink.iteration.proxy.state.StateNamePrefix
prepareSnapshotPreBarrier(long) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
prepareSnapshotPreBarrier(long) - Method in class org.apache.flink.iteration.operator.HeadOperator
prepareSnapshotPreBarrier(long) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
prepareSnapshotPreBarrier(long) - Method in class org.apache.flink.iteration.operator.TailOperator
prepareSnapshotPreBarrier(long) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
process(DataStreamList) - Method in interface org.apache.flink.iteration.IterationBody.PerRoundSubBody
process(DataStreamList, DataStreamList) - Method in interface org.apache.flink.iteration.IterationBody: This method creates the graph for the iteration body.
processElement(I, ProcessFunction<I, O>.Context, Collector<O>) - Method in class org.apache.flink.iteration.functions.EpochAwareAllRoundProcessFunction
processElement(I, int, ProcessFunction<I, O>.Context, Collector<O>) - Method in class org.apache.flink.iteration.functions.EpochAwareAllRoundProcessFunction
processElement(StreamRecord<IterationRecord<IN>>) - Method in class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
processElement(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.HeadOperator
processElement(StreamRecord<IterationRecord<?>>) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor
processElement(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
processElement(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.headprocessor.TerminatingHeadOperatorRecordProcessor
processElement(StreamRecord<T>) - Method in class org.apache.flink.iteration.operator.InputOperator
processElement(StreamRecord<IterationRecord<T>>) - Method in class org.apache.flink.iteration.operator.OutputOperator
processElement(StreamRecord<IterationRecord<IN>>) - Method in class org.apache.flink.iteration.operator.perround.OneInputPerRoundWrapperOperator
processElement(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.TailOperator
processElement(StreamRecord<IN>) - Method in class org.apache.flink.ml.common.broadcast.operator.OneInputBroadcastWrapperOperator
processElement1(I1, CoProcessFunction<I1, I2, O>.Context, Collector<O>) - Method in class org.apache.flink.iteration.functions.EpochAwareCoProcessFunction
processElement1(I1, int, CoProcessFunction<I1, I2, O>.Context, Collector<O>) - Method in class org.apache.flink.iteration.functions.EpochAwareCoProcessFunction
processElement1(StreamRecord<IterationRecord<IN1>>) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processElement1(StreamRecord<IterationRecord<IN1>>) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processElement1(StreamRecord<IterationRecord<T>>) - Method in class org.apache.flink.iteration.operator.ReplayOperator
processElement1(StreamRecord<IN1>) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processElement2(I2, CoProcessFunction<I1, I2, O>.Context, Collector<O>) - Method in class org.apache.flink.iteration.functions.EpochAwareCoProcessFunction
processElement2(I2, int, CoProcessFunction<I1, I2, O>.Context, Collector<O>) - Method in class org.apache.flink.iteration.functions.EpochAwareCoProcessFunction
processElement2(StreamRecord<IterationRecord<IN2>>) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processElement2(StreamRecord<IterationRecord<IN2>>) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processElement2(StreamRecord<IterationRecord<Void>>) - Method in class org.apache.flink.iteration.operator.ReplayOperator
processElement2(StreamRecord<IN2>) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processElementX(StreamRecord, int, ThrowingConsumer<StreamRecord, Exception>, ThrowingConsumer<Watermark, Exception>) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: extracts common processing logic in subclasses' processing elements.
processFeedback(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.HeadOperator
processFeedbackElement(StreamRecord<IterationRecord<?>>) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor
processFeedbackElement(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
processFeedbackElement(StreamRecord<IterationRecord<?>>) - Method in class org.apache.flink.iteration.operator.headprocessor.TerminatingHeadOperatorRecordProcessor
processForEachWrappedOperator(BiConsumerWithException<Integer, S, Exception>) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
processLatencyMarker(LatencyMarker) - Method in class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
processLatencyMarker(LatencyMarker) - Method in class org.apache.flink.iteration.operator.perround.OneInputPerRoundWrapperOperator
processLatencyMarker(LatencyMarker) - Method in class org.apache.flink.ml.common.broadcast.operator.OneInputBroadcastWrapperOperator
processLatencyMarker1(LatencyMarker) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processLatencyMarker1(LatencyMarker) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processLatencyMarker1(LatencyMarker) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processLatencyMarker2(LatencyMarker) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processLatencyMarker2(LatencyMarker) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processLatencyMarker2(LatencyMarker) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processOperatorOrUdfIfSatisfy(StreamOperator<?>, Class<T>, ThrowingConsumer<T, Exception>) - Static method in class org.apache.flink.iteration.operator.OperatorUtils
processWatermark(Watermark) - Method in class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
processWatermark(Watermark) - Method in class org.apache.flink.iteration.operator.perround.OneInputPerRoundWrapperOperator
processWatermark(Watermark) - Method in class org.apache.flink.ml.common.broadcast.operator.OneInputBroadcastWrapperOperator
processWatermark1(Watermark) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processWatermark1(Watermark) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processWatermark1(Watermark) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processWatermark2(Watermark) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processWatermark2(Watermark) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processWatermark2(Watermark) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processWatermarkStatus(WatermarkStatus) - Method in class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
processWatermarkStatus(WatermarkStatus) - Method in class org.apache.flink.iteration.operator.perround.OneInputPerRoundWrapperOperator
processWatermarkStatus(WatermarkStatus) - Method in class org.apache.flink.ml.common.broadcast.operator.OneInputBroadcastWrapperOperator
processWatermarkStatus1(WatermarkStatus) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processWatermarkStatus1(WatermarkStatus) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processWatermarkStatus1(WatermarkStatus) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processWatermarkStatus2(WatermarkStatus) - Method in class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
processWatermarkStatus2(WatermarkStatus) - Method in class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
processWatermarkStatus2(WatermarkStatus) - Method in class org.apache.flink.ml.common.broadcast.operator.TwoInputBroadcastWrapperOperator
processWatermarkX(Watermark, int, ThrowingConsumer<StreamRecord, Exception>, ThrowingConsumer<Watermark, Exception>) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator: extracts common processing logic in subclasses' processing watermarks.
ProxyInternalTimeServiceManager<K> - Class in org.apache.flink.iteration.proxy.state: Proxy InternalTimeServiceManager for the wrapped operators.
ProxyInternalTimeServiceManager(InternalTimeServiceManager<K>, StateNamePrefix) - Constructor for class org.apache.flink.iteration.proxy.state.ProxyInternalTimeServiceManager
ProxyKeyedStateBackend<K> - Class in org.apache.flink.iteration.proxy.state: Proxy KeyedStateBackend for the wrapped operators.
ProxyKeyedStateBackend(CheckpointableKeyedStateBackend<K>, StateNamePrefix) - Constructor for class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
ProxyKeySelector<T,KEY> - Class in org.apache.flink.iteration.proxy: Proxy key selector for the wrapped one.
ProxyKeySelector(KeySelector<T, KEY>) - Constructor for class org.apache.flink.iteration.proxy.ProxyKeySelector
ProxyOperatorStateBackend - Class in org.apache.flink.iteration.proxy.state: Proxy OperatorStateBackend for the wrapped Operator.
ProxyOperatorStateBackend(OperatorStateBackend, StateNamePrefix) - Constructor for class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
proxyOutput - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
ProxyOutput<T> - Class in org.apache.flink.iteration.proxy: Proxy output to provide to the wrapped operator.
ProxyOutput(Output<StreamRecord<IterationRecord<T>>>) - Constructor for class org.apache.flink.iteration.proxy.ProxyOutput
ProxyStateSnapshotContext - Class in org.apache.flink.iteration.proxy.state: Proxy StateSnapshotContext for the wrapped operators.
ProxyStateSnapshotContext(StateSnapshotContext) - Constructor for class org.apache.flink.iteration.proxy.state.ProxyStateSnapshotContext
ProxyStreamOperatorStateContext - Class in org.apache.flink.iteration.proxy.state: Proxy StreamOperatorStateContext for the wrapped operator.
ProxyStreamOperatorStateContext(StreamOperatorStateContext, String, Iterator<StatePartitionStreamProvider>, int) - Constructor for class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
ProxyStreamPartitioner<T> - Class in org.apache.flink.iteration.proxy: Proxy stream partitioner for the wrapped one.
ProxyStreamPartitioner(StreamPartitioner<T>) - Constructor for class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
putBroadcastVariable(String, Tuple2<Boolean, List<?>>) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastContext
putMailBoxExecutor(String, MailboxExecutor) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastContext

R

RAW_PREDICTION_COL - Static variable in interface org.apache.flink.ml.common.param.HasRawPredictionCol
rawKeyedStateInputs() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
rawOperatorStateInputs() - Method in class org.apache.flink.iteration.proxy.state.ProxyStreamOperatorStateContext
ReadWriteUtils - Class in org.apache.flink.ml.util: Utility methods for reading and writing stages.
ReadWriteUtils() - Constructor for class org.apache.flink.ml.util.ReadWriteUtils
RecordWriterBroadcastOutput<OUT> - Class in org.apache.flink.iteration.broadcast: The broadcast output corresponding to a record writer output.
RecordWriterBroadcastOutput(RecordWriter<SerializationDelegate<StreamElement>>, TypeSerializer<StreamElement>) - Constructor for class org.apache.flink.iteration.broadcast.RecordWriterBroadcastOutput
recover(InputStream, FileSystem, SupplierWithException<Path, IOException>) - Static method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot
ReduceTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the ReduceTransformation.
ReduceTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.ReduceTransformationTranslator
ReflectionUtils - Class in org.apache.flink.iteration.utils: Utility class to provide some reflection tools.
ReflectionUtils() - Constructor for class org.apache.flink.iteration.utils.ReflectionUtils
REG - Static variable in interface org.apache.flink.ml.common.param.HasReg
registerAlignedListener(OperatorID, SharedProgressAlignerListener) - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
registerFeedbackConsumer(FeedbackChannel<V>, FeedbackConsumer<V>, Executor) - Static method in class org.apache.flink.iteration.operator.OperatorUtils: Registers the specified feedbackConsumer to the feedbackChannel.
registerKeySelectionListener(KeyedStateBackend.KeySelectionListener<K>) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
RegularHeadOperatorRecordProcessor - Class in org.apache.flink.iteration.operator.headprocessor: Processes the event before we received the terminated global aligned event from the coordinator.
RegularHeadOperatorRecordProcessor(HeadOperatorRecordProcessor.Context) - Constructor for class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
remove(String) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastContext
removeProgressInfo(OperatorID) - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
removeProgressInfo(OperatorID, int) - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
replay(InputStream, TypeSerializer<T>, FileSystem, FeedbackConsumer<T>) - Static method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot
replay(DataStream<?>...) - Static method in class org.apache.flink.iteration.ReplayableDataStreamList
ReplayableDataStreamList - Class in org.apache.flink.iteration: A list of data streams and whether they need replayed.
ReplayableDataStreamList.NonReplayedDataStreamList - Class in org.apache.flink.iteration: A special ReplayableDataStreamList that all streams should be not replayed.
ReplayableDataStreamList.ReplayedDataStreamList - Class in org.apache.flink.iteration: A special ReplayableDataStreamList that all streams should be replayed.
ReplayedDataStreamList(List<DataStream<?>>) - Constructor for class org.apache.flink.iteration.ReplayableDataStreamList.ReplayedDataStreamList
ReplayOperator<T> - Class in org.apache.flink.iteration.operator: Replays the data received in the round 0 in the following round.
ReplayOperator() - Constructor for class org.apache.flink.iteration.operator.ReplayOperator
reportOrForwardLatencyMarker(LatencyMarker) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
reportSubtaskProgress(OperatorID, int, SubtaskAlignedEvent) - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
requestCheckpoint(long, int, CompletableFuture<byte[]>) - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
resetToCheckpoint(long, byte[]) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
run(SourceFunction.SourceContext<T>) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment.EmptySource

S

save(String) - Method in interface org.apache.flink.ml.api.Stage: Saves this stage to the given path.
save(String) - Method in class org.apache.flink.ml.builder.Graph
save(String) - Method in class org.apache.flink.ml.builder.GraphModel
save(String) - Method in class org.apache.flink.ml.builder.Pipeline
save(String) - Method in class org.apache.flink.ml.builder.PipelineModel
save(String) - Method in class org.apache.flink.ml.classification.knn.Knn
save(String) - Method in class org.apache.flink.ml.classification.knn.KnnModel
save(String) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegression
save(String) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
save(String) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayes
save(String) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
save(String) - Method in class org.apache.flink.ml.clustering.kmeans.KMeans
save(String) - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModel
save(String) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoder
save(String) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
saveGraph(Stage<?>, GraphData, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Saves a Graph or GraphModel with the given GraphData to the given path.
saveMetadata(Stage<?>, String, Map<String, ?>) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Saves the metadata of the given stage and the extra metadata to a file named `metadata` under the given path.
saveMetadata(Stage<?>, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Saves the metadata of the given stage to a file named `metadata` under the given path.
saveModelData(DataStream<T>, String, Encoder<T>) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Saves the model data stream to the given path using the model encoder.
savePipeline(Stage<?>, List<Stage<?>>, String) - Static method in class org.apache.flink.ml.util.ReadWriteUtils: Saves a Pipeline or PipelineModel with the given list of stages to the given path.
savepoint() - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
scal(double, DenseVector) - Static method in class org.apache.flink.ml.linalg.BLAS: x = x * a .
SEED - Static variable in interface org.apache.flink.ml.common.param.HasSeed
Segment - Class in org.apache.flink.iteration.datacache.nonkeyed: A segment represents a single file for the cache.
Segment(Path, int, long) - Constructor for class org.apache.flink.iteration.datacache.nonkeyed.Segment
selectChannel(SerializationDelegate<StreamRecord<IterationRecord<T>>>) - Method in class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
selectRandomCentroids(DataStream<DenseVector>, int, long) - Static method in class org.apache.flink.ml.clustering.kmeans.KMeans
serialize(IterationRecord<T>, DataOutputView) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
serialize(CacheElement<T>, DataOutputView) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
serialize(DenseMatrix, DataOutputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
serialize(DenseVector, DataOutputView) - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
serialize(SparseVector, DataOutputView) - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
serializerNumber(int, DataOutputView) - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer: Variant encoding for the epoch.
set(Param<V>, V) - Method in interface org.apache.flink.ml.param.WithParams: Sets the value of the parameter.
setBroadcastVariable(String, List<?>) - Method in class org.apache.flink.ml.common.broadcast.BroadcastStreamingRuntimeContext
setCheckpointId(long) - Method in class org.apache.flink.iteration.IterationRecord
setCheckpoints(SubtaskFeedbackKey<V>, Checkpoints<V>) - Method in class org.apache.flink.iteration.checkpoint.CheckpointsBroker
setContextRound(Integer) - Method in class org.apache.flink.iteration.proxy.ProxyOutput
setCriteriaStreamParallelism(int) - Method in class org.apache.flink.iteration.operator.HeadOperatorFactory
setCurrentKey(Object) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
setCurrentKey(Object) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
setCurrentKey(K) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
setCurrentKey(Object) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
setCurrentWrapper(OperatorWrapper<?, ?>) - Method in class org.apache.flink.iteration.compile.DraftExecutionEnvironment
setDistanceMeasure(String) - Method in interface org.apache.flink.ml.common.param.HasDistanceMeasure
setDropLast(boolean) - Method in interface org.apache.flink.ml.feature.onehotencoder.OneHotEncoderParams
setEpoch(int) - Method in class org.apache.flink.iteration.IterationRecord
setEpochSupplier(Supplier<Integer>) - Method in class org.apache.flink.iteration.functions.EpochAwareAllRoundProcessFunction
setEpochSupplier(Supplier<Integer>) - Method in class org.apache.flink.iteration.functions.EpochAwareCoProcessFunction
setEpochSupplier(Supplier<Integer>) - Method in interface org.apache.flink.iteration.operator.allround.EpochAware
setFeatures(DenseVector) - Method in class org.apache.flink.ml.common.feature.LabeledPointWithWeight
setFeaturesCol(String) - Method in interface org.apache.flink.ml.common.param.HasFeaturesCol
setGlobalBatchSize(Integer) - Method in interface org.apache.flink.ml.common.param.HasGlobalBatchSize
setHandleInvalid(String) - Method in interface org.apache.flink.ml.common.param.HasHandleInvalid
setInitMode(String) - Method in interface org.apache.flink.ml.clustering.kmeans.KMeansParams
setInputCols(String...) - Method in interface org.apache.flink.ml.common.param.HasInputCols
setIterationContextRound(Integer) - Method in class org.apache.flink.iteration.operator.AbstractWrapperOperator
setK(Integer) - Method in interface org.apache.flink.ml.classification.knn.KnnModelParams
setK(int) - Method in interface org.apache.flink.ml.clustering.kmeans.KMeansModelParams
setKeyContextElement(StreamRecord<IterationRecord<IN>>) - Method in class org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator
setKeyContextElement(StreamRecord<IN>) - Method in class org.apache.flink.ml.common.broadcast.operator.OneInputBroadcastWrapperOperator
setKeyContextElement1(StreamRecord<?>) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
setKeyContextElement1(StreamRecord) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
setKeyContextElement1(StreamRecord<?>) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
setKeyContextElement2(StreamRecord<?>) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
setKeyContextElement2(StreamRecord) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
setKeyContextElement2(StreamRecord<?>) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
setLabel(double) - Method in class org.apache.flink.ml.common.feature.LabeledPointWithWeight
setLabelCol(String) - Method in interface org.apache.flink.ml.common.param.HasLabelCol
setLearningRate(Double) - Method in interface org.apache.flink.ml.common.param.HasLearningRate
setMailboxExecutor(MailboxExecutor) - Method in class org.apache.flink.iteration.operator.HeadOperatorFactory
setMaxIter(int) - Method in interface org.apache.flink.ml.common.param.HasMaxIter
setMaxOutputTableNum(int) - Method in class org.apache.flink.ml.builder.GraphBuilder: Specifies the loose upper bound of the number of output tables that can be returned by the Model::getModelData() and AlgoOperator::transform() methods, for any stage involved in this Graph.
setModelData(Table...) - Method in interface org.apache.flink.ml.api.Model: Sets model data using the given list of tables.
setModelData(Table...) - Method in class org.apache.flink.ml.builder.GraphModel
setModelData(Table...) - Method in class org.apache.flink.ml.classification.knn.KnnModel
setModelData(Table...) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
setModelData(Table...) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
setModelData(Table...) - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModel
setModelData(Table...) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
setModelDataOnEstimator(Estimator<?, ?>, TableId...) - Method in class org.apache.flink.ml.builder.GraphBuilder: When the graph runs as Estimator, it first generates a GraphModel that contains the Model fitted by the given Estimator.
setModelDataOnModel(Model<?>, TableId...) - Method in class org.apache.flink.ml.builder.GraphBuilder: When the graph runs as Estimator, the setModelData() of the given Model would be invoked with the given inputs before its transform() is invoked.
setModelType(String) - Method in interface org.apache.flink.ml.classification.naivebayes.NaiveBayesModelParams
setMultiClass(String) - Method in interface org.apache.flink.ml.common.param.HasMultiClass
setOperatorLifeCycle(IterationConfig.OperatorLifeCycle) - Method in class org.apache.flink.iteration.IterationConfig.IterationConfigBuilder
setOutputCols(String...) - Method in interface org.apache.flink.ml.common.param.HasOutputCols
setParam(Stage<?>, Param<T>, Object) - Static method in class org.apache.flink.ml.util.ReadWriteUtils
setPredictionCol(String) - Method in interface org.apache.flink.ml.common.param.HasPredictionCol
setRawPredictionCol(String) - Method in interface org.apache.flink.ml.common.param.HasRawPredictionCol
setRecord(T) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
setReg(Double) - Method in interface org.apache.flink.ml.common.param.HasReg
setSeed(long) - Method in interface org.apache.flink.ml.common.param.HasSeed
setSender(String) - Method in class org.apache.flink.iteration.IterationRecord
setSmoothing(Double) - Method in interface org.apache.flink.ml.classification.naivebayes.NaiveBayesParams
setTol(Double) - Method in interface org.apache.flink.ml.common.param.HasTol
setType(IterationRecord.Type) - Method in class org.apache.flink.iteration.IterationRecord
setType(CacheElement.Type) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
setup(StreamTask<?, ?>, StreamConfig, Output<StreamRecord<IterationRecord<?>>>) - Method in class org.apache.flink.iteration.operator.HeadOperator
setup(StreamTask<?, ?>, StreamConfig, Output<StreamRecord<IterationRecord<T>>>) - Method in class org.apache.flink.iteration.operator.ReplayOperator
setup(StreamTask<?, ?>, StreamConfig, Output<StreamRecord<Void>>) - Method in class org.apache.flink.iteration.operator.TailOperator
setup(int) - Method in class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
setValue(T) - Method in class org.apache.flink.iteration.IterationRecord
setWatermark(long) - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElement
setWeight(double) - Method in class org.apache.flink.ml.common.feature.LabeledPointWithWeight
setWeightCol(String) - Method in interface org.apache.flink.ml.common.param.HasWeightCol
SharedProgressAligner - Class in org.apache.flink.iteration.operator.coordinator: The progress aligner shared between multiple HeadOperatorCoordinator.
SharedProgressAlignerListener - Interface in org.apache.flink.iteration.operator.coordinator: The listener of the SharedProgressAligner.
SideOutputTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the SideOutputTransformation.
SideOutputTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.SideOutputTransformationTranslator
size() - Method in class org.apache.flink.iteration.DataStreamList: Returns the number of data streams in this list.
size() - Method in class org.apache.flink.ml.linalg.DenseVector
size() - Method in class org.apache.flink.ml.linalg.SparseVector
size() - Method in interface org.apache.flink.ml.linalg.Vector: Gets the size of the vector.
SKIP_INVALID - Static variable in interface org.apache.flink.ml.common.param.HasHandleInvalid
SMOOTHING - Static variable in interface org.apache.flink.ml.classification.naivebayes.NaiveBayesParams
snapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.iteration.proxy.state.ProxyKeyedStateBackend
snapshot(long, long, CheckpointStreamFactory, CheckpointOptions) - Method in class org.apache.flink.iteration.proxy.state.ProxyOperatorStateBackend
snapshotConfiguration() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordSerializer
snapshotConfiguration() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementSerializer
snapshotConfiguration() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixSerializer
snapshotConfiguration() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorSerializer
snapshotConfiguration() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
snapshotState(long, long, CheckpointOptions, CheckpointStreamFactory) - Method in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
snapshotState(StateSnapshotContext) - Method in class org.apache.flink.iteration.operator.HeadOperator
snapshotState() - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor
snapshotState() - Method in class org.apache.flink.iteration.operator.headprocessor.RegularHeadOperatorRecordProcessor
snapshotState() - Method in class org.apache.flink.iteration.operator.headprocessor.TerminatingHeadOperatorRecordProcessor
snapshotState(long, long, CheckpointOptions, CheckpointStreamFactory) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
snapshotState(StateSnapshotContext) - Method in class org.apache.flink.iteration.operator.perround.AbstractPerRoundWrapperOperator
snapshotState(StateSnapshotContext) - Method in class org.apache.flink.iteration.operator.ReplayOperator
snapshotState(long, long, CheckpointOptions, CheckpointStreamFactory) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
snapshotState(StateSnapshotContext) - Method in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
snapshotState(StateSnapshotContext) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperator
snapshotToRawKeyedState(KeyedStateCheckpointOutputStream, String) - Method in class org.apache.flink.iteration.proxy.state.ProxyInternalTimeServiceManager
sparse(int, int[], double[]) - Static method in class org.apache.flink.ml.linalg.Vectors: Creates a sparse vector from its values.
SparseVector - Class in org.apache.flink.ml.linalg: A sparse vector of double values.
SparseVector(int, int[], double[]) - Constructor for class org.apache.flink.ml.linalg.SparseVector
SparseVectorSerializer - Class in org.apache.flink.ml.linalg.typeinfo: Specialized serializer for SparseVector.
SparseVectorSerializer() - Constructor for class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer
SparseVectorSerializer.SparseVectorSerializerSnapshot - Class in org.apache.flink.ml.linalg.typeinfo: Serializer configuration snapshot for compatibility and format evolution.
SparseVectorSerializerSnapshot() - Constructor for class org.apache.flink.ml.linalg.typeinfo.SparseVectorSerializer.SparseVectorSerializerSnapshot
SparseVectorTypeInfo - Class in org.apache.flink.ml.linalg.typeinfo: A TypeInformation for the SparseVector type.
SparseVectorTypeInfo() - Constructor for class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
SparseVectorTypeInfoFactory - Class in org.apache.flink.ml.linalg.typeinfo: Used by TypeExtractor to create a TypeInformation for implementations of SparseVector.
SparseVectorTypeInfoFactory() - Constructor for class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfoFactory
Stage<T extends Stage<T>> - Interface in org.apache.flink.ml.api: Base class for a node in a Pipeline or Graph.
stage - Variable in class org.apache.flink.ml.builder.GraphNode
stageType - Variable in class org.apache.flink.ml.builder.GraphNode
start() - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
startLogging(long, OperatorStateCheckpointOutputStream) - Method in class org.apache.flink.iteration.checkpoint.Checkpoints
stateHandler - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
StateNamePrefix - Class in org.apache.flink.iteration.proxy.state: The prefix for the state name.
StateNamePrefix(String) - Constructor for class org.apache.flink.iteration.proxy.state.StateNamePrefix
streamConfig - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
streamConfig - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
StringArrayParam - Class in org.apache.flink.ml.param: Class for the string array parameter.
StringArrayParam(String, String, String[], ParamValidator<String[]>) - Constructor for class org.apache.flink.ml.param.StringArrayParam
StringArrayParam(String, String, String[]) - Constructor for class org.apache.flink.ml.param.StringArrayParam
StringParam - Class in org.apache.flink.ml.param: Class for the string parameter.
StringParam(String, String, String, ParamValidator<String>) - Constructor for class org.apache.flink.ml.param.StringParam
StringParam(String, String, String) - Constructor for class org.apache.flink.ml.param.StringParam
SubtaskAlignedEvent - Class in org.apache.flink.iteration.operator.event: The event sent from HeadOperator to HeadOperatorCoordinator to notify the subtask has received the EpochWatermark for the specified round.
SubtaskAlignedEvent(int, long, boolean) - Constructor for class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
subtaskFailed(int, Throwable) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
subtaskReady(int, OperatorCoordinator.SubtaskGateway) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator
subtaskReset(int, long) - Method in class org.apache.flink.iteration.operator.coordinator.HeadOperatorCoordinator

T

TableId - Class in org.apache.flink.ml.builder: The TableId is necessary to pass the inputs/outputs of various API calls across the nodes of Graph and GraphModel.
TableId(int) - Constructor for class org.apache.flink.ml.builder.TableId
TableUtils - Class in org.apache.flink.ml.common.datastream: Utility class for table-related operations.
TableUtils() - Constructor for class org.apache.flink.ml.common.datastream.TableUtils
TailOperator - Class in org.apache.flink.iteration.operator: The tail operators is attached after each feedback operator to increment the round of each record.
TailOperator(IterationID, int) - Constructor for class org.apache.flink.iteration.operator.TailOperator
TerminateOnMaxIter<T> - Class in org.apache.flink.ml.common.iteration: A FlatMapFunction that emits values iff the iteration's epochWatermark does not exceed a certain threshold.
TerminateOnMaxIter(int) - Constructor for class org.apache.flink.ml.common.iteration.TerminateOnMaxIter
TerminateOnMaxIterOrTol - Class in org.apache.flink.ml.common.iteration: A FlatMapFunction that emits values iff the iteration's epochWatermark does not exceed a certain threshold and the loss exceeds a certain tolerance.
TerminateOnMaxIterOrTol(Integer, Double) - Constructor for class org.apache.flink.ml.common.iteration.TerminateOnMaxIterOrTol
TerminateOnMaxIterOrTol(Double) - Constructor for class org.apache.flink.ml.common.iteration.TerminateOnMaxIterOrTol
TerminatingHeadOperatorRecordProcessor - Class in org.apache.flink.iteration.operator.headprocessor: Processor used after we received terminated globally aligned event from the coordinator, but before we received the (Integer.MAX_VALUE + 1) from the feedback channel again.
TerminatingHeadOperatorRecordProcessor(HeadOperatorRecordProcessor.Context) - Constructor for class org.apache.flink.iteration.operator.headprocessor.TerminatingHeadOperatorRecordProcessor
TerminatingOnInitializeEvent - Class in org.apache.flink.iteration.operator.event: Notifies the HeadOperatorCoordinator that the status has been terminating on startup so that the coordinator would not emit CoordinatorCheckpointEvent.
theta - Variable in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModelData: Log of class conditional probabilities, whose dimension is C (number of classes) by D (number of features).
timeServiceManager - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
toArray() - Method in class org.apache.flink.ml.linalg.DenseVector
toArray() - Method in class org.apache.flink.ml.linalg.SparseVector
toArray() - Method in interface org.apache.flink.ml.linalg.Vector: Converts the instance to a double array.
TOL - Static variable in interface org.apache.flink.ml.common.param.HasTol
toList(TableId[]) - Static method in class org.apache.flink.ml.builder.TableId
toMap() - Method in class org.apache.flink.ml.builder.GraphData
toMap() - Method in class org.apache.flink.ml.builder.GraphNode
toString() - Method in class org.apache.flink.iteration.datacache.nonkeyed.Segment
toString() - Method in class org.apache.flink.iteration.IterationRecord
toString() - Method in class org.apache.flink.iteration.operator.event.CoordinatorCheckpointEvent
toString() - Method in class org.apache.flink.iteration.operator.event.GloballyAlignedEvent
toString() - Method in class org.apache.flink.iteration.operator.event.SubtaskAlignedEvent
toString() - Method in class org.apache.flink.iteration.proxy.ProxyStreamPartitioner
toString() - Method in class org.apache.flink.iteration.typeinfo.IterationRecordTypeInfo
toString() - Method in class org.apache.flink.ml.builder.GraphNode
toString() - Method in class org.apache.flink.ml.builder.TableId
toString() - Method in class org.apache.flink.ml.common.broadcast.typeinfo.CacheElementTypeInfo
toString() - Method in class org.apache.flink.ml.common.datastream.EndOfStreamWindows
toString() - Method in class org.apache.flink.ml.linalg.DenseVector
toString() - Method in class org.apache.flink.ml.linalg.SparseVector
toString() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseMatrixTypeInfo
toString() - Method in class org.apache.flink.ml.linalg.typeinfo.DenseVectorTypeInfo
toString() - Method in class org.apache.flink.ml.linalg.typeinfo.SparseVectorTypeInfo
toString() - Method in class org.apache.flink.ml.param.Param
transform(Table...) - Method in interface org.apache.flink.ml.api.AlgoOperator: Applies the AlgoOperator on the given input tables and returns the result tables.
transform(Table...) - Method in class org.apache.flink.ml.builder.GraphModel
transform(Table...) - Method in class org.apache.flink.ml.builder.PipelineModel: Applies all stages in this PipelineModel on the input tables in order.
transform(Table...) - Method in class org.apache.flink.ml.classification.knn.KnnModel
transform(Table...) - Method in class org.apache.flink.ml.classification.logisticregression.LogisticRegressionModel
transform(Table...) - Method in class org.apache.flink.ml.classification.naivebayes.NaiveBayesModel
transform(Table...) - Method in class org.apache.flink.ml.clustering.kmeans.KMeansModel
transform(Table...) - Method in class org.apache.flink.ml.feature.onehotencoder.OneHotEncoderModel
Transformer<T extends Transformer<T>> - Interface in org.apache.flink.ml.api: A Transformer is an AlgoOperator with the semantic difference that it encodes the Transformation logic, such that a record in the output typically corresponds to one record in the input.
translate(TF, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in interface org.apache.flink.iteration.compile.DraftTransformationTranslator
translate(BroadcastStateTransformation<?, ?, ?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.BroadcastStateTransformationTranslator
translate(KeyedBroadcastStateTransformation<?, ?, ?, ?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.KeyedBroadcastStateTransformationTranslator
translate(KeyedMultipleInputTransformation<?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.KeyedMultipleInputTransformationTranslator
translate(MultipleInputTransformation<?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.MultipleInputTransformationTranslator
translate(OneInputTransformation<?, ?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.OneInputTransformationTranslator
translate(PartitionTransformation<?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.PartitionTransformationTranslator
translate(ReduceTransformation<?, ?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.ReduceTransformationTranslator
translate(SideOutputTransformation<?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.SideOutputTransformationTranslator
translate(TwoInputTransformation<?, ?, ?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.TwoInputTransformationTranslator
translate(UnionTransformation<?>, OperatorWrapper<?, ?>, DraftTransformationTranslator.Context) - Method in class org.apache.flink.iteration.compile.translator.UnionTransformationTranslator
TwoInputAllRoundWrapperOperator<IN1,IN2,OUT> - Class in org.apache.flink.iteration.operator.allround: All-round wrapper for the two-inputs operator.
TwoInputAllRoundWrapperOperator(StreamOperatorParameters<IterationRecord<OUT>>, StreamOperatorFactory<OUT>) - Constructor for class org.apache.flink.iteration.operator.allround.TwoInputAllRoundWrapperOperator
TwoInputBroadcastWrapperOperator<IN1,IN2,OUT> - Class in org.apache.flink.ml.common.broadcast.operator: Wrapper for TwoInputStreamOperator.
TwoInputPerRoundWrapperOperator<IN1,IN2,OUT> - Class in org.apache.flink.iteration.operator.perround: Per-round wrapper for the two-inputs operator.
TwoInputPerRoundWrapperOperator(StreamOperatorParameters<IterationRecord<OUT>>, StreamOperatorFactory<OUT>) - Constructor for class org.apache.flink.iteration.operator.perround.TwoInputPerRoundWrapperOperator
TwoInputTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the TwoInputTransformation.
TwoInputTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.TwoInputTransformationTranslator

U

UnionTransformationTranslator - Class in org.apache.flink.iteration.compile.translator: Draft translator for the UnionTransformation.
UnionTransformationTranslator() - Constructor for class org.apache.flink.iteration.compile.translator.UnionTransformationTranslator
uniqueSenderId - Variable in class org.apache.flink.iteration.operator.AbstractWrapperOperator
unregisterListener(OperatorID) - Method in class org.apache.flink.iteration.operator.coordinator.SharedProgressAligner
updateEpochToCoordinator(int, long) - Method in interface org.apache.flink.iteration.operator.headprocessor.HeadOperatorRecordProcessor.Context
updateExistingParams(Stage<?>, Map<Param<?>, Object>) - Static method in class org.apache.flink.ml.util.ReadWriteUtils

V

validate(T) - Method in interface org.apache.flink.ml.param.ParamValidator: Validate whether the parameter value is valid.
validator - Variable in class org.apache.flink.ml.param.Param
valueOf(String) - Static method in enum org.apache.flink.iteration.IterationConfig.OperatorLifeCycle: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.iteration.IterationRecord.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.ml.builder.GraphNode.StageType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.ml.common.broadcast.typeinfo.CacheElement.Type: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.iteration.IterationConfig.OperatorLifeCycle: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.iteration.IterationRecord.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.ml.builder.GraphNode.StageType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.ml.common.broadcast.typeinfo.CacheElement.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values - Variable in class org.apache.flink.ml.linalg.DenseMatrix: Array for internal storage of elements.
values - Variable in class org.apache.flink.ml.linalg.DenseVector
values - Variable in class org.apache.flink.ml.linalg.SparseVector
Vector - Interface in org.apache.flink.ml.linalg: A vector of double values.
Vectors - Class in org.apache.flink.ml.linalg: Utility methods for instantiating Vector.
Vectors() - Constructor for class org.apache.flink.ml.linalg.Vectors

W

WEIGHT_COL - Static variable in interface org.apache.flink.ml.common.param.HasWeightCol
withBroadcastStream(List<DataStream<?>>, Map<String, DataStream<?>>, Function<List<DataStream<?>>, DataStream<OUT>>) - Static method in class org.apache.flink.ml.common.broadcast.BroadcastUtils: supports withBroadcastStream in DataStream API.
WithParams<T> - Interface in org.apache.flink.ml.param: Interface for classes that take parameters.
wrap(StreamOperatorParameters<IterationRecord<T>>, StreamOperatorFactory<T>) - Method in class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
wrap(StreamOperatorParameters<R>, StreamOperatorFactory<T>) - Method in interface org.apache.flink.iteration.operator.OperatorWrapper
wrap(StreamOperatorParameters<IterationRecord<T>>, StreamOperatorFactory<T>) - Method in class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
wrap(StreamOperatorParameters<T>, StreamOperatorFactory<T>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
wrapKeySelector(KeySelector<T, KEY>) - Method in class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
wrapKeySelector(KeySelector<T, KEY>) - Method in interface org.apache.flink.iteration.operator.OperatorWrapper
wrapKeySelector(KeySelector<T, KEY>) - Method in class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
wrapKeySelector(KeySelector<T, KEY>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
wrapOutputTag(OutputTag<T>) - Method in class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
wrapOutputTag(OutputTag<T>) - Method in interface org.apache.flink.iteration.operator.OperatorWrapper
wrapOutputTag(OutputTag<T>) - Method in class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
wrapOutputTag(OutputTag<T>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
wrappedOperator - Variable in class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator
wrappedOperator - Variable in class org.apache.flink.ml.common.broadcast.operator.AbstractBroadcastWrapperOperator
WrapperOperatorFactory<OUT> - Class in org.apache.flink.iteration.operator: The factory to create the subclass of AbstractWrapperOperator.
WrapperOperatorFactory(StreamOperatorFactory<OUT>, OperatorWrapper<OUT, IterationRecord<OUT>>) - Constructor for class org.apache.flink.iteration.operator.WrapperOperatorFactory
wrapStreamPartitioner(StreamPartitioner<T>) - Method in class org.apache.flink.iteration.operator.allround.AllRoundOperatorWrapper
wrapStreamPartitioner(StreamPartitioner<T>) - Method in interface org.apache.flink.iteration.operator.OperatorWrapper
wrapStreamPartitioner(StreamPartitioner<T>) - Method in class org.apache.flink.iteration.operator.perround.PerRoundOperatorWrapper
wrapStreamPartitioner(StreamPartitioner<T>) - Method in class org.apache.flink.ml.common.broadcast.operator.BroadcastWrapper
writeTo(OutputStream) - Method in class org.apache.flink.iteration.datacache.nonkeyed.DataCacheSnapshot

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

Back to Apache Flink Website

A

B

C

D

E

F

G

H

I

J

K

L

M

N

O

P

R

S

T

U

V

W

Back to Apache Flink Website