Uses of Class
com.streambase.sb.StreamBaseException

Packages that use StreamBaseException

Package	Description
com.streambase.liveview.client	Provides classes and interfaces fundamental to the TIBCO Live Datamart Java API.
com.streambase.liveview.server.table.plugin
com.streambase.sb	Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.
com.streambase.sb.adapter
com.streambase.sb.client	Provides classes and interfaces used to communicate with a StreamBase server.
com.streambase.sb.expr
com.streambase.sb.feedsim
com.streambase.sb.monitor	Provides classes and interfaces to monitor the behavior of a running StreamBase server.
com.streambase.sb.operator	Provides classes and interfaces to add custom operators to StreamBase applications.
com.streambase.sb.unittest	Provides classes and interfaces used to author StreamBase Unit tests.

Uses of StreamBaseException in com.streambase.liveview.client

Subclasses of StreamBaseException in com.streambase.liveview.client

Modifier and Type	Class and Description
class	LiveViewConnectionCanceledException Exception throws when the LiveView connection call is cancelled by the client
class	LiveViewException An exception thrown by the LiveView Server
class	LiveViewQuerySyntaxException Specific LiveViewException thrown when query syntax error occurs

Uses of StreamBaseException in com.streambase.liveview.server.table.plugin

Methods in com.streambase.liveview.server.table.plugin that throw StreamBaseException

Modifier and Type	Method and Description
Map<String,AbstractConfigObject>	TableProviderManager.compileLVConfs(List<File> tableFiles, boolean buildYaml)
void	TableProviderManager.createTable(String name, LiveviewConfiguration conf)
void	TableProviderManager.deleteTable(CatalogedTable catalogedTable)
void	TableProviderManager.dropTables(List<String> tables)
void	TableProviderManager.startTables(List<String> tables)

Uses of StreamBaseException in com.streambase.sb

Subclasses of StreamBaseException in com.streambase.sb

Modifier and Type	Class and Description
class	ApplicationValidationException
class	NotImplementedException Signals that some feature has not yet been implemented.
class	NotSupportedException Signals that some feature is not supported
class	NullValueException An exception that is thrown when a field value is requested as a primitive (e.g., Tuple.getBoolean(), Tuple.getTimestamp()), but it is null.
class	ParsingException
class	SchemaMismatchException
static class	SchemaUtil.FieldConflictException
class	SchemaValidationException Exception to indicate validation failures
class	SemanticValidationException
class	StreamBaseListException An exception that contains a list of exceptions
class	TupleException Signals that an operation related to fields failed.
class	XmlInterpretationException
class	XmlParsingException

Methods in com.streambase.sb that throw StreamBaseException

Modifier and Type	Method and Description
void	TimeService.advanceBy(long timeAdvance, TimeUnit timeUnit) Advances the service time by a certain number of time units in the future.
void	TimeService.advanceTo(long targetTimeMsec) Make the service advance to a specific time in the future
Object	Function.apply(Object... args) Applies the given arguments to this function and returns the output.
Object	Function.apply(Tuple input) Applies the given arguments to this function and returns the output.
static Constants.ContainerState	Constants.ContainerState.decode(int value) Decode an int value into the proper ContainerStatus
static Constants.LeadershipStatus	Constants.LeadershipStatus.decode(int value) Decode the given integer into a LeadershipStatus
static Constants.ContainerState	Constants.ContainerState.decode(String value) Decode a String value into the proper Container status
static Constants.LeadershipStatus	Constants.LeadershipStatus.decode(String value) Decode the given String into a LeadershipStatus
static Timestamp	Timestamp.fromString(CharSequence dateString) Create a timestamp using the given string
static Timestamp	Timestamp.fromString(String dateString) Create a timestamp using the given string
static Timestamp	Timestamp.fromString(String dateString, com.streambase.sb.util.CSV.FormatInfo format) Create a timestamp using the given string and format.
Schema	SchemaUtil.SchemaProvider.getSchemaByHash(byte[] hash) request a schema by hash

