| 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. 
 | 
StreamBaseURI | 
BaseClient.getURI()
Return the URI used by this Client. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<StreamBaseURI> | 
BaseClient.getURIs()
get all of the URI's for this client 
 | 
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 | 
|---|---|
(package private) void | 
TupleConnections.addConnection(StreamBaseURI uri,
             StreamProperties props)  | 
| Modifier and Type | Method and Description | 
|---|---|
(package private) static Admin | 
AdminFactory.create(List<StreamBaseURI> _uris)
Create the admin implementation object that does the actual
 communication to the server. 
 | 
static String | 
HAAdmin.createBaseURIString(Collection<StreamBaseURI> uris)
Create a URI string of baseURI's from a list of uris 
 | 
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 | 
|---|
BaseClient(List<StreamBaseURI> uris,
          ClientSettings settings)
Construct a BaseClient with the given URI 
 | 
DeMUXStreamBaseClient(List<StreamBaseURI> uris,
                     ClientSettings settings)  | 
HAAdmin(List<StreamBaseURI> uris)  | 
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 StreamBase Engine 
 | 
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.