A B C D E G H I K L M N O P Q R S T U V W

A

AbstractAggregator - Class in streamcruncher.api.aggregator

Custom Aggregator functions can be plugged into the Kernel before the Query is registered.

AbstractAggregator() - Constructor for class streamcruncher.api.aggregator.AbstractAggregator

AbstractAggregator.AggregationStage - Enum in streamcruncher.api.aggregator

This feature is to provide a choice for the User to decide whether an Event's entrance into a Window only or both entrance and exit should affect the aggregate.

AbstractAggregatorHelper - Class in streamcruncher.api.aggregator

An Aggregator must be accompanied by a Sub-class of this Helper, which provides all the details regarding the Aggregator being registered.

AbstractAggregatorHelper(String, Class<? extends AbstractAggregator>) - Constructor for class streamcruncher.api.aggregator.AbstractAggregatorHelper

added(String, Long, Object[]) - Method in interface streamcruncher.api.CustomStore

added(String, Long, Object[]) - Method in class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

addInfo(String, RowSpec.Info, Object) - Static method in class streamcruncher.api.artifact.RowSpec

A convenience method to add additional information to the Type.

addRow(Object[]) - Method in class streamcruncher.test.func.BatchResult

afterBootup() - Method in interface streamcruncher.api.StartupShutdownHook

Invoked by the Kernel, after all the internal Components have started successfully but before the Input Event Streams and Queries that were registered in a previous run of the Kernel (if any), are re-registered by the Kernel.

aggregate(List<Object[]>, List<Object[]>) - Method in class streamcruncher.api.aggregator.AbstractAggregator

At the end of each Query execution, this method will be called to aggregate the Events in the Window over which this Aggregate is created.

aggregate(List<Object[]>, List<Object[]>) - Method in class streamcruncher.test.func.generic.TimeWF2PartitionAggTest.TestAggregator

B

BatchResult - Class in streamcruncher.test.func

All the Test cases use this Class to hold the results of the Query and then verify the results against expected data.

BatchResult() - Constructor for class streamcruncher.test.func.BatchResult

beforeShutdown() - Method in interface streamcruncher.api.StartupShutdownHook

Invoked by the Kernel, before all the internal Components are stopped.

C

CaseWhenClauseTest - Class in streamcruncher.test.func.generic

This Test demonstrates the use of the SQL "Case..When..End" clause.

CaseWhenClauseTest() - Constructor for class streamcruncher.test.func.generic.CaseWhenClauseTest

clearStartupShutdownHook() - Method in class streamcruncher.api.StreamCruncher

Removes the Listener from the Kernel.

close() - Method in class streamcruncher.api.InputSession

close() - Method in class streamcruncher.api.OutputSession

ClusterHealthTest - Class in streamcruncher.test.func.generic

This Test demonstrates the use of the Extra parameters allowed in the In-built Aggregation functions.

ClusterHealthTest() - Constructor for class streamcruncher.test.func.generic.ClusterHealthTest

ClusterHealthTest.CountDiffBaselineProvider - Class in streamcruncher.test.func.generic

Custom Provider for the count function.

ClusterHealthTest.CountDiffBaselineProvider() - Constructor for class streamcruncher.test.func.generic.ClusterHealthTest.CountDiffBaselineProvider

ClusterHealthTest.StatsDiffBaselineProvider - Class in streamcruncher.test.func.generic

Custom Provider for the Statistics functions (avg,variance..).

ClusterHealthTest.StatsDiffBaselineProvider() - Constructor for class streamcruncher.test.func.generic.ClusterHealthTest.StatsDiffBaselineProvider

CorrelationExpressionsTest - Class in streamcruncher.test.func.generic

Test complex expression evaluation in Correlations.

CorrelationExpressionsTest() - Constructor for class streamcruncher.test.func.generic.CorrelationExpressionsTest

CorrelationPerfTest - Class in streamcruncher.test.func.generic

Generates test data for 4 Streams - for Correlation tests.

createConnection() - Method in class streamcruncher.api.StreamCruncher

createInputSession(String) - Method in class streamcruncher.api.StreamCruncher

Creates a helper object for the Input Event Stream.

createOutputSession(String) - Method in class streamcruncher.api.StreamCruncher

Creates a helper object for the Output Event Stream.

CustomStore - Interface in streamcruncher.api

D

DBName - Enum in streamcruncher.api

The names of Databases supported by the Kernel.

defaultAllowedPendingEvents - Static variable in class streamcruncher.api.QueryConfig

