public abstract class DataStream
extends org.apache.samoa.streams.clustering.ClusteringStream
Modifier and Type | Field and Description |
---|---|
Queue<double[]> |
cepEvents |
protected int |
numberOfAttributes |
protected int |
numberOfGeneratedInstances |
protected org.apache.samoa.instances.InstancesHeader |
streamHeader |
protected double[] |
values |
Constructor and Description |
---|
DataStream() |
Modifier and Type | Method and Description |
---|---|
long |
estimatedRemainingInstances() |
protected abstract void |
generateHeader() |
void |
getDescription(StringBuilder stringBuilder,
int i) |
org.apache.samoa.instances.InstancesHeader |
getHeader() |
boolean |
hasMoreInstances() |
boolean |
isRestartable() |
abstract org.apache.samoa.moa.core.Example<org.apache.samoa.instances.Instance> |
nextInstance() |
protected abstract void |
prepareForUseImpl(org.apache.samoa.moa.tasks.TaskMonitor taskMonitor,
org.apache.samoa.moa.core.ObjectRepository objectRepository) |
void |
restart() |
void |
setCepEvents(Queue<double[]> cepEvents) |
getDecayHorizon, getDecayThreshold, getEvaluationFrequency
copy, getCLICreationString, getOptions, getPreparedClassOption, getPurposeString, prepareClassOptions, prepareForUse, prepareForUse
copy, measureByteSize, measureByteSize, toString
protected org.apache.samoa.instances.InstancesHeader streamHeader
protected int numberOfGeneratedInstances
protected int numberOfAttributes
public Queue<double[]> cepEvents
protected double[] values
protected abstract void prepareForUseImpl(org.apache.samoa.moa.tasks.TaskMonitor taskMonitor, org.apache.samoa.moa.core.ObjectRepository objectRepository)
prepareForUseImpl
in class org.apache.samoa.moa.options.AbstractOptionHandler
protected abstract void generateHeader()
public abstract org.apache.samoa.moa.core.Example<org.apache.samoa.instances.Instance> nextInstance()
public org.apache.samoa.instances.InstancesHeader getHeader()
public long estimatedRemainingInstances()
public boolean hasMoreInstances()
public boolean isRestartable()
public void restart()
public void getDescription(StringBuilder stringBuilder, int i)
public void setCepEvents(Queue<double[]> cepEvents)
Copyright © 2017 WSO2. All rights reserved.