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 LiveView Java API.
com.streambase.sb	Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.
com.streambase.sb.adapter	Provides classes and interfaces to add custom adapters to StreamBase applications.
com.streambase.sb.client	Provides classes and interfaces used to communicate with a StreamBase server.
com.streambase.sb.feedsim	Provides abstract classes to extend feedsim input sources.
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	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	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	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	Description
void	TablePublisher.publish(long sequenceNumber, Tuple tuple)	Publish a tuple with a sequenceNumber.
void	TablePublisher.publish(long sequenceNumber, Boolean CQSDelete, 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.
void	TablePublisher.publish(Boolean CQSDelete, 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	Description
AbstractTupleEvent(Object source, Long key, Tuple tuple, Tuple keyData, List<TupleFieldComparator> fieldComparators)
HashableTuple(Tuple tuple)
TupleAddedEvent(Object source, Long key, Tuple tuple)	Deprecated.
TupleAddedEvent(Object source, Long oldKey, Tuple tuple, Tuple keyData, List<TupleFieldComparator> fieldComparators)
TupleRemovedEvent(Object source, Long key, Tuple tuple)	Deprecated.
TupleRemovedEvent(Object source, Long oldKey, Tuple tuple, Tuple keyData, List<TupleFieldComparator> fieldComparators)
TupleUpdatedEvent(Object source, Long oldKey, Tuple oldTuple, Tuple newTuple, Tuple keyData, List<Schema.Field> changedFields, List<TupleFieldComparator> fieldComparators)
TupleUpdatedEvent(Object source, Long key, Tuple oldTuple, Tuple newTuple, List<Schema.Field> changedFields)	Deprecated.

Uses of Tuple in com.streambase.sb

Subclasses of Tuple in com.streambase.sb

Modifier and Type	Class	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	Description
static Tuple	Tuple.EMPTY_TUPLE	An empty tuple

Methods in com.streambase.sb that return Tuple

Modifier and Type	Method	Description
Tuple	ReadOnlyTupleByIndexWrapper.clone()
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.
Tuple	ReadOnlyCompositeTuple.createReadOnlyTuple()
Tuple	ReadOnlyTupleByIndexWrapper.createReadOnlyTuple()
Tuple	ReadOnlyTupleRep.createReadOnlyTuple()
Tuple	ReadWriteTupleWrapper.createReadOnlyTuple()
abstract Tuple	Tuple.createReadOnlyTuple()	Return a new tuple that is guaranteed to be read only
Tuple	TupleRep.createReadOnlyTuple()
Tuple	Schema.createTuple()	Create a Tuple with this schema.
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
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	ReadOnlyTuple.createWritableTuple()
Tuple	ReadWriteTupleWrapper.createWritableTuple()
abstract Tuple	Tuple.createWritableTuple()	Return a new tuple that is guaranteed to be writable
Tuple	TupleRep.createWritableTuple()
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	ReadWriteTupleWrapper.getBaseTuple()	Returns the tuple wrapped inside this.
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 Tuple	ReadOnlyCompositeTuple.getCaptureImpl(Schema.Field field)
protected Tuple	ReadOnlyTupleByIndexWrapper.getCaptureImpl(Schema.Field field)
Tuple	ReadOnlyTupleRep.getCaptureImpl(Schema.Field field)
protected Tuple	ReadWriteTupleWrapper.getCaptureImpl(Schema.Field field)
protected abstract Tuple	Tuple.getCaptureImpl(Schema.Field field)	Get capture field
protected Tuple	TupleRep.getCaptureImpl(Schema.Field field)
abstract Tuple	AbstractFunction.getEnvironmentBindings()	Tuple with the vars in this function's context.
Tuple	BasicFunction.getEnvironmentBindings()
protected Tuple	ReadOnlyCompositeTuple.getReadOnlyTuple(Schema.Field field, int flags)
protected abstract Tuple	ReadOnlyTuple.getReadOnlyTuple(Schema.Field f, int flags)	The method that ReadOnly tuples are supposed to implement to get a nested Tuple so that we can consolidate nested tuple logic here for.
protected Tuple	ReadOnlyTupleByIndexWrapper.getReadOnlyTuple(Schema.Field field, int flags)
protected Tuple	ReadOnlyTupleRep.getReadOnlyTuple(Schema.Field field, int flags)
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.
protected Tuple	ReadOnlyTuple.getTupleImpl(Schema.Field field, int flags)	Get the tuple for the given field.
protected Tuple	ReadWriteTupleWrapper.getTupleImpl(Schema.Field field, int flags)
Tuple	TupleRep.getTupleImpl(Schema.Field field, int flags)
static Tuple	ClusterNotificationTupleFields.newTuple(int clusterEventType, String param0, String param1, String param2)	Return a new ClusterNotification tuple.
static Tuple	ControlStream.newTuple(ControlStream.Subsystems subsystem, int id, String param0, String param1, String param2)	Create a new tuple with the schema of the control stream and set its fields with the supplied values.
static Tuple	HATupleFields.newTuple(Constants.LeadershipStatus leadershipStatus)	Return a new HA tuple.
static Tuple	TupleUtil.randomTuple(Tuple tuple, int maxCount)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Tuple tuple, int maxCount, int flags)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Random random, Tuple tuple, int maxCount)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Random random, Tuple tuple, int maxCount, int flags)	Create a tuple which contains random values

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

