Uses of Class
org.apache.storm.tuple.Values

Packages that use Values

Package	Description
org.apache.storm.cassandra.query
org.apache.storm.cassandra.trident.state
org.apache.storm.elasticsearch
org.apache.storm.hbase.bolt.mapper
org.apache.storm.hbase.topology
org.apache.storm.hbase.trident.state
org.apache.storm.jdbc.mapper
org.apache.storm.jdbc.spout
org.apache.storm.jdbc.trident.state
org.apache.storm.jms
org.apache.storm.jms.example
org.apache.storm.kafka.spout
org.apache.storm.mqtt
org.apache.storm.mqtt.examples
org.apache.storm.mqtt.mappers
org.apache.storm.redis.common.mapper
org.apache.storm.redis.trident
org.apache.storm.redis.trident.state
org.apache.storm.solr.spout
org.apache.storm.sql.compiler.backends.standalone
org.apache.storm.sql.runtime
org.apache.storm.sql.runtime.trident.functions
org.apache.storm.testing
org.apache.storm.trident.operation

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

Methods in org.apache.storm.cassandra.query that return types with arguments of type Values

Modifier and Type	Method and Description
List<List<Values>>	CQLResultSetValuesMapper.map(com.datastax.driver.core.Session session, com.datastax.driver.core.Statement statement, ITuple tuple)

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

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

Modifier and Type	Method and Description
List<List<Values>>	CassandraQuery.batchRetrieve(CassandraState state, List<TridentTuple> tridentTuples)
List<List<Values>>	CassandraState.batchRetrieve(List<TridentTuple> tridentTuples)
List<List<Values>>	TridentResultSetValuesMapper.map(com.datastax.driver.core.Session session, com.datastax.driver.core.Statement statement, ITuple tuple)

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

Modifier and Type	Method and Description
void	CassandraQuery.execute(TridentTuple tuple, List<Values> valuesList, TridentCollector collector)

Uses of Values in org.apache.storm.elasticsearch

Methods in org.apache.storm.elasticsearch that return types with arguments of type Values

Modifier and Type	Method and Description
Collection<Values>	EsLookupResultOutput.toValues(org.elasticsearch.client.Response response)
Collection<Values>	DefaultEsLookupResultOutput.toValues(org.elasticsearch.client.Response response)

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

Methods in org.apache.storm.hbase.bolt.mapper that return types with arguments of type Values

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

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

Methods in org.apache.storm.hbase.topology that return types with arguments of type Values

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

Uses of Values in org.apache.storm.hbase.trident.state

Methods in org.apache.storm.hbase.trident.state that return types with arguments of type Values

Modifier and Type	Method and Description
List<List<Values>>	HBaseQuery.batchRetrieve(HBaseState hBaseState, List<TridentTuple> tridentTuples)
List<List<Values>>	HBaseState.batchRetrieve(List<TridentTuple> tridentTuples)

Method parameters in org.apache.storm.hbase.trident.state with type arguments of type Values

Modifier and Type	Method and Description
void	HBaseQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)

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

Methods in org.apache.storm.jdbc.mapper that return types with arguments of type Values

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

Uses of Values in org.apache.storm.jdbc.spout

Fields in org.apache.storm.jdbc.spout with type parameters of type Values

Modifier and Type	Field and Description
static List<Values>	UserSpout.rows

Uses of Values in org.apache.storm.jdbc.trident.state

Methods in org.apache.storm.jdbc.trident.state that return types with arguments of type Values

Modifier and Type	Method and Description
List<List<Values>>	JdbcQuery.batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)
List<List<Values>>	JdbcState.batchRetrieve(List<TridentTuple> tridentTuples)

Method parameters in org.apache.storm.jdbc.trident.state with type arguments of type Values

Modifier and Type	Method and Description
void	JdbcQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)

Uses of Values in org.apache.storm.jms

Methods in org.apache.storm.jms that return Values

Modifier and Type	Method and Description
Values	JmsTupleProducer.toTuple(javax.jms.Message msg) Process a JMS message object to create a Values object.

Uses of Values in org.apache.storm.jms.example