2147483647

defaultEventWeight - Static variable in class streamcruncher.api.QueryConfig

1.0f

defaultForceScheduleMarginMsecs - Static variable in class streamcruncher.api.QueryConfig

250L

defaultRefreshIntervalMsecs - Static variable in class streamcruncher.api.ResultSetCacheConfig

3600000L

defaultResumeCheckTimeMsecs - Static variable in class streamcruncher.api.QueryConfig

5000L

defaultSchPolicy - Static variable in class streamcruncher.api.QueryConfig

defaultSchTimeMillis - Static variable in class streamcruncher.api.QueryConfig

1500L

defaultStuckJobIntTimeMsecs - Static variable in class streamcruncher.api.QueryConfig

45000L

destroy() - Method in interface streamcruncher.api.CustomStore

destroy() - Method in class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

DiffBaselineProvider<T extends java.lang.Comparable> - Class in streamcruncher.api.aggregator

This Provider Class allows the customization of those Partitions with Aggregates that have been declared with the $diff keyword.

DiffBaselineProvider() - Constructor for class streamcruncher.api.aggregator.DiffBaselineProvider

E

endBatch() - Method in interface streamcruncher.api.CustomStore

endBatch() - Method in class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

equals(Object) - Method in class streamcruncher.api.artifact.RowSpec

G

getAggregatedColumnDDLFragment(DBName, String[], LinkedHashMap<String, String>) - Method in class streamcruncher.api.aggregator.AbstractAggregatorHelper

getAggregatedColumnDDLFragment(DBName, String[], LinkedHashMap<String, String>) - Method in class streamcruncher.test.func.generic.TimeWF2PartitionAggTest.TestAggregatorHelper

getAggregationStage() - Method in class streamcruncher.api.aggregator.AbstractAggregator

getAggregatorClass() - Method in class streamcruncher.api.aggregator.AbstractAggregatorHelper

getAllowedPendingEvents(String) - Method in class streamcruncher.api.QueryConfig

getAllowedPendingEventsKeys() - Method in class streamcruncher.api.QueryConfig

getBaseline(T, T) - Method in class streamcruncher.api.aggregator.DiffBaselineProvider

getBaseline(Integer, Integer) - Method in class streamcruncher.test.func.generic.ClusterHealthTest.CountDiffBaselineProvider

getBaseline(Double, Double) - Method in class streamcruncher.test.func.generic.ClusterHealthTest.StatsDiffBaselineProvider

getCachedSubQueries() - Method in class streamcruncher.api.ParsedQuery

getColumnNames() - Method in class streamcruncher.api.artifact.RowSpec

getColumnNamesAndTypes() - Method in class streamcruncher.api.aggregator.AbstractAggregator

getColumnNativeTypes() - Method in class streamcruncher.api.artifact.RowSpec

getData() - Method in class streamcruncher.test.func.MultiStreamEventGenerator.Event

getDBSchema() - Method in class streamcruncher.api.StreamCruncher

getForceScheduleMarginMsecs() - Method in class streamcruncher.api.QueryConfig

getFunctionName() - Method in class streamcruncher.api.aggregator.AbstractAggregatorHelper

getIdColumnPosition() - Method in class streamcruncher.api.artifact.RowSpec

getIdPosition() - Method in class streamcruncher.test.func.MultiStreamEventGenerator.Event

getKeys() - Method in class streamcruncher.api.QueryConfig

getMaxDataRows() - Method in class streamcruncher.test.func.generic.TimeWindowFPerfTest

getMaxDataRows() - Method in class streamcruncher.test.func.TimeWindowTest

getName() - Static method in class streamcruncher.api.aggregator.DiffBaselineProvider

getName() - Method in class streamcruncher.api.InputSession

getName() - Method in class streamcruncher.api.OutputSession

getName() - Static method in class streamcruncher.api.TimeWindowSizeProvider

getName() - Static method in class streamcruncher.api.WindowSizeProvider

getParams() - Method in class streamcruncher.api.aggregator.AbstractAggregator

getPolicy() - Method in class streamcruncher.api.QueryConfig.QuerySchedulePolicyValue

getQuery() - Method in class streamcruncher.api.ParserParameters

getQueryConfig() - Method in class streamcruncher.api.ParsedQuery

getQueryConfig(String) - Method in class streamcruncher.api.StreamCruncher

Each Query has a unique config-object and this method returns a handle to the same.

getQueryErrorCount() - Method in class streamcruncher.api.QueryConfig