Modifier and Type	Method	Description
static boolean	TupleUtil.allFieldsNull(Tuple t)	are all the fields in this tuple null
Object	BasicFunction.apply(Tuple input)
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.DefaultTupleFormatter.formatTuple(Tuple t)
CharSequence	Tuple.TupleFormatter.formatTuple(Tuple t)	Return a string representation of the given StreamBase Tuple value
int	TupleUtil.RepMethods.getFieldLength(Tuple tuple, Schema.Field field)	Get field length
static Tuple	TupleUtil.randomTuple(Tuple tuple, int maxCount)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Tuple tuple, int maxCount, int flags)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Random random, Tuple tuple, int maxCount)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Random random, Tuple tuple, int maxCount, int flags)	Create a tuple which contains random values
ReadOnlyCompositeTuple	ReadOnlyCompositeTuple.reset(Tuple... newTuples)	Reset the tuple with a set of newTuples.
void	ReadWriteTupleWrapper.setBaseTuple(Tuple base)
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.
protected void	ReadOnlyTuple.setCaptureImpl(Schema.Field field, Tuple value, boolean makeCopy)
protected void	ReadWriteTupleWrapper.setCaptureImpl(Schema.Field field, Tuple value, boolean makeCopy)
void	TupleRep.setCaptureImpl(Schema.Field field, Tuple value, boolean makeCopy)
static void	TupleUtil.setField(Tuple tuple, Schema.Field field, CharSequence value, CSV.FormatInfo csvFormat)	Set a specified field to the values the supplied value string.
static void	TupleUtil.setField(Tuple tuple, Schema.Field field, CharSequence value, String nullString)	Deprecated. use TupleUtil.setField(Tuple, Field, CharSequence, CSV.FormatInfo)
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.
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat, boolean numericTimestampsAsInterval)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleUtil.setTuple(Tuple tuple, com.alibaba.fastjson.JSONObject object)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString)	Set the fields of a tuple based on the contents of a JSON string
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat)	Set the fields of a tuple based on the contents of a JSON string
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Set the fields of a tuple based on the contents of a JSON string
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString)	Set the fields of a tuple based on the contents of a JSON string.
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat)	Set the fields of a tuple based on the contents of a JSON string.
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Set the fields of a tuple based on the contents of a JSON string.
protected void	ReadOnlyTuple.setTupleImpl(Schema.Field field, Tuple value)
protected void	ReadWriteTupleWrapper.setTupleImpl(Schema.Field field, Tuple value)
void	TupleRep.setTupleImpl(Schema.Field field, Tuple value)
static String	TupleJSONUtil.toJSONListString(Tuple tuple)	Return the JSON string representation of the supplied tuple.
static String	TupleJSONUtil.toJSONListString(Tuple tuple, String timeStampFormat)	Return the JSON string representation of the supplied tuple.
static String	TupleJSONUtil.toJSONMapString(Tuple tuple)	Return the JSON string representation of the supplied tuple.
static String	TupleJSONUtil.toJSONMapString(Tuple tuple, String timeStampFormat)	Return the JSON string representation of the supplied tuple.
static String	TupleJSONUtil.toJSONMapStringSingleQuote(Tuple tuple)	Return the single quote JSON string representation of the supplied tuple.
static String	TupleJSONUtil.toJSONString(Tuple t, EnumSet<TupleJSONUtil.Options> options)	Convert a tuple to its JSON representation.
static String	TupleJSONUtil.toJSONString(Tuple t, EnumSet<TupleJSONUtil.Options> options, String timestampFormat)	Convert a tuple to its JSON representation.
static String	TupleUtil.tupleEquals(Tuple t1, Tuple t2, EnumSet<TupleCopier.Options> options)	Compare 2 tuples with the given options
void	TupleCSVCharWriter.write(Tuple tuple)	Writes the contents of a tuple in a CSV format.
void	TupleCSVCharWriter.write(Tuple tuple, TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle)	Writes the contents of a tuple in a CSV format with user specified field quoting behavior.
void	TupleCSVCharWriter.write(Tuple tuple, TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle, TupleCSVOutputWriter.TimestampStyle timestampStyle)	Writes the contents of a tuple in a CSV format with user specified field quoting behavior.
void	TupleCSVOutputWriter.write(Tuple tuple)	Writes the contents of a tuple in a CSV format.
void	TupleCSVOutputWriter.write(Tuple tuple, TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle)	Writes the contents of a tuple in a CSV format with user specified field quoting behavior.
void	TupleCSVOutputWriter.write(Tuple tuple, TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle, TupleCSVOutputWriter.TimestampStyle timestampStyle)	Writes the contents of a tuple in a CSV format with user specified field quoting behavior.

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

