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.iteration.operator.HeadOperator.MailboxExecutorWithYieldTimeout 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
Random random
long numValues
long initSeed
long numValuesOnThisTask
int numPreGeneratedRows
org.apache.flink.types.Row[] preGeneratedRows
DenseVectorSerializer serializer
DenseVectorSerializer serializer
DenseVectorSerializer serializer
DenseVectorSerializer serializer
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.typeutils.TypeSerializer<T>[] inTypeSerializers
boolean broadcastVariablesReady
int numInputs
BroadcastStreamingRuntimeContext wrappedOperatorRuntimeContext
org.apache.flink.core.fs.Path basePath
DataCacheWriter<T>[] dataCacheWriters
boolean[] hasPendingElements
boolean hasRichFunction
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.typeutils.TypeSerializer<T> recordSerializer
org.apache.flink.api.common.typeinfo.TypeInformation<T> recordTypeInfo
org.apache.flink.runtime.operators.sort.PushSorter<E> sorterA
org.apache.flink.runtime.operators.sort.PushSorter<E> sorterB
org.apache.flink.api.common.typeutils.TypeComparator<T> comparatorA
org.apache.flink.api.common.typeutils.TypeComparator<T> comparatorB
org.apache.flink.api.java.functions.KeySelector<IN,KEY> keySelectorA
org.apache.flink.api.java.functions.KeySelector<IN,KEY> keySelectorB
org.apache.flink.api.common.typeutils.TypeSerializer<T> keyAndValueSerializerA
org.apache.flink.api.common.typeutils.TypeSerializer<T> keyAndValueSerializerB
org.apache.flink.api.common.typeutils.TypeSerializer<T> keySerializer
org.apache.flink.core.memory.DataOutputSerializer dataOutputSerializer
long lastWatermarkTimestamp
int remainingInputNum
int keyLength
byte[] keyReference
long timestampReference
org.apache.flink.api.common.typeutils.TypeSerializer<T> valueSerializer
int serializedKeyLength
byte[] keyReference
long timestampReference
int maxIter
int maxIter
double tol
double loss
Comparator<T> comparator
org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer
Comparator<T> comparator
org.apache.flink.api.common.typeinfo.TypeInformation<T> elementTypeInfo
double relativeError
int compressThreshold
long count
List<E> sampled
List<E> headBuffer
boolean compressed
double value
long g
long delta
Integer taskId
double maxScore
long curPositive
long curNegative
String inputCol
boolean binary
int numFeatures
DenseVectorSerializer denseVectorSerializer
DenseVectorSerializer serializer
org.apache.flink.api.common.state.ListState<T> minState
org.apache.flink.api.common.state.ListState<T> maxState
DenseVector minVector
DenseVector maxVector
DenseVectorSerializer serializer
DenseVectorSerializer serializer
DenseVectorSerializer serializer
int numRows
int numCols
double[] values
The matrix data is stored in column major format internally.
double[] values
int n
int[] indices
double[] values
byte[] buf
DenseVectorSerializer denseVectorSerializer
VectorSerializer vectorSerializer
DenseVectorSerializer serializer
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.