Uses of Interface
org.apache.storm.streams.operations.mappers.TupleValueMapper

Packages that use TupleValueMapper

Package	Description
org.apache.storm.sql.runtime.streams.functions
org.apache.storm.streams
org.apache.storm.streams.operations.mappers

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

Classes in org.apache.storm.sql.runtime.streams.functions that implement TupleValueMapper

Modifier and Type	Class	Description
class	StreamsScanTupleValueMapper

Uses of TupleValueMapper in org.apache.storm.streams

Methods in org.apache.storm.streams with parameters of type TupleValueMapper

Modifier and Type	Method	Description
<T> Stream<T>	StreamBuilder.newStream(IRichSpout spout, TupleValueMapper<T> valueMapper)	Creates a new Stream of values from the given IRichSpout by extracting field(s) from tuples via the supplied TupleValueMapper.
<T> Stream<T>	StreamBuilder.newStream(IRichSpout spout, TupleValueMapper<T> valueMapper, int parallelism)	Creates a new Stream of values from the given IRichSpout by extracting field(s) from tuples via the supplied TupleValueMapper with the given parallelism.

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

Classes in org.apache.storm.streams.operations.mappers that implement TupleValueMapper

Modifier and Type	Class	Description
class	PairValueMapper<K,V>	Extracts a typed key-value pair from a tuple.
class	ValueMapper<T>	Extracts a single typed value from a tuple.
class	ValuesMapper	Constructs a Values from a Tuple based on indicies.

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

Modifier and Type	Method	Description
static <T1, T2, T3> TupleValueMapper<Tuple3<T1,T2,T3>>	TupleValueMappers.of(int index1, int index2, int index3)
static <T1, T2, T3, T4> TupleValueMapper<Tuple4<T1,T2,T3,T4>>	TupleValueMappers.of(int index1, int index2, int index3, int index4)
static <T1, T2, T3, T4, T5> TupleValueMapper<Tuple5<T1,T2,T3,T4,T5>>	TupleValueMappers.of(int index1, int index2, int index3, int index4, int index5)
static <T1, T2, T3, T4, T5, T6> TupleValueMapper<Tuple6<T1,T2,T3,T4,T5,T6>>	TupleValueMappers.of(int index1, int index2, int index3, int index4, int index5, int index6)
static <T1, T2, T3, T4, T5, T6, T7> TupleValueMapper<Tuple7<T1,T2,T3,T4,T5,T6,T7>>	TupleValueMappers.of(int index1, int index2, int index3, int index4, int index5, int index6, int index7)
static <T1, T2, T3, T4, T5, T6, T7, T8> TupleValueMapper<Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>>	TupleValueMappers.of(int index1, int index2, int index3, int index4, int index5, int index6, int index7, int index8)
static <T1, T2, T3, T4, T5, T6, T7, T8, T9> TupleValueMapper<Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>>	TupleValueMappers.of(int index1, int index2, int index3, int index4, int index5, int index6, int index7, int index8, int index9)
static <T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> TupleValueMapper<Tuple10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>>	TupleValueMappers.of(int index1, int index2, int index3, int index4, int index5, int index6, int index7, int index8, int index9, int index10)