getQueryLastRanAt() - Method in class streamcruncher.api.QueryConfig

getQueryName() - Method in class streamcruncher.api.ParserParameters

getQueryRunCount() - Method in class streamcruncher.api.QueryConfig

getQuerySchedulePolicy() - Method in class streamcruncher.api.QueryConfig

getRefreshIntervalMsecs() - Method in class streamcruncher.api.ResultSetCacheConfig

getResultColumnTypes() - Method in class streamcruncher.api.ParserParameters

getResultSetCacheConfig(String) - Method in class streamcruncher.api.StreamCruncher

getResultSetCacheConfigKeys() - Method in class streamcruncher.api.StreamCruncher

getResumeCheckTimeMsecs() - Method in class streamcruncher.api.QueryConfig

getRows() - Method in class streamcruncher.test.func.BatchResult

getSize() - Method in class streamcruncher.api.WindowSizeProvider

getSizeMillis() - Method in class streamcruncher.api.TimeWindowSizeProvider

getStartupShutdownHook() - Method in class streamcruncher.api.StreamCruncher

getStuckJobInterruptionTimeMsecs() - Method in class streamcruncher.api.QueryConfig

getTimeBiasMsecs() - Method in class streamcruncher.api.StreamCruncher

getTimeMillis() - Method in class streamcruncher.api.QueryConfig.QuerySchedulePolicyValue

getTimestamp() - Method in class streamcruncher.test.func.BatchResult

getTimestampColumnPosition() - Method in class streamcruncher.api.artifact.RowSpec

getType() - Method in class streamcruncher.test.func.MultiStreamEventGenerator.Event

getUnprocessedEventWeight(String) - Method in class streamcruncher.api.QueryConfig

getUnprocessedEventWeightKeys() - Method in class streamcruncher.api.QueryConfig

getVersionColumnPosition() - Method in class streamcruncher.api.artifact.RowSpec

H

hashCode() - Method in class streamcruncher.api.artifact.RowSpec

HighestRowsWindowFTest - Class in streamcruncher.test.func.generic

Test for the "Highest X" in a Partition Window clause.

HighestRowsWindowFTest() - Constructor for class streamcruncher.test.func.generic.HighestRowsWindowFTest

I

INFO_NAME_VALUE_SEPARATOR - Static variable in class streamcruncher.api.artifact.RowSpec

"="

INFO_SEPARATOR - Static variable in class streamcruncher.api.artifact.RowSpec

":"

init(String[], LinkedHashMap<String, String>, AbstractAggregator.AggregationStage) - Method in class streamcruncher.api.aggregator.AbstractAggregator

Note: This class' method must be invoked even if it is over-ridden (i.e super.init(...)).

init(String, Map<String, RowSpec>, String) - Method in interface streamcruncher.api.CustomStore

init(String, Map<String, RowSpec>, String) - Method in class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

init(String[], LinkedHashMap<String, String>, AbstractAggregator.AggregationStage) - Method in class streamcruncher.test.func.generic.TimeWF2PartitionAggTest.TestAggregator

InputSession - Class in streamcruncher.api

Each Input Event Stream can have 1 instance, which should be used to notify the Kernel of Events that have been added and committed into the underlying Database.

isQueryPaused() - Method in class streamcruncher.api.QueryConfig

K

keepRunning() - Method in class streamcruncher.api.StreamCruncher

Once the Kernel has started, this method can be invoked, where the invoking Thread blocks and waits for the stop-instruction to be typed at the System Console.

L

LowestRowsWindowFTest - Class in streamcruncher.test.func.generic

Test for the "Lowest X" in a Partition Window clause.

LowestRowsWindowFTest() - Constructor for class streamcruncher.test.func.generic.LowestRowsWindowFTest

M

MultiStreamEventGenerator - Class in streamcruncher.test.func

Generates test data for 3 Streams - for Correlation tests.

MultiStreamEventGenerator.Event - Class in streamcruncher.test.func

MultiStreamEventGenerator.Event(MultiStreamEventGenerator.EventType, Object[], int) - Constructor for class streamcruncher.test.func.MultiStreamEventGenerator.Event

MultiStreamEventGenerator.EventType - Enum in streamcruncher.test.func

MultiStreamEventGeneratorChainTest - Class in streamcruncher.test.func.generic

This Test demonstrates some of the more advanced features of the Alert-Query by making use of Chained Partitions and an additional where clause as a Post-Filter on the alert clause.

