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 classStreamsScanTupleValueMapper -
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 newStreamof values from the givenIRichSpoutby extracting field(s) from tuples via the suppliedTupleValueMapper.<T> Stream<T>StreamBuilder. newStream(IRichSpout spout, TupleValueMapper<T> valueMapper, int parallelism)Creates a newStreamof values from the givenIRichSpoutby extracting field(s) from tuples via the suppliedTupleValueMapperwith 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 classPairValueMapper<K,V>Extracts a typed key-value pair from a tuple.classValueMapper<T>Extracts a single typed value from a tuple.classValuesMapperMethods 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)
-