MOA 12.03
Real Time Analytics for Data Streams
|
Interface representing a data stream of instances. More...
Public Member Functions | |
InstancesHeader | getHeader () |
Gets the header of this stream. | |
long | estimatedRemainingInstances () |
Gets the estimated number of remaining instances in this stream. | |
boolean | hasMoreInstances () |
Gets whether this stream has more instances to output. | |
Instance | nextInstance () |
Gets the next instance from this stream. | |
boolean | isRestartable () |
Gets whether this stream can restart. | |
void | restart () |
Restarts this stream. |
Interface representing a data stream of instances.
Definition at line 32 of file InstanceStream.java.
long moa.streams.InstanceStream.estimatedRemainingInstances | ( | ) |
Gets the estimated number of remaining instances in this stream.
Implemented in moa.streams.ArffFileStream, moa.streams.CachedInstancesStream, moa.streams.clustering.FileStream, moa.streams.clustering.RandomRBFGeneratorEvents, moa.streams.ConceptDriftRealStream, moa.streams.ConceptDriftStream, moa.streams.FilteredStream, moa.streams.filters.AbstractStreamFilter, moa.streams.generators.AgrawalGenerator, moa.streams.generators.HyperplaneGenerator, moa.streams.generators.LEDGenerator, moa.streams.generators.multilabel.MetaMultilabelGenerator, moa.streams.generators.RandomRBFGenerator, moa.streams.generators.RandomTreeGenerator, moa.streams.generators.SEAGenerator, moa.streams.generators.STAGGERGenerator, and moa.streams.generators.WaveformGenerator.
Referenced by weka.datagenerators.classifiers.classification.MOA.defineDataFormat(), moa.tasks.LearnModel.doMainTask(), moa.tasks.EvaluatePrequential.doMainTask(), moa.tasks.EvaluateModel.doMainTask(), moa.tasks.EvaluateInterleavedTestThenTrain.doMainTask(), moa.tasks.EvaluateInterleavedChunks.doMainTask(), moa.tasks.CacheShuffledStream.doTaskImpl(), moa.streams.FilteredStream.estimatedRemainingInstances(), moa.streams.ConceptDriftStream.estimatedRemainingInstances(), and moa.streams.filters.AbstractStreamFilter.estimatedRemainingInstances().
InstancesHeader moa.streams.InstanceStream.getHeader | ( | ) |
Gets the header of this stream.
This is useful to know attributes and classes. InstancesHeader is an extension of weka.Instances.
Implemented in moa.streams.ArffFileStream, moa.streams.CachedInstancesStream, moa.streams.clustering.FileStream, moa.streams.clustering.RandomRBFGeneratorEvents, moa.streams.ConceptDriftRealStream, moa.streams.ConceptDriftStream, moa.streams.FilteredStream, moa.streams.filters.AddNoiseFilter, moa.streams.generators.AgrawalGenerator, moa.streams.generators.HyperplaneGenerator, moa.streams.generators.LEDGenerator, moa.streams.generators.multilabel.MetaMultilabelGenerator, moa.streams.generators.multilabel.MultilabelArffFileStream, moa.streams.generators.RandomRBFGenerator, moa.streams.generators.RandomTreeGenerator, moa.streams.generators.SEAGenerator, moa.streams.generators.STAGGERGenerator, and moa.streams.generators.WaveformGenerator.
Referenced by weka.datagenerators.classifiers.classification.MOA.defineDataFormat(), moa.tasks.WriteStreamToARFFFile.doMainTask(), moa.tasks.LearnModel.doMainTask(), moa.tasks.EvaluatePrequential.doMainTask(), moa.tasks.EvaluatePeriodicHeldOutTest.doMainTask(), moa.tasks.EvaluateInterleavedTestThenTrain.doMainTask(), moa.tasks.EvaluateInterleavedChunks.doMainTask(), moa.tasks.CacheShuffledStream.doTaskImpl(), moa.streams.FilteredStream.getHeader(), moa.streams.ConceptDriftStream.getHeader(), moa.streams.filters.AddNoiseFilter.getHeader(), moa.streams.ConceptDriftRealStream.prepareForUseImpl(), and moa.streams.generators.multilabel.MetaMultilabelGenerator.restart().
boolean moa.streams.InstanceStream.hasMoreInstances | ( | ) |
Gets whether this stream has more instances to output.
This is useful when reading streams from files.
Implemented in moa.streams.ArffFileStream, moa.streams.CachedInstancesStream, moa.streams.clustering.FileStream, moa.streams.clustering.RandomRBFGeneratorEvents, moa.streams.ConceptDriftRealStream, moa.streams.ConceptDriftStream, moa.streams.FilteredStream, moa.streams.filters.AbstractStreamFilter, moa.streams.generators.AgrawalGenerator, moa.streams.generators.HyperplaneGenerator, moa.streams.generators.LEDGenerator, moa.streams.generators.multilabel.MetaMultilabelGenerator, moa.streams.generators.RandomRBFGenerator, moa.streams.generators.RandomTreeGenerator, moa.streams.generators.SEAGenerator, moa.streams.generators.STAGGERGenerator, and moa.streams.generators.WaveformGenerator.
Referenced by moa.tasks.WriteStreamToARFFFile.doMainTask(), moa.tasks.LearnModel.doMainTask(), moa.tasks.EvaluatePrequential.doMainTask(), moa.tasks.EvaluatePeriodicHeldOutTest.doMainTask(), moa.tasks.EvaluateModel.doMainTask(), moa.tasks.EvaluateInterleavedTestThenTrain.doMainTask(), moa.tasks.EvaluateInterleavedChunks.doMainTask(), moa.tasks.CacheShuffledStream.doTaskImpl(), weka.datagenerators.classifiers.classification.MOA.generateExample(), moa.streams.FilteredStream.hasMoreInstances(), moa.streams.ConceptDriftStream.hasMoreInstances(), moa.streams.filters.AbstractStreamFilter.hasMoreInstances(), moa.streams.ConceptDriftRealStream.nextInstance(), moa.gui.BatchCmd.run(), and moa.gui.visualization.RunVisualizer.runVisual().
boolean moa.streams.InstanceStream.isRestartable | ( | ) |
Gets whether this stream can restart.
Implemented in moa.streams.ArffFileStream, moa.streams.CachedInstancesStream, moa.streams.clustering.FileStream, moa.streams.clustering.RandomRBFGeneratorEvents, moa.streams.ConceptDriftRealStream, moa.streams.ConceptDriftStream, moa.streams.FilteredStream, moa.streams.filters.AbstractStreamFilter, moa.streams.generators.AgrawalGenerator, moa.streams.generators.HyperplaneGenerator, moa.streams.generators.LEDGenerator, moa.streams.generators.multilabel.MetaMultilabelGenerator, moa.streams.generators.RandomRBFGenerator, moa.streams.generators.RandomTreeGenerator, moa.streams.generators.SEAGenerator, moa.streams.generators.STAGGERGenerator, and moa.streams.generators.WaveformGenerator.
Referenced by moa.streams.FilteredStream.isRestartable(), moa.streams.ConceptDriftStream.isRestartable(), moa.streams.ConceptDriftRealStream.isRestartable(), and moa.streams.filters.AbstractStreamFilter.isRestartable().
Instance moa.streams.InstanceStream.nextInstance | ( | ) |
Gets the next instance from this stream.
Implemented in moa.streams.ArffFileStream, moa.streams.CachedInstancesStream, moa.streams.clustering.FileStream, moa.streams.clustering.RandomRBFGeneratorEvents, moa.streams.ConceptDriftRealStream, moa.streams.ConceptDriftStream, moa.streams.FilteredStream, moa.streams.filters.AddNoiseFilter, moa.streams.generators.AgrawalGenerator, moa.streams.generators.HyperplaneGenerator, moa.streams.generators.LEDGenerator, moa.streams.generators.LEDGeneratorDrift, moa.streams.generators.multilabel.MetaMultilabelGenerator, moa.streams.generators.RandomRBFGenerator, moa.streams.generators.RandomRBFGeneratorDrift, moa.streams.generators.RandomTreeGenerator, moa.streams.generators.SEAGenerator, moa.streams.generators.STAGGERGenerator, moa.streams.generators.WaveformGenerator, and moa.streams.generators.WaveformGeneratorDrift.
Referenced by moa.tasks.WriteStreamToARFFFile.doMainTask(), moa.tasks.MeasureStreamSpeed.doMainTask(), moa.tasks.LearnModel.doMainTask(), moa.tasks.EvaluatePrequential.doMainTask(), moa.tasks.EvaluatePeriodicHeldOutTest.doMainTask(), moa.tasks.EvaluateModel.doMainTask(), moa.tasks.EvaluateInterleavedTestThenTrain.doMainTask(), moa.tasks.EvaluateInterleavedChunks.doMainTask(), moa.tasks.CacheShuffledStream.doTaskImpl(), weka.datagenerators.classifiers.classification.MOA.generateExample(), moa.streams.FilteredStream.nextInstance(), moa.streams.ConceptDriftStream.nextInstance(), moa.streams.ConceptDriftRealStream.nextInstance(), moa.streams.filters.AddNoiseFilter.nextInstance(), moa.streams.ConceptDriftRealStream.restart(), moa.gui.BatchCmd.run(), and moa.gui.visualization.RunVisualizer.runVisual().
void moa.streams.InstanceStream.restart | ( | ) |
Restarts this stream.
It must be similar to starting a new stream from scratch.
Implemented in moa.streams.ArffFileStream, moa.streams.CachedInstancesStream, moa.streams.clustering.FileStream, moa.streams.clustering.RandomRBFGeneratorEvents, moa.streams.ConceptDriftRealStream, moa.streams.ConceptDriftStream, moa.streams.FilteredStream, moa.streams.filters.AbstractStreamFilter, moa.streams.generators.AgrawalGenerator, moa.streams.generators.HyperplaneGenerator, moa.streams.generators.LEDGenerator, moa.streams.generators.multilabel.MetaMultilabelGenerator, moa.streams.generators.RandomRBFGenerator, moa.streams.generators.RandomTreeGenerator, moa.streams.generators.SEAGenerator, moa.streams.generators.STAGGERGenerator, and moa.streams.generators.WaveformGenerator.
Referenced by moa.tasks.LearnModel.doMainTask(), moa.tasks.EvaluatePeriodicHeldOutTest.doMainTask(), moa.streams.ConceptDriftRealStream.nextInstance(), moa.streams.generators.multilabel.MetaMultilabelGenerator.restart(), moa.streams.FilteredStream.restart(), moa.streams.ConceptDriftStream.restart(), moa.streams.ConceptDriftRealStream.restart(), and moa.streams.filters.AbstractStreamFilter.restart().