Uses of Interface
org.apache.storm.tuple.ITuple

Packages that use ITuple

Package	Description
org.apache.storm.cassandra.query
org.apache.storm.cassandra.query.impl
org.apache.storm.cassandra.query.selector
org.apache.storm.cassandra.trident.state
org.apache.storm.clojure
org.apache.storm.elasticsearch.common	Shared code for example classes.
org.apache.storm.hbase.bolt.mapper
org.apache.storm.hbase.topology
org.apache.storm.jdbc.mapper
org.apache.storm.jms
org.apache.storm.mongodb.common
org.apache.storm.mongodb.common.mapper
org.apache.storm.mqtt
org.apache.storm.opentsdb.bolt
org.apache.storm.redis.common.mapper
org.apache.storm.redis.trident
org.apache.storm.rocketmq.common.mapper
org.apache.storm.rocketmq.common.selector
org.apache.storm.solr.mapper
org.apache.storm.trident.tuple
org.apache.storm.tuple

Uses of ITuple in org.apache.storm.cassandra.query

Methods in org.apache.storm.cassandra.query with parameters of type ITuple

Modifier and Type	Method and Description
List<Column>	CqlMapper.map(ITuple tuple) Maps the specified input tuple to a list of CQL columns.
List<Column>	CqlMapper.SelectableCqlMapper.map(ITuple tuple) Maps the specified input tuple to a list of CQL columns.
List<Column>	CqlMapper.DefaultCqlMapper.map(ITuple tuple) Maps the specified input tuple to a list of CQL columns.
abstract com.datastax.driver.core.Statement	BaseCQLStatementTupleMapper.map(ITuple tuple) Maps a given tuple to a single CQL statements.
List<com.datastax.driver.core.Statement>	BaseCQLStatementTupleMapper.map(Map<String,Object> conf, com.datastax.driver.core.Session session, ITuple tuple) Maps a given tuple to one or multiple CQL statements.
List<com.datastax.driver.core.Statement>	CQLStatementTupleMapper.map(Map<String,Object> conf, com.datastax.driver.core.Session session, ITuple tuple) Maps a given tuple to one or multiple CQL statements.
List<com.datastax.driver.core.Statement>	CQLStatementTupleMapper.DynamicCQLStatementTupleMapper.map(Map<String,Object> conf, com.datastax.driver.core.Session session, ITuple tuple)
List<List<Values>>	CQLResultSetValuesMapper.map(com.datastax.driver.core.Session session, com.datastax.driver.core.Statement statement, ITuple tuple)
String	ContextQuery.resolves(Map<String,Object> config, ITuple tuple) Resolves a cassandra bound query.
String	ContextQuery.StaticContextQuery.resolves(Map<String,Object> config, ITuple tuple)
String	ContextQuery.BoundQueryContext.resolves(Map<String,Object> config, ITuple tuple)
String	ContextQuery.BoundQueryNamedByFieldContext.resolves(Map<String,Object> config, ITuple tuple)

Method parameters in org.apache.storm.cassandra.query with type arguments of type ITuple

Modifier and Type	Method and Description
List<List<Values>>	AyncCQLResultSetValuesMapper.map(com.datastax.driver.core.Session session, List<com.datastax.driver.core.Statement> statements, List<ITuple> tuples)

Uses of ITuple in org.apache.storm.cassandra.query.impl

Methods in org.apache.storm.cassandra.query.impl with parameters of type ITuple

Modifier and Type	Method and Description
List<ByteBuffer>	RoutingKeyGenerator.getRoutingKeys(ITuple tuple)
List<com.datastax.driver.core.Statement>	SimpleCQLStatementMapper.map(Map<String,Object> conf, com.datastax.driver.core.Session session, ITuple tuple) Maps a given tuple to one or multiple CQL statements.
List<com.datastax.driver.core.Statement>	BatchCQLStatementTupleMapper.map(Map<String,Object> conf, com.datastax.driver.core.Session session, ITuple tuple) Maps a given tuple to one or multiple CQL statements.
List<com.datastax.driver.core.Statement>	BoundCQLStatementTupleMapper.map(Map<String,Object> config, com.datastax.driver.core.Session session, ITuple tuple) Maps a given tuple to one or multiple CQL statements.
List<com.datastax.driver.core.Statement>	ObjectMapperCqlStatementMapper.map(Map<String,Object> map, com.datastax.driver.core.Session session, ITuple tuple)

Uses of ITuple in org.apache.storm.cassandra.query.selector

Methods in org.apache.storm.cassandra.query.selector with parameters of type ITuple

Modifier and Type	Method and Description
protected Object	FieldSelector.getFieldValue(ITuple tuple) Get field value.
Column	FieldSelector.select(ITuple t)

Uses of ITuple in org.apache.storm.cassandra.trident.state

Classes in org.apache.storm.cassandra.trident.state that implement ITuple

Modifier and Type	Class and Description
class	SimpleTuple Utility class for passing around ordered key/value data with an immutable key set.

Methods in org.apache.storm.cassandra.trident.state that return ITuple

