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.loadgen
org.apache.storm.mongodb.common.mapper
org.apache.storm.mongodb.trident.state
org.apache.storm.mqtt
org.apache.storm.mqtt.examples	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
org.apache.storm.sql.planner.streams
org.apache.storm.sql.runtime.streams.functions
org.apache.storm.st.topology.window.data
org.apache.storm.streams.operations.mappers
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>>	AyncCQLResultSetValuesMapper.map(com.datastax.driver.core.Session session, List<com.datastax.driver.core.Statement> statements, List<ITuple> tuples)
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 Values

Modifier and Type	Method and Description
Values	NonTransactionalTupleStateMapper.toValues(ITuple t)
Values	OpaqueTupleStateMapper.toValues(OpaqueValue<ITuple> tuple)
Values	SimpleStateMapper.toValues(T value)
Values	StateMapper.toValues(T value)
Values	SerializedStateMapper.toValues(T value)
Values	TransactionalTupleStateMapper.toValues(TransactionalValue<ITuple> tuple)

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)
protected List<Values>	TridentAyncCQLResultSetValuesMapper.handleResult(com.datastax.driver.core.ResultSet resultSet, ITuple tuple)
List<List<Values>>	TridentAyncCQLResultSetValuesMapper.map(com.datastax.driver.core.Session session, List<com.datastax.driver.core.Statement> statements, List<ITuple> tuples)
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)
OpaqueValue<ITuple>	OpaqueTupleStateMapper.fromValues(List<Values> valuesList)
ITuple	NonTransactionalTupleStateMapper.fromValues(List<Values> values)
T	SimpleStateMapper.fromValues(List<Values> valuesSet)
T	StateMapper.fromValues(List<Values> values)
TransactionalValue<ITuple>	TransactionalTupleStateMapper.fromValues(List<Values> valuesList)
T	SerializedStateMapper.fromValues(List<Values> values)

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>	DefaultEsLookupResultOutput.toValues(org.elasticsearch.client.Response response)
Collection<Values>	EsLookupResultOutput.toValues(org.elasticsearch.client.Response response) Convert Elasticsearch response to a collection of Values.

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) Map to values.

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>	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 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.loadgen

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

Modifier and Type	Method and Description
protected Values	ThroughputVsLatency.FastRandomSentenceSpout.getNextValues(OutputStreamEngine se)
protected Values	LoadSpout.getNextValues(OutputStreamEngine se)

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

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

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

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

Modifier and Type	Method and Description
List<List<Values>>	MongoState.batchRetrieve(List<TridentTuple> tridentTuples) Batch retrieve values.
List<List<Values>>	MongoStateQuery.batchRetrieve(MongoState mongoState, List<TridentTuple> tridentTuples)

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

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

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) Converts MQTT message to an instance of Values.

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

Fields in org.apache.storm.sql with type parameters of type Values

Modifier and Type	Field and Description
protected Stream<Values>	AbstractStreamsProcessor.outputStream

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

Modifier and Type	Method and Description
Stream<Values>	AbstractStreamsProcessor.outputStream() Return final output stream of SQL topology structure.

Uses of Values in org.apache.storm.sql.planner.streams

Methods in org.apache.storm.sql.planner.streams that return types with arguments of type Values

Modifier and Type	Method and Description
Stream<Values>	StreamsPlanCreator.pop()

Method parameters in org.apache.storm.sql.planner.streams with type arguments of type Values

Modifier and Type	Method and Description
void	StreamsPlanCreator.addStream(Stream<Values> stream)

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

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

Modifier and Type	Method and Description
Values	StreamsScanTupleValueMapper.apply(Tuple input)
Values	EvaluationFunction.apply(Values input)

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

Modifier and Type	Method and Description
Pair<Object,Values>	StreamInsertMapToPairFunction.apply(Values input)
Iterable<Values>	EvaluationCalc.apply(Values input)

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

Modifier and Type	Method and Description
Values	EvaluationFunction.apply(Values input)
Pair<Object,Values>	StreamInsertMapToPairFunction.apply(Values input)
Iterable<Values>	EvaluationCalc.apply(Values input)
boolean	EvaluationFilter.test(Values input)

Uses of Values in org.apache.storm.st.topology.window.data

Methods in org.apache.storm.st.topology.window.data that return Values

Modifier and Type	Method and Description
Values	TimeData.getValues()

Uses of Values in org.apache.storm.streams.operations.mappers

Methods in org.apache.storm.streams.operations.mappers that return Values

Modifier and Type	Method and Description
Values	ValuesMapper.apply(Tuple 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.