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 StreamPropertiesCreate new stream properties from XML stringstatic StreamPropertiesCreate 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 StreamPropertiesDequeueResult.propsStream 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 StringStreamBaseClient.assureNameStartsWithContainer(StreamProperties base, String logicalName) Ensure name starts with containerbooleanStreamBaseClient.TupleBuffer.canDequeue(StreamProperties props) Can dequeue?booleanStreamBaseClient.TupleBuffer.canEnqueue(StreamProperties props) Can enqueue?voidStreamBaseClient.enqueue(StreamProperties props, Tuple tuple) Enqueue a single Tuple onto a stream.voidStreamBaseClient.enqueue(StreamProperties props, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.voidXmlRpcAdmin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples) voidStreamBaseClient.flushBuffer(StreamProperties props) Deprecated.protected static StringDeMUXStreamBaseClient.getFullLogicalName(StreamProperties streamProperties) Get full logical namebooleanDeMUXStreamBaseClient.isSubscribed(StreamProperties stream) booleanStreamBaseClient.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.voidDeMUXStreamBaseClient.unsubscribe(StreamProperties logicalProps) voidStreamBaseClient.unsubscribe(StreamProperties logicalProps) Unsubscribe from the given stream name.voidXmlRpcAdmin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<com.streambase.sb.client.TupleConnections.StreamTupleConnection> connections) protected voidStreamBaseClient.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 theStreamPropertiesfor the associated stream.Enqueuer.getStreamProperties()Get theStreamPropertiesfor the associated stream.
StreamBaseClient.flushAllBuffers()to preserve inter-stream ordering