double[] doubleArray
double weightObserved
double weightCorrect
double[] columnKappa
double[] rowKappa
int numClasses
double weightCorrectNoChangeClassifier
int lastSeenClass
double weightObserved
double squareError
double averageError
double sumTarget
double squareTargetError
double averageTargetError
Clustering gtClustering
DataPoint dataPoint
boolean isLast
String key
int samplingFrequency
int decayHorizon
File dumpFile
long totalCount
long experimentStart
LearningCurve learningCurve
MeasureCollection[] measures
int id
Clustering gtClustering
ArrayList<E> points
Clustering clustering
boolean isLast
String key
PerformanceEvaluator evaluator
int samplingFrequency
File dumpFile
long totalCount
long experimentStart
long sampleStart
LearningCurve learningCurve
int id
com.github.javacliparser.IntOption widthOption
double TotalweightObserved
WindowClassificationPerformanceEvaluator.Estimator weightObserved
WindowClassificationPerformanceEvaluator.Estimator weightCorrect
WindowClassificationPerformanceEvaluator.Estimator weightCorrectNoChangeClassifier
double lastSeenClass
WindowClassificationPerformanceEvaluator.Estimator[] columnKappa
WindowClassificationPerformanceEvaluator.Estimator[] rowKappa
WindowClassificationPerformanceEvaluator.Estimator[] classAccuracy
int numClasses
Clustering clustering
CMM_GTAnalysis gtAnalysis
int numPoints
int numFClusters
int numGT0Classes
int[] matchMap
double[][] pointInclusionProbFC
double pointInclusionProbThreshold
double lamdaMissed
boolean debug
boolean enableClassMerge
boolean enableModelError
DataPoint p
int pID
int trueClass
double connectivity
double knnInCluster
ArrayList<E> knnIndices
int numPoints
int numFClusters
int numDims
double pointInclusionProbThreshold
Clustering clustering
ArrayList<E> points
boolean debug
boolean isLastEvent
int helloWorldData
int processorId
Random rnd
long maxInst
long count
TopologyBuilder builder
Topology helloWorldTopology
com.github.javacliparser.IntOption instanceLimitOption
com.github.javacliparser.IntOption helloWorldParallelismOption
com.github.javacliparser.StringOption evaluationNameOption
FlinkComponent procItem
int sourcePiId
String flinkStreamId
InstanceInformation instanceInformation
Reader reader
int size
int classAttribute
List<E> attributes
double[] attributeValues
InstanceInformation instanceInformation
List<E> instances
int classAttribute
double classValue
double weight
InstanceData instanceData
InstanceData classData
InstancesHeader instanceInformation
double[] attributeValues
int[] indexValues
int numberAttributes
long instanceIndex
int classifierIndex
int evaluationIndex
SerializableInstance instance
boolean isTraining
boolean isTesting
boolean isLast
long instanceIndex
int classifierIndex
int evaluationIndex
SerializableInstance instance
int classId
double[] classVotes
boolean isLast
LocalLearner model
Stream outputStream
int modelId
long instancesCount
int test
ChangeDetector changeDetector
com.github.javacliparser.ClassOption learnerOption
Classifier learner
Boolean isInit
Instances dataset
LocalLearnerProcessor learnerP
Stream resultStream
Instances dataset
com.github.javacliparser.ClassOption learnerOption
TopologyBuilder builder
int parallelism
ChangeDetector changeDetector
com.github.javacliparser.ClassOption baseLearnerOption
com.github.javacliparser.IntOption ensembleSizeOption
com.github.javacliparser.ClassOption driftDetectionMethodOption
BaggingDistributorProcessor distributorP
Stream[] ensembleStreams
Stream resultStream
Instances dataset
AdaptiveLearner[] ensemble
TopologyBuilder builder
com.github.javacliparser.ClassOption baseLearnerOption
com.github.javacliparser.IntOption ensembleSizeOption
BaggingDistributorProcessor distributorP
Stream[] ensembleStreams
Stream resultStream
Instances dataset
Learner[] ensemble
TopologyBuilder builder
com.github.javacliparser.ClassOption baseLearnerOption
com.github.javacliparser.IntOption ensembleSizeOption
BoostingDistributorProcessor distributorP
Stream resultStream
Instances dataset
Learner classifier
int parallelism
TopologyBuilder builder
com.github.javacliparser.FloatOption splitConfidenceOption
com.github.javacliparser.FloatOption tieThresholdOption
com.github.javacliparser.IntOption gracePeriodOption
com.github.javacliparser.FlagOption DriftDetectionOption
com.github.javacliparser.FloatOption pageHinckleyAlphaOption
com.github.javacliparser.IntOption pageHinckleyThresholdOption
com.github.javacliparser.FlagOption noAnomalyDetectionOption
com.github.javacliparser.FloatOption multivariateAnomalyProbabilityThresholdOption
com.github.javacliparser.FloatOption univariateAnomalyProbabilityThresholdOption
com.github.javacliparser.IntOption anomalyNumInstThresholdOption
com.github.javacliparser.FlagOption unorderedRulesOption
com.github.javacliparser.ClassOption numericObserverOption
com.github.javacliparser.MultiChoiceOption predictionFunctionOption
com.github.javacliparser.FlagOption constantLearningRatioDecayOption
com.github.javacliparser.FloatOption learningRatioOption
com.github.javacliparser.ClassOption votingTypeOption
AMRulesRegressorProcessor processor
Stream resultStream
com.github.javacliparser.FloatOption splitConfidenceOption
com.github.javacliparser.FloatOption tieThresholdOption
com.github.javacliparser.IntOption gracePeriodOption
com.github.javacliparser.FlagOption DriftDetectionOption
com.github.javacliparser.FloatOption pageHinckleyAlphaOption
com.github.javacliparser.IntOption pageHinckleyThresholdOption
com.github.javacliparser.FlagOption noAnomalyDetectionOption
com.github.javacliparser.FloatOption multivariateAnomalyProbabilityThresholdOption
com.github.javacliparser.FloatOption univariateAnomalyProbabilityThresholdOption
com.github.javacliparser.IntOption anomalyNumInstThresholdOption
com.github.javacliparser.FlagOption unorderedRulesOption
com.github.javacliparser.ClassOption numericObserverOption
com.github.javacliparser.MultiChoiceOption predictionFunctionOption
com.github.javacliparser.FlagOption constantLearningRatioDecayOption
com.github.javacliparser.FloatOption learningRatioOption
com.github.javacliparser.MultiChoiceOption votingTypeOption
com.github.javacliparser.IntOption learnerParallelismOption
com.github.javacliparser.IntOption ruleSetParallelismOption
AMRRuleSetProcessor model
Stream modelResultStream
Stream rootResultStream
com.github.javacliparser.FloatOption splitConfidenceOption
com.github.javacliparser.FloatOption tieThresholdOption
com.github.javacliparser.IntOption gracePeriodOption
com.github.javacliparser.FlagOption DriftDetectionOption
com.github.javacliparser.FloatOption pageHinckleyAlphaOption
com.github.javacliparser.IntOption pageHinckleyThresholdOption
com.github.javacliparser.FlagOption noAnomalyDetectionOption
com.github.javacliparser.FloatOption multivariateAnomalyProbabilityThresholdOption
com.github.javacliparser.FloatOption univariateAnomalyProbabilityThresholdOption
com.github.javacliparser.IntOption anomalyNumInstThresholdOption
com.github.javacliparser.FlagOption unorderedRulesOption
com.github.javacliparser.ClassOption numericObserverOption
com.github.javacliparser.MultiChoiceOption predictionFunctionOption
com.github.javacliparser.FlagOption constantLearningRatioDecayOption
com.github.javacliparser.FloatOption learningRatioOption
com.github.javacliparser.MultiChoiceOption votingTypeOption
com.github.javacliparser.IntOption parallelismHintOption
AMRulesAggregatorProcessor aggregator
Stream resultStream
int processorId
List<E> ruleSet
ActiveRule defaultRule
int ruleNumberID
double[] statistics
Stream resultStream
int pageHinckleyThreshold
double pageHinckleyAlpha
boolean driftDetection
int predictionFunction
boolean constantLearningRatioDecay
double learningRatio
double splitConfidence
double tieThreshold
int gracePeriod
boolean noAnomalyDetection
double multivariateAnomalyProbabilityThreshold
double univariateAnomalyprobabilityThreshold
int anomalyNumInstThreshold
boolean unorderedRules
FIMTDDNumericAttributeClassLimitObserver numericObserver
ErrorWeightedVote voteType
double[] statisticsOtherBranchSplit
ActiveRule.Builder builder
RuleActiveRegressionNode learningNode
RuleSplitNode lastUpdatedRuleSplitNode
boolean changeDetection
boolean usePerceptron
double threshold
double alpha
int predictionFunction
boolean constantLearningRatioDecay
double learningRatio
double[] statistics
FIMTDDNumericAttributeClassLimitObserver numericObserver
double lastTargetMean
int id
RulePassiveRegressionNode learningNode
double SD_THRESHOLD
boolean constantLearningRatioDecay
double originalLearningRatio
double nError
double fadingFactor
double learningRatio
double learningRateDecay
double[] weightAttribute
DoubleVector perceptronattributeStatistics
DoubleVector squaredperceptronattributeStatistics
int perceptronInstancesSeen
int perceptronYSeen
double accumulatedError
boolean initialisePerceptron
double perceptronsumY
double squaredperceptronsumY
boolean constantLearningRatioDecay
boolean initialisePerceptron
double nError
double fadingFactor
double originalLearningRatio
double learningRatio
double learningRateDecay
double accumulatedError
double perceptronsumY
double squaredperceptronsumY
double[] weightAttribute
DoubleVector perceptronattributeStatistics
DoubleVector squaredperceptronattributeStatistics
int perceptronInstancesSeen
int perceptronYSeen
int splitIndex
PageHinkleyTest pageHinckleyTest
boolean changeDetection
double[] statisticsNewRuleActiveLearningNode
double[] statisticsBranchSplit
double[] statisticsOtherBranchSplit
AttributeSplitSuggestion bestSuggestion
AutoExpandVector<T> attributeObservers
FIMTDDNumericAttributeClassLimitObserver numericObserver
int predictionFunction
int ruleNumberID
DoubleVector nodeStatistics
Perceptron perceptron
TargetMean targetMean
double learningRatio
double lastTargetMean
int operatorObserver
long n
double sum
double errorSum
double nError
double fadingErrorFactor
com.github.javacliparser.FloatOption fadingErrorFactorOption
int processorId
Stream ruleStream
Stream resultStream
int pageHinckleyThreshold
double pageHinckleyAlpha
boolean driftDetection
int predictionFunction
boolean constantLearningRatioDecay
double learningRatio
double splitConfidence
double tieThreshold
int gracePeriod
FIMTDDNumericAttributeClassLimitObserver numericObserver
int processorId
Stream outputStream
double splitConfidence
double tieThreshold
int gracePeriod
boolean noAnomalyDetection
double multivariateAnomalyProbabilityThreshold
double univariateAnomalyprobabilityThreshold
int anomalyNumInstThreshold
int processorId
Stream statisticsStream
Stream resultStream
Stream defaultRuleStream
boolean noAnomalyDetection
double multivariateAnomalyProbabilityThreshold
double univariateAnomalyprobabilityThreshold
int anomalyNumInstThreshold
boolean unorderedRules
int voteType
int processorId
Stream statisticsStream
Stream resultStream
int pageHinckleyThreshold
double pageHinckleyAlpha
boolean driftDetection
int predictionFunction
boolean constantLearningRatioDecay
double learningRatio
double splitConfidence
double tieThreshold
int gracePeriod
boolean noAnomalyDetection
double multivariateAnomalyProbabilityThreshold
double univariateAnomalyprobabilityThreshold
int anomalyNumInstThreshold
boolean unorderedRules
FIMTDDNumericAttributeClassLimitObserver numericObserver
int voteType
int processorId
Stream outputStream
double splitConfidence
double tieThreshold
int gracePeriod
int frequency
int ruleNumberID
Instance instance
int ruleNumberID
RuleSplitNode ruleSplitNode
RulePassiveRegressionNode learningNode
int ruleNumberID
ActiveRule addingRule
boolean isRemoving
long learningNodeId
int obsIndex
double attrVal
int classVal
double weight
boolean isNominal
double[] preSplitDist
long splitId
AutoExpandVector<T> children
InstanceConditionalTest splitTest
com.github.javacliparser.ClassOption numericEstimatorOption
com.github.javacliparser.ClassOption nominalEstimatorOption
com.github.javacliparser.ClassOption splitCriterionOption
com.github.javacliparser.FloatOption splitConfidenceOption
com.github.javacliparser.FloatOption tieThresholdOption
com.github.javacliparser.IntOption gracePeriodOption
com.github.javacliparser.IntOption parallelismHintOption
com.github.javacliparser.IntOption timeOutOption
com.github.javacliparser.FlagOption binarySplitsOption
Stream resultStream
org.apache.samoa.learners.classifiers.trees.FilterProcessor filterProc
ChangeDetector changeDetector
LocalClustererAdapter model
Stream outputStream
int modelId
long instancesCount
long sampleFrequency
LocalClustererProcessor learnerP
Stream resultStream
Instances dataset
com.github.javacliparser.ClassOption learnerOption
TopologyBuilder builder
int parallelism
Stream resultStream
Instances dataset
com.github.javacliparser.ClassOption learnerOption
com.github.javacliparser.IntOption paralellismOption
TopologyBuilder builder
LocalClustererProcessor learnerP
Stream localToGlobalStream
InstancesHeader modelContext
double trainingWeightSeenByModel
int randomSeed
com.github.javacliparser.IntOption randomSeedOption
Random classifierRandom
InstanceConditionalTest splitTest
double[][] resultingClassDistributions
double merit
double cut_point
DoubleVector classCountsLeft
DoubleVector classCountsRight
BinaryTreeNumericAttributeClassObserver.Node left
BinaryTreeNumericAttributeClassObserver.Node right
double cut_point
double[] lessThan
double[] greaterThan
BinaryTreeNumericAttributeClassObserverRegression.Node left
BinaryTreeNumericAttributeClassObserverRegression.Node right
org.apache.samoa.moa.classifiers.core.attributeclassobservers.FIMTDDNumericAttributeClassObserver.Node root
double sumTotalLeft
double sumTotalRight
double sumSqTotalLeft
double sumSqTotalRight
double countRightTotal
double countLeftTotal
double cut_point
DoubleVector leftStatistics
DoubleVector rightStatistics
org.apache.samoa.moa.classifiers.core.attributeclassobservers.FIMTDDNumericAttributeClassObserver.Node left
org.apache.samoa.moa.classifiers.core.attributeclassobservers.FIMTDDNumericAttributeClassObserver.Node right
DoubleVector minValueObservedPerClass
DoubleVector maxValueObservedPerClass
AutoExpandVector<T> attValDistPerClass
com.github.javacliparser.IntOption numBinsOption
AutoExpandVector<T> attValDistPerClass
com.github.javacliparser.IntOption numTuplesOption
double totalWeightObserved
double missingWeightObserved
AutoExpandVector<T> attValDistPerClass
double lowerBound
double upperBound
DoubleVector classWeights
int boundaryClass
double boundaryWeight
int attIndex
int attValue
int attIndex
int attIndex
double attValue
boolean equalsPassesTest
boolean isChangeDetected
boolean isWarningZone
double estimation
double delay
double mdbldelta
int mintTime
int mintClock
double mdblWidth
int lastBucketRow
double TOTAL
double VARIANCE
int WIDTH
int BucketNumber
int Detect
int numberDetections
int DetectTwice
boolean blnBucketDeleted
int BucketNumberMAX
int mintMinWinLength
org.apache.samoa.moa.classifiers.core.driftdetection.ADWIN.List listRowBuckets
ADWIN adwin
com.github.javacliparser.FloatOption deltaAdwinOption
com.github.javacliparser.IntOption minNumInstancesOption
com.github.javacliparser.FloatOption deltaOption
com.github.javacliparser.FloatOption lambdaOption
int m_n
double sum
double x_mean
double delta
double lambda
com.github.javacliparser.IntOption minNumInstancesOption
int m_n
double m_p
double m_s
double m_psmin
double m_pmin
double m_smin
double m_numErrors
int m_minNumErrors
int m_n
int m_d
int m_lastd
double m_mean
double m_stdTemp
double m_m2smax
com.github.javacliparser.IntOption minNumInstancesOption
com.github.javacliparser.FloatOption lambdaOption
double m_n
double m_sum
double m_p
double m_s
double lambda
double z_t
com.github.javacliparser.IntOption minNumInstancesOption
com.github.javacliparser.FloatOption lambdaOption
com.github.javacliparser.FloatOption alphaOption
double m_n
double sum
double x_mean
double alpha
double lambda
com.github.javacliparser.IntOption minNumInstancesOption
com.github.javacliparser.FloatOption deltaOption
com.github.javacliparser.FloatOption lambdaOption
com.github.javacliparser.FloatOption alphaOption
int m_n
double sum
double x_mean
double alpha
double delta
double lambda
com.github.javacliparser.FloatOption minBranchFracOption
DoubleVector observedClassDistribution
int maxNodes
int numNodes
org.apache.samoa.moa.classifiers.rules.core.attributeclassobservers.FIMTDDNumericAttributeClassLimitObserver.Node root
int attIndex
double attValue
int operator
double fadingFactor
double instancesSeen
double cumulativeSum
double minimumValue
double sumAbsolutError
long phinstancesSeen
double threshold
double alpha
double radiusFactor
double N
double[] LS
double[] SS
AutoExpandVector<T> clusters
double[] center
double radius
double weight
InstancesHeader modelContext
double trainingWeightSeenByModel
int randomSeed
com.github.javacliparser.IntOption randomSeedOption
com.github.javacliparser.FlagOption evaluateMicroClusteringOption
Random clustererRandom
Clustering clustering
com.github.javacliparser.IntOption timeWindowOption
com.github.javacliparser.FloatOption radiusDecreaseOption
com.github.javacliparser.FloatOption radiusIncreaseOption
com.github.javacliparser.FloatOption positionOffsetOption
com.github.javacliparser.FloatOption clusterRemoveOption
com.github.javacliparser.FloatOption joinClustersOption
com.github.javacliparser.FloatOption clusterAddOption
ArrayList<E> points
int instanceCounter
int windowCounter
Random random
Clustering sourceClustering
com.github.javacliparser.IntOption timeWindowOption
com.github.javacliparser.IntOption maxNumKernelsOption
com.github.javacliparser.IntOption kernelRadiFactorOption
int timeWindow
long timestamp
ClustreamKernel[] kernels
boolean initialized
List<E> buffer
int bufferSize
double t
int m
double LST
double SST
int m
double t
com.github.javacliparser.IntOption timeWindowOption
com.github.javacliparser.IntOption maxNumKernelsOption
com.github.javacliparser.IntOption kernelRadiFactorOption
com.github.javacliparser.IntOption kOption
int timeWindow
long timestamp
ClustreamKernel[] kernels
boolean initialized
List<E> buffer
int bufferSize
double t
int m
double[] array
double weightSum
double mean
double varianceSum
org.apache.samoa.moa.core.GreenwaldKhannaQuantileSummary.Tuple[] summary
int numTuples
long numObservations
double v
long g
long delta
int inputByteSize
int inputBytesRead
Instance instance
String name
double value
Measurement[] measurements
String[] names
ArrayList<E>[] values
ArrayList<E>[] sortedValues
ArrayList<E> events
double[] minValue
double[] maxValue
double[] sumValues
boolean[] enabled
boolean[] corrupted
double time
boolean debug
MembershipMatrix mm
HashMap<K,V> map
int numMeasures
OptionsHandler config
com.github.javacliparser.FileOption arffFileOption
com.github.javacliparser.IntOption classIndexOption
Instances instances
boolean hitEndOfFile
InstanceExample lastInstanceRead
int numInstancesRead
boolean hasStarted
com.github.javacliparser.IntOption decayHorizonOption
com.github.javacliparser.FloatOption decayThresholdOption
com.github.javacliparser.IntOption evaluationFrequencyOption
com.github.javacliparser.IntOption numAttsOption
com.github.javacliparser.IntOption modelRandomSeedOption
com.github.javacliparser.IntOption instanceRandomSeedOption
com.github.javacliparser.IntOption numClusterOption
com.github.javacliparser.IntOption numClusterRangeOption
com.github.javacliparser.FloatOption kernelRadiiOption
com.github.javacliparser.FloatOption kernelRadiiRangeOption
com.github.javacliparser.FloatOption densityRangeOption
com.github.javacliparser.IntOption speedOption
com.github.javacliparser.IntOption speedRangeOption
com.github.javacliparser.FloatOption noiseLevelOption
com.github.javacliparser.FlagOption noiseInClusterOption
com.github.javacliparser.IntOption eventFrequencyOption
com.github.javacliparser.FlagOption eventMergeSplitOption
com.github.javacliparser.FlagOption eventDeleteCreateOption
double merge_threshold
int kernelMovePointFrequency
double maxDistanceMoveThresholdByStep
int maxOverlapFitRuns
double eventFrequencyRange
boolean debug
AutoExpandVector<T> kernels
Random instanceRandom
InstancesHeader streamHeader
int numGeneratedInstances
int numActiveKernels
int nextEventCounter
int nextEventChoice
int clusterIdCounter
org.apache.samoa.moa.streams.clustering.RandomRBFGeneratorEvents.GeneratorCluster mergeClusterA
org.apache.samoa.moa.streams.clustering.RandomRBFGeneratorEvents.GeneratorCluster mergeClusterB
boolean mergeKernelsOverlapping
com.github.javacliparser.IntOption instanceRandomSeedOption
com.github.javacliparser.IntOption numClassesOption
com.github.javacliparser.IntOption numAttsOption
com.github.javacliparser.IntOption numDriftAttsOption
com.github.javacliparser.FloatOption magChangeOption
com.github.javacliparser.IntOption noisePercentageOption
com.github.javacliparser.IntOption sigmaPercentageOption
InstancesHeader streamHeader
Random instanceRandom
double[] weights
int[] sigma
int numberInstance
com.github.javacliparser.IntOption treeRandomSeedOption
com.github.javacliparser.IntOption instanceRandomSeedOption
com.github.javacliparser.IntOption numClassesOption
com.github.javacliparser.IntOption numNominalsOption
com.github.javacliparser.IntOption numNumericsOption
com.github.javacliparser.IntOption numValsPerNominalOption
com.github.javacliparser.IntOption maxTreeDepthOption
com.github.javacliparser.IntOption firstLeafLevelOption
com.github.javacliparser.FloatOption leafFractionOption
org.apache.samoa.moa.streams.generators.RandomTreeGenerator.Node treeRoot
InstancesHeader streamHeader
Random instanceRandom
int classLabel
int splitAttIndex
double splitAttValue
org.apache.samoa.moa.streams.generators.RandomTreeGenerator.Node[] children
com.github.javacliparser.FileOption arffFileOption
com.github.javacliparser.IntOption classIndexOption
InstanceExample lastInstanceRead
StreamSource streamSource
Instance firstInstance
boolean isInited
Random random
double samplingThreshold
int numberInstances
int numInstanceSent
int groundTruthSamplingFrequency
com.github.javacliparser.ClassOption sourceTypeOption
Instances instances
boolean hitEndOfStream
boolean hasStarted
boolean isInited
StreamSource streamSource
Instance firstInstance
int numberInstances
int numInstanceSent
InstanceStream sourceStream
int readyEventIndex
int delay
int batchSize
boolean finished
InstanceStream stream
StreamSource streamSource
long numberInstancesSent
boolean isInited
Instance firstInstance
com.github.javacliparser.ClassOption learnerOption
com.github.javacliparser.ClassOption streamTrainOption
com.github.javacliparser.IntOption instanceLimitOption
com.github.javacliparser.IntOption measureCollectionTypeOption
com.github.javacliparser.IntOption timeLimitOption
com.github.javacliparser.IntOption sampleFrequencyOption
com.github.javacliparser.StringOption evaluationNameOption
com.github.javacliparser.FileOption dumpFileOption
com.github.javacliparser.FloatOption samplingThresholdOption
ClusteringEntranceProcessor source
InstanceStream streamTrain
ClusteringDistributorProcessor distributor
Stream distributorStream
Stream evaluationStream
com.github.javacliparser.IntOption sourceDelayOption
Learner learner
ClusteringEvaluatorProcessor evaluator
Topology topology
TopologyBuilder builder
com.github.javacliparser.ClassOption learnerOption
com.github.javacliparser.ClassOption streamTrainOption
com.github.javacliparser.ClassOption evaluatorOption
com.github.javacliparser.IntOption instanceLimitOption
com.github.javacliparser.IntOption timeLimitOption
com.github.javacliparser.IntOption sampleFrequencyOption
com.github.javacliparser.StringOption evaluationNameOption
com.github.javacliparser.FileOption dumpFileOption
com.github.javacliparser.IntOption sourceDelayOption
com.github.javacliparser.IntOption batchDelayOption
PrequentialSourceProcessor preqSource
Stream sourcePiOutputStream
Learner classifier
EvaluatorProcessor evaluator
Topology prequentialTopology
TopologyBuilder builder
private Object writeReplace()
String system
String stream
PartitioningScheme scheme
int parallelism
Copyright © 2013–2015 The Apache Software Foundation. All rights reserved.