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