Package com.streambase.sb.unittest
package com.streambase.sb.unittest
Provides classes and interfaces used to author Streaming Unit tests.
-
ClassDescriptionA convenience class which implements all of the methods of
TupleMaker
in terms ofAbstractTupleMaker.createTuple(Schema, Object)
.A default implementation ofSBTestEnvironment
for use bySBServerManager
instances.A Dequeuer is used for dequeueing tuples from a specific stream.An Enqueuer is used for enqueueing tuples onto a stream.Subclass this and override isExpected(Tuple t) to simplify creating predicates.Dequeue settingsTo expect tuples by predicate, implement this interface.ATupleComparator
that compares tuples in a naive field-by-field manner.A strategy object for handling comparisons of specific field types.Compare double values using a ratio test and a tolerance.Ignore timestamp compare functorList compare functorSimple object compare functorCheck if the second argument matches the regex defined for the first argument.Tuple compare functorA factory to buildTuple
s from Java objects.SBServerManager
provides control and access to a StreamBase Engine.This interface is not expected to be implemented by end-users.Contains static methods for creating concreteSBServerManager
Contains static methods for creating concreteTimeService
ATupleComparator
abstracts comparison of tuples.TupleMaker<T>Interface for constructing tuples from data.Unit test properties