Uses of Class
com.streambase.sb.Tuple

Packages that use Tuple

Package	Description
com.streambase.liveview.client	Provides classes and interfaces fundamental to the LiveView Java API.
com.streambase.sb	Provides classes and interfaces fundamental to the Streaming Java API.
com.streambase.sb.adapter	Provides classes and interfaces to add custom adapters to Streaming applications.
com.streambase.sb.client	Provides classes and interfaces used to communicate with a Streaming 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 Streaming server.
com.streambase.sb.operator	Provides classes and interfaces to add custom operators to Streaming applications.
com.streambase.sb.unittest	Provides classes and interfaces used to author Streaming 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 final Tuple	AbstractTupleEvent.keyData
protected final Tuple	AbstractTupleEvent.tuple
protected final 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.
final 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
final Collection<Tuple>	LiveResult.getTuples()	Retrieves the current tuples in the result.
final 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

Modifier	Constructor	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 oldKey, Tuple oldTuple, Tuple newTuple, Tuple keyData, List<Schema.Field> changedFields, List<com.streambase.liveview.client.internal.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 final 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'
final 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.
final 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.
final Tuple	Tuple.getCapture(int fieldIndex)	Return the value of the named capture field.
final Tuple	Tuple.getCapture(Schema.Field field)	Return the value of the named capture field.
final 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)
final 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.
final Tuple	Tuple.getTuple(String fieldPathName)	Return a reference (not a copy) to the specified nested tuple field.
protected final 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(com.streambase.sb.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	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.
(package private) static void	DataTypeCopier.copyField(Tuple sourceTuple, Schema.Field sourceField, Tuple destTuple, Schema.Field destField, com.streambase.sb.DataTypeCopier fieldCopier)	Copy the field from the source tuple to the destination tuple
void	Tuple.copyField(Schema.Field sourceField, Tuple destTuple, Schema.Field destField)	Copy the field from this tuple to the destination tuple
(package private) void	ListCopier.copyList(Tuple sourceTuple, Schema.Field sourceField, Tuple destTuple, Schema.Field destField)	Copy list
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
TupleJSONUtil.SetTupleFromJSON	TupleJSONUtil.SetTupleFromJSON.process(String jsonVal, Tuple tuple)	Handles the processing of a JSON value into a tuple, replaces the deprecated setTupleFromJSON and setTuple methods in the API.
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
com.streambase.sb.ReadOnlyCompositeTuple	ReadOnlyCompositeTuple.reset(Tuple... newTuples)	Reset the tuple with a set of newTuples.
void	ReadWriteTupleWrapper.setBaseTuple(Tuple base)	Set base tuple
final void	Tuple.setCapture(int field, Tuple value)	Set a specified capture field to a copy of a specified tuple.
final void	Tuple.setCapture(Schema.Field field, Tuple value)	Set a specified capture field to a copy of a specified tuple.
final 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, com.streambase.sb.util.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)
final 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.
final 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)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat, boolean numericTimestampsAsInterval)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleUtil.setTuple(Tuple tuple, com.fasterxml.jackson.databind.JsonNode object)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
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, com.streambase.sb.TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle)	Writes the contents of a tuple in a CSV format with user specified field quoting behavior.
void	TupleCSVCharWriter.write(Tuple tuple, com.streambase.sb.TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle, com.streambase.sb.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, com.streambase.sb.TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle)	Writes the contents of a tuple in a CSV format with user specified field quoting behavior.
void	TupleCSVOutputWriter.write(Tuple tuple, com.streambase.sb.TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle, com.streambase.sb.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
(package private) void	Schema.setTupleClassInfo(Class<? extends Tuple> tupleClass, Schema.TupleClassInfo info)	Set class-specific info about this schema.
static String	TupleJSONUtil.toJSONString(Collection<Tuple> tuples)

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

Modifier	Constructor	Description
	BasicFunction(CompleteDataType.FunctionType type, Tuple environment, String stringRep, String bodyRep, String name)	Constructor
protected	ControlStreamTupleFields(Tuple tuple)	Constructor
	ReadOnlyCompositeTuple(Schema compositeSchema, Tuple... tuples)	Create a Tuple with the given compositeSchema.
	ReadOnlyTupleByIndexWrapper(Schema derived, Tuple baseTuple)	Create a Tuple Wrapper
	ReadWriteTupleWrapper(Tuple baseTuple)	Constructor
(package private)	TupleMapView(Tuple tuple)	Constructor
	TupleRep(Tuple other)	Copy constructor

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	Admin.getDynamicVariables(long timeoutMS, com.streambase.sb.util.Path modulePath)	Return the current value of the dynamic variables in the given module, as a Tuple of field name to Java value.
Tuple	HAAdmin.getDynamicVariables(long timeoutMS, com.streambase.sb.util.Path modulePath)
Tuple	StreamBaseClient.getDynamicVariables(String modulePath)	Get a Tuple of all the dynamic variables on the given module
Tuple	XmlRpcAdmin.getDynamicVariables(long timeoutMS, com.streambase.sb.util.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>	Admin.readTable(long timeoutMS, String tablePath, int rowLimit, String predicate)	Return rows from the table.
List<Tuple>	HAAdmin.readTable(long timeoutMS, String tablePath, int rowLimit, String predicate)
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
(package private) boolean	StreamBaseClient.TupleBuffer.addTuple(Tuple tuple)	Add a tuple
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
(package private) boolean	StreamBaseClient.TupleBuffer.addTuples(Collection<Tuple> tuples)	Add tuples
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

Modifier	Constructor	Description
	SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server)	Constructor

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

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

Modifier and Type	Method	Description
Tuple	StatsUtil.StatEncoder.marshal(Tuple t, com.streambase.sb.monitor.StatTuplev3 data)	Put data in StatBuffer into the tuple; after marshaling, the stat buffer is recycled.
Tuple	StatsUtil.What.marshal(Tuple t, com.streambase.sb.monitor.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
(package private) Iterator<Tuple>	Snapshot.getResults()	Get results
Iterator<Tuple>	Snapshot.Source.nextResult()	Get next result

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

Modifier and Type	Method	Description
(package private) void	StatTuplev3.fillTuple(Tuple t)	Fill tuple
(package private) void	StatTuplev3.fromTuple(Tuple t)	Populate from tuple
Tuple	StatsUtil.StatEncoder.marshal(Tuple t, com.streambase.sb.monitor.StatTuplev3 data)	Put data in StatBuffer into the tuple; after marshaling, the stat buffer is recycled.
Tuple	StatsUtil.What.marshal(Tuple t, com.streambase.sb.monitor.StatTuplev3 data)	Marshal data into tuple, data would be recycled
Tuple	StatTuplev3.marshalTo(Tuple t)	Same as calling What#marshal(Tuple, StatTuple)
static com.streambase.sb.monitor.StatTuplev3	StatsUtil.toStatTuple(Tuple t)
com.streambase.sb.monitor.StatTuplev3	StatsUtil.StatEncoder.unmarshal(Tuple t)	Retrieve data from tuple and returns a StatBuffer
com.streambase.sb.monitor.StatTuplev3	StatsUtil.What.unmarshal(Tuple t)	Un-marshal a tuple to a StatTuple

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

Modifier	Constructor	Description
	StatTuple(Tuple t)	Constructor

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	ITupleDataInitializer.newOutputTuple()	Create a new output tuple.
default Tuple	ITupleDataInitializer.newOutputTuple(Tuple inputTuple)	Deprecated. Use a combination of ITupleDataInitializer.newOutputTuple() and ITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
default Tuple	ITupleDataInitializer.newOutputTuple(Tuple inputTuple, ITupleDataInitializer.ITupleHandler handler)	Deprecated. Use a combination of ITupleDataInitializer.newOutputTuple() and ITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
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	ITupleDataInitializer.ITupleHandler.accept(Tuple inputTuple, Tuple outputTuple)
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	ITupleDataInitializer.fillOutputTuple(Tuple inputTuple, Tuple outputTuple, ITupleDataInitializer.ITupleHandler handler)	Fill the output tuple from the input value, process the tuple handler to updated additional fields in the output.
void	TableAccessor.insert(Tuple row)	Insert a new row into the table.
default Tuple	ITupleDataInitializer.newOutputTuple(Tuple inputTuple)	Deprecated. Use a combination of ITupleDataInitializer.newOutputTuple() and ITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
default Tuple	ITupleDataInitializer.newOutputTuple(Tuple inputTuple, ITupleDataInitializer.ITupleHandler handler)	Deprecated. Use a combination of ITupleDataInitializer.newOutputTuple() and ITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
void	ITupleDataInitializer.populateOutputTuple(Tuple inputTuple, Tuple outputTuple)	Populate the ouptu tuple from the input value (no clearing done on output before filling, and no clearing done on the input tuple at the end)
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.