MultiStreamEventGeneratorChainTest() - Constructor for class streamcruncher.test.func.generic.MultiStreamEventGeneratorChainTest

MultiStreamEventGeneratorTest - Class in streamcruncher.test.func.generic

This Test demonstrates the use of the Pattern matching features (Multi-Stream Correlation).

MultiStreamEventGeneratorTest() - Constructor for class streamcruncher.test.func.generic.MultiStreamEventGeneratorTest

N

name - Static variable in class streamcruncher.api.aggregator.DiffBaselineProvider

name - Static variable in class streamcruncher.api.WindowSizeProvider

name2 - Static variable in class streamcruncher.api.TimeWindowSizeProvider

O

OAConfigurableFTest - Class in streamcruncher.test.func.generic

This Test demonstrates that some part of the behaviour of the Query can be made dynamically configurable.

OAConfigurableFTest() - Constructor for class streamcruncher.test.func.generic.OAConfigurableFTest

OAFJoinTest - Class in streamcruncher.test.func.generic

Demonstrates a simple SQL-Join on 2 Event Streams.

OAFJoinTest() - Constructor for class streamcruncher.test.func.generic.OAFJoinTest

OrderAndFulfillmentGenerator - Class in streamcruncher.test.func

Parent Class for all Order-Fulfillment Co-relation Test Cases.

OrderAndFulfillmentGeneratorTest - Class in streamcruncher.test.func.generic

OrderAndFulfillmentGeneratorTest() - Constructor for class streamcruncher.test.func.generic.OrderAndFulfillmentGeneratorTest

OrderGenenerator - Class in streamcruncher.test.func

Test Case parent Class for single Stream Tests.

OrderGeneratorTest - Class in streamcruncher.test.func.generic

OrderGeneratorTest() - Constructor for class streamcruncher.test.func.generic.OrderGeneratorTest

OutOfOrderEventTest - Class in streamcruncher.test.func.generic

This test uses only one Stream.

OutOfOrderEventTest() - Constructor for class streamcruncher.test.func.generic.OutOfOrderEventTest

OutputSession - Class in streamcruncher.api

Each Output Event Stream can have 1 instance, which should be used to retrieve Events that have been added and committed into the underlying Database by the Kernel.

OutputSession(String) - Constructor for class streamcruncher.api.OutputSession

P

ParsedQuery - Class in streamcruncher.api

This is the output of the Query parsing, produced by the Kernel which should then be used to register with the Kernel.

parseQuery(ParserParameters) - Method in class streamcruncher.api.StreamCruncher

The "Running Query" that will execute on the Event Stream has to be parsed by the Kernel first.

ParserParameters - Class in streamcruncher.api

This class should be used to wrap the "Running Query" along with the name and Output Event Stream's Table definition, which should then be submitted to the Kernel for parsing.

ParserParameters() - Constructor for class streamcruncher.api.ParserParameters

pauseQuery() - Method in class streamcruncher.api.QueryConfig

PreFilterSyntaxTest - Class in streamcruncher.test.func.generic

PreFilterSyntaxTest() - Constructor for class streamcruncher.test.func.generic.PreFilterSyntaxTest

PreFilterTriggerTest - Class in streamcruncher.test.func.generic

This tests and demonstrates the re-architected Partition clause with Pre-filters, where the Query is triggered only by the filtered Events.

PreFilterTriggerTest() - Constructor for class streamcruncher.test.func.generic.PreFilterTriggerTest

Provider - Interface in streamcruncher.api

A simple marker Interface for all customization code/hooks into the Kernel.

provideSize(Object[]) - Method in class streamcruncher.api.WindowSizeProvider

provideSize(Object[]) - Method in class streamcruncher.test.func.generic.TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider

provideSizeMillis(Object[]) - Method in class streamcruncher.api.TimeWindowSizeProvider

provideSizeMillis(Object[]) - Method in class streamcruncher.test.func.generic.TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider

Q

QueryConfig - Class in streamcruncher.api

Each registered Query has a configuration object that can be retrieved after parsing or at any time during the life of the Query from the API provided.

QueryConfig.QuerySchedulePolicy - Enum in streamcruncher.api

QueryConfig.QuerySchedulePolicyValue - Class in streamcruncher.api

QueryConfig.QuerySchedulePolicyValue(QueryConfig.QuerySchedulePolicy, long) - Constructor for class streamcruncher.api.QueryConfig.QuerySchedulePolicyValue

R

RandomRowsWindowFTest - Class in streamcruncher.test.func.generic

