public class PerceptronClassifierUpdaterStreamProcessorExtension
extends io.siddhi.core.query.processor.stream.StreamProcessor<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState>
Constructor and Description |
---|
PerceptronClassifierUpdaterStreamProcessorExtension() |
Modifier and Type | Method and Description |
---|---|
io.siddhi.core.query.processor.ProcessingMode |
getProcessingMode() |
List<io.siddhi.query.api.definition.Attribute> |
getReturnAttributes() |
protected io.siddhi.core.util.snapshot.state.StateFactory<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState> |
init(io.siddhi.core.event.stream.MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition abstractDefinition,
io.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
io.siddhi.core.util.config.ConfigReader configReader,
io.siddhi.core.event.stream.holder.StreamEventClonerHolder streamEventClonerHolder,
boolean b,
boolean b1,
io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext) |
protected void |
process(io.siddhi.core.event.ComplexEventChunk<io.siddhi.core.event.stream.StreamEvent> complexEventChunk,
io.siddhi.core.query.processor.Processor processor,
io.siddhi.core.event.stream.StreamEventCloner streamEventCloner,
io.siddhi.core.event.stream.populater.ComplexEventPopulater complexEventPopulater,
org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState extensionState) |
void |
start() |
void |
stop() |
processEventChunk
public PerceptronClassifierUpdaterStreamProcessorExtension()
protected io.siddhi.core.util.snapshot.state.StateFactory<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState> init(io.siddhi.core.event.stream.MetaStreamEvent metaStreamEvent, io.siddhi.query.api.definition.AbstractDefinition abstractDefinition, io.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, io.siddhi.core.util.config.ConfigReader configReader, io.siddhi.core.event.stream.holder.StreamEventClonerHolder streamEventClonerHolder, boolean b, boolean b1, io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)
init
in class io.siddhi.core.query.processor.stream.AbstractStreamProcessor<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState>
public List<io.siddhi.query.api.definition.Attribute> getReturnAttributes()
getReturnAttributes
in class io.siddhi.core.query.processor.stream.AbstractStreamProcessor<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState>
public io.siddhi.core.query.processor.ProcessingMode getProcessingMode()
getProcessingMode
in class io.siddhi.core.query.processor.stream.AbstractStreamProcessor<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState>
public void start()
public void stop()
protected void process(io.siddhi.core.event.ComplexEventChunk<io.siddhi.core.event.stream.StreamEvent> complexEventChunk, io.siddhi.core.query.processor.Processor processor, io.siddhi.core.event.stream.StreamEventCloner streamEventCloner, io.siddhi.core.event.stream.populater.ComplexEventPopulater complexEventPopulater, org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState extensionState)
process
in class io.siddhi.core.query.processor.stream.StreamProcessor<org.wso2.extension.siddhi.execution.streamingml.classification.perceptron.PerceptronClassifierUpdaterStreamProcessorExtension.ExtensionState>
Copyright © 2019 WSO2. All rights reserved.