public class StreamingClusteringEntranceProcessor extends SourceProcessor
delay, finished, firstInstance, maxEvents, numberOfInstancesSent, schedule, timer
Constructor and Description |
---|
StreamingClusteringEntranceProcessor() |
Modifier and Type | Method and Description |
---|---|
org.apache.samoa.core.Processor |
newProcessor(org.apache.samoa.core.Processor processor) |
org.apache.samoa.core.ContentEvent |
nextEvent() |
getDataset, getStreamSource, hasNext, hasReachedEndOfStream, increaseReadyEventIndex, isFinished, nextInstance, onCreate, process, setDelayBatchSize, setMaxEvents, setSourceDelay, setStreamSource
public StreamingClusteringEntranceProcessor()
public org.apache.samoa.core.ContentEvent nextEvent()
nextEvent
in interface org.apache.samoa.core.EntranceProcessor
nextEvent
in class SourceProcessor
public org.apache.samoa.core.Processor newProcessor(org.apache.samoa.core.Processor processor)
newProcessor
in interface org.apache.samoa.core.Processor
newProcessor
in class SourceProcessor
Copyright © 2017 WSO2. All rights reserved.