This Test demonstrates the "Random X" Window Feature.

RandomRowsWindowFTest() - Constructor for class streamcruncher.test.func.generic.RandomRowsWindowFTest

readEvents() - Method in class streamcruncher.api.OutputSession

Blocks until at least one Event is available.

readEvents(long, TimeUnit) - Method in class streamcruncher.api.OutputSession

registerAggregator(AbstractAggregatorHelper) - Method in class streamcruncher.api.StreamCruncher

Registers an Aggregator function.

registerInStream(String, RowSpec, int) - Method in class streamcruncher.api.StreamCruncher

Register an Input Event Stream as described by the RowSpec.

registerInStream(String, RowSpec) - Method in class streamcruncher.api.StreamCruncher

Register an Input Event Stream as described by the RowSpec and default Block size of 1024.

registerProvider(String, Class<? extends Provider>) - Method in class streamcruncher.api.StreamCruncher

Registers a Provider.

registerQuery(ParsedQuery) - Method in class streamcruncher.api.StreamCruncher

Registers the Query that was parsed using StreamCruncher.parseQuery(ParserParameters).

removed(String, Long, Object[]) - Method in interface streamcruncher.api.CustomStore

removed(String, Long, Object[]) - Method in class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

ReStockAlertPerfTest - Class in streamcruncher.test.func.generic

todo Not sure how to measure the performance.

ReStockAlertPerfTest() - Constructor for class streamcruncher.test.func.generic.ReStockAlertPerfTest

ReStockAlertTest - Class in streamcruncher.test.func.generic

Another example to show how normal Tables containing Master-Data can be used to drive the behaviour of the Query.

ReStockAlertTest() - Constructor for class streamcruncher.test.func.generic.ReStockAlertTest

ResultSetCacheConfig - Class in streamcruncher.api

The Kernel performs many operations inside its own Process.

ResultSetCacheConfig() - Constructor for class streamcruncher.api.ResultSetCacheConfig

resumeQuery() - Method in class streamcruncher.api.QueryConfig

RowSpec - Class in streamcruncher.api.artifact

The column-set definition of the Table of an Input/Output Event Stream.

RowSpec(String[], String[]) - Constructor for class streamcruncher.api.artifact.RowSpec

Creates a RowSpec without id-column, timestamp-column and version-column i.e with -1 as their positions.

RowSpec(String[], String[], int, int) - Constructor for class streamcruncher.api.artifact.RowSpec

Creates a RowSpec without version-column i.e with -1 as its position.

RowSpec(String[], String[], int, int, int) - Constructor for class streamcruncher.api.artifact.RowSpec

Internal use.

RowSpec.Info - Enum in streamcruncher.api.artifact

Additional information can be appended to the Java type.

S

setAllowedPendingEvents(String, int) - Method in class streamcruncher.api.QueryConfig

setData(Object[]) - Method in class streamcruncher.test.func.MultiStreamEventGenerator.Event

setForceScheduleMarginMsecs(long) - Method in class streamcruncher.api.QueryConfig

The duration in milliseconds below which a forced schedule will not occur, even if the event-weights have crossed 1.0 if the time left before a natural/periodic schedule occurs is less than or equal to this margin.

setQuery(String) - Method in class streamcruncher.api.ParserParameters

setQueryName(String) - Method in class streamcruncher.api.ParserParameters

setQuerySchedulePolicy(QueryConfig.QuerySchedulePolicyValue) - Method in class streamcruncher.api.QueryConfig

Set the Query's scheduling policy.

setRefreshIntervalMsecs(long) - Method in class streamcruncher.api.ResultSetCacheConfig

setResultColumnTypes(String[]) - Method in class streamcruncher.api.ParserParameters

setResumeCheckTimeMsecs(long) - Method in class streamcruncher.api.QueryConfig

The duration in milliseconds after which the Query wakes up to check if it has been resumed.

setSize(int) - Method in class streamcruncher.api.WindowSizeProvider

setSizeMillis(Long) - Method in class streamcruncher.api.TimeWindowSizeProvider

setStartupShutdownHook(StartupShutdownHook) - Method in class streamcruncher.api.StreamCruncher

Sets the lifecycle Listener.

setStuckJobInterruptionTimeMsecs(long) - Method in class streamcruncher.api.QueryConfig

Some parts of the Query processing are multi-threaded.

setTimeBiasMsecs(long) - Method in class streamcruncher.api.StreamCruncher

