Package | Description |
---|---|
com.streambase.sb |
Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.
|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a 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 |
---|---|
CaptureTransformStrategy |
StreamProperties.getCaptureTransformStrategy() |
static CaptureTransformStrategy |
CaptureTransformStrategy.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CaptureTransformStrategy[] |
CaptureTransformStrategy.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Set<StreamProperties> |
StreamBaseClient.getAllStreamProperties(EntityType type,
CaptureTransformStrategy strategy)
Return all the StreamProperties available
|
StreamProperties |
StreamBaseClient.getStreamProperties(String streamName,
CaptureTransformStrategy strategy)
Return the StreamProperties for the given stream name
|
String[] |
StreamBaseClient.listEntities(EntityType entityType,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity type.
|
String[] |
StreamBaseClient.listEntities(EntityType entityType,
int flags,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity type and flags.
|
String[] |
StreamBaseClient.listEntities(String entityPath,
int flags,
CaptureTransformStrategy strategy)
Return an array of entity names for the given entity path.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(String streamName,
CaptureTransformStrategy strategy) |
StreamProperties |
StreamBaseClient.subscribe(String streamName,
CaptureTransformStrategy strategy)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(String streamName,
CaptureTransformStrategy strategy,
String logicalstream,
String predicate) |
StreamProperties |
StreamBaseClient.subscribe(String streamName,
CaptureTransformStrategy strategy,
String logicalstream,
String predicate)
Subscribe to a stream with a predicate.
|
Modifier and Type | Method and Description |
---|---|
CaptureTransformStrategy |
Operator.getCaptureStrategy()
Returns the capture transform strategy that this Operator will use.
|
Modifier and Type | Method and Description |
---|---|
void |
Operator.setCaptureStrategy(CaptureTransformStrategy cts)
Set the capture transform strategy to use for the inputs and outputs
of this Operator.
|
Modifier and Type | Method and Description |
---|---|
TableAccessor |
SBServerManager.getTableAccessor(String tablePath,
CaptureTransformStrategy captureStrategy)
Return a TableAccessor suitable for manipulating this table.
|