| Package | Description |
|---|---|
| com.streambase.liveview.client |
Provides classes and interfaces fundamental to the TIBCO Live Datamart Java API.
|
| com.streambase.liveview.server.table.plugin |
Provides classes and interfaces to add custom table providers to TIBCO Live Datamart.
|
| 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.
|
| 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
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<java.lang.String,AbstractConfigObject> |
TableProviderManager.compileLVConfs(java.util.List<java.io.File> tableFiles,
boolean buildYaml) |
void |
TableProviderManager.createTable(java.lang.String name,
LiveviewConfiguration conf,
boolean saveInProject)
Does pre-checks, saves lvconf file and registers the table in defined state with the services layer
|
void |
TableProviderManager.deleteTable(CatalogedTable catalogedTable) |
void |
TableProviderManager.dropTables(java.util.List<java.lang.String> tables) |
void |
TableProviderManager.startTables(java.util.List<java.lang.String> tables) |
| 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 |
| Modifier and Type | Method and Description |
|---|---|
void |
TimeService.advanceBy(long timeAdvance,
java.util.concurrent.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
|
java.lang.Object |
Function.apply(java.lang.Object... args)
Applies the given arguments to this function and returns the output.
|
java.lang.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(java.lang.String value)
Decode a String value into the proper Container status
|
static Constants.LeadershipStatus |
Constants.LeadershipStatus.decode(java.lang.String value)
Decode the given String into a LeadershipStatus
|
static Timestamp |
Timestamp.fromString(java.lang.CharSequence dateString)
Create a timestamp using the given string
|
static Timestamp |
Timestamp.fromString(java.lang.String dateString)
Create a timestamp using the given string
|
static Timestamp |
Timestamp.fromString(java.lang.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
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
java.lang.Object jsonObject,
boolean strict)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
java.lang.Object jsonObject,
boolean strict,
java.lang.String timestampFormat)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
java.lang.Object jsonObject,
boolean strict,
java.lang.String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
java.lang.String JSONString)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
java.lang.String JSONString)
Set the fields of a tuple based on the contents of a JSON string.
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat)
Set the fields of a tuple based on the contents of a JSON string.
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON string.
|
| Constructor and Description |
|---|
StreamBaseIllegalArgumentException(StreamBaseException e) |
| Constructor and Description |
|---|
Schema(java.lang.String xmlSchema)
Construct a Schema out of XML represented as a String
|
StreamProperties(org.w3c.dom.Element element)
Create a StreamProperties from the given XML document
|
StreamProperties(java.lang.String a_xmlString)
Create a StreamProperties from the given string representation of an XML document
|
| Modifier and Type | Method and Description |
|---|---|
void |
InputAdapter.processTuple(int inputPort,
Tuple tuple) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String[] |
StreamBaseAdminClient.addContainer(java.lang.String containerName,
byte[] application,
java.util.List<java.lang.String> options)
Add the given application to the given container in the StreamBase server
|
java.lang.String[] |
StreamBaseAdminClient.addContainer(java.lang.String containerName,
java.io.File application,
java.util.List<java.lang.String> options)
Add the given application to the given container in the StreamBase server
|
java.lang.String[] |
StreamBaseAdminClient.addContainer(java.lang.String containerName,
java.lang.String applicationText,
java.util.List<java.lang.String> options)
Add the given application to the given container in the StreamBase server
|
java.lang.String[] |
StreamBaseAdminClient.addDeploy(byte[] deployText,
java.lang.String... args)
Add the given deployment file to the server given the byte content of the file.
|
java.lang.String[] |
StreamBaseAdminClient.addDeploy(java.io.File deployFile,
java.lang.String... options)
Adds applications and containers defined in the given deployment or archive file to the StreamBase server.
|
java.lang.String[] |
StreamBaseAdminClient.addDeploy(java.lang.String deployText,
java.lang.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(java.lang.String streamname) |
java.lang.String |
StreamBaseAdminClient.clearEvalCache(java.lang.String containerName) |
void |
StreamBaseClient.close() |
void |
StreamBaseClient.close(java.lang.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.
|
java.lang.String |
StreamBaseClient.describe(java.lang.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(java.lang.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,
java.util.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(java.lang.String stream,
java.util.Collection<Tuple> tuples)
Enqueue a collection of Tuples onto a stream.
|
void |
StreamBaseClient.enqueue(java.lang.String stream,
Tuple tuple)
Enqueue a single Tuple onto a stream.
|
void |
StreamBaseAdminClient.fastForwardTime(java.lang.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(java.lang.String stream_name)
Deprecated.
use
StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering |
java.util.Set<StreamProperties> |
StreamBaseClient.getAllStreamProperties(EntityType type)
Return all the StreamProperties available.
|
java.util.Set<StreamProperties> |
StreamBaseClient.getAllStreamProperties(EntityType type,
CaptureTransformStrategy strategy)
Return all the StreamProperties available
|
java.lang.Object |
StreamBaseClient.getDynamicVariable(java.lang.String dynamicVariablePath)
Get the given dynamic variable
|
Tuple |
StreamBaseClient.getDynamicVariables(java.lang.String modulePath)
Get a Tuple of all the dynamic variables on the given module
|
java.lang.String |
StreamBaseAdminClient.getEvalCacheContent(java.lang.String containerName) |
Constants.LeadershipStatus |
StreamBaseAdminClient.getLeadershipStatus()
Get the leadership status of the server.
|
java.lang.String |
StreamBaseAdminClient.getMapperCacheContent(java.lang.String containerName) |
java.lang.String[] |
StreamBaseAdminClient.getOperatorProperties(java.lang.String operatorName)
For the given Operator, return its set of properties and their values.
|
java.lang.String |
StreamBaseAdminClient.getOperatorProperty(java.lang.String operatorName,
java.lang.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(java.lang.String name)
Return the Schema object for the given name.
|
Schema |
StreamBaseClient.getSchemaForStream(java.lang.String streamName)
Return the schema of a stream.
|
StreamProperties |
StreamBaseClient.getStreamProperties(java.lang.String streamName)
Return the StreamProperties for the given stream name
|
StreamProperties |
StreamBaseClient.getStreamProperties(java.lang.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(java.lang.String hashHexString)
Return the StreamProperties for the given hash
StreamProperties are cached locally in the client.
|
java.lang.String |
StreamBaseAdminClient.getTargetTime() |
java.lang.String[] |
StreamBaseAdminClient.killAllConnections()
Kill all of the connections on the server
|
java.lang.String[] |
StreamBaseAdminClient.killConnection(byte[] connectionId)
Kill the connection with the given connectionId
|
java.lang.String[] |
StreamBaseAdminClient.listConnections(StreamBaseAdminClient.ListConnectionArgument... args)
Return an array of client connections
|
java.lang.String[] |
StreamBaseClient.listEntities(EntityType entityType)
Return an array of entity names for the given entity type.
|
java.lang.String[] |
StreamBaseClient.listEntities(EntityType entityType,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity type.
|
java.lang.String[] |
StreamBaseClient.listEntities(EntityType entityType,
int flags)
Return an array of entity names for the given entity type and flags.
|
java.lang.String[] |
StreamBaseClient.listEntities(EntityType entityType,
int flags,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity type and flags.
|
java.lang.String[] |
StreamBaseAdminClient.listEntities(java.lang.String entityType,
int flags)
Return an array of entity names for the given entity type
|
java.lang.String[] |
StreamBaseClient.listEntities(java.lang.String entityPath,
int flags)
Return an array of entity names for the given entity path.
|
java.lang.String[] |
StreamBaseClient.listEntities(java.lang.String entityPath,
int flags,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity path.
|
java.lang.String[] |
StreamBaseAdminClient.manageJdbcConnections(java.util.List<java.lang.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)
|
java.lang.String[] |
StreamBaseAdminClient.modifyContainer(java.lang.String containerName,
java.util.List<java.lang.String> options)
Modifies the given container.
|
java.util.List<Tuple> |
StreamBaseClient.readTable(java.lang.String tablePath,
int rowLimit)
Return rows from a Query Table or Materialized Window.
|
java.util.List<Tuple> |
StreamBaseClient.readTable(java.lang.String tablePath,
int rowLimit,
java.lang.String predicate)
Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.
|
java.lang.String[] |
StreamBaseAdminClient.removeContainer(java.lang.String containerName,
java.lang.String... args)
Remove the given container in the StreamBase server
|
java.lang.String[] |
StreamBaseAdminClient.restartContainer(java.lang.String containerName) |
void |
StreamBaseAdminClient.restartOperators(java.util.List<java.lang.String> operatorNames)
Restart the given Operators on the StreamBase server.
|
StreamProperties |
DeMUXStreamBaseClient.resubscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.resubscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate)
Resubscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.resubscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.resubscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate)
Resubscribe to a stream with a predicate.
|
void |
StreamBaseAdminClient.resume(java.lang.String containerName)
Resume a container in a StreamBase server
|
void |
StreamBaseAdminClient.resumeOperators(java.util.List<java.lang.String> operatorNames)
Resume the given Operators on the StreamBase server
|
void |
StreamBaseClient.setDynamicVariable(java.lang.String dynvarPath,
java.lang.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(java.lang.String operatorName,
java.lang.String propertyName,
java.lang.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(java.lang.String paramName,
java.lang.String paramValue,
java.lang.String operator)
Set a runtime parameter on one, or all, operators.
|
java.lang.String |
StreamBaseAdminClient.shutdown()
Shutdown a StreamBase server
|
java.lang.String |
StreamBaseAdminClient.shutdown(java.lang.String containerName)
Shutdown a container within a StreamBase server
|
void |
StreamBaseAdminClient.shutdownOperators(java.util.List<java.lang.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,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamname) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamname)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate,
DeMUXStreamBaseClient.DequeueListener listener)
This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
|
void |
StreamBaseAdminClient.suspend(java.lang.String name)
Suspend (pause) a container or operator within a StreamBase Server
|
void |
StreamBaseAdminClient.suspendOperators(java.util.List<java.lang.String> operatorNames)
Suspend (pause) the given Operators on the StreamBase Server
|
StreamProperties[] |
StreamBaseClient.typecheck(java.lang.String application)
Typecheck (validate) the given StreamBase Application.
|
StreamProperties[] |
StreamBaseClient.typecheck(java.lang.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(java.lang.String logicalStreamName) |
void |
StreamBaseClient.unsubscribe(java.lang.String logicalStreamName)
Unsubscribe from the given stream name.
|
protected void |
StreamBaseClient.unsubscribeInternal(StreamProperties logicalProps) |
| Constructor and Description |
|---|
DeMUXStreamBaseClient(java.util.List<StreamBaseURI> uris,
ClientSettings settings) |
DeMUXStreamBaseClient(StreamBaseURI streamBaseURI) |
DeMUXStreamBaseClient(java.lang.String uri) |
StreamBaseAdminClient()
Create a StreamBaseAdminClient.
|
StreamBaseAdminClient(java.util.List<StreamBaseURI> uris)
Create a StreamBaseAdminClient.
|
StreamBaseAdminClient(java.util.List<StreamBaseURI> uris,
ClientSettings settings)
Create a StreamBaseAdminClient.
|
StreamBaseAdminClient(StreamBaseURI uri)
Create a StreamBaseAdminClient, connecting to the server at the provided URI.
|
StreamBaseAdminClient(java.lang.String uri)
Create a StreamBaseAdminClient.
|
StreamBaseClient()
Create a StreamBaseClient.
|
StreamBaseClient(java.util.List<StreamBaseURI> uris)
Create a StreamBaseClient, connecting to the servers at the provided URIs.
|
StreamBaseClient(java.util.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(java.lang.String uriStrings)
Create a StreamBaseClient from one or more comma-separated URI strings
|
| Modifier and Type | Class and Description |
|---|---|
class |
com.streambase.sb.expr.ExprException |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
StatsUtil.IdentityHelper.getName(StatTuplev3 st) |
java.lang.String |
StatsUtil.IdentityHelper.getNameFromId(long id)
Stats Stream v3 only.
|
protected java.lang.String |
Snapshot.getOperatorType(StreamBaseClient sbClient,
java.lang.String name) |
java.util.Map<java.lang.Integer,java.lang.String> |
StatsUtil.IdentityHelper.IdentityUpdater.getUpdateByContainerId(int containerId) |
java.util.Iterator<Tuple> |
Snapshot.Source.nextResult() |
void |
StreamBaseMonitor.run()
Read and process monitor snapshots from sbd.
|
| Constructor and Description |
|---|
StreamBaseMonitor(StreamBaseClient client)
Create a monitoring object, which will connect to a server with the given
StreamBaseClient object.
|
StreamBaseMonitor(StreamBaseClient sbClient,
java.lang.String streamName) |
StreamBaseMonitor(StreamBaseURI uri)
Create a monitoring object, which will connect to a server with the given
StreamBase URI.
|
StreamBaseMonitor(java.lang.String uri)
Create a monitoring object
The given uri can either be a StreamBaseURI or a filename.
|
| 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.
|
| 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.
|
java.lang.String |
Operator.evaluate(java.lang.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 |
void |
PreparedQuery.execute(CompiledTuple args,
TableAccessor table,
RowConsumer consumer) |
java.io.InputStream |
IResourceReader.getResourceContents(java.lang.String name) |
java.io.InputStream |
Operator.getResourceContents(java.lang.String name)
Returns an open input stream on the contents of the named resource file.
|
java.io.File |
IResourceReader.getResourceFile(java.lang.String name) |
java.io.File |
Operator.getResourceFile(java.lang.String name)
Returns a
File pointing to the regular file or directory
if it exists. |
TableAccessor |
Operator.getTableAccessor(java.lang.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(java.lang.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(java.lang.Runnable operatorRunnable)
Deprecated.
As of StreamBase version 3.7, replaced by
Operator.registerRunnable(Runnable, boolean) |
void |
Operator.registerRunnable(java.lang.Runnable operatorRunnable,
boolean shouldInterrupt)
Register a Runnable object to be managed by this Operator.
|
void |
Operator.registerRunnable(java.lang.String runnableName,
java.lang.Runnable operatorRunnable,
boolean shouldInterrupt)
Register a Runnable object to be managed by this Operator.
|
void |
Operator.registerRunnable(java.lang.String runnableName,
java.lang.Runnable operatorRunnable,
boolean shouldInterrupt,
boolean synchronizedShutdown)
Register a Runnable object to be managed by this Operator.
|
void |
Operator.SharedObjectManager.registerSharedObject(java.lang.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,
java.util.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,
java.util.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(java.lang.String name,
java.lang.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,
java.lang.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
|
| Constructor and Description |
|---|
TypecheckException(StreamBaseException cause) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
FieldBasedTupleComparator.CompareFunctor.compare(TupleComparator comparator,
CompleteDataType cdt,
java.lang.Object expected,
java.lang.Object actual)
|
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,
java.lang.Object expected,
java.lang.Object actual)
Compare two values expected and actual, using
comparator for recursion as necessary. |
boolean |
FieldBasedTupleComparator.ListCompareFunctor.compareImpl(TupleComparator comparator,
CompleteDataType cdt,
java.lang.Object expected,
java.lang.Object actual) |
boolean |
FieldBasedTupleComparator.TupleCompareFunctor.compareImpl(TupleComparator comparator,
CompleteDataType cdt,
java.lang.Object expected,
java.lang.Object actual) |
boolean |
FieldBasedTupleComparator.compareValues(CompleteDataType cdt,
java.lang.Object expected,
java.lang.Object actual) |
boolean |
TupleComparator.compareValues(CompleteDataType cdt,
java.lang.Object expected,
java.lang.Object actual)
Compare two values with
CompleteDataType cdt. |
Tuple |
ObjectArrayTupleMaker.createTuple(Schema schema,
java.lang.Object[] objs) |
Tuple |
CSVTupleMaker.createTuple(Schema schema,
java.lang.String str) |
Tuple |
JSONSingleQuotesTupleMaker.createTuple(Schema schema,
java.lang.String str) |
Tuple |
JSONTupleMaker.createTuple(Schema schema,
java.lang.String str) |
abstract Tuple |
AbstractTupleMaker.createTuple(Schema schema,
T t) |
Tuple |
TupleMaker.createTuple(Schema schema,
T t)
create a
Tuples from an input object |
java.util.List<Tuple> |
AbstractTupleMaker.createTuples(Schema schema,
java.util.Collection<T> ts) |
java.util.List<Tuple> |
TupleMaker.createTuples(Schema schema,
java.util.Collection<T> t)
create multiple
Tuples from input objects |
java.util.List<Tuple> |
AbstractTupleMaker.createTuples(Schema schema,
T... ts) |
java.util.List<Tuple> |
TupleMaker.createTuples(Schema schema,
T... t)
create multiple
Tuples from input objects |
java.util.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
|
java.util.List<Tuple> |
Dequeuer.dequeue(int numTuples,
long timeout,
java.util.concurrent.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(java.util.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,
java.util.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,
java.util.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,
java.util.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(java.util.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,
java.util.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,
java.util.concurrent.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,
java.util.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,
java.util.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,
java.util.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(java.util.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,
java.util.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,
java.util.List<Expecter.Predicate> expected)
Expect tuples that fulfill multiple predicates in any order from the dequeuer
|
java.lang.String |
BaseTestEnvironment.getConf() |
java.lang.String |
SBTestEnvironment.getConf() |
Dequeuer |
SBServerManager.getDequeuer(java.lang.String path)
Get the dequeuer for this stream
|
static SBServerManager |
ServerManagerFactory.getEmbeddedServer() |
static SBServerManager |
ServerManagerFactory.getEmbeddedServer(SBTestEnvironment testEnv) |
static SBServerManager |
ServerManagerFactory.getEmbeddedServer(java.lang.String confFilePath) |
Enqueuer |
SBServerManager.getEnqueuer(java.lang.String path)
Get the enqueuer for this stream
|
TableAccessor |
SBServerManager.getTableAccessor(java.lang.String tablePath)
Return a TableAccessor suitable for manipulating this table.
|
TableAccessor |
SBServerManager.getTableAccessor(java.lang.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(java.lang.String appFile)
Load an application into the default container.
|
void |
SBServerManager.loadApp(java.lang.String appFile,
java.lang.String container)
Load an application into the specified container.
|
void |
SBServerManager.loadAppString(java.lang.String appString,
java.lang.String container)
Load an application (from a String) into the specified container.
|
void |
SBServerManager.loadDeploy(java.lang.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(java.util.Set<java.lang.String> containersSuspendedOnStartup)
Start all but the specified containers for this server.
|
void |
SBServerManager.startContainers(java.util.Set<java.lang.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(java.lang.String streamPath)
Subscribes to a stream.
|
void |
SBServerManager.subscribeAll()
Subscribes to all streams
|
| Constructor and Description |
|---|
FieldBasedTupleComparator(DataType.Registry<FieldBasedTupleComparator.CompareFunctor> comparators,
java.lang.String... fields) |
FieldBasedTupleComparator(FieldBasedTupleComparator baseComparator,
java.lang.String... fields) |