Package | Description |
---|---|
com.streambase.liveview.client |
Provides classes and interfaces fundamental to the TIBCO Live Datamart Java API.
|
com.streambase.sb |
Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.
|
com.streambase.sb.adapter | |
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
com.streambase.sb.feedsim | |
com.streambase.sb.monitor |
Provides classes and interfaces to monitor the behavior of a running 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 | Field and Description |
---|---|
protected Tuple |
AbstractTupleEvent.keyData |
protected Tuple |
AbstractTupleEvent.tuple |
protected Tuple |
HashableTuple.tuple |
Modifier and Type | Method and Description |
---|---|
Tuple |
TupleUpdatedEvent.getOld()
Retrieve the old version of the tuple.
|
Tuple |
AbstractTupleEvent.getTuple()
Get the tuple
|
Tuple |
LiveResult.getTuple(KeyValue keyValue)
Get a tuple from the KeyValue obtained from an Event.
|
Tuple |
DeleteQueryListener.next()
Retrieves the next tuple in the result.
|
Tuple |
SnapshotQueryListener.next()
Retrieves the next tuple in the result.
|
Tuple |
SnapshotResult.next()
Retrieves the next tuple in the result.
|
Tuple |
LiveViewConnection.sendTupleAction(StreamBaseURI sbUri,
java.lang.String targetInputStreamName,
Tuple tuple,
java.lang.String responseOutputStreamName,
Schema expectedResponseSchema,
long timeout,
java.util.concurrent.TimeUnit unit)
Sends a tuple to an existing StreamBase application.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Tuple> |
LiveResult.getTuples()
Retrieves the current tuples in the result
|
java.util.Collection<Tuple> |
LiveResult.getTuples(boolean waitForSnapshot)
Retrieves the current tuples in the result
|
Modifier and Type | Method and Description |
---|---|
void |
TablePublisher.publish(long sequenceNumber,
java.lang.Boolean CQSDelete,
Tuple tuple)
Publish a tuple with a sequenceNumber.
|
void |
TablePublisher.publish(long sequenceNumber,
Tuple tuple)
Publish a tuple with a sequenceNumber.
|
void |
TablePublisher.publish(Tuple tuple)
Publish a tuple without regard for recovering since no sequence number is specified.
|
Tuple |
LiveViewConnection.sendTupleAction(StreamBaseURI sbUri,
java.lang.String targetInputStreamName,
Tuple tuple,
java.lang.String responseOutputStreamName,
Schema expectedResponseSchema,
long timeout,
java.util.concurrent.TimeUnit unit)
Sends a tuple to an existing StreamBase application.
|
Constructor and Description |
---|
AbstractTupleEvent(java.lang.Object source,
java.lang.Long key,
Tuple tuple,
Tuple keyData,
java.util.List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators) |
HashableTuple(Tuple tuple) |
TupleAddedEvent(java.lang.Object source,
java.lang.Long key,
Tuple tuple)
Deprecated.
|
TupleAddedEvent(java.lang.Object source,
java.lang.Long oldKey,
Tuple tuple,
Tuple keyData,
java.util.List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators) |
TupleRemovedEvent(java.lang.Object source,
java.lang.Long key,
Tuple tuple)
Deprecated.
|
TupleRemovedEvent(java.lang.Object source,
java.lang.Long oldKey,
Tuple tuple,
Tuple keyData,
java.util.List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators) |
TupleUpdatedEvent(java.lang.Object source,
java.lang.Long key,
Tuple oldTuple,
Tuple newTuple,
java.util.List<Schema.Field> changedFields)
Deprecated.
|
TupleUpdatedEvent(java.lang.Object source,
java.lang.Long oldKey,
Tuple oldTuple,
Tuple newTuple,
Tuple keyData,
java.util.List<Schema.Field> changedFields,
java.util.List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators) |
Modifier and Type | Class and Description |
---|---|
class |
CompiledTuple
Subclass of tuple that indicates a tuple has a compiled representation for better performance.
|
Modifier and Type | Field and Description |
---|---|
static Tuple |
Tuple.EMPTY_TUPLE |
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.clone()
Clone this tuple, the new tuple will not share any buffers or data with the original
|
Tuple |
TupleCaptureTransformer.collapse(Tuple in)
Capture all the extra fields in 'in' into their correct capture fields.
|
abstract Tuple |
Tuple.createReadOnlyTuple()
Return a new tuple that is guaranteed to be read only
|
Tuple |
Schema.createTuple()
Create a Tuple with this schema.
|
Tuple |
Schema.createTuple(java.util.List<java.lang.String> fieldValues,
int offset,
int length)
Create a Tuple with this schema from the supplied collection of strings
|
Tuple |
Schema.createTuple(java.util.List<java.lang.String> fieldValues,
int offset,
int length,
java.lang.String nullString)
Create a Tuple with this schema from the supplied collection of strings
|
Tuple |
Schema.createTuple(java.lang.String... fieldValues)
Create a Tuple with this schema from the supplied collection of strings
|
Tuple |
Schema.createTuple(java.lang.String[] fieldValues,
int offset,
int length)
Create a Tuple with this schema from the supplied collection of strings
|
Tuple |
Schema.createTuple(java.lang.String[] fieldValues,
int offset,
int length,
java.lang.String nullString)
Create a Tuple with this schema from the supplied collection of strings
|
abstract Tuple |
Tuple.createWritableTuple()
Return a new tuple that is guaranteed to be writable
|
Tuple |
TupleCaptureTransformer.expand(Tuple in)
Expand all the capture fields in 'in'
|
Tuple |
Tuple.getAllocatedTuple(int fieldIndex)
Return a reference (not a copy) to the specified nested tuple field.
|
Tuple |
Tuple.getAllocatedTuple(Schema.Field field)
Return a reference (not a copy) to the specified nested tuple field.
|
Tuple |
Tuple.getAllocatedTuple(java.lang.String fieldPathName)
Return a reference (not a copy) to the specified nested tuple field.
|
Tuple |
Tuple.getCapture(int fieldIndex)
Return the value of the named capture field.
|
Tuple |
Tuple.getCapture(Schema.Field field)
Return the value of the named capture field.
|
Tuple |
Tuple.getCapture(java.lang.String fieldPathName)
Return the value of the named capture field.
|
protected abstract Tuple |
Tuple.getCaptureImpl(Schema.Field field) |
Tuple |
Tuple.getTuple(int fieldIndex)
Return a reference (not a copy) to the specified nested tuple field.
|
Tuple |
Tuple.getTuple(Schema.Field field)
Return a reference (not a copy) to the specified nested tuple field.
|
Tuple |
Tuple.getTuple(java.lang.String fieldPathName)
Return a reference (not a copy) to the specified nested tuple field.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
Function.apply(Tuple input)
Applies the given arguments to this function and returns the output.
|
Tuple |
TupleCaptureTransformer.collapse(Tuple in)
Capture all the extra fields in 'in' into their correct capture fields.
|
void |
Tuple.copyField(Schema.Field sourceField,
Tuple destTuple,
Schema.Field destField)
Copy the field from this tuple to the destination tuple
|
protected void |
Tuple.copyTuple(Tuple sourceTuple)
copy the source tuple to this tuple
|
void |
TupleCopier.copyTuple(Tuple sourceTuple,
Tuple destTuple)
Copy the fields from the sourceTuple to the destTuple.
|
Tuple |
TupleCaptureTransformer.expand(Tuple in)
Expand all the capture fields in 'in'
|
java.lang.CharSequence |
Tuple.TupleFormatter.formatTuple(Tuple t)
Return a string representation of the given StreamBase Tuple value
|
java.lang.CharSequence |
Tuple.DefaultTupleFormatter.formatTuple(Tuple t) |
int |
TupleUtil.RepMethods.getFieldLength(Tuple tuple,
Schema.Field field) |
void |
Tuple.setCapture(int field,
Tuple value)
Set a specified capture field to a copy of a specified tuple.
|
void |
Tuple.setCapture(Schema.Field field,
Tuple value)
Set a specified capture field to a copy of a specified tuple.
|
void |
Tuple.setCapture(java.lang.String field,
Tuple value)
Set a specified capture field to a copy of a specified tuple.
|
void |
Tuple.setTuple(int fieldIndex,
Tuple value)
Set a specified nested tuple field to that of the specified tuple.
|
void |
Tuple.setTuple(Schema.Field field,
Tuple value)
Set a specified nested tuple field to that of the specified tuple
NOTE: A copy of the the tuple may be made to convert the given tuple to the appropriate
internal representation.
|
void |
Tuple.setTuple(java.lang.String fieldPathName,
Tuple value)
Set a named nested tuple field to a specified tuple.
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
java.lang.Object jsonObject,
boolean strict)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
java.lang.Object jsonObject,
boolean strict,
java.lang.String timestampFormat)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTuple(Tuple tuple,
java.lang.Object jsonObject,
boolean strict,
java.lang.String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON object
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
java.lang.String JSONString)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSON(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON string
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
java.lang.String JSONString)
Set the fields of a tuple based on the contents of a JSON string.
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat)
Set the fields of a tuple based on the contents of a JSON string.
|
static void |
TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple,
java.lang.String JSONString,
java.lang.String timestampFormat,
boolean numericTimestampsAsInterval)
Set the fields of a tuple based on the contents of a JSON string.
|
static java.lang.String |
TupleJSONUtil.toJSONListString(Tuple tuple)
Return the JSON string representation of the supplied tuple.
|
static java.lang.String |
TupleJSONUtil.toJSONListString(Tuple tuple,
java.lang.String timeStampFormat)
Return the JSON string representation of the supplied tuple.
|
static java.lang.String |
TupleJSONUtil.toJSONMapString(Tuple tuple)
Return the JSON string representation of the supplied tuple.
|
static java.lang.String |
TupleJSONUtil.toJSONMapString(Tuple tuple,
java.lang.String timeStampFormat)
Return the JSON string representation of the supplied tuple.
|
static java.lang.String |
TupleJSONUtil.toJSONMapStringSingleQuote(Tuple tuple)
Return the single quote JSON string representation of the supplied tuple.
|
static java.lang.String |
TupleJSONUtil.toJSONString(Tuple t,
java.util.EnumSet<TupleJSONUtil.Options> options)
Convert a tuple to its JSON representation.
|
static java.lang.String |
TupleJSONUtil.toJSONString(Tuple t,
java.util.EnumSet<TupleJSONUtil.Options> options,
java.lang.String timestampFormat)
Convert a tuple to its JSON representation.
|
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
TupleJSONUtil.toJSONString(java.util.Collection<Tuple> tuples) |
Modifier and Type | Method and Description |
---|---|
void |
InputAdapter.processTuple(int inputPort,
Tuple tuple) |
Modifier and Type | Method and Description |
---|---|
Tuple |
StreamBaseClient.getDynamicVariables(java.lang.String modulePath)
Get a Tuple of all the dynamic variables on the given module
|
Modifier and Type | Method and Description |
---|---|
abstract java.util.Iterator<Tuple> |
DequeueResult.iterator()
Returns an iterator of all tuples.
|
java.util.Iterator<Tuple> |
SimpleDequeueResult.iterator() |
java.util.List<Tuple> |
StreamBaseClient.readTable(java.lang.String tablePath,
int rowLimit)
Return rows from a Query Table or Materialized Window.
|
java.util.List<Tuple> |
StreamBaseClient.readTable(java.lang.String tablePath,
int rowLimit,
java.lang.String predicate)
Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
StreamBaseClient.TupleBuffer.addToBuffer(Tuple tuple,
int id) |
protected void |
StreamBaseClient.SerializedTupleBuffer.addToBuffer(Tuple tuple,
int id)
Possibly add a tuple if there is room
|
protected void |
StreamBaseClient.TupleBuffer.checkTuple(Tuple tuple)
Check tuple to make sure it is up to snuff
|
void |
StreamBaseClient.enqueue(StreamProperties props,
Tuple tuple)
Enqueue a single Tuple onto a stream.
|
void |
StreamBaseClient.enqueue(java.lang.String stream,
Tuple tuple)
Enqueue a single Tuple onto a stream.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamBaseClient.enqueue(StreamProperties props,
java.util.Collection<Tuple> tuples)
Enqueue a collection of Tuples onto a stream.
|
void |
StreamBaseClient.enqueue(java.lang.String stream,
java.util.Collection<Tuple> tuples)
Enqueue a collection of Tuples onto a stream.
|
Constructor and Description |
---|
SimpleDequeueResult(java.util.List<Tuple> tuples,
StreamProperties props,
StreamBaseURI server,
Constants.LeadershipStatus leadershipStatus) |
Modifier and Type | Method and Description |
---|---|
abstract Tuple |
FeedSimTupleInputStream.readTuple()
This method is called by a FeedSim thread to get the next tuple to send.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Iterator<Tuple> |
Snapshot.resultIterator |
Modifier and Type | Method and Description |
---|---|
Tuple |
StatsUtil.StatEncoder.marshal(Tuple t,
StatTuplev3 data)
Put data in StatBuffer into the tuple; after marshaling the stat buffer is recycled.
|
Tuple |
StatsUtil.What.marshal(Tuple t,
StatTuplev3 data)
Marshal data into tuple, data would be recycled
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<Tuple> |
Snapshot.Source.nextResult() |
Modifier and Type | Method and Description |
---|---|
Tuple |
StatsUtil.StatEncoder.marshal(Tuple t,
StatTuplev3 data)
Put data in StatBuffer into the tuple; after marshaling the stat buffer is recycled.
|
Tuple |
StatsUtil.What.marshal(Tuple t,
StatTuplev3 data)
Marshal data into tuple, data would be recycled
|
StatTuplev3 |
StatsUtil.StatEncoder.unmarshal(Tuple t)
Retrieve data from tuple and returns a StatBuffer
|
StatTuplev3 |
StatsUtil.What.unmarshal(Tuple t)
Un-marshal a tuple to a StatTuple
|
Modifier and Type | Method and Description |
---|---|
Tuple |
TableAccessor.createRow() |
Tuple |
TableAccessor.delete(Tuple pkey)
Delete a row in the table based on primary key.
|
Tuple |
Operator.getDynamicVariables()
Retrieves a read-only tuple describing the current value of all dynamic variables in the module
this operator is contained in.
|
Tuple |
TableAccessor.readPrimary(Tuple pkey)
Read a row from the table by primary key.
|
Tuple |
TableAccessor.replace(Tuple row)
Replace a row in the table, or insert if there is no existing row with matching primary key.
|
Modifier and Type | Method and Description |
---|---|
void |
RowConsumer.consume(Tuple row)
Override this method to consume rows.
|
Tuple |
TableAccessor.delete(Tuple pkey)
Delete a row in the table based on primary key.
|
java.lang.String |
Operator.evaluate(java.lang.String st,
Tuple input)
evaluate the given string expression in the context of the running module
If an error occurs during the evaluation, the error message return value
will be a string containing the error message
|
void |
TableAccessor.insert(Tuple row)
Insert a new row into the table.
|
abstract void |
Operator.processTuple(int inputPort,
Tuple tuple)
This method will be called by the StreamBase server for each Tuple given
to the Operator to process.
|
Tuple |
TableAccessor.readPrimary(Tuple pkey)
Read a row from the table by primary key.
|
Tuple |
TableAccessor.replace(Tuple row)
Replace a row in the table, or insert if there is no existing row with matching primary key.
|
void |
Operator.sendErrorOutput(java.lang.Throwable t,
int port,
Tuple errorTuple)
Send an exception via the error output port
|
void |
Operator.sendOutput(int port,
Tuple tuple)
Enqueue a Tuple to be sent synchronously to downstream operators.
|
void |
Operator.sendOutputAsync(int port,
Tuple tuple)
Enqueue a Tuple to be sent asynchronously to downstream operators.
|
Modifier and Type | Method and Description |
---|---|
void |
Operator.sendOutput(int port,
java.util.List<Tuple> tuples)
Enqueue a List of Tuples to be sent synchronously to downstream operators.
|
void |
Operator.sendOutputAsync(int port,
java.util.List<Tuple> tuples)
Enqueue a List of Tuples to be sent asynchronously to downstream operators.
|
Modifier and Type | Method and Description |
---|---|
Tuple |
ObjectArrayTupleMaker.createTuple(Schema schema,
java.lang.Object[] objs) |
Tuple |
CSVTupleMaker.createTuple(Schema schema,
java.lang.String str) |
Tuple |
JSONSingleQuotesTupleMaker.createTuple(Schema schema,
java.lang.String str) |
Tuple |
JSONTupleMaker.createTuple(Schema schema,
java.lang.String str) |
abstract Tuple |
AbstractTupleMaker.createTuple(Schema schema,
T t) |
Tuple |
TupleMaker.createTuple(Schema schema,
T t)
create a
Tuple s from an input object |
Modifier and Type | Method and Description |
---|---|
java.util.List<Tuple> |
AbstractTupleMaker.createTuples(Schema schema,
java.util.Collection<T> ts) |
java.util.List<Tuple> |
TupleMaker.createTuples(Schema schema,
java.util.Collection<T> t)
create multiple
Tuple s from input objects |
java.util.List<Tuple> |
AbstractTupleMaker.createTuples(Schema schema,
T... ts) |
java.util.List<Tuple> |
TupleMaker.createTuples(Schema schema,
T... t)
create multiple
Tuple s from input objects |
java.util.List<Tuple> |
Dequeuer.dequeue(int numTuples)
Try to dequeue tuples with the
Dequeuer.DEFAULT_TIMEOUT and Dequeuer.DEFAULT_TIMEOUT_UNIT
if numTuples == 0 will return immediately
if numTuples < 0 will wait the maximum timeout before returning
|
java.util.List<Tuple> |
Dequeuer.dequeue(int numTuples,
long timeout,
java.util.concurrent.TimeUnit timeUnit)
Try to dequeue tuples within a provided timeout.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FieldBasedTupleComparator.compare(Tuple expected,
Tuple actual) |
boolean |
TupleComparator.compare(Tuple expected,
Tuple actual)
Compare two tuples.
|
void |
Enqueuer.enqueue(Tuple... tuples)
Enqueue multiple tuples to the stream
|
void |
Enqueuer.enqueue(Tuple tuple)
Enqueue Tuple to the stream
|
void |
Expecter.expect(Expecter.DequeueSetting mode,
Tuple... tuples)
Expect multiple tuples in a particular order from the dequeuer
|
void |
Expecter.expect(Expecter.DequeueSetting mode,
Tuple expected)
Expect a given tuple from the dequeuer
|
void |
Expecter.expect(Tuple... tuples)
Expect multiple tuples in a particular order from the dequeuer.
|
void |
Expecter.expect(Tuple tuple)
Expect a tuple from the dequeuer.
|
void |
Expecter.expectUnordered(Expecter.DequeueSetting mode,
Tuple... expected)
Expect multiple tuples in any order from the dequeuer
|
void |
Expecter.expectUnordered(Tuple... expected)
Expect multiple tuples in any order from the dequeuer.
|
java.lang.String |
FieldBasedTupleComparator.formatForErrorMessage(Tuple t) |
java.lang.String |
TupleComparator.formatForErrorMessage(Tuple t)
Convert the provided Tuple into a string appropriate for error messages.
|
boolean |
Expecter.Predicate.isExpected(Tuple t) |
abstract boolean |
Expecter.AbstractPredicate.isExpected(Tuple t) |
Modifier and Type | Method and Description |
---|---|
void |
Enqueuer.enqueue(java.util.List<Tuple> tuples)
Enqueue multiple tuples to the stream
|
void |
Expecter.expect(Expecter.DequeueSetting mode,
java.util.List<Tuple> expected)
Expect multiple tuples in a particular order from the dequeuer
|
void |
Expecter.expect(java.util.List<Tuple> expected)
Expect multiple tuples in a particular order from the dequeuer.
|
void |
Expecter.expectUnordered(Expecter.DequeueSetting mode,
java.util.List<Tuple> expected)
Expect multiple tuples in any order from the dequeuer
|
void |
Expecter.expectUnordered(java.util.List<Tuple> expected)
Expect multiple tuples in any order from the dequeuer.
|