Modifier and Type	Method	Description
static String	TupleJSONUtil.toJSONString(Collection<Tuple> tuples)

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

Constructor	Description
BasicFunction(CompleteDataType.FunctionType type, Tuple environment, String stringRep, String bodyRep, String name)	Constructor
ClusterNotificationTupleFields(Tuple tuple)
ControlStreamTupleFields(Tuple tuple)
HATupleFields(Tuple tuple)
ReadOnlyCompositeTuple(Schema compositeSchema, Tuple... tuples)	Create a Tuple with the given compositeSchema.
ReadOnlyTupleByIndexWrapper(Schema derived, Tuple baseTuple)	Create a Tuple Wrapper
ReadWriteTupleWrapper(Tuple baseTuple)
TupleRep(Tuple other)

Uses of Tuple in com.streambase.sb.adapter

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

Modifier and Type	Method	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	Description
Tuple	StreamBaseClient.getDynamicVariables(String modulePath)	Get a Tuple of all the dynamic variables on the given module
Tuple	XmlRpcAdmin.getDynamicVariables(long timeoutMS, Path modulePath)

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

Modifier and Type	Method	Description
abstract Iterator<Tuple>	DequeueResult.iterator()	Returns an iterator of all tuples.
Iterator<Tuple>	InternalDequeueResult.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.
List<Tuple>	XmlRpcAdmin.readTable(long timeoutMS, String tablePath, int rowLimit, String predicate)

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

Modifier and Type	Method	Description
protected void	StreamBaseClient.SerializedTupleBuffer.addToBuffer(Tuple tuple, int id)	Possibly add a tuple if there is room
protected abstract void	StreamBaseClient.TupleBuffer.addToBuffer(Tuple tuple, int id)	Add to buffer
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	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	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	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	Description
protected Iterator<Tuple>	Snapshot.resultIterator

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

Modifier and Type	Method	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
Tuple	StatTuplev3.marshalTo(Tuple t)	Same as calling What#marshal(Tuple, StatTuple)

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

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

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

Modifier and Type	Method	Description
protected void	StatTuplev3.fillTuple(Tuple t)
protected void	StatTuplev3.fromTuple(Tuple t)
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
Tuple	StatTuplev3.marshalTo(Tuple t)	Same as calling What#marshal(Tuple, StatTuple)
static StatTuplev3	StatsUtil.toStatTuple(Tuple t)
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	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	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 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	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	Description
abstract Tuple	AbstractTupleMaker.createTuple(Schema schema, T t)
Tuple	CSVTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONSingleQuotesTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONTupleMaker.createTuple(Schema schema, String str)
Tuple	ObjectArrayTupleMaker.createTuple(Schema schema, Object[] objs)
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	Description
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, Collection<T> ts)
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, T... ts)
List<Tuple>	TupleMaker.createTuples(Schema schema, Collection<T> t)	create multiple Tuples from input objects
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	Description
boolean	FieldBasedTupleComparator.compare(Tuple expected, Tuple actual)
boolean	TupleComparator.compare(Tuple expected, Tuple actual)	Compare two tuples.
void	Enqueuer.enqueue(Tuple tuple)	Enqueue Tuple to the stream
void	Enqueuer.enqueue(Tuple... tuples)	Enqueue multiple tuples to the stream
void	Expecter.expect(Tuple tuple)	Expect a tuple from the dequeuer.
void	Expecter.expect(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(Expecter.DequeueSetting mode, Tuple... tuples)	Expect multiple tuples in a particular order from the dequeuer
void	Expecter.expectUnordered(Tuple... expected)	Expect multiple tuples in any order from the dequeuer.
void	Expecter.expectUnordered(Expecter.DequeueSetting mode, 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.
abstract boolean	Expecter.AbstractPredicate.isExpected(Tuple t)
boolean	Expecter.Predicate.isExpected(Tuple t)

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

Modifier and Type	Method	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.