Forces the Kernel to add the number provided to the time it obtains from the System clock.

setUnprocessedEventWeight(String, float) - Method in class streamcruncher.api.QueryConfig

ShipmentAggregatorTest - Class in streamcruncher.test.func.generic

This example demonstrates the Store-And-Forward mechanism that can be simulated using Time Windows.

ShipmentAggregatorTest() - Constructor for class streamcruncher.test.func.generic.ShipmentAggregatorTest

SLAAlertCorrelationTest - Class in streamcruncher.test.func.generic

SLAAlertCorrelationTest() - Constructor for class streamcruncher.test.func.generic.SLAAlertCorrelationTest

SLAAlertTest - Class in streamcruncher.test.func.generic

This example demonstrates the use of a Co-related Sub-Query and Filters in a Partition (a rather complex example).

SLAAlertTest() - Constructor for class streamcruncher.test.func.generic.SLAAlertTest

SlidingDeadWindowFTest - Class in streamcruncher.test.func.generic

Test Case to show the "$row_status is dead" feature.

SlidingDeadWindowFTest() - Constructor for class streamcruncher.test.func.generic.SlidingDeadWindowFTest

SlidingNewWindowFPerfTest - Class in streamcruncher.test.func.generic

Performance test.

SlidingNewWindowFPerfTest() - Constructor for class streamcruncher.test.func.generic.SlidingNewWindowFPerfTest

SlidingNewWindowFTest - Class in streamcruncher.test.func.generic

Anonymous Partition with Sliding Windows.

SlidingNewWindowFTest() - Constructor for class streamcruncher.test.func.generic.SlidingNewWindowFTest

SlidingWF1PartitionTest - Class in streamcruncher.test.func.generic

Sliding Window Partition at "item-sku" level.

SlidingWF1PartitionTest() - Constructor for class streamcruncher.test.func.generic.SlidingWF1PartitionTest

SlidingWF2PartitionTest - Class in streamcruncher.test.func.generic

Sliding Window Test with Partitions at "Country > Item-SKU" level.

SlidingWF2PartitionTest() - Constructor for class streamcruncher.test.func.generic.SlidingWF2PartitionTest

SlidingWF3PartitionWhereTest - Class in streamcruncher.test.func.generic

Sliding Window Test with Partitions at "Country > Item-SKU" level and a pre-filter on Country.

SlidingWF3PartitionWhereTest() - Constructor for class streamcruncher.test.func.generic.SlidingWF3PartitionWhereTest

SlidingWFEvtDropTest - Class in streamcruncher.test.func.generic

This Test demonstrates the Sliding Window feature where a policy has been defined to prevent the Window and hence the Query from lagging behind the Stream, which tends to produce bursts of Events.

SlidingWFEvtDropTest() - Constructor for class streamcruncher.test.func.generic.SlidingWFEvtDropTest

SlidingWindowFTest - Class in streamcruncher.test.func.generic

Sliding Window Test on Partitions.

SlidingWindowFTest() - Constructor for class streamcruncher.test.func.generic.SlidingWindowFTest

SlidingWindowTest - Class in streamcruncher.test.func

Special Test Case for the "Sliding Window" feature.

SlidingWindowTest() - Constructor for class streamcruncher.test.func.SlidingWindowTest

start() - Method in class streamcruncher.api.InputSession

start() - Method in class streamcruncher.api.OutputSession

start(String) - Method in class streamcruncher.api.StreamCruncher

Starts the Kernel.

startBatch() - Method in interface streamcruncher.api.CustomStore

startBatch() - Method in class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

StartupShutdownHook - Interface in streamcruncher.api

A Listener interface to listen to the lifecycle of the Kernel.

StockPriceComparison2Test - Class in streamcruncher.test.func.generic

Special feature.

StockPriceComparison2Test() - Constructor for class streamcruncher.test.func.generic.StockPriceComparison2Test

StockPriceComparison2Test.CustomStoreImpl - Class in streamcruncher.test.func.generic

StockPriceComparison2Test.CustomStoreImpl() - Constructor for class streamcruncher.test.func.generic.StockPriceComparison2Test.CustomStoreImpl

StockPriceComparisonTest - Class in streamcruncher.test.func.generic

This Test demonstrates the use of the self# keyword to perform Self-Joins across a Partition.

StockPriceComparisonTest() - Constructor for class streamcruncher.test.func.generic.StockPriceComparisonTest

stop() - Method in class streamcruncher.api.StreamCruncher