Constructors in com.streambase.sb with parameters of type StreamBaseException

Constructor and Description
StreamBaseIllegalArgumentException(StreamBaseException e)

Constructors in com.streambase.sb that throw StreamBaseException

Constructor and Description
Schema(String xmlSchema) Construct a Schema out of XML represented as a String
StreamProperties(Element element) Create a StreamProperties from the given XML document
StreamProperties(String a_xmlString) Create a StreamProperties from the given string representation of an XML document

Uses of StreamBaseException in com.streambase.sb.adapter

Methods in com.streambase.sb.adapter that throw StreamBaseException

Modifier and Type	Method and Description
void	InputAdapter.processTuple(int inputPort, Tuple tuple)

Uses of StreamBaseException in com.streambase.sb.client

Subclasses of StreamBaseException in com.streambase.sb.client

Modifier and Type	Class and Description
class	ClientConnectException
class	HAServerIOException Exception thrown when there's an I/O error with a HA server
class	NetworkException Exception thrown when a network error/problem occurs
class	ProtocolException Exception thrown when a protocol error/problem occurs
class	URIException Exception thrown when URI parsing fails.

Methods in com.streambase.sb.client that throw StreamBaseException

Modifier and Type	Method and Description
String[]	StreamBaseAdminClient.addContainer(String containerName, byte[] application, List<String> options) Add the given application to the given container in the StreamBase server
String[]	StreamBaseAdminClient.addContainer(String containerName, File application, List<String> options) Add the given application to the given container in the StreamBase server
String[]	StreamBaseAdminClient.addContainer(String containerName, String applicationText, List<String> options) Add the given application to the given container in the StreamBase server
String[]	StreamBaseAdminClient.addDeploy(byte[] deployText, String... args) Add the given deployment file to the server given the byte content of the file.
String[]	StreamBaseAdminClient.addDeploy(File deployFile, String... options) Adds applications and containers defined in the given deployment or archive file to the StreamBase server.
String[]	StreamBaseAdminClient.addDeploy(String deployText, String... args) Add the given deployment file to the server given the text of the file
int	DequeueResult.checkStatus() Check and return the status of this DequeueResult.
protected static void	StreamBaseClient.checkValidStreamname(String streamname)
String	StreamBaseAdminClient.clearEvalCache(String containerName)
void	StreamBaseClient.close()
void	StreamBaseClient.close(String msg) Flush all buffers and close the connection to the StreamBase server.
DequeueResult	DeMUXStreamBaseClient.dequeue()
DequeueResult	StreamBaseClient.dequeue() Dequeue a batch of tuples from a subscribed stream.
DequeueResult	DeMUXStreamBaseClient.dequeue(long timeoutMS)
DequeueResult	StreamBaseClient.dequeue(long timeoutMS) Dequeue a batch of tuples from a subscribed stream.
String	StreamBaseClient.describe(String entityName) Return an XML description of a StreamBase entity
void	StreamBaseAdminClient.drain() Drain a StreamBase Server Has no effect if the server is not running
void	StreamBaseAdminClient.drain(String containerName) Drain a container within a StreamBase Server Has no effect if the server is not running
void	StreamBaseClient.enableBuffering(int bufferSize) Turn on buffering with a default WakeAndFlushBuffer thread set to 250ms
void	StreamBaseClient.enableBuffering(int bufferSize, long flushIntervalMilliSeconds) Turn on buffering.
void	StreamBaseClient.enqueue(StreamProperties props, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.
void	StreamBaseClient.enqueue(StreamProperties props, Tuple tuple) Enqueue a single Tuple onto a stream.
void	StreamBaseClient.enqueue(String stream, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.
void	StreamBaseClient.enqueue(String stream, Tuple tuple) Enqueue a single Tuple onto a stream.
void	StreamBaseAdminClient.fastForwardTime(String msecs)
void	StreamBaseClient.flushAllBuffers() Flush any pending enqueue buffers.
void	StreamBaseClient.flushBuffer(StreamProperties props) Deprecated. use StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering
void	StreamBaseClient.flushBuffer(String stream_name) Deprecated. use StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type) Return all the StreamProperties available.
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type, CaptureTransformStrategy strategy) Return all the StreamProperties available
Object	StreamBaseClient.getDynamicVariable(String dynamicVariablePath) Get the given dynamic variable
Tuple	StreamBaseClient.getDynamicVariables(String modulePath) Get a Tuple of all the dynamic variables on the given module
String	StreamBaseAdminClient.getEvalCacheContent(String containerName)
Constants.LeadershipStatus	StreamBaseAdminClient.getLeadershipStatus() Get the leadership status of the server.
String	StreamBaseAdminClient.getMapperCacheContent(String containerName)
String[]	StreamBaseAdminClient.getOperatorProperties(String operatorName) For the given Operator, return its set of properties and their values.
String	StreamBaseAdminClient.getOperatorProperty(String operatorName, String propertyName) Return the value of the given property on the given Operator.
Schema	StreamBaseClient.getSchemaByHash(byte[] hash) Return the Schema object for the given hash value
Schema	StreamBaseClient.getSchemaByName(String name) Return the Schema object for the given name.
Schema	StreamBaseClient.getSchemaForStream(String streamName) Return the schema of a stream.
StreamProperties	StreamBaseClient.getStreamProperties(String streamName) Return the StreamProperties for the given stream name
StreamProperties	StreamBaseClient.getStreamProperties(String streamName, CaptureTransformStrategy strategy) Return the StreamProperties for the given stream name
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(byte[] hash) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(String hashHexString) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
String	StreamBaseAdminClient.getTargetTime()
String[]	StreamBaseAdminClient.killAllConnections() Kill all of the connections on the server
String[]	StreamBaseAdminClient.killConnection(byte[] connectionId) Kill the connection with the given connectionId
String[]	StreamBaseAdminClient.listConnections(StreamBaseAdminClient.ListConnectionArgument... args) Return an array of client connections
String[]	StreamBaseClient.listEntities(EntityType entityType) Return an array of entity names for the given entity type.
String[]	StreamBaseClient.listEntities(EntityType entityType, CaptureTransformStrategy strategy) Return an array of entity names for the given entity type.
String[]	StreamBaseClient.listEntities(EntityType entityType, int flags) Return an array of entity names for the given entity type and flags.
String[]	StreamBaseClient.listEntities(EntityType entityType, int flags, CaptureTransformStrategy strategy) Return an array of entity names for the given entity type and flags.
String[]	StreamBaseAdminClient.listEntities(String entityType, int flags) Return an array of entity names for the given entity type
String[]	StreamBaseClient.listEntities(String entityPath, int flags) Return an array of entity names for the given entity path.
String[]	StreamBaseClient.listEntities(String entityPath, int flags, CaptureTransformStrategy strategy) Return an array of entity names for the given entity path.
String[]	StreamBaseAdminClient.manageJdbcConnections(List<String> args) Manage JDBC connections: count [name]Count the open JDBC connections to the named data source (or all data sources if ommitted) close [name]Close any open JDBC connections to the named data source (or all data sources if ommitted)
String[]	StreamBaseAdminClient.modifyContainer(String containerName, List<String> options) Modifies the given container.
List<Tuple>	StreamBaseClient.readTable(String tablePath, int rowLimit) Return rows from a Query Table or Materialized Window.
List<Tuple>	StreamBaseClient.readTable(String tablePath, int rowLimit, String predicate) Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.
String[]	StreamBaseAdminClient.removeContainer(String containerName, String... args) Remove the given container in the StreamBase server
String[]	StreamBaseAdminClient.restartContainer(String containerName)
void	StreamBaseAdminClient.restartOperators(List<String> operatorNames) Restart the given Operators on the StreamBase server.
StreamProperties	DeMUXStreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate) Resubscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate) Resubscribe to a stream with a predicate.
void	StreamBaseAdminClient.resume(String containerName) Resume a container in a StreamBase server
void	StreamBaseAdminClient.resumeOperators(List<String> operatorNames) Resume the given Operators on the StreamBase server
void	StreamBaseClient.setDynamicVariable(String dynvarPath, Object value) Set the given dynamic variable to a new value
void	StreamBaseAdminClient.setLeadershipStatus(Constants.LeadershipStatus leadershipStatus) Set the leadership status of the server.
void	StreamBaseAdminClient.setOperatorProperty(String operatorName, String propertyName, String value) On the given Operator, set the given property to the given value.
void	StreamBaseClient.setQuiescentLimit(long timeoutMS) If more then timeoutMS milliseconds elapse without receiving data or a heart beat from the server, the client will close.
void	StreamBaseAdminClient.setRuntimeParam(String paramName, String paramValue, String operator) Set a runtime parameter on one, or all, operators.
String	StreamBaseAdminClient.shutdown() Shutdown a StreamBase server
String	StreamBaseAdminClient.shutdown(String containerName) Shutdown a container within a StreamBase server
void	StreamBaseAdminClient.shutdownOperators(List<String> operatorNames) Shut down the given Operators on the StreamBase server.
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props)
StreamProperties	StreamBaseClient.subscribe(StreamProperties props) Subscribe to a stream
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate) Subscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname)
StreamProperties	StreamBaseClient.subscribe(String streamname) Subscribe to a stream
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy)
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy) Subscribe to a stream
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate) Subscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(String streamname, String logicalstream, String predicate) Subscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate, DeMUXStreamBaseClient.DequeueListener listener) This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
void	StreamBaseAdminClient.suspend(String name) Suspend (pause) a container or operator within a StreamBase Server
void	StreamBaseAdminClient.suspendOperators(List<String> operatorNames) Suspend (pause) the given Operators on the StreamBase Server
StreamProperties[]	StreamBaseClient.typecheck(String application) Typecheck (validate) the given StreamBase Application.
StreamProperties[]	StreamBaseClient.typecheck(String application, boolean full) Typecheck (validate) the given StreamBase Application.
void	DeMUXStreamBaseClient.unsubscribe(StreamProperties logicalProps)
void	StreamBaseClient.unsubscribe(StreamProperties logicalProps) Unsubscribe from the given stream name.
void	DeMUXStreamBaseClient.unsubscribe(String logicalStreamName)
void	StreamBaseClient.unsubscribe(String logicalStreamName) Unsubscribe from the given stream name.
protected void	StreamBaseClient.unsubscribeInternal(StreamProperties logicalProps)

