Uses of Class
com.streambase.sb.Tuple

Packages that use Tuple

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.

Uses of Tuple in com.streambase.liveview.client

Fields in com.streambase.liveview.client declared as Tuple

Modifier and Type	Field and Description
protected Tuple	AbstractTupleEvent.keyData
protected Tuple	AbstractTupleEvent.tuple
protected Tuple	HashableTuple.tuple

Methods in com.streambase.liveview.client that return 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, String targetInputStreamName, Tuple tuple, String responseOutputStreamName, Schema expectedResponseSchema, long timeout, TimeUnit unit) Sends a tuple to an existing StreamBase application.

Methods in com.streambase.liveview.client that return types with arguments of type Tuple

Modifier and Type	Method and Description
Collection<Tuple>	LiveResult.getTuples() Retrieves the current tuples in the result
Collection<Tuple>	LiveResult.getTuples(boolean waitForSnapshot) Retrieves the current tuples in the result

Methods in com.streambase.liveview.client with parameters of type Tuple

Modifier and Type	Method and Description
void	TablePublisher.publish(long sequenceNumber, 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, 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 Tuple

Constructor and Description
AbstractTupleEvent(Object source, Long key, Tuple tuple, Tuple keyData, List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators)
HashableTuple(Tuple tuple)
TupleAddedEvent(Object source, Long key, Tuple tuple) Deprecated.
TupleAddedEvent(Object source, Long oldKey, Tuple tuple, Tuple keyData, List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators)
TupleRemovedEvent(Object source, Long key, Tuple tuple) Deprecated.
TupleRemovedEvent(Object source, Long oldKey, Tuple tuple, Tuple keyData, List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators)
TupleUpdatedEvent(Object source, Long key, Tuple oldTuple, Tuple newTuple, List<Schema.Field> changedFields) Deprecated.
TupleUpdatedEvent(Object source, Long oldKey, Tuple oldTuple, Tuple newTuple, Tuple keyData, List<Schema.Field> changedFields, List<com.streambase.liveview.client.internal.TupleFieldComparator> fieldComparators)

Uses of Tuple in com.streambase.sb

Subclasses of Tuple in com.streambase.sb

Modifier and Type	Class and Description
class	CompiledTuple Subclass of tuple that indicates a tuple has a compiled representation for better performance.

Fields in com.streambase.sb declared as Tuple

Modifier and Type	Field and Description
static Tuple	Tuple.EMPTY_TUPLE

Methods in com.streambase.sb that return 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(List<String> fieldValues, int offset, int length) Create a Tuple with this schema from the supplied collection of strings
Tuple	Schema.createTuple(List<String> fieldValues, int offset, int length, String nullString) Create a Tuple with this schema from the supplied collection of strings
Tuple	Schema.createTuple(String... fieldValues) Create a Tuple with this schema from the supplied collection of strings
Tuple	Schema.createTuple(String[] fieldValues, int offset, int length) Create a Tuple with this schema from the supplied collection of strings
Tuple	Schema.createTuple(String[] fieldValues, int offset, int length, 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(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(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(String fieldPathName) Return a reference (not a copy) to the specified nested tuple field.

Methods in com.streambase.sb with parameters of type Tuple

Modifier and Type	Method and Description
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'
CharSequence	Tuple.TupleFormatter.formatTuple(Tuple t) Return a string representation of the given StreamBase Tuple value
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(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(String fieldPathName, Tuple value) Set a named nested tuple field to a specified tuple.

Uses of Tuple in com.streambase.sb.adapter

Methods in com.streambase.sb.adapter with parameters of type Tuple

Modifier and Type	Method and Description
void	InputAdapter.processTuple(int inputPort, Tuple tuple)

Uses of Tuple in com.streambase.sb.client

Methods in com.streambase.sb.client that return Tuple

Modifier and Type	Method and Description
Tuple	StreamBaseClient.getDynamicVariables(String modulePath) Get a Tuple of all the dynamic variables on the given module

Methods in com.streambase.sb.client that return types with arguments of type Tuple

Modifier and Type	Method and Description
abstract Iterator<Tuple>	DequeueResult.iterator() Returns an iterator of all tuples.
Iterator<Tuple>	SimpleDequeueResult.iterator()
List<Tuple>	StreamBaseClient.readTable(String tablePath, int rowLimit) Return rows from a Query Table or Materialized Window.
List<Tuple>	StreamBaseClient.readTable(String tablePath, int rowLimit, String predicate) Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.

Methods in com.streambase.sb.client with parameters of type Tuple

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(String stream, Tuple tuple) Enqueue a single Tuple onto a stream.

Method parameters in com.streambase.sb.client with type arguments of type Tuple

Modifier and Type	Method and Description
void	StreamBaseClient.enqueue(StreamProperties props, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.
void	StreamBaseClient.enqueue(String stream, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.

Constructor parameters in com.streambase.sb.client with type arguments of type Tuple

Constructor and Description
SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server, Constants.LeadershipStatus leadershipStatus)

Uses of Tuple in com.streambase.sb.feedsim

Methods in com.streambase.sb.feedsim that return Tuple

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.

Uses of Tuple in com.streambase.sb.monitor

Fields in com.streambase.sb.monitor with type parameters of type Tuple

Modifier and Type	Field and Description
protected Iterator<Tuple>	Snapshot.resultIterator

Methods in com.streambase.sb.monitor that return Tuple

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

Methods in com.streambase.sb.monitor that return types with arguments of type Tuple

Modifier and Type	Method and Description
Iterator<Tuple>	Snapshot.Source.nextResult()

Methods in com.streambase.sb.monitor with parameters of type Tuple

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

Uses of Tuple in com.streambase.sb.operator

Methods in com.streambase.sb.operator that return Tuple

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.

Methods in com.streambase.sb.operator with parameters of type Tuple

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.
String	Operator.evaluate(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(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.

Method parameters in com.streambase.sb.operator with type arguments of type Tuple

Modifier and Type	Method and Description
void	Operator.sendOutput(int port, List<Tuple> tuples) Enqueue a List of Tuples to be sent synchronously to downstream operators.
void	Operator.sendOutputAsync(int port, List<Tuple> tuples) Enqueue a List of Tuples to be sent asynchronously to downstream operators.

Uses of Tuple in com.streambase.sb.unittest

Methods in com.streambase.sb.unittest that return Tuple

Modifier and Type	Method and Description
Tuple	ObjectArrayTupleMaker.createTuple(Schema schema, Object[] objs)
Tuple	CSVTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONSingleQuotesTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONTupleMaker.createTuple(Schema schema, String str)
abstract Tuple	AbstractTupleMaker.createTuple(Schema schema, T t)
Tuple	TupleMaker.createTuple(Schema schema, T t) create a Tuples from an input object

Methods in com.streambase.sb.unittest that return types with arguments of type Tuple

Modifier and Type	Method and Description
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, Collection<T> ts)
List<Tuple>	TupleMaker.createTuples(Schema schema, Collection<T> t) create multiple Tuples from input objects
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, T... ts)
List<Tuple>	TupleMaker.createTuples(Schema schema, T... t) create multiple Tuples from input objects
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
List<Tuple>	Dequeuer.dequeue(int numTuples, long timeout, TimeUnit timeUnit) Try to dequeue tuples within a provided timeout.

Methods in com.streambase.sb.unittest with parameters of type Tuple

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.
String	FieldBasedTupleComparator.formatForErrorMessage(Tuple t)
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)

Method parameters in com.streambase.sb.unittest with type arguments of type Tuple

Modifier and Type	Method and Description
void	Enqueuer.enqueue(List<Tuple> tuples) Enqueue multiple tuples to the stream
void	Expecter.expect(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer
void	Expecter.expect(List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer.
void	Expecter.expectUnordered(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in any order from the dequeuer
void	Expecter.expectUnordered(List<Tuple> expected) Expect multiple tuples in any order from the dequeuer.