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 StreamBaseURIStreamBaseURI.DEFAULT_URIThe default URI (sb://localhost:10000/) pointing to localhost, no container, port 10000).Methods in com.streambase.sb.client that return StreamBaseURIModifier and TypeMethodDescriptionstatic StreamBaseURIStreamBaseURI.fromEnvironment()Returns the URI found by searching the following property and environment variables: Using the string value found in thestreambase.urisystem property, if set Using the string value found in theSTREAMBASE_URIenvironment variable, if set Using the string value found in theSTREAMBASE_SERVERenvironment variable, if setDEFAULT_URIif 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.urisystem property, if set Using the string value found in theSTREAMBASE_URIenvironment variable, if set Using the string value found in theSTREAMBASE_SERVERenvironment variable, if setDEFAULT_URIif 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.TupleIOTupleIOFactory.makeTupleIO(StreamBaseURI uri, ClientSettings settings) Method parameters in com.streambase.sb.client with type arguments of type StreamBaseURIModifier and TypeMethodDescriptionstatic StringStreamBaseURI.toSafeString(Collection<StreamBaseURI> uris) Create a string representation of a list of uris, that is safe for logging.static StringStreamBaseURI.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