public abstract class SourceProcessor extends Object implements org.apache.samoa.core.EntranceProcessor
Modifier and Type | Field and Description |
---|---|
protected int |
delay |
protected boolean |
finished |
protected org.apache.samoa.instances.Instance |
firstInstance |
protected int |
maxEvents |
protected int |
numberOfInstancesSent |
protected ScheduledFuture<?> |
schedule |
protected ScheduledExecutorService |
timer |
Constructor and Description |
---|
SourceProcessor() |
Modifier and Type | Method and Description |
---|---|
org.apache.samoa.instances.Instances |
getDataset() |
protected org.apache.samoa.streams.StreamSource |
getStreamSource() |
boolean |
hasNext() |
protected boolean |
hasReachedEndOfStream() |
protected void |
increaseReadyEventIndex() |
boolean |
isFinished() |
abstract org.apache.samoa.core.Processor |
newProcessor(org.apache.samoa.core.Processor p) |
abstract org.apache.samoa.core.ContentEvent |
nextEvent() |
protected org.apache.samoa.instances.Instance |
nextInstance() |
void |
onCreate(int id) |
boolean |
process(org.apache.samoa.core.ContentEvent event) |
void |
setDelayBatchSize(int batch) |
void |
setMaxEvents(int value) |
void |
setSourceDelay(int delay) |
void |
setStreamSource(org.apache.samoa.streams.InstanceStream stream) |
protected transient ScheduledExecutorService timer
protected transient ScheduledFuture<?> schedule
protected int delay
protected org.apache.samoa.instances.Instance firstInstance
protected int maxEvents
protected int numberOfInstancesSent
protected boolean finished
public abstract org.apache.samoa.core.ContentEvent nextEvent()
nextEvent
in interface org.apache.samoa.core.EntranceProcessor
public abstract org.apache.samoa.core.Processor newProcessor(org.apache.samoa.core.Processor p)
newProcessor
in interface org.apache.samoa.core.Processor
public boolean process(org.apache.samoa.core.ContentEvent event)
process
in interface org.apache.samoa.core.Processor
public void onCreate(int id)
onCreate
in interface org.apache.samoa.core.EntranceProcessor
onCreate
in interface org.apache.samoa.core.Processor
public boolean hasNext()
hasNext
in interface org.apache.samoa.core.EntranceProcessor
public boolean isFinished()
isFinished
in interface org.apache.samoa.core.EntranceProcessor
protected boolean hasReachedEndOfStream()
public void setStreamSource(org.apache.samoa.streams.InstanceStream stream)
protected org.apache.samoa.instances.Instance nextInstance()
protected void increaseReadyEventIndex()
public org.apache.samoa.instances.Instances getDataset()
public void setMaxEvents(int value)
public void setSourceDelay(int delay)
public void setDelayBatchSize(int batch)
protected org.apache.samoa.streams.StreamSource getStreamSource()
Copyright © 2017 WSO2. All rights reserved.