Modifier and Type | Class and Description |
---|---|
class |
FunctionExecutor<S extends State>
Parent abstract class for Function Executors.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
MaximumFunctionExecutor.execute(Object[] data,
State state)
return maximum of arbitrary long set of Double values
|
protected Object |
EventTimestampFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
InstanceOfFloatFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
CurrentTimeMillisFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
CreateSetFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
InstanceOfIntegerFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
SizeOfSetFunctionExecutor.execute(Object[] data,
State state)
return maximum of arbitrary long set of Double values
|
protected Object |
InstanceOfStringFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
CastFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
CoalesceFunctionExecutor.execute(Object[] obj,
State state) |
protected Object |
ConvertFunctionExecutor.execute(Object[] obj,
State state) |
protected Object |
MinimumFunctionExecutor.execute(Object[] data,
State state)
return maximum of arbitrary long set of Double values
|
protected Object |
InstanceOfDoubleFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
InstanceOfLongFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
UUIDFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
InstanceOfBooleanFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
DefaultFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
ScriptFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
IfThenElseFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
MaximumFunctionExecutor.execute(Object data,
State state) |
protected Object |
EventTimestampFunctionExecutor.execute(Object data,
State state) |
protected Object |
InstanceOfFloatFunctionExecutor.execute(Object data,
State state) |
protected Object |
CurrentTimeMillisFunctionExecutor.execute(Object data,
State state) |
protected Object |
CreateSetFunctionExecutor.execute(Object data,
State state)
return set object, containing only one element: data.
|
protected Object |
InstanceOfIntegerFunctionExecutor.execute(Object data,
State state) |
protected Object |
SizeOfSetFunctionExecutor.execute(Object data,
State state) |
protected Object |
InstanceOfStringFunctionExecutor.execute(Object data,
State state) |
protected Object |
CastFunctionExecutor.execute(Object data,
State state) |
protected Object |
CoalesceFunctionExecutor.execute(Object data,
State state) |
protected Object |
ConvertFunctionExecutor.execute(Object data,
State state) |
protected Object |
MinimumFunctionExecutor.execute(Object data,
State state) |
protected Object |
InstanceOfDoubleFunctionExecutor.execute(Object data,
State state) |
protected Object |
InstanceOfLongFunctionExecutor.execute(Object data,
State state) |
protected Object |
UUIDFunctionExecutor.execute(Object data,
State state) |
protected Object |
InstanceOfBooleanFunctionExecutor.execute(Object data,
State state) |
protected Object |
DefaultFunctionExecutor.execute(Object data,
State state) |
protected Object |
ScriptFunctionExecutor.execute(Object data,
State state) |
protected Object |
IfThenElseFunctionExecutor.execute(Object data,
State state) |
Modifier and Type | Method and Description |
---|---|
protected Object |
IncrementalAggregateBaseTimeFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
IncrementalStartTimeEndTimeFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
IncrementalUnixTimeFunctionExecutor.execute(Object[] data,
State state) |
protected Object |
IncrementalTimeGetTimeZone.execute(Object[] data,
State state) |
protected Object |
IncrementalAggregateBaseTimeFunctionExecutor.execute(Object data,
State state) |
protected Object |
IncrementalStartTimeEndTimeFunctionExecutor.execute(Object data,
State state) |
protected Object |
IncrementalUnixTimeFunctionExecutor.execute(Object data,
State state) |
protected Object |
IncrementalTimeGetTimeZone.execute(Object data,
State state) |
Modifier and Type | Class and Description |
---|---|
class |
PartitionRuntime.PartitionState
State of partition
|
Modifier and Type | Class and Description |
---|---|
class |
OutputRateLimiter<S extends State>
Abstract parent implementation of Output Rate Limiting.
|
Modifier and Type | Class and Description |
---|---|
class |
SnapshotOutputRateLimiter<S extends State>
Parent implementation to run the
Scheduler to handle periodic snapshot rate
limiting. |
class |
WrappedSnapshotOutputRateLimiter<S extends State>
Implementation of
OutputRateLimiter to be used by Snapshot Output Rate Limiting implementations. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStreamProcessor<S extends State>
Abstract implementation of
Processor intended to be used by any Stream Processors. |
class |
StreamProcessor<S extends State>
For Siddhi extensions, extend this class to use the functionality of
AbstractStreamProcessor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
LogStreamProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state) |
Modifier and Type | Class and Description |
---|---|
class |
StreamFunctionProcessor<S extends State>
Stream Processor to handle Stream Functions.
|
Modifier and Type | Class and Description |
---|---|
class |
BatchingFindableWindowProcessor<S extends State>
Window to process events as batches while supporting event search
|
class |
BatchingWindowProcessor<S extends State>
Performs event processing in a tumbling manner
|
class |
GroupingFindableWindowProcessor<S extends State>
Window that process event processing as a group while supporting event search
|
class |
GroupingWindowProcessor<S extends State>
Performs event processing with key based event groups
|
class |
HopingWindowProcessor<S extends State>
Performs event processing in a hopping manner
|
class |
SlidingFindableWindowProcessor<S extends State>
Performs event processing in a sliding manner while supporting event search
|
class |
SlidingWindowProcessor<S extends State>
Performs event processing in a sliding manner
|
class |
WindowProcessor<S extends State>
Abstract parent implementation of Processor to represent Windows.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AggregateWindowProcessor.process(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
State state) |
protected void |
TableWindowProcessor.process(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
State state) |
protected void |
WindowWindowProcessor.processEventChunk(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state) |
Modifier and Type | Class and Description |
---|---|
class |
AttributeAggregatorExecutor<S extends State>
Abstract parent class for attribute aggregators.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceHandler<S extends State>
SourceHandler is an optional implementable class that wraps
InputHandler . |
Modifier and Type | Class and Description |
---|---|
class |
SinkHandler<S extends State>
SinkHandler is an optional interface before
SinkMapper . |
Modifier and Type | Class and Description |
---|---|
class |
RecordTableHandler<S extends State>
RecordTableHandler is an optional handler that can be implemented to do processing on output events before sending
to the AbstractRecordTable.
|
Modifier and Type | Interface and Description |
---|---|
interface |
StateFactory<S extends State>
State factory that create states that are used to store query and other states
|
interface |
StateHolder<S extends State>
Holder to have all the states
|
Modifier and Type | Method and Description |
---|---|
State |
EmptyStateHolder.cleanGroupByStates() |
State |
SingleSyncStateHolder.cleanGroupByStates() |
State |
PartitionSyncStateHolder.cleanGroupByStates() |
State |
PartitionStateHolder.cleanGroupByStates() |
State |
SingleStateHolder.cleanGroupByStates() |
State |
EmptyStateHolder.getState() |
State |
SingleSyncStateHolder.getState() |
State |
PartitionSyncStateHolder.getState() |
State |
PartitionStateHolder.getState() |
State |
SingleStateHolder.getState() |
Modifier and Type | Method and Description |
---|---|
Map<String,State> |
SingleSyncStateHolder.getAllGroupByStates() |
Map<String,State> |
PartitionSyncStateHolder.getAllGroupByStates() |
Map<String,State> |
PartitionStateHolder.getAllGroupByStates() |
Map<String,State> |
SingleStateHolder.getAllGroupByStates() |
Map<String,State> |
EmptyStateHolder.getAllStates() |
Map<String,Map<String,State>> |
SingleSyncStateHolder.getAllStates() |
Map<String,Map<String,State>> |
PartitionSyncStateHolder.getAllStates() |
Map<String,Map<String,State>> |
PartitionStateHolder.getAllStates() |
Map<String,Map<String,State>> |
SingleStateHolder.getAllStates() |
Modifier and Type | Method and Description |
---|---|
void |
EmptyStateHolder.returnState(State state) |
void |
SingleSyncStateHolder.returnState(State state) |
void |
PartitionSyncStateHolder.returnState(State state) |
void |
PartitionStateHolder.returnState(State state) |
void |
SingleStateHolder.returnState(State state) |
Copyright © 2019. All rights reserved.