Uses of Class
com.streambase.sb.StreamProperties
Packages that use StreamProperties
Package
Description
Provides classes and interfaces fundamental to the Streaming 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 used to author Streaming Unit tests.
-
Uses of StreamProperties in com.streambase.sb
Methods in com.streambase.sb that return StreamPropertiesModifier and TypeMethodDescriptionstatic StreamProperties
Create new stream properties from XML stringstatic StreamProperties
Create new stream properties from XML element -
Uses of StreamProperties in com.streambase.sb.client
Fields in com.streambase.sb.client declared as StreamPropertiesModifier and TypeFieldDescriptionprotected final StreamProperties
DequeueResult.props
Stream propertiesMethods in com.streambase.sb.client that return StreamPropertiesModifier and TypeMethodDescriptionDequeueResult.getStreamProperties()
Return the StreamProperties for this DequeueResult.StreamBaseClient.getStreamProperties
(String streamName) Return the StreamProperties for the given stream nameStreamBaseClient.getStreamProperties
(String streamName, CaptureTransformStrategy strategy) Return the StreamProperties for the given stream nameXmlRpcAdmin.getStreamProperties
(long timeoutMS, String streamName) XmlRpcAdmin.getStreamProperties
(long timeoutMS, String streamName, CaptureTransformStrategy strategy) StreamBaseClient.getStreamPropertiesByHash
(byte[] hash) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.StreamBaseClient.getStreamPropertiesByHash
(String hashHexString) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.XmlRpcAdmin.getStreamPropertiesByHash
(long timeoutMS, byte[] hash) StreamBaseClient.TupleBuffer.props()
get stream properties for this BufferDeMUXStreamBaseClient.resubscribe
(StreamProperties props, String logicalstream, String predicate) DeMUXStreamBaseClient.resubscribe
(String streamname, String logicalstream, String predicate) StreamBaseClient.resubscribe
(StreamProperties props, String logicalStream, String predicate) Resubscribe to a stream with a predicate.StreamBaseClient.resubscribe
(String streamname, String logicalstream, String predicate) Resubscribe to a stream with a predicate.DeMUXStreamBaseClient.subscribe
(StreamProperties props) DeMUXStreamBaseClient.subscribe
(StreamProperties props, String logicalstream, String predicate) DeMUXStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy) DeMUXStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate) DeMUXStreamBaseClient.subscribe
(String streamName, String logicalStream, String predicate, DeMUXStreamBaseClient.DequeueListener listener) This is the only subscribe operation that is supported by the DeMUXStreamBaseClientStreamBaseClient.subscribe
(StreamProperties props) Subscribe to a streamStreamBaseClient.subscribe
(StreamProperties props, String logicalStream, String predicate) Subscribe to a stream with a predicate.Subscribe to a streamStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy) Subscribe to a streamStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate) Subscribe to a stream with a predicate.Subscribe to a stream with a predicate.Typecheck (validate) the given StreamBase Application.Typecheck (validate) the given StreamBase Application.XmlRpcAdmin.typecheck
(long timeoutMS, String application, boolean full) Methods in com.streambase.sb.client that return types with arguments of type StreamPropertiesModifier and TypeMethodDescriptionStreamBaseClient.getAllStreamProperties
(EntityType type) Return all the StreamProperties available.StreamBaseClient.getAllStreamProperties
(EntityType type, CaptureTransformStrategy strategy) Return all the StreamProperties availableMethods in com.streambase.sb.client with parameters of type StreamPropertiesModifier and TypeMethodDescriptionprotected static String
StreamBaseClient.assureNameStartsWithContainer
(StreamProperties base, String logicalName) Ensure name starts with containerboolean
StreamBaseClient.TupleBuffer.canDequeue
(StreamProperties props) Can dequeue?boolean
StreamBaseClient.TupleBuffer.canEnqueue
(StreamProperties props) Can enqueue?void
StreamBaseClient.enqueue
(StreamProperties props, Tuple tuple) Enqueue a single Tuple onto a stream.void
StreamBaseClient.enqueue
(StreamProperties props, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.void
XmlRpcAdmin.enqueue
(long timeoutMS, StreamProperties props, Collection<String> tuples) void
StreamBaseClient.flushBuffer
(StreamProperties props) Deprecated.protected static String
DeMUXStreamBaseClient.getFullLogicalName
(StreamProperties streamProperties) Get full logical nameboolean
DeMUXStreamBaseClient.isSubscribed
(StreamProperties stream) boolean
StreamBaseClient.isSubscribed
(StreamProperties stream) Return status if we are subscribed to the given streamDeMUXStreamBaseClient.resubscribe
(StreamProperties props, String logicalstream, String predicate) StreamBaseClient.resubscribe
(StreamProperties props, String logicalStream, String predicate) Resubscribe to a stream with a predicate.DeMUXStreamBaseClient.subscribe
(StreamProperties props) DeMUXStreamBaseClient.subscribe
(StreamProperties props, String logicalstream, String predicate) StreamBaseClient.subscribe
(StreamProperties props) Subscribe to a streamStreamBaseClient.subscribe
(StreamProperties props, String logicalStream, String predicate) Subscribe to a stream with a predicate.void
DeMUXStreamBaseClient.unsubscribe
(StreamProperties logicalProps) void
StreamBaseClient.unsubscribe
(StreamProperties logicalProps) Unsubscribe from the given stream name.void
XmlRpcAdmin.unsubscribe
(long timeoutMS, StreamProperties props, String logicalstream, List<com.streambase.sb.client.TupleConnections.StreamTupleConnection> connections) protected void
StreamBaseClient.unsubscribeInternal
(StreamProperties logicalProps) Un-subscribe from streamConstructors in com.streambase.sb.client with parameters of type StreamPropertiesModifierConstructorDescriptionSimpleDequeueResult
(List<Tuple> tuples, StreamProperties props, StreamBaseURI server) Constructor -
Uses of StreamProperties in com.streambase.sb.monitor
Methods in com.streambase.sb.monitor that return StreamPropertiesModifier and TypeMethodDescriptionStreamInfo.getStreamProperties()
Returns the StreamProperties of the stream -
Uses of StreamProperties in com.streambase.sb.unittest
Methods in com.streambase.sb.unittest that return StreamPropertiesModifier and TypeMethodDescriptionDequeuer.getStreamProperties()
Get theStreamProperties
for the associated stream.Enqueuer.getStreamProperties()
Get theStreamProperties
for the associated stream.
StreamBaseClient.flushAllBuffers()
to preserve inter-stream ordering