boolean endReached
org.apache.hadoop.hbase.client.ResultScanner rs
byte[] lastRow
int scannedRows
byte[] tableName
byte[] startRow
byte[] endRow
DataOutput out
ExecutionMode executionMode
boolean useClosureCleaner
int parallelism
int numberOfExecutionRetries
boolean forceKryo
boolean objectReuse
boolean autoTypeRegistrationEnabled
boolean forceAvro
CodeAnalysisMode codeAnalysisMode
boolean printProgressDuringExecution
ExecutionConfig.GlobalJobParameters globalJobParameters
long autoWatermarkInterval
boolean timestampsEnabled
long executionRetryDelay
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
LinkedHashMap<K,V> registeredTypesWithKryoSerializers
LinkedHashMap<K,V> registeredTypesWithKryoSerializerClasses
LinkedHashMap<K,V> defaultKryoSerializers
LinkedHashMap<K,V> defaultKryoSerializerClasses
LinkedHashSet<E> registeredKryoTypes
LinkedHashSet<E> registeredPojoTypes
com.esotericsoftware.kryo.Serializer<T> serializer
double localValue
long count
double localValue
int localValue
long localValue
DoubleValue wrapper
double sum
long sum
TypeComparator<T> typeComparator
Object[][] boundaries
TypeComparator<T>[] flatComparators
Object[] keys
double min
double max
int min
int max
long blockSize
long readRecords
long blockSize
byte[] delimiter
int lineLengthLimit
int bufferSize
int numLineSamples
Path filePath
long minSplitSize
int numSplits
long openTimeout
boolean unsplittable
boolean enumerateNestedFiles
Path outputFilePath
FileSystem.WriteMode writeMode
FileOutputFormat.OutputDirectoryMode outputDirectoryMode
boolean testFileName
boolean lineDelimiterIsLinebreak
Class<T>[] fieldTypes
boolean[] fieldIncluded
byte[] fieldDelim
boolean lenient
boolean skipFirstLineAsHeader
boolean quotedStringParsing
byte quoteCharacter
byte[] commentPrefix
int partitionNumber
InputFormat<OT,T extends InputSplit> replicatedIF
Map<K,V> fieldMapping1
Map<K,V> fieldMapping2
FieldSet readFields1
FieldSet readFields2
GenericDataSourceBase<OUT,T extends InputFormat<OUT,?>> source
long count
BulkIterationBase.TerminationCriterionAggregator aggregator
boolean isOpened
boolean isClosed
FlatJoinFunction<IN1,IN2,OUT> joiner
OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>> baseOperator
int partitionNumber
int count
int count
Object userCodeObject
int restartAttempts
long delayBetweenAttempts
FoldFunction<O,T> foldFunction
ReduceFunction<T> reduceFunction
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
String name
TypeSerializer<T> serializer
Class<T> arrayClass
TypeInformation<T> componentInfo
TypeComparator<T> comparator1
TypeComparator<T> comparator2
TypeComparator<T>[] comparators1
TypeComparator<T>[] comparators2
Object[] referenceKeyFields
Object[] candidateKeyFields
boolean ascendingComparison
TypeComparator<T>[] comparators
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> componentClass
TypeSerializer<T> componentSerializer
TypeComparator<T>[] comparators
boolean ascending
BasicTypeComparator<T extends Comparable<T>> comparator
long count
long checksum
String id
long counter
long checksum
String id
TypeSerializer<T> serializer
SerializedListAccumulator<T> accumulator
String id
long counter
Comparable<T> value
Comparable<T> value
Comparable<T> value
Comparable<T> value
long agg
long agg
double agg
double agg
double agg
double agg
long agg
long agg
long agg
long agg
long agg
long agg
int count
TextOutputFormat.TextFormatter<IN> formatter
boolean withReplacement
int numSample
long seed
boolean withReplacement
int numSample
long seed
boolean withReplacement
double fraction
long seed
int[] fields
int[] fields
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hadoop.mapred.JobConf jobConf
org.apache.hadoop.mapred.OutputFormat<K,V> mapredOutputFormat
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hadoop.conf.Configuration configuration
org.apache.hadoop.mapreduce.OutputFormat<K,V> mapreduceOutputFormat
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
TypeSerializer<T> serializer
TypeSerializer<T> typeSerializer
int id
SplittableIterator<T> source
String sinkIdentifier
boolean target
String partitionMarker
String charsetName
String charsetName
String charsetName
boolean skipInvalidLines
TupleSerializerBase<T> tupleSerializer
TypeSerializer<T> serializer
TypeSerializer<T> serializer
String username
String password
String drivername
String dbURL
String query
int batchInterval
Connection dbConn
PreparedStatement upload
org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.SupportedTypes[] types
int batchCount
int[] fieldPositions
AggregationFunction<T>[] aggFunctions
int[] fields
boolean[] isFromFirst
Tuple outTuple
int[] fields
boolean[] isFromFirst
Tuple outTuple
CombineFunction<IN,OUT> wrappedFunction
TupleUnwrappingIterator<T,K> iter1
TupleUnwrappingIterator<T,K> iter2
TupleUnwrappingIterator<T,K> iter1
int[] fields
Tuple outTuple
TupleUnwrappingIterator<T,K> iter2
TupleUnwrappingIterator<T,K> iter
TupleUnwrappingIterator<T,K> iter
TupleWrappingCollector<IN,K> coll
TupleUnwrappingIterator<T,K> iter
Tuple3UnwrappingIterator<T,K1,K2> iter
Tuple3UnwrappingIterator<T,K1,K2> iter
Tuple3WrappingCollector<IN,K1,K2> coll
Tuple3UnwrappingIterator<T,K1,K2> iter
KeySelector<IN,KEY> keySelector1
KeySelector<IN,KEY> keySelector2
Tuple3<T0,T1,T2> tuple
Function wrappedFunction
private Object readResolve() throws ObjectStreamException
ObjectStreamException
Object f0
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f22
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f22
Object f23
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
Object f9
Object f10
Object f11
Object f12
Object f13
Object f14
Object f15
Object f16
Object f17
Object f18
Object f19
Object f20
Object f21
Object f22
Object f23
Object f24
Object f0
Object f1
Object f2
Object f3
Object f4
Object f5
Object f6
Object f7
Object f8
TypeInformation<T> leftType
TypeInformation<T> rightType
String functionName
InvalidTypesException typeException
Class<T> arrayType
TypeInformation<T> componentInfo
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeInformation<T> type
int special
Object extraField
PojoField[] fields
int totalFields
String[] fieldNames
TypeInformation<T>[] types
int totalFields
private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> type
boolean ascendingComparison
TypeComparator<T>[] comparators
private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeSerializer<T> leftSerializer
TypeSerializer<T> rightSerializer
boolean ascending
Class<T> type
TypeSerializer<T> serializer
TypeComparator<T>[] comparators
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeComparator<T>[] comparators
int[] normalizedKeyLengths
int numLeadingNormalizableKeys
int normalizableKeyPrefixLen
boolean invertNormKey
TypeSerializer<T> serializer
Class<T> type
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Class<T> clazz
TypeSerializer<T>[] fieldSerializers
int numFields
Map<K,V> registeredClasses
TypeSerializer<T>[] registeredSerializers
ExecutionConfig executionConfig
TypeComparator<T> comparator
TypeSerializer<T> serializer
boolean firstSerializer
Class<T> clazz
int[] keyPositions
TypeComparator<T>[] comparators
int[] normalizedKeyLengths
int numLeadingNormalizableKeys
int normalizableKeyPrefixLen
boolean invertNormKey
TypeSerializer<T>[] serializers
Class<T> tupleClass
TypeSerializer<T>[] fieldSerializers
int arity
Class<T> type
boolean ascendingComparison
TypeComparator<T>[] comparators
UUID id
Class<T> type
boolean ascendingComparison
TypeComparator<T>[] comparators
LinkedHashMap<K,V> registeredTypesWithSerializers
LinkedHashMap<K,V> registeredTypesWithSerializerClasses
LinkedHashMap<K,V> defaultSerializers
LinkedHashMap<K,V> defaultSerializerClasses
LinkedHashSet<E> registeredTypes
Class<T> type
int[] fieldPositions
AggregationFunction<T>[] aggFunctions
TupleSerializerBase<T> serializer
TypeInformation<T> typeInfo
private void readObject(ObjectInputStream in)
private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
TypeSerializer<T> typeSerializer
int[] deweyNumber
private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream oos) throws IOException
IOException
NonDuplicatingTypeSerializer<T> nonDuplicatingTypeSerializer
SharedBuffer<K extends Serializable,V> sharedBuffer
Set<E> states
long windowTime
int startEventCounter
private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream oos) throws IOException
IOException
TypeSerializer<T> valueSerializer
String name
State.StateType stateType
Collection<E> stateTransitions
StateTransitionAction action
State<T> targetState
FilterFunction<T> condition
TypeSerializer<T> inputSerializer
boolean isProcessingTime
StreamRecordSerializer<T> streamRecordSerializer
NFA<T> nfa
KeySelector<IN,KEY> keySelector
TypeSerializer<T> keySerializer
org.apache.flink.cep.operator.KeyedCEPPatternOperator.PriorityQueueFactory<T> priorityQueueFactory
NFACompiler.NFAFactory<T> nfaFactory
FilterFunction<T> left
FilterFunction<T> right
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
OperatorStatisticsConfig config
long cardinality
OperatorStatistics local
int countDbitmap
int countDlog2m
int heavyHitterSeed
double heavyHitterConfidence
double heavyHitterFraction
double heavyHitterError
boolean collectMin
boolean collectMax
boolean collectCountDistinct
boolean collectHeavyHitters
OperatorStatisticsConfig.CountDistinctAlgorithm countDistinctAlgorithm
OperatorStatisticsConfig.HeavyHitterAlgorithm heavyHitterAlgorithm
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream oos) throws IOException
IOException
File basePath
String checkpointPath
URI backupUri
long checkpointId
TypeSerializer<T> keySerializer
TypeSerializer<T> namespaceSerializer
StateDescriptor<S extends State,T> stateDesc
String userName
String userPassword
List<E> shardUrls
DbAdapter dbAdapter
String JDBCDriver
int maxNumberOfSqlRetries
int sleepBetweenSqlRetries
int kvStateCacheSize
int maxKvInsertBatchSize
float maxKvEvictFraction
int kvStateCompactionFreq
ShardedConnection.Partitioner shardPartitioner
Random rnd
DbBackendConfig dbConfig
DbAdapter dbAdapter
ShardedConnection connections
int numSqlRetries
int sqlRetrySleep
String operatorIdentifier
AbstractStateBackend nonPartitionedStateBackend
String jobId
DbBackendConfig dbConfig
long checkpointId
long checkpointTs
long handleId
long stateSize
Path checkpointDirectory
AbstractStateBackend nonPartitionedStateBackend
String operatorIdentifier
JobID jobId
Path[] configuredDbBasePaths
File[] initializedDbBasePaths
int nextDirectory
PredefinedOptions predefinedOptions
OptionsFactory optionsFactory
Connection[] connections
int numShards
ShardedConnection.Partitioner partitioner
PreparedStatement[] statements
Path file
long start
long length
URI uri
int partitionNumber
int totalNumberOfPartitions
int splitNumber
String[] hostnames
int id
double x
double y
Collection<E> centroids
List<E> tasks
FileCopyTaskInputSplit curInputSplit
FileCopyTask task
int splitNumber
EnumTrianglesDataTypes.Edge outEdge
double dampening
double randomJump
double x
double y
double theta0
double theta1
Collection<E> parameters
LinearRegression.Params parameter
int count
EmptyFieldsCountAccumulator.VectorAccumulator emptyFieldCounter
double x
double y
String message
long numberOfVertices
IterationRuntimeContext runtimeContext
long numberOfVertices
IterationRuntimeContext runtimeContext
Double delta
Object srcVertexId
TypeInformation<T> typeInformation
long numVertices
double beta
long numVertices
Object srcVertexId
long numberOfVertices
EdgeDirection direction
Tuple2<T0,T1> outValue
IterationRuntimeContext runtimeContext
Iterator<E> edges
Collector<T> out
Object vertexId
org.apache.flink.graph.spargel.MessagingFunction.EdgesIterator<K,EV> edgeIterator
boolean edgesUsed
long inDegree
long outDegree
long numberOfVertices
boolean optDegrees
IterationRuntimeContext runtimeContext
Collector<T> out
Collector<T> outWithDegrees
Vertex<K,V> outVal
Vertex<K,V> outValWithDegrees
long inDegree
long outDegree
boolean setNewVertexValueCalled
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.hadoop.conf.Configuration configuration
org.apache.hive.hcatalog.mapreduce.HCatInputFormat hCatInputFormat
org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> recordReader
boolean fetched
boolean hasNext
String[] fieldNames
org.apache.hive.hcatalog.data.schema.HCatSchema outputSchema
TypeInformation<T> resultType
scala.Function2<T1,T2,R> fun
Object broadcastVariable
scala.Function2<T1,T2,R> fun
Object broadcastVariable
scala.Function3<T1,T2,T3,R> fun
Object broadcastVariable
int fieldNumber
PythonStreamer streamer
PythonStreamer streamer
SerializationUtils.Serializer<IN> serializer
File inputFile
RandomAccessFile inputRAF
FileChannel inputChannel
MappedByteBuffer fileBuffer
boolean readAsByteArray
org.apache.flink.python.api.streaming.data.PythonReceiver.Deserializer<T> deserializer
File outputFile
RandomAccessFile outputRAF
FileChannel outputChannel
MappedByteBuffer fileBuffer
ByteBuffer[] saved
org.apache.flink.python.api.streaming.data.PythonSender.Serializer<T>[] serializer
int id
boolean usePython3
String planArguments
String inputFilePath
String outputFilePath
Process process
Thread shutdownThread
ServerSocket server
Socket socket
DataInputStream in
DataOutputStream out
int port
PythonSender<IN> sender
PythonReceiver receiver
StringBuilder msg
AbstractRichFunction function
DataInputStream input
DataOutputStream output
PythonPlanSender sender
PythonPlanReceiver receiver
Process process
ServerSocket server
Socket socket
JobID jobID
ExecutionAttemptID executionAttemptID
SerializedValue<T> flinkAccumulators
SerializedValue<T> userAccumulators
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$FunSuiteLike$$engine
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
byte[] key
boolean isDiscarded
SerializedValue<T> state
long stateSize
JobVertexID operatorId
int subtask
long duration
JobID jobID
ResultPartitionID consumedPartitionId
ResultPartitionLocation consumedPartitionLocation
IntermediateDataSetID consumedResultId
int consumedSubpartitionIndex
DistributionPattern
and the subtask indices of the producing and consuming task.InputChannelDeploymentDescriptor[] inputChannels
IntermediateDataSetID resultId
IntermediateResultPartitionID partitionId
ResultPartitionType partitionType
int numberOfSubpartitions
boolean eagerlyDeployConsumers
If true
, the consumers are deployed as soon as the
runtime result is registered at the result manager of the task manager.
org.apache.flink.runtime.deployment.ResultPartitionLocation.LocationType locationType
ConnectionID connectionId
JobID jobID
JobVertexID vertexID
ExecutionAttemptID executionId
String taskName
int indexInSubtaskGroup
int numberOfSubtasks
int attemptNumber
Configuration jobConfiguration
Configuration taskConfiguration
String invokableClassName
List<E> producedPartitions
List<E> inputGates
int targetSlotNumber
List<E> requiredJarFiles
List<E> requiredClasspaths
SerializedValue<T> operatorState
long recoveryTimestamp
ExecutionVertex vertex
ExecutionAttemptID attemptId
long[] stateTimestamps
int attemptNumber
scala.concurrent.duration.FiniteDuration timeout
ConcurrentLinkedQueue<E> partialInputChannelDeploymentDescriptors
ExecutionState state
SimpleSlot assignedResource
Throwable failureCause
InstanceConnectionInfo assignedResourceLocation
SerializedValue<T> operatorState
long recoveryTimestamp
scala.concurrent.ExecutionContext executionContext
SerializableObject accumulatorLock
Map<K,V> userAccumulators
Map<K,V> flinkAccumulators
SerializableObject progressLock
JobID jobID
String jobName
Configuration jobConfiguration
boolean isStoppable
true
if all source tasks are stoppable.ConcurrentHashMap<K,V> tasks
List<E> verticesInCreationOrder
ConcurrentHashMap<K,V> intermediateResults
ConcurrentHashMap<K,V> currentExecutions
List<E> requiredJarFiles
List<E> requiredClasspaths
List<E> jobStatusListenerActors
List<E> executionListenerActors
long[] stateTimestamps
System.currentTimeMillis()
when
the execution graph transitioned into a certain state. The index into this array is the
ordinal of the enum value, i.e. the timestamp when the graph went into state "RUNNING" is
at stateTimestamps[RUNNING.ordinal()]
.scala.concurrent.duration.FiniteDuration timeout
boolean allowQueuedScheduling
ScheduleMode scheduleMode
boolean isArchived
JobStatus state
Throwable failureCause
int numFinishedJobVertices
Scheduler scheduler
RestartStrategy restartStrategy
ClassLoader userClassLoader
CheckpointCoordinator checkpointCoordinator
CheckpointStatsTracker checkpointStatsTracker
scala.concurrent.ExecutionContext executionContext
ExecutionConfig executionConfig
String jsonPlan
TaskDeploymentDescriptor lastTDD
SerializableObject stateMonitor
ExecutionGraph graph
JobVertex jobVertex
ExecutionVertex[] taskVertices
IntermediateResult[] producedDataSets
List<E> inputs
int parallelism
boolean[] finishedSubtasks
int numSubtasksInFinalState
SlotSharingGroup slotSharingGroup
CoLocationGroup coLocationGroup
InputSplit[] inputSplits
List<E>[] inputSplitsPerSubtask
InputSplitAssigner splitAssigner
ExecutionJobVertex jobVertex
Map<K,V> resultPartitions
ExecutionEdge[][] inputEdges
int subTaskIndex
List<E> priorExecutions
scala.concurrent.duration.FiniteDuration timeout
CoLocationConstraint locationConstraint
Execution currentExecution
List<E> locationConstraintInstances
boolean scheduleLocalOnly
TaskMessages.TaskOperationResult[] results
int index
TaskMessages.TaskOperationResult result
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
akka.actor.ActorRef actor
UUID leaderSessionID
MessageDecorator decorator
scala.concurrent.ExecutionContext executionContext
String path
int numberOfCPUCores
long sizeOfPhysicalMemory
long sizeOfJvmHeap
long sizeOfManagedMemory
InetAddress inetAddress
int dataPort
String fqdnHostName
String hostName
Instance instance
boolean closed
InetSocketAddress address
int connectionIndex
SocketAddress address
ResultPartitionID partitionId
String causeAsString
IntermediateResultPartitionID partitionId
ExecutionAttemptID producerId
int expectedSequenceNumber
int actualSequenceNumber
String formatDescription
IntermediateDataSetID id
JobVertex producer
List<E> consumers
ResultPartitionType resultType
boolean eagerlyDeployConsumers
If true
, the consumers are deployed as soon as the
runtime result is registered at the result manager of the task manager.
JobVertex target
DistributionPattern distributionPattern
IntermediateDataSet source
IntermediateDataSetID sourceId
String shipStrategyName
String preProcessingOperationName
String operatorLevelCachingDescription
Map<K,V> taskVertices
Configuration jobConfiguration
List<E> userJars
List<E> userJarBlobKeys
JobID jobID
String jobName
RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration
long sessionTimeout
boolean allowQueuedScheduling
ScheduleMode scheduleMode
JobSnapshottingSettings snapshotSettings
List<E> classpaths
JobVertexID id
ArrayList<E> results
ArrayList<E> inputs
int parallelism
Configuration configuration
String invokableClassName
boolean isStoppable
InputSplitSource<T extends InputSplit> inputSplitSource
String name
SlotSharingGroup slotSharingGroup
CoLocationGroup coLocationGroup
String operatorName
String operatorDescription
String operatorPrettyName
String resultOptimizerProperties
String formatDescription
List<E> verticesToTrigger
List<E> verticesToAcknowledge
List<E> verticesToConfirm
long checkpointInterval
long checkpointTimeout
long minPauseBetweenCheckpoints
int maxConcurrentCheckpoints
String savepointPath
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
scala.concurrent.duration.FiniteDuration duration
akka.util.Timeout timeout
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
long waitingTime
boolean finished
akka.actor.ActorSystem org$apache$flink$runtime$jobmanager$JobManagerRegistrationTest$$_system
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
private Object readResolve()
int NUM_TASKS
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
boolean invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected
org.scalatest.Matchers.KeyWord key
org.scalatest.Matchers.ValueWord value
org.scalatest.Matchers.AWord a
org.scalatest.Matchers.AnWord an
org.scalatest.Matchers.TheSameInstanceAsPhrase theSameInstanceAs
org.scalatest.Matchers.RegexWord regex
org.scalactic.Explicitly.DecidedWord decided
org.scalactic.Explicitly.DeterminedWord determined
org.scalactic.Explicitly.TheAfterWord after
org.scalatest.words.FullyMatchWord fullyMatch
org.scalatest.words.StartWithWord startWith
org.scalatest.words.EndWithWord endWith
org.scalatest.words.IncludeWord include
org.scalatest.words.HaveWord have
org.scalatest.words.BeWord be
org.scalatest.words.ContainWord contain
org.scalatest.words.NotWord not
org.scalatest.words.LengthWord length
org.scalatest.words.SizeWord size
org.scalatest.words.SortedWord sorted
org.scalatest.words.DefinedWord defined
org.scalatest.words.NoExceptionWord noException
org.scalatest.words.ExistWord exist
org.scalatest.words.ReadableWord readable
org.scalatest.words.WritableWord writable
org.scalatest.words.EmptyWord empty
org.scalatest.words.CompileWord compile
org.scalatest.words.TypeCheckWord typeCheck
org.scalatest.words.MatchPatternWord matchPattern
org.scalatest.Engine org$scalatest$WordSpecLike$$engine
org.scalatest.WordSpecLike.ItWord it
org.scalatest.WordSpecLike.TheyWord they
org.scalatest.words.StringVerbBlockRegistration subjectRegistrationFunction
scala.Function3<T1,T2,T3,R> subjectWithAfterWordRegistrationFunction
org.scalatest.words.BehaveWord behave
String styleName
org.scalatest.Assertions.AssertionsHelper assertionsHelper
org.scalatest.Matchers.AllCollected$ org$scalatest$Matchers$$AllCollected$module
org.scalatest.Matchers.EveryCollected$ org$scalatest$Matchers$$EveryCollected$module
org.scalatest.Matchers.BetweenCollected$ org$scalatest$Matchers$$BetweenCollected$module
org.scalatest.Matchers.AtLeastCollected$ org$scalatest$Matchers$$AtLeastCollected$module
org.scalatest.Matchers.AtMostCollected$ org$scalatest$Matchers$$AtMostCollected$module
org.scalatest.Matchers.NoCollected$ org$scalatest$Matchers$$NoCollected$module
org.scalatest.Matchers.ExactlyCollected$ org$scalatest$Matchers$$ExactlyCollected$module
org.scalatest.Matchers.ShouldMethodHelper$ org$scalatest$Matchers$$ShouldMethodHelper$module
org.scalatest.Suite.NoArgTest$ NoArgTest$module
AbstractID id
List<E> vertices
JobID job
ExecutionAttemptID taskExecutionId
long checkpointId
SerializedValue<T> state
long stateSize
long timestamp
long timestamp
long timestamp
int numJobsRunningOrPending
int numJobsFinished
int numJobsCancelled
int numJobsFailed
JobDetails[] runningJobs
JobDetails[] finishedJobs
boolean includeRunning
boolean includeFinished
private Object readResolve()
private Object readResolve()
private Object readResolve()
int numTaskManagersConnected
int numSlotsTotal
int numSlotsAvailable
int cnt
int cnt
Record res
int cnt
IntValue theInteger
int cnt
int cnt
int cnt
StringBuilder bld
int cnt
int cnt
int cnt
Integer count
boolean opened
boolean closed
boolean opened
boolean closed
int val
int size
int val
boolean isLong
int val
TypeComparatorFactory<T> typeComparator
int parallelism
TypeComparatorFactory<T> comparatorFactory
Configuration config
Configuration backingConfig
String prefix
TypeSerializer<T> elementSerializer
Serializable state
long checkpointId
byte[] serializedData
int numIds
Path filePath
TypeSerializer<T> keySerializer
TypeSerializer<T> namespaceSerializer
TypeSerializer<T> stateSerializer
StateDescriptor<S extends State,T> stateDesc
Path basePath
int fileStateThreshold
TypeSerializer<T> keySerializer
TypeSerializer<T> namespaceSerializer
TypeSerializer<T> stateSerializer
StateDescriptor<S extends State,T> stateDesc
byte[] data
byte[] data
int maxStateSize
byte[] serializedData
JobID jobID
ExecutionAttemptID executionId
ExecutionState executionState
SerializedThrowable throwable
AccumulatorSnapshot accumulators
String hostname
Configuration configuration
UUID leaderSessionID
UUID leaderSessionID
akka.actor.ActorRef testActor
byte[] buffer
int end
int position
byte[] serializedException
String originalErrorClassName
String fullStingifiedStackTrace
Exception placeholder
int numberOfTaskManagers
int numberOfSlots
backtype.storm.task.OutputCollector collector
String exclamation
boolean split
Random r
backtype.storm.spout.SpoutOutputCollector collector
boolean evenOrOdd
String token
backtype.storm.task.OutputCollector collector
StringBuilder lineBuilder
String prefix
OutputFormatter formatter
backtype.storm.spout.SpoutOutputCollector collector
String path
BufferedWriter writer
String path
BufferedReader reader
String line
boolean newLineRead
Object[] source
int counter
backtype.storm.topology.IRichSpout spout
org.apache.flink.storm.util.SpoutOutputCollectorObserver observer
backtype.storm.task.OutputCollector collector
backtype.storm.task.OutputCollector collector
String sentence
backtype.storm.topology.IRichBolt bolt
bolt
.String name
HashMap<K,V> numberOfAttributes
backtype.storm.generated.StormTopology stormTopology
HashMap<K,V> inputStreamIds
HashMap<K,V> inputComponentIds
HashMap<K,V> inputSchemas
HashMap<K,V> numberOfAttributes
backtype.storm.topology.IRichSpout spout
spout
.String name
boolean isRunning
Integer numberOfInvocations
ISpout.nextTuple()
calls.backtype.storm.generated.StormTopology stormTopology
CheckpointingMode checkpointingMode
long checkpointInterval
long checkpointTimeout
long minPauseBetweenCheckpoints
int maxConcurrentCheckpoints
boolean forceCheckpointing
long currentTimestamp
AscendingTimestampExtractor.MonotonyViolationHandler violationHandler
long maxTimestamp
Comparator comparator
boolean byAggregate
boolean first
FieldAccessor<R,F> fieldAccessor
FieldAccessor<R,F> fieldAccessor
SumFunction adder
TypeSerializer<T> serializer
boolean isTuple
OutputFormat<IT> format
boolean cleanupCalled
boolean target
SerializableObject lock
SerializationSchema<T> schema
String hostName
int port
int maxNumRetries
boolean autoFlush
int retries
boolean isRunning
String path
ArrayList<E> tupleList
WriteFormat<IN> format
long millis
long lastTime
DeserializationSchema<T> schema
TypeInformation<T> typeInfo
InputFormat<OT,T extends InputSplit> format
boolean isRunning
TypeSerializer<T> serializer
byte[] elementsSerialized
int numElements
int numElementsEmitted
int numElementsToSkip
boolean isRunning
SplittableIterator<T> fullIterator
boolean isRunning
TypeSerializer<T> idSerializer
int numCheckpointsToKeep
String hostname
int port
char delimiter
long maxNumRetries
long delayBetweenRetries
boolean isRunning
long start
long end
long collected
boolean isRunning
FoldFunction<O,T> foldFunction
byte[] serializedInitialValue
TypeSerializer<T> accSerializer
FoldFunction<O,T> foldFunction
byte[] serializedInitialValue
TypeSerializer<T> accSerializer
ReduceFunction<T> reduceFunction
AllWindowFunction<IN,OUT,W extends Window> windowFunction
ReduceFunction<T> reduceFunction
WindowFunction<IN,OUT,KEY,W extends Window> windowFunction
ReduceFunction<T> reduceFunction
ReduceFunction<T> reduceFunction
int[] order
int fieldId
int fieldId
int[] indexes
Configuration config
String edgeId
StreamNode sourceVertex
StreamNode targetVertex
int typeNumber
List<E> selectedNames
StreamPartitioner<T> outputPartitioner
int id
Integer parallelism
Long bufferTimeout
String operatorName
String slotSharingGroup
KeySelector<IN,KEY> statePartitioner1
KeySelector<IN,KEY> statePartitioner2
TypeSerializer<T> stateKeySerializer
List<E> outputSelectors
TypeSerializer<T> typeSerializerIn1
TypeSerializer<T> typeSerializerIn2
TypeSerializer<T> typeSerializerOut
List<E> inEdges
List<E> outEdges
Class<T> jobVertexClass
InputFormat<OT,T extends InputSplit> inputFormat
String transformationId
ChainingStrategy chainingStrategy
boolean inputCopyDisabled
AbstractStateBackend stateBackend
Function userFunction
Long count
byte[] serializedInitialValue
TypeSerializer<T> outTypeSerializer
TypeSerializer<T> serializer
TypeSerializer<T> outSerializer
int[] fields
int numFields
long combinedWatermark
long input1Watermark
long input2Watermark
long combinedWatermark
long input1Watermark
long input2Watermark
long size
long slide
long size
long slide
long size
long size
long maxCount
DeltaFunction<DATA> deltaFunction
double threshold
long windowSize
long interval
ValueStateDescriptor<T> stateDesc
long interval
ValueStateDescriptor<T> stateDesc
long maxCount
ValueStateDescriptor<T> stateDesc
DeltaFunction<DATA> deltaFunction
double threshold
ValueStateDescriptor<T> stateDesc
Map<K,V> userConfig
List<E> transportNodes
IndexRequestBuilder<T> indexRequestBuilder
IndexRequest
from the incoming element.AtomicBoolean hasFailure
AtomicReference<V> failureThrowable
boolean initDone
String host
int port
SerializationSchema<T> schema
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
String formatString
long DEFAULT_BATCH_SIZE
String DEFAULT_IN_PROGRESS_SUFFIX
String DEFAULT_IN_PROGRESS_PREFIX
String DEFAULT_PENDING_SUFFIX
String DEFAULT_PENDING_PREFIX
String DEFAULT_VALID_SUFFIX
String DEFAULT_VALID_PREFIX
String DEFAULT_PART_REFIX
long DEFAULT_ASYNC_TIMEOUT_MS
String basePath
Path
that stored all rolling bucket directories.Bucketer bucketer
Bucketer
that is used to determine the path of bucket directories.Writer<T> writerTemplate
Writer<T> writer
long batchSize
boolean cleanupOnOpen
This should only be set to false if using the sink without checkpoints, to not remove the files already in the directory.
String inProgressSuffix
String inProgressPrefix
String pendingSuffix
String pendingPrefix
String validLengthSuffix
String validLengthPrefix
String partPrefix
long asyncTimeout
String charsetName
List<E> partitionInfos
Properties props
Properties properties
List<E> partitionInfos
String consumerId
KeyedDeserializationSchema<T> deserializer
org.apache.commons.collections.map.LinkedMap pendingCheckpoints
boolean running
int[] partitions
Properties producerConfig
String topicId
KeyedSerializationSchema<T> schema
KafkaPartitioner<T> partitioner
String producerId
boolean logFailuresOnly
String topic
int partition
int cachedHash
int leaderId
int leaderPort
String leaderHost
KafkaTopicPartition topicPartition
int cachedHash
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.flink.streaming.connectors.kafka.internals.metrics.AvgKafkaMetricAccumulator.AvgSumCount lastSumCount
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
boolean isMerged
double mergedValue
int targetPartition
org.apache.nifi.remote.client.SiteToSiteClient client
org.apache.nifi.remote.client.SiteToSiteClientConfig clientConfig
NiFiDataPacketBuilder<T> builder
long waitTimeMs
org.apache.nifi.remote.client.SiteToSiteClient client
org.apache.nifi.remote.client.SiteToSiteClientConfig clientConfig
String QUEUE_NAME
String HOST_NAME
SerializationSchema<T> schema
String authPath
int queueSize
int waitSec
int maxNumberOfTweets
int currentNumberOfTweets
String[] record
boolean isRunning
int counter
int counter
int counter
long counter
long currentWatermark
Function function
KeySelector<IN,KEY> keySelector
TypeSerializer<T> keySerializer
TypeSerializer<T> stateTypeSerializer
long windowSize
long windowSlide
long paneSize
int numPanesPerWindow
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
WindowAssigner<T,W extends Window> windowAssigner
Trigger<T,W extends Window> trigger
WindowBufferFactory<T,O,B extends WindowBuffer<T,O>> windowBufferFactory
TypeSerializer<T> inputSerializer
TypeSerializer<T> windowSerializer
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
WindowAssigner<T,W extends Window> windowAssigner
KeySelector<IN,KEY> keySelector
Trigger<T,W extends Window> trigger
StateDescriptor<S extends State,T> windowStateDescriptor
TypeSerializer<T> inputSerializer
TypeSerializer<T> keySerializer
TypeSerializer<T> windowSerializer
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
FoldFunction<O,T> foldFunction
TypeSerializer<T> accSerializer
TypeSerializer<T> serializer
ReduceFunction<T> reduceFunction
TypeSerializer<T> serializer
int[] returnArray
boolean set
int setNumber
int[] returnArray
Partitioner<K> partitioner
KeySelector<IN,KEY> keySelector
int[] returnArray
int[] returnArray
int[] returnArray
KeySelector<IN,KEY> keySelector
int[] returnArray
int[] returnArray
Random random
int[] returnArray
TypeSerializer<T> typeSerializer
TypeSerializer<T> typeSerializer
StateHandle<T> operatorState
StateHandle<T> functionState
HashMap<K,V> kvStates
StreamTaskState[] states
TypeInformation<T> fieldType
int pos
PojoComparator<T> comparator
int pos
TupleSerializerBase<T> serializer
Object[] fields
int length
int pos
TypeComparator<T> comparator
int keyLength
Object[] keyArray
TypeComparator<T> comparator
Object[] keyArray
DeserializationSchema<T> deserializationSchema
SerializationSchema<T> serializationSchema
TypeSerializer<T> keySerializer
TypeSerializer<T> valueSerializer
DataInputDeserializer inputDeserializer
TypeSerializer<T> serializer
boolean value
byte value
char value
double value
float value
int value
int fieldNumber
long value
int fieldPos
int fieldNumber
org.apache.flink.types.Record.InternalDeSerializer serializer
byte[] binaryData
byte[] switchBuffer
int[] offsets
int[] lengths
Value[] readFields
Value[] writeFields
int binaryLen
int numFields
int firstModifiedPos
short value
char[] value
int len
int hashCode
long upperPart
long lowerPart
String toString
long to
long current
byte[] serializedData
StringValue toTokenize
int pos
int limit
long seed
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.