public class SiddhiAppContext extends Object
SiddhiApp
.Constructor and Description |
---|
SiddhiAppContext() |
public static void startGroupByFlow(String key)
public static void stopGroupByFlow()
public static void startPartitionFlow(String key)
public static void stopPartitionFlow()
public static String getCurrentFlowId()
public static String getPartitionFlowId()
public static String getGroupByFlowId()
public SiddhiContext getSiddhiContext()
public void setSiddhiContext(SiddhiContext siddhiContext)
public Map<String,Object> getAttributes()
public String getName()
public void setName(String name)
public boolean isPlayback()
public void setPlayback(boolean playback)
public boolean isEnforceOrder()
public void setEnforceOrder(boolean enforceOrder)
public Level getRootMetricsLevel()
public void setRootMetricsLevel(Level rootMetricsLevel)
public StatisticsManager getStatisticsManager()
public void setStatisticsManager(StatisticsManager statisticsManager)
public ScheduledExecutorService getScheduledExecutorService()
public void setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)
public void addEternalReferencedHolder(ExternalReferencedHolder externalReferencedHolder)
public List<ExternalReferencedHolder> getExternalReferencedHolders()
public void addTrigger(Trigger trigger)
public ThreadBarrier getThreadBarrier()
public void setThreadBarrier(ThreadBarrier threadBarrier)
public ExecutorService getExecutorService()
public void setExecutorService(ExecutorService executorService)
public TimestampGenerator getTimestampGenerator()
public void setTimestampGenerator(TimestampGenerator timestampGenerator)
public SnapshotService getSnapshotService()
public void setSnapshotService(SnapshotService snapshotService)
public void setIdGenerator(IdGenerator idGenerator)
public boolean isFunctionExist(String name)
public com.lmax.disruptor.ExceptionHandler<Object> getDisruptorExceptionHandler()
public void setDisruptorExceptionHandler(com.lmax.disruptor.ExceptionHandler<Object> disruptorExceptionHandler)
public ExceptionListener getRuntimeExceptionListener()
public void setRuntimeExceptionListener(ExceptionListener runtimeExceptionListener)
public int getBufferSize()
public void setBufferSize(int bufferSize)
public String getSiddhiAppString()
public void setSiddhiAppString(String siddhiAppString)
public io.siddhi.query.api.SiddhiApp getSiddhiApp()
public void setSiddhiApp(io.siddhi.query.api.SiddhiApp siddhiApp)
public boolean isTransportChannelCreationEnabled()
public void setTransportChannelCreationEnabled(boolean transportChannelCreationEnabled)
public void addScheduler(Scheduler scheduler)
public StateHolder generateStateHolder(String name, StateFactory stateFactory)
public StateHolder generateStateHolder(String name, StateFactory stateFactory, boolean unSafe)
Copyright © 2021. All rights reserved.