public class BinarySourceMapper
extends org.wso2.siddhi.core.stream.input.source.SourceMapper
Constructor and Description |
---|
BinarySourceMapper() |
Modifier and Type | Method and Description |
---|---|
Class[] |
getSupportedInputEventClasses() |
void |
init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition,
org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
List<org.wso2.siddhi.core.stream.input.source.AttributeMapping> attributeMappings,
org.wso2.siddhi.core.util.config.ConfigReader configReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext) |
protected void |
mapAndProcess(Object o,
org.wso2.siddhi.core.stream.input.source.InputEventHandler inputEventHandler) |
public void init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, List<org.wso2.siddhi.core.stream.input.source.AttributeMapping> attributeMappings, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
init
in class org.wso2.siddhi.core.stream.input.source.SourceMapper
protected void mapAndProcess(Object o, org.wso2.siddhi.core.stream.input.source.InputEventHandler inputEventHandler) throws InterruptedException
mapAndProcess
in class org.wso2.siddhi.core.stream.input.source.SourceMapper
InterruptedException
public Class[] getSupportedInputEventClasses()
getSupportedInputEventClasses
in class org.wso2.siddhi.core.stream.input.source.SourceMapper
Copyright © 2017 WSO2. All rights reserved.