Modifier and Type	Method and Description
ITuple	NonTransactionalTupleStateMapper.fromValues(List<Values> values)

Methods in org.apache.storm.cassandra.trident.state that return types with arguments of type ITuple

Modifier and Type	Method and Description
OpaqueValue<ITuple>	OpaqueTupleStateMapper.fromValues(List<Values> valuesList)
TransactionalValue<ITuple>	TransactionalTupleStateMapper.fromValues(List<Values> valuesList)

Methods in org.apache.storm.cassandra.trident.state with parameters of type ITuple

Modifier and Type	Method and Description
protected List<Values>	TridentAyncCQLResultSetValuesMapper.handleResult(com.datastax.driver.core.ResultSet resultSet, ITuple tuple)
List<List<Values>>	TridentResultSetValuesMapper.map(com.datastax.driver.core.Session session, com.datastax.driver.core.Statement statement, ITuple tuple)
Values	NonTransactionalTupleStateMapper.toValues(ITuple t)

Method parameters in org.apache.storm.cassandra.trident.state with type arguments of type ITuple

Modifier and Type	Method and Description
List<List<Values>>	TridentAyncCQLResultSetValuesMapper.map(com.datastax.driver.core.Session session, List<com.datastax.driver.core.Statement> statements, List<ITuple> tuples)
Values	OpaqueTupleStateMapper.toValues(OpaqueValue<ITuple> tuple)
Values	TransactionalTupleStateMapper.toValues(TransactionalValue<ITuple> tuple)

Uses of ITuple in org.apache.storm.clojure

Classes in org.apache.storm.clojure that implement ITuple

Modifier and Type	Class and Description
class	ClojureTuple

Uses of ITuple in org.apache.storm.elasticsearch.common

Methods in org.apache.storm.elasticsearch.common with parameters of type ITuple

Modifier and Type	Method and Description
String	EsTupleMapper.getId(ITuple tuple) Extracts id from tuple.
String	DefaultEsTupleMapper.getId(ITuple tuple)
String	EsTupleMapper.getIndex(ITuple tuple) Extracts index from tuple.
String	DefaultEsTupleMapper.getIndex(ITuple tuple)
Map<String,String>	EsTupleMapper.getParams(ITuple tuple, Map<String,String> defaultValue) Extracts params from tuple if available.
Map<String,String>	DefaultEsTupleMapper.getParams(ITuple tuple, Map<String,String> defaultValue)
String	EsTupleMapper.getSource(ITuple tuple) Extracts source from tuple.
String	DefaultEsTupleMapper.getSource(ITuple tuple)
String	EsTupleMapper.getType(ITuple tuple) Extracts type from tuple.
String	DefaultEsTupleMapper.getType(ITuple tuple)

Uses of ITuple in org.apache.storm.hbase.bolt.mapper

Methods in org.apache.storm.hbase.bolt.mapper with parameters of type ITuple

Modifier and Type	Method and Description
List<Values>	HBaseValueMapper.toValues(ITuple input, org.apache.hadoop.hbase.client.Result result) Map to values.

Uses of ITuple in org.apache.storm.hbase.topology

Methods in org.apache.storm.hbase.topology with parameters of type ITuple

Modifier and Type	Method and Description
List<Values>	WordCountValueMapper.toValues(ITuple tuple, org.apache.hadoop.hbase.client.Result result)

Uses of ITuple in org.apache.storm.jdbc.mapper

Methods in org.apache.storm.jdbc.mapper with parameters of type ITuple

Modifier and Type	Method and Description
List<Column>	SimpleJdbcMapper.getColumns(ITuple tuple)
List<Column>	JdbcMapper.getColumns(ITuple tuple) Get columns.
List<Values>	JdbcLookupMapper.toTuple(ITuple input, List<Column> columns) Converts a DB row to a list of storm values that can be emitted.
List<Values>	SimpleJdbcLookupMapper.toTuple(ITuple input, List<Column> columns)

Uses of ITuple in org.apache.storm.jms

Methods in org.apache.storm.jms with parameters of type ITuple

Modifier and Type	Method and Description
javax.jms.Message	JmsMessageProducer.toMessage(javax.jms.Session session, ITuple input) Translate a org.apache.storm.tuple.Tuple object to a javax.jms.Message object.

Uses of ITuple in org.apache.storm.mongodb.common

Methods in org.apache.storm.mongodb.common with parameters of type ITuple

Modifier and Type	Method and Description
org.bson.conversions.Bson	QueryFilterCreator.createFilter(ITuple tuple) Create a query Filter by given Tuple.
org.bson.conversions.Bson	SimpleQueryFilterCreator.createFilter(ITuple tuple)

Uses of ITuple in org.apache.storm.mongodb.common.mapper

Methods in org.apache.storm.mongodb.common.mapper with parameters of type ITuple

