Package | Description |
---|---|
com.streambase.liveview.client |
Provides classes and interfaces fundamental to the TIBCO Live Datamart Java API.
|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
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 | Method and Description |
---|---|
StreamBaseURI |
SendTupleInfo.getSbUri() |
Modifier and Type | Method and Description |
---|---|
SendTupleInfo |
LiveViewConnection.getSendTupleInfo(StreamBaseURI sbUri,
String targetInputStreamName,
String responseOutputStreamName)
Gets the schemas associated with streams, for the purposes of using SendTupleAction.
|
Tuple |
LiveViewConnection.sendTupleAction(StreamBaseURI sbUri,
String targetInputStreamName,
Tuple tuple,
String responseOutputStreamName,
Schema expectedResponseSchema,
long timeout,
TimeUnit unit)
Sends a tuple to an existing StreamBase application.
|
Constructor and Description |
---|
SendTupleInfo(StreamBaseURI sbUri,
String inputStreamName,
String outputStreamName,
Schema inputSchema,
Schema outputSchema) |
Modifier and Type | Field and Description |
---|---|
static StreamBaseURI |
StreamBaseURI.DEFAULT_URI
The default URI (sb://localhost:10000/) pointing to localhost, no container, port 10000).
|
Modifier and Type | Method and Description |
---|---|
static StreamBaseURI |
StreamBaseURI.fromEnvironment()
Returns the URI found by searching the following property and environment variables:
Using the string value found in the
streambase.uri system property, if set
Using the string value found in the STREAMBASE_URI environment variable, if set
Using the string value found in the STREAMBASE_SERVER environment variable, if set
StreamBaseURI.DEFAULT_URI if no value has been found above
|
StreamBaseURI |
StreamBaseURI.getBaseURI()
Return a copy of this URI without any params
|
StreamBaseURI |
DequeueResult.getServerURI()
return the server that produced this DequeueResult.
|
Modifier and Type | Method and Description |
---|---|
static List<StreamBaseURI> |
StreamBaseURI.listFromEnvironment()
Returns the list of URIs found by searching the following property and environment variables for a
comma separated URI list:
Using the string value found in the
streambase.uri system property, if set
Using the string value found in the STREAMBASE_URI environment variable, if set
Using the string value found in the STREAMBASE_SERVER environment variable, if set
StreamBaseURI.DEFAULT_URI if no value has been above
The supplied URIs must conform to a valid High Availability URI list, for example they
must all reference the same container. |
static List<StreamBaseURI> |
StreamBaseURI.listFromString(String uriStrings)
Parse a comma-separated list of URIs in a string into a List<StreamBaseURI>.
|
Modifier and Type | Method and Description |
---|---|
static String |
StreamBaseURI.toString(Collection<StreamBaseURI> uris)
Create a string representation of a list of uris.
|
Constructor and Description |
---|
DeMUXStreamBaseClient(StreamBaseURI streamBaseURI) |
SimpleDequeueResult(List<Tuple> tuples,
StreamProperties props,
StreamBaseURI server,
Constants.LeadershipStatus leadershipStatus) |
StreamBaseAdminClient(StreamBaseURI uri)
Create a StreamBaseAdminClient, connecting to the server at the provided URI.
|
StreamBaseClient(StreamBaseURI uri)
Create a StreamBaseClient, connecting to the server at the provided URI
|
Constructor and Description |
---|
DeMUXStreamBaseClient(List<StreamBaseURI> uris,
ClientSettings settings) |
StreamBaseAdminClient(List<StreamBaseURI> uris)
Create a StreamBaseAdminClient.
|
StreamBaseAdminClient(List<StreamBaseURI> uris,
ClientSettings settings)
Create a StreamBaseAdminClient.
|
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.
|
Constructor and Description |
---|
StreamBaseMonitor(StreamBaseURI uri)
Create a monitoring object, which will connect to a server with the given
StreamBase URI.
|
Modifier and Type | Method and Description |
---|---|
StreamBaseURI |
Operator.RuntimeEnvironment.getURI()
Return the URI of this Server.
|
Modifier and Type | Method and Description |
---|---|
StreamBaseURI |
SBServerManager.getURI()
return the URI of the server
|