Methods in org.apache.storm.jms.example that return Values

Modifier and Type	Method and Description
Values	JsonTupleProducer.toTuple(javax.jms.Message msg)

Uses of Values in org.apache.storm.kafka.spout

Subclasses of Values in org.apache.storm.kafka.spout

Modifier and Type	Class and Description
class	KafkaTuple A list of Values in a tuple that can be routed to a given stream.

Uses of Values in org.apache.storm.mqtt

Methods in org.apache.storm.mqtt that return Values

Modifier and Type	Method and Description
Values	MqttMessageMapper.toValues(MqttMessage message) Convert a MqttMessage to a set of Values that can be emitted as a Storm Tuple.

Uses of Values in org.apache.storm.mqtt.examples

Methods in org.apache.storm.mqtt.examples that return Values

Modifier and Type	Method and Description
Values	CustomMessageMapper.toValues(MqttMessage message)

Uses of Values in org.apache.storm.mqtt.mappers

Methods in org.apache.storm.mqtt.mappers that return Values

Modifier and Type	Method and Description
Values	StringMessageMapper.toValues(MqttMessage message)
Values	ByteArrayMessageMapper.toValues(MqttMessage message)

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

Methods in org.apache.storm.redis.common.mapper that return types with arguments of type Values

Modifier and Type	Method and Description
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 Values in org.apache.storm.redis.trident

Methods in org.apache.storm.redis.trident that return types with arguments of type Values

Modifier and Type	Method and Description
List<Values>	WordCountLookupMapper.toTuple(ITuple input, Object value)

Uses of Values in org.apache.storm.redis.trident.state

Methods in org.apache.storm.redis.trident.state that return types with arguments of type Values

Modifier and Type	Method and Description
List<List<Values>>	AbstractRedisStateQuerier.batchRetrieve(T state, List<TridentTuple> inputs)

Method parameters in org.apache.storm.redis.trident.state with type arguments of type Values

Modifier and Type	Method and Description
void	AbstractRedisStateQuerier.execute(TridentTuple tuple, List<Values> values, TridentCollector collector)

Uses of Values in org.apache.storm.solr.spout

Fields in org.apache.storm.solr.spout with type parameters of type Values

Modifier and Type	Field and Description
static List<Values>	SolrFieldsSpout.listValues

Uses of Values in org.apache.storm.sql.compiler.backends.standalone

Methods in org.apache.storm.sql.compiler.backends.standalone with parameters of type Values

Modifier and Type	Method and Description
static Long	BuiltinAggregateFunctions.Count.add(Long accumulator, Values vals)

Uses of Values in org.apache.storm.sql.runtime

Methods in org.apache.storm.sql.runtime with parameters of type Values

Modifier and Type	Method and Description
void	ChannelHandler.dataReceived(ChannelContext ctx, Values data)
abstract void	AbstractChannelHandler.dataReceived(ChannelContext ctx, Values data)
void	ChannelContext.emit(Values data) Emit data to the next stage of the data pipeline.

Uses of Values in org.apache.storm.sql.runtime.trident.functions

Methods in org.apache.storm.sql.runtime.trident.functions that return Values

Modifier and Type	Method and Description
Values	EvaluationFunction.execute(TridentTuple input)

Methods in org.apache.storm.sql.runtime.trident.functions that return types with arguments of type Values

Modifier and Type	Method and Description
Iterable<Values>	EvaluationCalc.execute(TridentTuple input)

Uses of Values in org.apache.storm.testing

Methods in org.apache.storm.testing with parameters of type Values

Modifier and Type	Method and Description
void	MockedSources.addMockData(String spoutId, String streamId, Values... valueses) add mock data for the spout.
void	MockedSources.addMockData(String spoutId, Values... valueses)

Uses of Values in org.apache.storm.trident.operation

Methods in org.apache.storm.trident.operation that return Values

Modifier and Type	Method and Description
Values	MapFunction.execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.

Methods in org.apache.storm.trident.operation that return types with arguments of type Values

Modifier and Type	Method and Description
Iterable<Values>	FlatMapFunction.execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.