Package | Description |
---|---|
com.streambase.liveview.client |
Provides classes and interfaces fundamental to the TIBCO Live Datamart Java API.
|
com.streambase.sb |
Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.
|
com.streambase.sb.adapter |
Provides classes and interfaces to add custom adapters to StreamBase applications.
|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
com.streambase.sb.expr | |
com.streambase.sb.feedsim |
Provides abstract classes to extend feedsim input sources.
|
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.
|
com.tibco.ep.sb.ads |
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 | 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,
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)
Deprecated.
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)
Deprecated.
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,
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,
Object jsonObject,
boolean strict)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
Object jsonObject,
boolean strict,
String timestampFormat)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
Object jsonObject,
boolean strict,
String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
String JSONString)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
String JSONString,
String timestampFormat)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
String JSONString,
String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
String JSONString)
Set the fields of a tuple based on the contents of a JSON string.
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
String JSONString,
String timestampFormat)
Set the fields of a tuple based on the contents of a JSON string.
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
String JSONString,
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 |
---|
ClusterNotificationTupleFields(Tuple tuple) |
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(Element element,
ByteOrder byteOrder)
Create a StreamProperties from the given XML document
|
StreamProperties(String a_xmlString)
Create a StreamProperties from the given string representation of an XML document
|
StreamProperties(String a_xmlString,
ByteOrder a_order)
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 |
(package private) class |
ClusterRedirectException |
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 |
---|---|
static StreamBaseException |
HAAdmin.processExceptions(String message,
List<Throwable> exceptions,
String baseURIString,
Class<?> exceptionsCheck)
Look through the exceptions; if we have one that isn't an XMLRPCException then throw that one
otherwise bundle them all up into a list exception.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
TupleConnections.addConnection(StreamBaseURI uri,
StreamProperties props) |
String[] |
Admin.addContainer(long timeoutMS,
String containerName,
byte[] application,
List<String> containerStreamMappings)
Add the given application to the given container in the StreamBaseServer
|
String[] |
HAAdmin.addContainer(long timeoutMS,
String containerName,
byte[] application,
List<String> containerStreamMappings) |
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)
Deprecated.
Replaced with application fragments and HOCON configuration
|
String[] |
StreamBaseAdminClient.addDeploy(File deployFile,
String... options)
Deprecated.
Replaced with application fragments and HOCON configuration
|
String[] |
Admin.addDeploy(long timeoutMS,
byte[] deploy,
List<String> args)
Add the given deploy file to the server.
|
String[] |
HAAdmin.addDeploy(long timeoutMS,
byte[] deploy,
List<String> args) |
String[] |
StreamBaseAdminClient.addDeploy(String deployText,
String... args)
Deprecated.
Replaced with application fragments and HOCON configuration
|
(package private) boolean |
StreamBaseClient.TupleBuffer.addTuple(Tuple tuple)
Add a tuple
|
(package private) boolean |
StreamBaseClient.TupleBuffer.addTuples(Collection<Tuple> tuples)
Add tuples
|
boolean |
Admin.checkLicense(long timeoutMS,
String featureName)
Return true if a license for the specified feature is available and false otherwise.
|
boolean |
HAAdmin.checkLicense(long timeoutMS,
String featureName)
Return true if a license for the specified feature is available and false otherwise.
|
int |
DequeueResult.checkStatus()
Check and return the status of this DequeueResult.
|
protected static void |
StreamBaseClient.checkValidStreamname(String streamname)
Validate stream name
|
String |
Admin.clearEvalCache(long timeoutMS,
String containerName)
Clear evaluation cache
|
String |
HAAdmin.clearEvalCache(long timeoutMS,
String containerName) |
String |
StreamBaseAdminClient.clearEvalCache(String containerName)
Clear evaluation cache
|
abstract void |
BaseClient.close()
close the client
|
void |
StreamBaseClient.close() |
void |
StreamBaseClient.close(String msg)
Flush all buffers and close the connection to the StreamBase server.
|
(package private) static Admin |
AdminFactory.create(List<StreamBaseURI> _uris)
Create the admin implementation object that does the actual
communication to the 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 |
Admin.describe(long timeoutMS,
String entityName)
Return an XML description of a StreamBase entity
|
String |
HAAdmin.describe(long timeoutMS,
String entityName)
Return an XML description of a StreamBase entity
|
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 |
Admin.drain(long timeoutMS,
String containerName)
Drain a StreamBase container or if empty the entire Server
|
void |
HAAdmin.drain(long timeoutMS,
String containerName) |
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.
|
(package private) abstract void |
StreamBaseClient.TupleBuffer.enqueue(boolean hasMore)
actually enqueue the buffer
|
(package private) void |
StreamBaseClient.SerializedTupleBuffer.enqueue(boolean hasMore) |
void |
Admin.enqueue(long timeoutMS,
StreamProperties props,
Collection<String> tuples)
Enqueue a list of CSV encoded tuples using connectionless XMLRPC
|
void |
HAAdmin.enqueue(long timeoutMS,
StreamProperties props,
Collection<String> tuples) |
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.
|
(package private) void |
TupleConnections.enqueueTupleBuffer(StreamBaseClient.SerializedTupleBuffer buffer,
boolean hasMore)
Private version of enqueue that does all of the work.
|
void |
Admin.fastForwardTime(long timeoutMS,
Object msecs)
Number of milliseconds to jump forward in time.
|
void |
HAAdmin.fastForwardTime(long timeout,
Object value) |
void |
StreamBaseAdminClient.fastForwardTime(String msecs)
Fast forward time
|
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
|
ByteOrder |
Admin.getByteOrder(long timeoutMS)
What is the byte order of the server?
|
ByteOrder |
HAAdmin.getByteOrder(long timeoutMS) |
(package private) List<TupleConnections.StreamTupleConnection> |
TupleConnections.getConnections(StreamProperties props)
Return an unmodifable list of List<StreamConnection>
|
Object |
StreamBaseClient.getDynamicVariable(String dynamicVariablePath)
Get the given dynamic variable
|
Schema.Field |
HAAdmin.getDynamicVariableField(long timeoutMS,
Path dynamicVariablePath) |
Tuple |
Admin.getDynamicVariables(long timeoutMS,
Path modulePath)
Return the current value of the dynamic variables in the given module,
as a Tuple of field name to Java value.
|
Tuple |
HAAdmin.getDynamicVariables(long timeoutMS,
Path modulePath) |
Tuple |
StreamBaseClient.getDynamicVariables(String modulePath)
Get a Tuple of all the dynamic variables on the given module
|
String |
Admin.getEvalCacheContent(long timeoutMS,
String containerName)
Get evaluation cache content
|
String |
HAAdmin.getEvalCacheContent(long timeout,
String containerName) |
String |
StreamBaseAdminClient.getEvalCacheContent(String containerName)
Get evaluation cache content
|
Constants.LeadershipStatus |
StreamBaseAdminClient.getLeadershipStatus()
Deprecated.
Legacy high-availability service, migrate to SB 10 high-availability service.
|
Constants.LeadershipStatus |
Admin.getLeadershipStatus(long timeoutMS)
Deprecated.
Legacy high-availability service, migrate to SB 10 high-availability service.
|
Constants.LeadershipStatus |
HAAdmin.getLeadershipStatus(long timeoutMS) |
String |
Admin.getMapperCacheContent(long timeoutMS,
String containerName)
Get mapper cache content
|
String |
HAAdmin.getMapperCacheContent(long timeoutMS,
String containerName) |
String |
StreamBaseAdminClient.getMapperCacheContent(String containerName)
Get mapper cache contents
|
Map<Integer,String> |
Admin.getNamesForContainer(long timeoutMS,
int id)
Return a map of id and names for the given container id.
|
Map<Integer,String> |
HAAdmin.getNamesForContainer(long timeoutMS,
int id) |
String[] |
Admin.getOperatorProperties(long timeoutMS,
String operatorName)
For the given Operator, return its set of properties and their values.
|
String[] |
HAAdmin.getOperatorProperties(long timeoutMS,
String operatorName) |
String[] |
StreamBaseAdminClient.getOperatorProperties(String operatorName)
For the given Operator, return its set of properties and their values.
|
String |
Admin.getOperatorProperty(long timeoutMS,
String operatorName,
String propertyName)
Return the value of the given property on the given Operator.
|
String |
HAAdmin.getOperatorProperty(long timeoutMS,
String operatorName,
String propertyName)
Return the value of the given property on the given Operator.
|
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 |
Admin.getSchemaByHash(long timeoutMS,
byte[] hash)
Return the Schema object for the given hash value
|
Schema |
HAAdmin.getSchemaByHash(long timeoutMS,
byte[] hash)
Return the Schema object for the given hash value
|
Schema |
Admin.getSchemaByName(long timeoutMS,
String schemaName)
Return the Schema object for the given name
|
Schema |
HAAdmin.getSchemaByName(long timeoutMS,
String schemaName)
Return the Schema object for the given name
|
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 |
Admin.getStreamProperties(long timeoutMS,
String streamName)
Return the StreamProperties for the given name.
|
StreamProperties |
HAAdmin.getStreamProperties(long timeoutMS,
String streamName) |
StreamProperties |
Admin.getStreamProperties(long timeoutMS,
String streamName,
CaptureTransformStrategy strategy)
Return the StreamProperties for the given name.
|
StreamProperties |
HAAdmin.getStreamProperties(long timeoutMS,
String streamName,
CaptureTransformStrategy strategy)
Return the StreamProperties for the given name
|
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 |
Admin.getStreamPropertiesByHash(long timeoutMS,
byte[] hash)
Return the StreamProperties for the given hash
|
StreamProperties |
HAAdmin.getStreamPropertiesByHash(long timeoutMS,
byte[] hash)
Return the StreamProperties for the given hash
|
StreamProperties |
StreamBaseClient.getStreamPropertiesByHash(String hashHexString)
Return the StreamProperties for the given hash
StreamProperties are cached locally in the client.
|
String |
StreamBaseAdminClient.getTargetTime()
Get target time
|
String |
Admin.getTargetTime(long timeoutMS)
Get target time
|
String |
HAAdmin.getTargetTime(long timeout) |
String[] |
Admin.internalCommand(long timeoutMS,
String... args)
run an internal command
|
String[] |
HAAdmin.internalCommand(long timeoutMS,
String... args)
Run the given internal command
|
String[] |
StreamBaseAdminClient.killAllConnections()
Kill all of the connections on the server
|
String[] |
Admin.killAllConnections(long timeoutMS)
Kill all of the connections on the server
|
String[] |
HAAdmin.killAllConnections(long timeoutMS) |
String[] |
StreamBaseAdminClient.killConnection(byte[] connectionId)
Kill the connection with the given connectionId
|
String[] |
Admin.killConnection(long timeoutMS,
byte[] connectionId)
Kill the connection with the given connectionId
|
String[] |
HAAdmin.killConnection(long timeoutMS,
byte[] connectionId) |
String[] |
Admin.listConnections(long timeoutMS,
StreamBaseAdminClient.ListConnectionArgument... arg)
Return an array of client connections
|
String[] |
HAAdmin.listConnections(long timeoutMS,
StreamBaseAdminClient.ListConnectionArgument... args)
Return an array of client connections
|
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[] |
Admin.listEntities(long timeoutMS,
String entityType,
int flags,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity type
|
String[] |
HAAdmin.listEntities(long timeoutMS,
String entityType,
int flags,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity type
|
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[] |
Admin.manageJdbcConnections(long timeoutMS,
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[] |
HAAdmin.manageJdbcConnections(long timeoutMS,
List<String> args) |
void |
HAAdmin.modifyApplication(long timeoutMS,
byte[] application)
Modify the StreamBase Server with the given StreamBase application.
|
String[] |
Admin.modifyContainer(long timeoutMS,
String containerName,
List<String> args)
Modify the given container
|
String[] |
HAAdmin.modifyContainer(long timeoutMS,
String containerName,
List<String> args)
Modify the given container
|
String[] |
StreamBaseAdminClient.modifyContainer(String containerName,
List<String> options)
Modifies the given container.
|
String[] |
Admin.operatorStatus(long timeoutMS,
String containerName)
Return the status of each Operator present in the StreamBase server.
|
String[] |
HAAdmin.operatorStatus(long timeoutMS,
String containerName)
Return the status of each Operator present in the StreamBase server.
|
String[] |
BaseClient.operatorStatus(String containerName)
Return the status of all the operators in the specified container
|
List<Tuple> |
Admin.readTable(long timeoutMS,
String tablePath,
int rowLimit,
String predicate)
Return rows from the table.
|
List<Tuple> |
HAAdmin.readTable(long timeoutMS,
String tablePath,
int rowLimit,
String predicate) |
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[] |
Admin.removeContainer(long timeoutMS,
String containerName,
List<String> args)
Remove the given container in the StreamBaseServer
|
String[] |
HAAdmin.removeContainer(long timeoutMS,
String containerName,
List<String> args) |
String[] |
StreamBaseAdminClient.removeContainer(String containerName,
String... args)
Remove the given container in the StreamBase server
|
String[] |
Admin.restartContainer(long timeoutMS,
String containerName)
Restart the given container
|
String[] |
HAAdmin.restartContainer(long timeoutMS,
String containerName) |
String[] |
StreamBaseAdminClient.restartContainer(String containerName)
Restart a container
|
void |
StreamBaseAdminClient.restartOperators(List<String> operatorNames)
Restart the given Operators on the StreamBase server.
|
void |
Admin.restartOperators(long timeoutMS,
List<String> operators)
Restart the given Operators on the StreamBase server.
|
void |
HAAdmin.restartOperators(long timeoutMS,
List<String> operatorNames) |
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 |
Admin.resume(long timeoutMS,
String containerName)
Resume a paused StreamBase container of if empty the whole Server
|
void |
HAAdmin.resume(long timeoutMS,
String containerName)
Resume a paused StreamBase server
|
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 |
Admin.resumeOperators(long timeoutMS,
List<String> operators)
Resume the given Operators on the StreamBase server
|
void |
HAAdmin.resumeOperators(long timeoutMS,
List<String> operatorsNames) |
void |
Admin.setDynamicVariable(long timeoutMS,
Path dynamicVariablePath,
Object value)
Set the value of the given dynamic variable to the given value.
|
void |
HAAdmin.setDynamicVariable(long timeoutMS,
Path dynamicVariablePath,
Object value) |
void |
StreamBaseClient.setDynamicVariable(String dynvarPath,
Object value)
Set the given dynamic variable to a new value
|
void |
StreamBaseAdminClient.setLeadershipStatus(Constants.LeadershipStatus leadershipStatus)
Deprecated.
Legacy high-availability service, migrate to SB 10 high-availability service.
|
void |
Admin.setLeadershipStatus(long timeoutMS,
Constants.LeadershipStatus leadershipStatus)
Deprecated.
Legacy high-availability service, migrate to SB 10 high-availability service.
|
void |
HAAdmin.setLeadershipStatus(long timeoutMS,
Constants.LeadershipStatus leadershipStatus) |
void |
Admin.setOperatorProperty(long timeoutMS,
String operatorName,
String propertyName,
String value)
On the given Operator, set the given property to the given value.
|
void |
HAAdmin.setOperatorProperty(long timeoutMS,
String operatorName,
String propertyName,
String value)
On the given Operator, set the given property to the given value.
|
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 |
TupleConnections.setQuiescentLimit(long timeoutMS) |
void |
Admin.setRuntimeParam(long timeoutMS,
String paramName,
String paramValue,
String operator)
set the given runtime param
|
void |
HAAdmin.setRuntimeParam(long timeoutMS,
String paramName,
String paramValue,
String operator) |
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 |
Admin.shutdown(long timeoutMS,
String containerName)
Shutdown a StreamBase container or if empty the whole server
|
String |
HAAdmin.shutdown(long timeoutMS,
String containerName) |
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.
|
void |
Admin.shutdownOperators(long timeoutMS,
List<String> operators)
Shut down the given Operators on the StreamBase server.
|
void |
HAAdmin.shutdownOperators(long timeoutMS,
List<String> operatorNames) |
String[] |
BaseClient.status()
Return the status of the StreamBase Server
|
String[] |
BaseClient.status(boolean verbose)
Return the status of the StreamBase Server
|
String[] |
Admin.status(long timeoutMS,
boolean verbose)
Return the status of the StreamBase Server
|
String[] |
HAAdmin.status(long timeoutMS,
boolean verbose)
Return the status of the StreamBase Server
|
SubscriptionEntry |
Admin.subscribe(long timeoutMS,
SubscriptionEntry subscription,
List<TupleConnections.StreamTupleConnection> connections)
Subscribe to an output stream.
|
SubscriptionEntry |
HAAdmin.subscribe(long timeoutMS,
SubscriptionEntry subscription,
List<TupleConnections.StreamTupleConnection> connections)
Subscribe to an output stream with predicate
|
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 |
Admin.suspend(long timeoutMS,
String name)
Suspend (pause) a StreamBase container or operator
|
void |
HAAdmin.suspend(long timeoutMS,
String name)
Suspend (pause) a StreamBase container or operator
|
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
|
void |
Admin.suspendOperators(long timeoutMS,
List<String> operators)
Suspend the given Operators on the StreamBase Server
|
void |
HAAdmin.suspendOperators(long timeoutMS,
List<String> operatorNames) |
StreamProperties[] |
Admin.typecheck(long timeoutMS,
String application,
boolean full)
Typecheck (validate) the given StreamBase Application.
|
StreamProperties[] |
HAAdmin.typecheck(long timeoutMS,
String application,
boolean full)
Typecheck (validate) the given StreamBase Application.
|
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 |
Admin.unsubscribe(long timeoutMS,
StreamProperties props,
String logicalstream,
List<TupleConnections.StreamTupleConnection> connections)
UnSubscribe to an output stream.
|
void |
HAAdmin.unsubscribe(long timeoutMS,
StreamProperties props,
String logicalstream,
List<TupleConnections.StreamTupleConnection> connections)
UnSubscribe to an output stream.
|
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)
Un-subscribe from stream
|
Constructor and Description |
---|
BaseClient(List<StreamBaseURI> uris,
ClientSettings settings)
Construct a BaseClient with the given URI
|
DeMUXStreamBaseClient(List<StreamBaseURI> uris,
ClientSettings settings) |
DeMUXStreamBaseClient(StreamBaseURI streamBaseURI) |
DeMUXStreamBaseClient(String uri) |
HAAdmin(List<StreamBaseURI> uris) |
SerializedTupleBuffer(StreamProperties props)
Constructor
|
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
|
Modifier and Type | Class and Description |
---|---|
class |
ExprException
Semantic exception parsing an expression.
|
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 |
---|---|
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() |
(package private) Snapshot.Status |
Snapshot.readNextMonitorSnap(StreamBaseClient sbClient,
Snapshot.Source source)
Read the next monitor snapshot, return Status if we are done or not
|
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,
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.
|
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.
|
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 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)
Execute the query
|
InputStream |
IResourceReader.getResourceContents(String name) |
InputStream |
Operator.getResourceContents(String name)
Returns an open input stream on the contents of the named resource file.
|
File |
IResourceReader.getResourceFile(String name) |
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
|
(package private) void |
Operator.OperatorThread.waitForAcceptance()
Block until the operator thread has successfully switched into the
new state requested by postStateChange.
|
Constructor and Description |
---|
TypecheckException(StreamBaseException cause) |
Modifier and Type | Method and Description |
---|---|
boolean |
FieldBasedTupleComparator.CompareFunctor.compare(TupleComparator comparator,
CompleteDataType cdt,
Object expected,
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,
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
Tuple s from an input object |
List<Tuple> |
AbstractTupleMaker.createTuples(Schema schema,
Collection<T> ts) |
List<Tuple> |
TupleMaker.createTuples(Schema schema,
Collection<T> t)
create multiple
Tuple s from input objects |
List<Tuple> |
AbstractTupleMaker.createTuples(Schema schema,
T... ts) |
List<Tuple> |
TupleMaker.createTuples(Schema schema,
T... t)
create multiple
Tuple s 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 Tuple dequeue object for a stream
|
static SBServerManager |
ServerManagerFactory.getEmbeddedServer() |
static SBServerManager |
ServerManagerFactory.getEmbeddedServer(SBTestEnvironment testEnv) |
static SBServerManager |
ServerManagerFactory.getEmbeddedServer(String confFilePath) |
Enqueuer |
SBServerManager.getEnqueuer(String path)
Get the Tuple enqueue object for a 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 the StreamBase Engine
|
boolean |
Expecter.Predicate.isExpected(Tuple t) |
abstract boolean |
Expecter.AbstractPredicate.isExpected(Tuple t) |
void |
SBServerManager.loadApp(String fullyQualifiedModuleName)
Load a module into the default container.
|
void |
SBServerManager.loadApp(String fullyQualifiedModuleName,
String container)
Load a module 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 StreamBase Engine, blocking until the StreamBase Engine is finished shutting down
|
void |
SBServerManager.startContainers()
Start all the containers for this StreamBase Engine.
|
void |
SBServerManager.startContainers(Set<String> containersSuspendedOnStartup)
Start all but the specified containers for this StreamBase Engine.
|
void |
SBServerManager.startContainers(Set<String> containersSuspendedOnStartup,
boolean deferSubscriptions)
Start all but the specified containers for this StreamBase Engine
|
void |
SBServerManager.startServer()
Start the StreamBase Engine, blocking until the StreamBase Engine will accept connections
|
void |
SBServerManager.stopContainers()
Stop all containers in this StreamBase Engine
|
void |
SBServerManager.subscribe(String streamPath)
Subscribes to a stream.
|
void |
SBServerManager.subscribeAll()
Subscribes to all streams
|
Constructor and Description |
---|
FieldBasedTupleComparator(DataType.Registry<FieldBasedTupleComparator.CompareFunctor> comparators,
String... fields) |
FieldBasedTupleComparator(FieldBasedTupleComparator baseComparator,
String... fields) |
Modifier and Type | Class and Description |
---|---|
class |
ArtifactException
Artifact exception.
|
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.