Constructors in com.streambase.sb.client that throw StreamBaseException

Constructor and Description
DeMUXStreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings)
DeMUXStreamBaseClient(StreamBaseURI streamBaseURI)
DeMUXStreamBaseClient(String uri)
StreamBaseAdminClient() Create a StreamBaseAdminClient.
StreamBaseAdminClient(List<StreamBaseURI> uris) Create a StreamBaseAdminClient.
StreamBaseAdminClient(List<StreamBaseURI> uris, ClientSettings settings) Create a StreamBaseAdminClient.
StreamBaseAdminClient(StreamBaseURI uri) Create a StreamBaseAdminClient, connecting to the server at the provided URI.
StreamBaseAdminClient(String uri) Create a StreamBaseAdminClient.
StreamBaseClient() Create a StreamBaseClient.
StreamBaseClient(List<StreamBaseURI> uris) Create a StreamBaseClient, connecting to the servers at the provided URIs.
StreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings) Create a StreamBaseClient, connecting to the servers at the provided URIs.
StreamBaseClient(StreamBaseURI uri) Create a StreamBaseClient, connecting to the server at the provided URI
StreamBaseClient(String uriStrings) Create a StreamBaseClient from one or more comma-separated URI strings

Uses of StreamBaseException in com.streambase.sb.expr

