Constructor and Description |
---|
InputManager(SiddhiAppContext siddhiAppContext,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
ConcurrentMap<String,Table> tableMap) |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
InputHandler |
constructInputHandler(String streamId) |
TableInputHandler |
constructTableInputHandler(String tableId) |
void |
disconnect() |
InputHandler |
getInputHandler(String streamId) |
TableInputHandler |
getTableInputHandler(String tableId) |
public InputManager(SiddhiAppContext siddhiAppContext, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap, ConcurrentMap<String,StreamJunction> streamJunctionMap, ConcurrentMap<String,Table> tableMap)
public InputHandler getInputHandler(String streamId)
public TableInputHandler getTableInputHandler(String tableId)
public void connect()
public void disconnect()
public InputHandler constructInputHandler(String streamId)
public TableInputHandler constructTableInputHandler(String tableId)
Copyright © 2021. All rights reserved.