This is an alternative way of stopping the Kernel (also see StreamCruncher.keepRunning())

StreamCruncher - Class in streamcruncher.api

The main class provided by the Kernel to - register/unregister Event Streams, Queries, hooks etc.

StreamCruncher() - Constructor for class streamcruncher.api.StreamCruncher

Any number of these instances can be created.

streamcruncher.api - package streamcruncher.api

streamcruncher.api.aggregator - package streamcruncher.api.aggregator

streamcruncher.api.artifact - package streamcruncher.api.artifact

streamcruncher.test.func - package streamcruncher.test.func

streamcruncher.test.func.generic - package streamcruncher.test.func.generic

StreamCruncherException - Exception in streamcruncher.api

StreamCruncherException() - Constructor for exception streamcruncher.api.StreamCruncherException

StreamCruncherException(String) - Constructor for exception streamcruncher.api.StreamCruncherException

StreamCruncherException(String, Throwable) - Constructor for exception streamcruncher.api.StreamCruncherException

StreamCruncherException(Throwable) - Constructor for exception streamcruncher.api.StreamCruncherException

submitEvent(Object[]) - Method in class streamcruncher.api.InputSession

Note: This operation works by assuming that there will be only one Thread invoking this method at a time.

submitEvents(Object[][]) - Method in class streamcruncher.api.InputSession

Note: This operation works by assuming that there will be only one Thread invoking this method at a time.

T

ThreeEventOrderTest - Class in streamcruncher.test.func.generic

This example demonstrates a scenario where there are 3 Event Streams.

ThreeEventOrderTest() - Constructor for class streamcruncher.test.func.generic.ThreeEventOrderTest

TimeMaxWindowFTest - Class in streamcruncher.test.func.generic

TimeMaxWindowFTest() - Constructor for class streamcruncher.test.func.generic.TimeMaxWindowFTest

TimeMaxWindowTest - Class in streamcruncher.test.func

Special Test Case for "Time based Windows" with the "Max" clause.

TimeMaxWindowTest() - Constructor for class streamcruncher.test.func.TimeMaxWindowTest

TimeWF1ChainedPartitionTest - Class in streamcruncher.test.func.generic

This Test demonstrates the "Chained Partition" feature, where a series of Partitions can be tied together like a pipeline, with the "to" clause.

TimeWF1ChainedPartitionTest() - Constructor for class streamcruncher.test.func.generic.TimeWF1ChainedPartitionTest

TimeWF1PartitionAvgCountTest - Class in streamcruncher.test.func.generic

A demonstration of a Partition with Aggregates.

TimeWF1PartitionAvgCountTest() - Constructor for class streamcruncher.test.func.generic.TimeWF1PartitionAvgCountTest

TimeWF1PartitionTest - Class in streamcruncher.test.func.generic

Time based Window in a Partition.

TimeWF1PartitionTest() - Constructor for class streamcruncher.test.func.generic.TimeWF1PartitionTest

TimeWF2PartitionAggTest - Class in streamcruncher.test.func.generic

This Test lists all the Aggregate Functions that are available.

TimeWF2PartitionAggTest() - Constructor for class streamcruncher.test.func.generic.TimeWF2PartitionAggTest

TimeWF2PartitionAggTest.TestAggregator - Class in streamcruncher.test.func.generic

Adds up the int-values of the Order-Id's in the Window and then converts the sum into a char.

TimeWF2PartitionAggTest.TestAggregator() - Constructor for class streamcruncher.test.func.generic.TimeWF2PartitionAggTest.TestAggregator

TimeWF2PartitionAggTest.TestAggregatorHelper - Class in streamcruncher.test.func.generic

TimeWF2PartitionAggTest.TestAggregatorHelper() - Constructor for class streamcruncher.test.func.generic.TimeWF2PartitionAggTest.TestAggregatorHelper

TimeWFPartitionWinSizeProviderTest - Class in streamcruncher.test.func.generic

This Test demonstrates the use of the TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider and the TimeWindowSizeProvider, which can be used to modify the default size of the Window for a particular sub-Window in a Partition.

TimeWFPartitionWinSizeProviderTest() - Constructor for class streamcruncher.test.func.generic.TimeWFPartitionWinSizeProviderTest

TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider - Class in streamcruncher.test.func.generic

TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider() - Constructor for class streamcruncher.test.func.generic.TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider

TimeWindowFPerfTest - Class in streamcruncher.test.func.generic

Performance test.