Subclasses of StreamBaseException in com.streambase.sb.expr with annotations of type with type parameters of type that implement declared as with annotations of type with type parameters of type with annotations of type with annotations of type with type parameters of type that return that return types with arguments of type with parameters of type with type arguments of type that throw with annotations of type with annotations of type with parameters of type with type arguments of type that throw

Modifier and Type	Class and Description
class	com.streambase.sb.expr.ExprException

Uses of StreamBaseException in com.streambase.sb.feedsim

Methods in com.streambase.sb.feedsim that throw StreamBaseException

Modifier and Type	Method and Description
abstract Schema	FeedSimTupleInputStream.getSchema() This method must return the Schema of the data to be returned by readTuple()
abstract Tuple	FeedSimTupleInputStream.readTuple() This method is called by a FeedSim thread to get the next tuple to send.

Uses of StreamBaseException in com.streambase.sb.monitor

Methods in com.streambase.sb.monitor that throw StreamBaseException

Modifier and Type	Method and Description
String	StatsUtil.IdentityHelper.getName(StatTuplev3 st)
String	StatsUtil.IdentityHelper.getNameFromId(long id) Stats Stream v3 only.
protected String	Snapshot.getOperatorType(StreamBaseClient sbClient, String name)
Map<Integer,String>	StatsUtil.IdentityHelper.IdentityUpdater.getUpdateByContainerId(int containerId)
Iterator<Tuple>	Snapshot.Source.nextResult()
void	StreamBaseMonitor.run() Read and process monitor snapshots from sbd.

