Class SiddhiQueryGroup
- java.lang.Object
-
- org.wso2.siddhi.parser.core.topology.SiddhiQueryGroup
-
public class SiddhiQueryGroup extends Object
Data Holder to hold required details of Query Groups inSiddhiTopology.
-
-
Constructor Summary
Constructors Constructor Description SiddhiQueryGroup(String name, int parallelism)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddInputStreams(Map<String,InputStreamDataHolder> inputStreamDataHolderMap)voidaddOutputStream(String key, OutputStreamDataHolder outputStreamDataHolder)voidaddQuery(String query)voidaddQueryAtFirst(String query)Map<String,InputStreamDataHolder>getInputStreams()StringgetName()Map<String,OutputStreamDataHolder>getOutputStreams()intgetParallelism()List<String>getQueryList()StringgetSiddhiApp()booleanisMessagingSourceAvailable()booleanisReceiverQueryGroup()voidsetMessagingSourceAvailable(boolean messagingSourceAvailable)voidsetName(String name)voidsetParallelism(int parallelism)voidsetReceiverQueryGroup(boolean receiverQueryGroup)
-
-
-
Constructor Detail
-
SiddhiQueryGroup
public SiddhiQueryGroup(String name, int parallelism)
-
-
Method Detail
-
getName
public String getName()
-
setName
public void setName(String name)
-
getParallelism
public int getParallelism()
-
getSiddhiApp
public String getSiddhiApp()
-
addQuery
public void addQuery(String query)
-
addQueryAtFirst
public void addQueryAtFirst(String query)
-
addOutputStream
public void addOutputStream(String key, OutputStreamDataHolder outputStreamDataHolder)
-
addInputStreams
public void addInputStreams(Map<String,InputStreamDataHolder> inputStreamDataHolderMap)
-
getInputStreams
public Map<String,InputStreamDataHolder> getInputStreams()
-
getOutputStreams
public Map<String,OutputStreamDataHolder> getOutputStreams()
-
isReceiverQueryGroup
public boolean isReceiverQueryGroup()
-
setReceiverQueryGroup
public void setReceiverQueryGroup(boolean receiverQueryGroup)
-
setParallelism
public void setParallelism(int parallelism)
-
isMessagingSourceAvailable
public boolean isMessagingSourceAvailable()
-
setMessagingSourceAvailable
public void setMessagingSourceAvailable(boolean messagingSourceAvailable)
-
-