Uses of Interface
org.apache.storm.streams.operations.mappers.TupleValueMapper
Packages that use TupleValueMapper
Package
Description
-
Uses of TupleValueMapper in org.apache.storm.sql.runtime.streams.functions
Classes in org.apache.storm.sql.runtime.streams.functions that implement TupleValueMapper -
Uses of TupleValueMapper in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type TupleValueMapperModifier and TypeMethodDescription<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 TupleValueMapperModifier and TypeClassDescriptionclassPairValueMapper<K,V> Extracts a typed key-value pair from a tuple.classValueMapper<T>Extracts a single typed value from a tuple.classMethods in org.apache.storm.streams.operations.mappers that return TupleValueMapperModifier and TypeMethodDescriptionstatic <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)