org.apache.flink.core.fs.Path path
int count
long size
java.util.function.Supplier<T> epochSupplier
java.util.function.Supplier<T> epochSupplier
org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters
org.apache.flink.streaming.api.graph.StreamConfig streamConfig
org.apache.flink.streaming.runtime.tasks.StreamTask<OUT,OP extends org.apache.flink.streaming.api.operators.StreamOperator<OUT>> containingTask
org.apache.flink.streaming.api.operators.Output<T> output
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory
org.apache.flink.iteration.operator.AbstractWrapperOperator.IterationContext iterationContext
ProxyOutput<T> proxyOutput
org.apache.flink.iteration.operator.AbstractWrapperOperator.EpochSupplier epochWatermarkSupplier
org.apache.flink.runtime.metrics.groups.InternalOperatorMetricGroup metrics
OperatorEpochWatermarkTracker epochWatermarkTracker
String uniqueSenderId
BroadcastOutput<OUT> eventBroadcastOutput
IterationID iterationId
int feedbackIndex
boolean isCriteriaStream
org.apache.flink.runtime.operators.coordination.OperatorEventGateway operatorEventGateway
org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor
org.apache.flink.iteration.operator.HeadOperator.HeadOperatorStatus status
HeadOperatorRecordProcessor recordProcessor
org.apache.flink.iteration.operator.HeadOperatorCheckpointAligner checkpointAligner
org.apache.flink.api.common.state.ListState<T> parallelismState
org.apache.flink.api.common.state.ListState<T> statusState
org.apache.flink.api.common.state.ListState<T> processorState
Checkpoints<T> checkpoints
IterationID iterationId
int feedbackIndex
boolean isCriteriaStream
int totalInitialVariableParallelism
int criteriaStreamParallelism
OperatorEpochWatermarkTracker progressTracker
org.apache.flink.core.fs.Path basePath
org.apache.flink.core.fs.FileSystem fileSystem
org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer
org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor
DataCacheWriter<T> dataCacheWriter
DataCacheReader<T> currentDataCacheReader
int currentEpoch
org.apache.flink.api.common.state.ListState<T> parallelismState
org.apache.flink.api.common.state.ListState<T> currentEpochState
IterationID iterationId
int feedbackIndex
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory
OperatorWrapper<T,R> wrapper
org.apache.flink.streaming.api.operators.StreamOperator<OUT> wrappedOperator
int latestEpochWatermark
org.apache.flink.api.common.state.ListState<T> parallelismState
org.apache.flink.api.common.state.ListState<T> latestEpochWatermarkState
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> reusedInput
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> reusedInput1
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> reusedInput2
org.apache.flink.runtime.jobgraph.OperatorID operatorId
IterationID iterationId
int totalHeadParallelism
long checkpointId
int epoch
boolean isTerminated
int epoch
long numRecordsThisRound
boolean isCriteriaStream
Map<K,V> wrappedOperators
org.apache.flink.streaming.util.LatencyStats latencyStats
int latestEpochWatermark
org.apache.flink.api.common.state.ListState<T> parallelismState
org.apache.flink.api.common.state.ListState<T> latestEpochWatermarkState
org.apache.flink.api.common.state.ListState<T> pendingEpochState
org.apache.flink.api.common.state.ListState<T> rawStateEpochState
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> reusedInput
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> reusedInput1
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> reusedInput2
org.apache.flink.api.java.functions.KeySelector<IN,KEY> wrappedKeySelector
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> wrappedStreamPartitioner
org.apache.flink.api.common.typeutils.TypeSerializer<T> innerSerializer
org.apache.flink.api.common.typeinfo.TypeInformation<T> innerTypeInfo
double l2
org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters
org.apache.flink.streaming.api.graph.StreamConfig streamConfig
org.apache.flink.streaming.runtime.tasks.StreamTask<OUT,OP extends org.apache.flink.streaming.api.operators.StreamOperator<OUT>> containingTask
org.apache.flink.streaming.api.operators.Output<T> output
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory
org.apache.flink.metrics.groups.OperatorMetricGroup metrics
org.apache.flink.streaming.api.operators.StreamOperator<OUT> wrappedOperator
org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor
String[] broadcastStreamNames
boolean[] isBlocked
org.apache.flink.api.common.typeinfo.TypeInformation<T>[] inTypes
boolean broadcastVariablesReady
int numInputs
BroadcastStreamingRuntimeContext wrappedOperatorRuntimeContext
org.apache.flink.core.fs.Path basePath
DataCacheWriter<T>[] dataCacheWriters
boolean[] hasPendingElements
String[] broadcastStreamNames
org.apache.flink.api.common.typeinfo.TypeInformation<T>[] inTypes
List<E> inputList
boolean[] cachesReady
org.apache.flink.api.common.state.ListState<T>[] cacheStates
org.apache.flink.api.common.state.ListState<T>[] cacheReadyStates
String[] broadcastNames
org.apache.flink.api.common.typeinfo.TypeInformation<T>[] inTypes
String[] broadcastStreamNames
org.apache.flink.api.common.typeinfo.TypeInformation<T>[] inTypes
boolean[] isBlocked
org.apache.flink.api.common.typeutils.TypeSerializer<T> recordSerializer
org.apache.flink.api.common.typeinfo.TypeInformation<T> recordTypeInfo
int maxIter
int maxIter
double tol
double loss
int numRows
int numCols
double[] values
The matrix data is stored in column major format internally.
double[] values
int n
int[] indices
double[] values
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.