Constructors in com.streambase.sb.monitor that throw StreamBaseException

Constructor and Description
StreamBaseMonitor(StreamBaseClient client) Create a monitoring object, which will connect to a server with the given StreamBaseClient object.
StreamBaseMonitor(StreamBaseClient sbClient, String streamName)
StreamBaseMonitor(StreamBaseURI uri) Create a monitoring object, which will connect to a server with the given StreamBase URI.
StreamBaseMonitor(String uri) Create a monitoring object The given uri can either be a StreamBaseURI or a filename.

Uses of StreamBaseException in com.streambase.sb.operator

Subclasses of StreamBaseException in com.streambase.sb.operator

Modifier and Type	Class and Description
class	AlreadyRegisteredException
class	DbConnectTypecheckException
class	Operator.PropertyTypecheckException A typecheck exception associated with an Operator property (or parameter) by name.
class	ParameterInterpretationException
class	ResourceNotFoundException Thrown when an operator tries to get a resource by name, but no such resource exists.
class	SqlTypecheckException
class	TypecheckException May be thrown when an error occurs during an Operator's typecheck() method.

Methods in com.streambase.sb.operator that throw StreamBaseException

Modifier and Type	Method and Description
void	RowConsumer.consume(Tuple row) Override this method to consume rows.
Tuple	TableAccessor.delete(Tuple pkey) Delete a row in the table based on primary key.
String	Operator.evaluate(String st, Tuple input) evaluate the given string expression in the context of the running module If an error occurs during the evaluation, the error message return value will be a string containing the error message
void	PreparedQuery.execute(CompiledTuple args, RowConsumer consumer) Run the query against a given set of arguments, and pass the results to consumer
InputStream	Operator.getResourceContents(String name) Returns an open input stream on the contents of the named resource file.
File	Operator.getResourceFile(String name) Returns a File pointing to the regular file or directory if it exists.
TableAccessor	Operator.getTableAccessor(String name) Get a TableAccessor for a table in the local module by name of that table.
TupleCaptureTransformer	Operator.getTupleCaptureTransformer(Schema s) Get a TupleCaptureTransformer capable of translating tuples with the given schema to the equivalent schema with all the capture fields expanded out, and translating expanded tuples back into tuples with the given schema This method may only be called at runtime; the exact schemas of any capture fields are not fully determined at typecheck time.
void	Operator.init() After the Operator has typechecked successfully, but before the application or any managed threads start, the StreamBase server will call the init method.
void	TableAccessor.insert(Tuple row) Insert a new row into the table.
PreparedQuery	TableAccessor.prepare(String predicate, Schema args) Prepare an index-accessing query.
abstract void	Operator.processTuple(int inputPort, Tuple tuple) This method will be called by the StreamBase server for each Tuple given to the Operator to process.
Tuple	TableAccessor.readPrimary(Tuple pkey) Read a row from the table by primary key.
void	Operator.registerRunnable(Runnable operatorRunnable) Deprecated. As of StreamBase version 3.7, replaced by Operator.registerRunnable(Runnable, boolean)
void	Operator.registerRunnable(Runnable operatorRunnable, boolean shouldInterrupt) Register a Runnable object to be managed by this Operator.
void	Operator.registerRunnable(String runnableName, Runnable operatorRunnable, boolean shouldInterrupt) Register a Runnable object to be managed by this Operator.
void	Operator.registerRunnable(String runnableName, Runnable operatorRunnable, boolean shouldInterrupt, boolean synchronizedShutdown) Register a Runnable object to be managed by this Operator.
void	Operator.SharedObjectManager.registerSharedObject(Object key, Operator.SharedObject value) Add the given SharedObject to this Container.
Tuple	TableAccessor.replace(Tuple row) Replace a row in the table, or insert if there is no existing row with matching primary key.
void	Operator.SharedObject.resumeObject() Resume the SharedObject.
void	Operator.sendOutput(int port, List<Tuple> tuples) Enqueue a List of Tuples to be sent synchronously to downstream operators.
void	Operator.sendOutput(int port, Tuple tuple) Enqueue a Tuple to be sent synchronously to downstream operators.
void	Operator.sendOutputAsync(int port, List<Tuple> tuples) Enqueue a List of Tuples to be sent asynchronously to downstream operators.
void	Operator.sendOutputAsync(int port, Tuple tuple) Enqueue a Tuple to be sent asynchronously to downstream operators.
void	Operator.setDynamicVariable(String name, Object value) Sets the value of this module's dynamic variable.
static void	Operator.setLogLevel(org.slf4j.Logger logger, Operator.LogLevel level) Sets the log level of the given logger.
static void	Operator.setLogLevel(org.slf4j.Logger logger, String level) Sets the log level of the given logger.
void	Operator.SharedObject.shutdownObject() Shutdown the SharedObject.
void	Operator.SharedObject.startObject() Start the SharedObject.
void	Operator.SharedObject.suspendObject() Suspend the SharedObject.
void	TableAccessor.truncate() Truncate the table, by removing all rows

