MOA 12.03
Real Time Analytics for Data Streams
moa.streams.InstanceStream Interface Reference

Interface representing a data stream of instances. More...

Inheritance diagram for moa.streams.InstanceStream:
Collaboration diagram for moa.streams.InstanceStream:

List of all members.

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.

Detailed Description

Interface representing a data stream of instances.

Author:
Richard Kirkby (rkirkby@cs.waikato.ac.nz)
Version:
Revision:
7

Definition at line 32 of file InstanceStream.java.


Member Function Documentation

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.

Returns:
the header of 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.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().

Here is the caller graph for this function:

boolean moa.streams.InstanceStream.hasMoreInstances ( )

Gets whether this stream has more instances to output.

This is useful when reading streams from files.

Returns:
true if this stream has more instances to output

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().

Here is the caller graph for this function:

Instance moa.streams.InstanceStream.nextInstance ( )

Gets the next instance from this stream.

Returns:
the next instance of 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().

Here is the caller graph for this function:


The documentation for this interface was generated from the following file:
 All Classes Namespaces Files Functions Variables Enumerations