Uses of Class
com.streambase.sb.client.StreamBaseURI
Packages that use StreamBaseURI
Package
Description
Provides classes and interfaces fundamental to the LiveView Java API.
Provides classes and interfaces used to communicate with a Streaming server.
Provides classes and interfaces to monitor the behavior of a running Streaming server.
Provides classes and interfaces to add custom operators to Streaming applications.
Provides classes and interfaces used to author Streaming Unit tests.
-
Uses of StreamBaseURI in com.streambase.liveview.client
Methods in com.streambase.liveview.client that return StreamBaseURIMethods in com.streambase.liveview.client with parameters of type StreamBaseURIModifier and TypeMethodDescriptionLiveViewConnection.getSendTupleInfo
(StreamBaseURI sbUri, String targetInputStreamName, String responseOutputStreamName) Gets the schemas associated with streams, for the purposes of using SendTupleAction.LiveViewConnection.sendTupleAction
(StreamBaseURI sbUri, String targetInputStreamName, Tuple tuple, String responseOutputStreamName, Schema expectedResponseSchema, long timeout, TimeUnit unit) Sends a tuple to an existing StreamBase application.Constructors in com.streambase.liveview.client with parameters of type StreamBaseURIModifierConstructorDescriptionSendTupleInfo
(StreamBaseURI sbUri, String inputStreamName, String outputStreamName, Schema inputSchema, Schema outputSchema) -
Uses of StreamBaseURI in com.streambase.sb.client
Fields in com.streambase.sb.client declared as StreamBaseURIModifier and TypeFieldDescriptionstatic final StreamBaseURI
StreamBaseURI.DEFAULT_URI
The default URI (sb://localhost:10000/) pointing to localhost, no container, port 10000).Methods in com.streambase.sb.client that return StreamBaseURIModifier and TypeMethodDescriptionstatic StreamBaseURI
StreamBaseURI.fromEnvironment()
Returns the URI found by searching the following property and environment variables: Using the string value found in thestreambase.uri
system property, if set Using the string value found in theSTREAMBASE_URI
environment variable, if set Using the string value found in theSTREAMBASE_SERVER
environment variable, if setDEFAULT_URI
if no value has been found aboveStreamBaseURI.getBaseURI()
Return a copy of this URI without any paramsDequeueResult.getServerURI()
return the server that produced this DequeueResult.TupleConnection.getURI()
Get URIMethods in com.streambase.sb.client that return types with arguments of type StreamBaseURIModifier and TypeMethodDescriptionstatic 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 thestreambase.uri
system property, if set Using the string value found in theSTREAMBASE_URI
environment variable, if set Using the string value found in theSTREAMBASE_SERVER
environment variable, if setDEFAULT_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>.Methods in com.streambase.sb.client with parameters of type StreamBaseURIModifier and TypeMethodDescriptionstatic com.streambase.sb.client.TupleIO
TupleIOFactory.makeTupleIO
(StreamBaseURI uri, ClientSettings settings) Method parameters in com.streambase.sb.client with type arguments of type StreamBaseURIModifier and TypeMethodDescriptionstatic String
StreamBaseURI.toSafeString
(Collection<StreamBaseURI> uris) Create a string representation of a list of uris, that is safe for logging.static String
StreamBaseURI.toString
(Collection<StreamBaseURI> uris) Create a string representation of a list of uris.Constructors in com.streambase.sb.client with parameters of type StreamBaseURIModifierConstructorDescriptionDeMUXStreamBaseClient
(StreamBaseURI streamBaseURI) ConstructorInternalDequeueResult
(Throwable e, StreamBaseURI server) ConstructorSimpleDequeueResult
(List<Tuple> tuples, StreamProperties props, StreamBaseURI server) ConstructorSocketChannelWrapper
(StreamBaseURI uri, ClientSettings settings) open the socketSSLSocketWrapper
(StreamBaseURI uri, ClientSettings settings) Create a StreamBaseAdminClient, connecting to the server at the provided URI.Create a StreamBaseClient, connecting to the server at the provided URIConstructor parameters in com.streambase.sb.client with type arguments of type StreamBaseURIModifierConstructorDescriptionDeMUXStreamBaseClient
(List<StreamBaseURI> uris, ClientSettings settings) ConstructorCreate 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. -
Uses of StreamBaseURI in com.streambase.sb.monitor
Constructors in com.streambase.sb.monitor with parameters of type StreamBaseURIModifierConstructorDescriptionCreate a monitoring object, which will connect to a server with the given StreamBase URI. -
Uses of StreamBaseURI in com.streambase.sb.operator
Methods in com.streambase.sb.operator that return StreamBaseURIModifier and TypeMethodDescriptionOperator.RuntimeEnvironment.getURI()
Return the URI of this Server. -
Uses of StreamBaseURI in com.streambase.sb.unittest
Methods in com.streambase.sb.unittest that return StreamBaseURIModifier and TypeMethodDescriptionSBServerManager.getURI()
return the URI of the StreamBase Engine