TimeWindowFPerfTest() - Constructor for class streamcruncher.test.func.generic.TimeWindowFPerfTest

TimeWindowFTest - Class in streamcruncher.test.func.generic

TimeWindowFTest() - Constructor for class streamcruncher.test.func.generic.TimeWindowFTest

TimeWindowSizeProvider - Class in streamcruncher.api

Window Size Provider for Time based Windows.

TimeWindowSizeProvider() - Constructor for class streamcruncher.api.TimeWindowSizeProvider

TimeWindowTest - Class in streamcruncher.test.func

Special Test Case for "Time based Windows".

TimeWindowTest() - Constructor for class streamcruncher.test.func.TimeWindowTest

TopOrLimitClauseTest - Class in streamcruncher.test.func.generic

This Test demonstrates the "TOP | FIRST xx" clause or the equivalent "LIMIT xx [OFFSET yy]" clause.

TopOrLimitClauseTest() - Constructor for class streamcruncher.test.func.generic.TopOrLimitClauseTest

TopSellingItemsTest - Class in streamcruncher.test.func.generic

This example along with TopSellingItemsUpdateGroupTest shows how Chained Partitions and the "Highest X elements Window" can be used to keep track of the top selling items in a Store.

TopSellingItemsTest() - Constructor for class streamcruncher.test.func.generic.TopSellingItemsTest

TopSellingItemsUpdateGroupTest - Class in streamcruncher.test.func.generic

This is the correct version of the Query as against TopSellingItemsTest.

TopSellingItemsUpdateGroupTest() - Constructor for class streamcruncher.test.func.generic.TopSellingItemsUpdateGroupTest

toString() - Method in class streamcruncher.api.artifact.RowSpec

TrafficGenerator - Class in streamcruncher.test.func

Test Case with a single Stream of Vehicular traffic data.

TumblingWF1PartitionEvtWtTest - Class in streamcruncher.test.func.generic

This Test demonstrates the "Event Weights" feature.

TumblingWF1PartitionEvtWtTest() - Constructor for class streamcruncher.test.func.generic.TumblingWF1PartitionEvtWtTest

TumblingWF1PartitionPauseTest - Class in streamcruncher.test.func.generic

This Test shows that the Query can be paused and resumed at will.

TumblingWF1PartitionPauseTest() - Constructor for class streamcruncher.test.func.generic.TumblingWF1PartitionPauseTest

TumblingWindowFTest - Class in streamcruncher.test.func.generic

A simple Test to demonstrate the "Latest Rows Window" in an anonymous Partition.

TumblingWindowFTest() - Constructor for class streamcruncher.test.func.generic.TumblingWindowFTest

TumblingWindowTest - Class in streamcruncher.test.func

Simple Test driver for "Latest Rows Window" feature tests.

TumblingWindowTest() - Constructor for class streamcruncher.test.func.TumblingWindowTest

U

unregisterAggregator(String) - Method in class streamcruncher.api.StreamCruncher

An Aggregator must be unregistered only after all the Queries that use it have been unregistered.

unregisterInStream(String) - Method in class streamcruncher.api.StreamCruncher

Unregisters the Input Event Stream.

unregisterProvider(String) - Method in class streamcruncher.api.StreamCruncher

A Provider must be unregistered only after all the Queries that use it have been unregistered.

unregisterQuery(String) - Method in class streamcruncher.api.StreamCruncher

Stops and unregisters the Query that is running on the Kernel.

V

valueOf(String) - Static method in enum streamcruncher.api.aggregator.AbstractAggregator.AggregationStage

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum streamcruncher.api.artifact.RowSpec.Info

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum streamcruncher.api.DBName

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum streamcruncher.api.QueryConfig.QuerySchedulePolicy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum streamcruncher.test.func.MultiStreamEventGenerator.EventType

Returns the enum constant of this type with the specified name.

values() - Static method in enum streamcruncher.api.aggregator.AbstractAggregator.AggregationStage

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum streamcruncher.api.artifact.RowSpec.Info

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum streamcruncher.api.DBName

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum streamcruncher.api.QueryConfig.QuerySchedulePolicy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum streamcruncher.test.func.MultiStreamEventGenerator.EventType

Returns an array containing the constants of this enum type, in the order they are declared.

W

WindowSizeProvider - Class in streamcruncher.api

This Provider Class enables Window sizes in Partitions to be customized at Run-time.

WindowSizeProvider() - Constructor for class streamcruncher.api.WindowSizeProvider

A B C D E G H I K L M N O P Q R S T U V W