Constructors in com.streambase.sb.operator with parameters of type StreamBaseException

Constructor and Description
TypecheckException(StreamBaseException cause)

Uses of StreamBaseException in com.streambase.sb.unittest

Methods in com.streambase.sb.unittest that throw StreamBaseException

Modifier and Type	Method and Description
boolean	FieldBasedTupleComparator.CompareFunctor.compare(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) Handle null checks before delegating to FieldBasedTupleComparator.CompareFunctor.compareImpl(com.streambase.sb.unittest.TupleComparator, com.streambase.sb.CompleteDataType, java.lang.Object, java.lang.Object)
boolean	FieldBasedTupleComparator.compare(Tuple expected, Tuple actual)
boolean	TupleComparator.compare(Tuple expected, Tuple actual) Compare two tuples.
abstract boolean	FieldBasedTupleComparator.CompareFunctor.compareImpl(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) Compare two values expected and actual, using comparator for recursion as necessary.
boolean	FieldBasedTupleComparator.ListCompareFunctor.compareImpl(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual)
boolean	FieldBasedTupleComparator.TupleCompareFunctor.compareImpl(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual)
boolean	FieldBasedTupleComparator.compareValues(CompleteDataType cdt, Object expected, Object actual)
boolean	TupleComparator.compareValues(CompleteDataType cdt, Object expected, Object actual) Compare two values with CompleteDataType cdt.
Tuple	ObjectArrayTupleMaker.createTuple(Schema schema, Object[] objs)
Tuple	CSVTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONSingleQuotesTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONTupleMaker.createTuple(Schema schema, String str)
abstract Tuple	AbstractTupleMaker.createTuple(Schema schema, T t)
Tuple	TupleMaker.createTuple(Schema schema, T t) create a Tuples from an input object
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, Collection<T> ts)
List<Tuple>	TupleMaker.createTuples(Schema schema, Collection<T> t) create multiple Tuples from input objects
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, T... ts)
List<Tuple>	TupleMaker.createTuples(Schema schema, T... t) create multiple Tuples from input objects
List<Tuple>	Dequeuer.dequeue(int numTuples) Try to dequeue tuples with the Dequeuer.DEFAULT_TIMEOUT and Dequeuer.DEFAULT_TIMEOUT_UNIT if numTuples == 0 will return immediately if numTuples < 0 will wait the maximum timeout before returning
List<Tuple>	Dequeuer.dequeue(int numTuples, long timeout, TimeUnit timeUnit) Try to dequeue tuples within a provided timeout.
void	Dequeuer.drain() Drain any tuples that are currently in flight in the server.
void	SBServerManager.drain() Wait for processing to complete on all currently enqueued tuples.
void	Enqueuer.enqueue(List<Tuple> tuples) Enqueue multiple tuples to the stream
void	Enqueuer.enqueue(Tuple... tuples) Enqueue multiple tuples to the stream
void	Enqueuer.enqueue(Tuple tuple) Enqueue Tuple to the stream
<T> void	Enqueuer.enqueue(TupleMaker<T> tupleMaker, List<T> t) Create multiple tuples using a TupleMaker and then enqueue them.
<T> void	Enqueuer.enqueue(TupleMaker<T> tupleMaker, T... t) Create multiple tuples using a TupleMaker and then enqueue them.
<T> void	Enqueuer.enqueue(TupleMaker<T> tupleMaker, T t) Create a tuple using a TupleMaker and then enqueue it.
void	Expecter.expect(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer
void	Expecter.expect(Expecter.DequeueSetting mode, Tuple... tuples) Expect multiple tuples in a particular order from the dequeuer
void	Expecter.expect(Expecter.DequeueSetting mode, Tuple expected) Expect a given tuple from the dequeuer
<T> void	Expecter.expect(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, List<T> t) Expect a tuple from the dequeuer
<T> void	Expecter.expect(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T... t) Expect a tuple from the dequeuer
<T> void	Expecter.expect(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T t) Expect a tuple from the dequeuer
void	Expecter.expect(List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer.
void	Expecter.expect(Tuple... tuples) Expect multiple tuples in a particular order from the dequeuer.
void	Expecter.expect(Tuple tuple) Expect a tuple from the dequeuer.
<T> void	Expecter.expect(TupleMaker<T> tupleMaker, List<T> t) Expect multiple tuples in a particular order from the dequeuer.
<T> void	Expecter.expect(TupleMaker<T> tupleMaker, T... t) Expect multiple tuples in a particular order from the dequeuer.
<T> void	Expecter.expect(TupleMaker<T> tupleMaker, T t) Expect a tuple from the dequeuer.
void	Expecter.expectNothing() Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.
void	Expecter.expectNothing(long time, TimeUnit unit) Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.
void	Expecter.expectPredicate(Expecter.DequeueSetting mode, Expecter.Predicate p) Expect a tuple that fulfills the given predicate from the dequeuer
void	Expecter.expectPredicate(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected) Expect a number of tuples, each fulfilling one predicate in a list, from the Dequeuer
void	Expecter.expectUnordered(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in any order from the dequeuer
void	Expecter.expectUnordered(Expecter.DequeueSetting mode, Tuple... expected) Expect multiple tuples in any order from the dequeuer
<T> void	Expecter.expectUnordered(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, List<T> t) Expect multiple tuples in any order from the dequeuer
<T> void	Expecter.expectUnordered(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T... t) Expect multiple tuples in any order from the dequeuer
void	Expecter.expectUnordered(List<Tuple> expected) Expect multiple tuples in any order from the dequeuer.
void	Expecter.expectUnordered(Tuple... expected) Expect multiple tuples in any order from the dequeuer.
<T> void	Expecter.expectUnordered(TupleMaker<T> tupleMaker, List<T> t) Expect multiple tuples in any order from the dequeuer.
<T> void	Expecter.expectUnordered(TupleMaker<T> tupleMaker, T... t) Expect multiple tuples in any order from the dequeuer.
void	Expecter.expectUnorderedPredicate(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected) Expect tuples that fulfill multiple predicates in any order from the dequeuer
String	BaseTestEnvironment.getConf()
String	SBTestEnvironment.getConf()
Dequeuer	SBServerManager.getDequeuer(String path) Get the dequeuer for this stream
static SBServerManager	ServerManagerFactory.getEmbeddedServer()
static SBServerManager	ServerManagerFactory.getEmbeddedServer(SBTestEnvironment testEnv)
static SBServerManager	ServerManagerFactory.getEmbeddedServer(String confFilePath)
Enqueuer	SBServerManager.getEnqueuer(String path) Get the enqueuer for this stream
TableAccessor	SBServerManager.getTableAccessor(String tablePath) Return a TableAccessor suitable for manipulating this table.
TableAccessor	SBServerManager.getTableAccessor(String tablePath, CaptureTransformStrategy captureStrategy) Return a TableAccessor suitable for manipulating this table.
TimeService	SBServerManager.getTimeService() Return the current TimeService implementation used by StreamBase server
boolean	Expecter.Predicate.isExpected(Tuple t)
abstract boolean	Expecter.AbstractPredicate.isExpected(Tuple t)
void	SBServerManager.loadApp(String appFile) Load an application into the default container.
void	SBServerManager.loadApp(String appFile, String container) Load an application into the specified container.
void	SBServerManager.loadAppString(String appString, String container) Load an application (from a String) into the specified container.
void	SBServerManager.loadDeploy(String deployFile) Load the given StreamBase deployment file.
void	BaseTestEnvironment.setNowImpl(NowImplementation nowImpl)
void	SBTestEnvironment.setNowImpl(NowImplementation nowImpl) Set the current implementation of now() function
void	SBServerManager.shutdownServer() Shutdown the server, blocking until the server is finished shutting down
void	SBServerManager.startContainers() Start all the containers for this server.
void	SBServerManager.startContainers(Set<String> containersSuspendedOnStartup) Start all but the specified containers for this server.
void	SBServerManager.startContainers(Set<String> containersSuspendedOnStartup, boolean deferSubscriptions) Start all but the specified containers for this server
void	SBServerManager.startServer() Start the server, blocking until the server will accept connections
void	SBServerManager.stopContainers() Stop all containers in this server
void	SBServerManager.subscribe(String streamPath) Subscribes to a stream.
void	SBServerManager.subscribeAll() Subscribes to all streams

Constructors in com.streambase.sb.unittest that throw StreamBaseException

Constructor and Description
FieldBasedTupleComparator(DataType.Registry<FieldBasedTupleComparator.CompareFunctor> comparators, String... fields)
FieldBasedTupleComparator(FieldBasedTupleComparator baseComparator, String... fields)