Modifier and Type	Method and Description
org.bson.Document	MongoMapper.toDocument(ITuple tuple) Converts a Tuple to a Document.
org.bson.Document	SimpleMongoMapper.toDocument(ITuple tuple)
org.bson.Document	SimpleMongoUpdateMapper.toDocument(ITuple tuple)
List<Values>	MongoLookupMapper.toTuple(ITuple input, org.bson.Document doc) Converts a Mongo document to a list of storm values that can be emitted.
List<Values>	SimpleMongoLookupMapper.toTuple(ITuple input, org.bson.Document doc)

Uses of ITuple in org.apache.storm.mqtt

Methods in org.apache.storm.mqtt with parameters of type ITuple

Modifier and Type	Method and Description
MqttMessage	MqttTupleMapper.toMessage(ITuple tuple) Converts a Tuple to a MqttMessage.

Uses of ITuple in org.apache.storm.opentsdb.bolt

Methods in org.apache.storm.opentsdb.bolt with parameters of type ITuple

Modifier and Type	Method and Description
OpenTsdbMetricDatapoint	ITupleOpenTsdbDatapointMapper.getMetricPoint(ITuple tuple) Returns a OpenTsdbMetricDatapoint for a given tuple.
OpenTsdbMetricDatapoint	TupleOpenTsdbDatapointMapper.getMetricPoint(ITuple tuple)

Uses of ITuple in org.apache.storm.redis.common.mapper

Methods in org.apache.storm.redis.common.mapper with parameters of type ITuple

Modifier and Type	Method and Description
String	TupleMapper.getKeyFromTuple(ITuple tuple) Extracts key from tuple.
String	TupleMapper.getValueFromTuple(ITuple tuple) Extracts value from tuple.
List<Values>	RedisLookupMapper.toTuple(ITuple input, Object value) Converts return value from Redis to a list of storm values that can be emitted.

Uses of ITuple in org.apache.storm.redis.trident

Methods in org.apache.storm.redis.trident with parameters of type ITuple

Modifier and Type	Method and Description
String	WordCountLookupMapper.getKeyFromTuple(ITuple tuple)
String	WordCountStoreMapper.getKeyFromTuple(ITuple tuple)
String	WordCountLookupMapper.getValueFromTuple(ITuple tuple)
String	WordCountStoreMapper.getValueFromTuple(ITuple tuple)
List<Values>	WordCountLookupMapper.toTuple(ITuple input, Object value)

Uses of ITuple in org.apache.storm.rocketmq.common.mapper

Methods in org.apache.storm.rocketmq.common.mapper with parameters of type ITuple

Modifier and Type	Method and Description
String	FieldNameBasedTupleToMessageMapper.getKeyFromTuple(ITuple tuple)
String	TupleToMessageMapper.getKeyFromTuple(ITuple tuple)
byte[]	FieldNameBasedTupleToMessageMapper.getValueFromTuple(ITuple tuple)
byte[]	TupleToMessageMapper.getValueFromTuple(ITuple tuple)

Uses of ITuple in org.apache.storm.rocketmq.common.selector

Methods in org.apache.storm.rocketmq.common.selector with parameters of type ITuple

Modifier and Type	Method and Description
String	FieldNameBasedTopicSelector.getTag(ITuple tuple)
String	TopicSelector.getTag(ITuple tuple)
String	DefaultTopicSelector.getTag(ITuple tuple)
String	FieldNameBasedTopicSelector.getTopic(ITuple tuple)
String	TopicSelector.getTopic(ITuple tuple)
String	DefaultTopicSelector.getTopic(ITuple tuple)

Uses of ITuple in org.apache.storm.solr.mapper

Methods in org.apache.storm.solr.mapper with parameters of type ITuple

Modifier and Type	Method and Description
org.apache.solr.client.solrj.SolrRequest	SolrJsonMapper.toSolrRequest(ITuple tuple)
org.apache.solr.client.solrj.SolrRequest	SolrMapper.toSolrRequest(ITuple tuple)
org.apache.solr.client.solrj.SolrRequest	SolrFieldsMapper.toSolrRequest(ITuple tuple)

Method parameters in org.apache.storm.solr.mapper with type arguments of type ITuple

Modifier and Type	Method and Description
org.apache.solr.client.solrj.SolrRequest	SolrJsonMapper.toSolrRequest(List<? extends ITuple> tuples) Maps to Solr request.
org.apache.solr.client.solrj.SolrRequest	SolrMapper.toSolrRequest(List<? extends ITuple> tuples)
org.apache.solr.client.solrj.SolrRequest	SolrFieldsMapper.toSolrRequest(List<? extends ITuple> tuples)

Uses of ITuple in org.apache.storm.trident.tuple

Subinterfaces of ITuple in org.apache.storm.trident.tuple

Modifier and Type	Interface and Description
interface	TridentTuple

Classes in org.apache.storm.trident.tuple that implement ITuple

Modifier and Type	Class and Description
class	TridentTupleView Extends AbstractList so that it can be emitted directly as Storm tuples.

Uses of ITuple in org.apache.storm.tuple

Subinterfaces of ITuple in org.apache.storm.tuple

Modifier and Type	Interface and Description
interface	Tuple The tuple is the main data structure in Storm.

Classes in org.apache.storm.tuple that implement ITuple

Modifier and Type	Class and Description
class	TupleImpl