Class ValuesMapper

java.lang.Object
org.apache.storm.streams.operations.mappers.ValuesMapper
All Implemented Interfaces:
Serializable, Function<Tuple,Values>, TupleValueMapper<Values>, Operation

public class ValuesMapper extends Object implements TupleValueMapper<Values>
Constructs a Values from a Tuple based on indicies.
See Also:
  • Constructor Details

    • ValuesMapper

      public ValuesMapper(int... indices)
      Constructs a new ValuesMapper that extracts value from a Tuple at specified indices.
      Parameters:
      indices - the indices
  • Method Details

    • apply

      public Values apply(Tuple input)
      Description copied from interface: Function
      Applies this function to the given argument.
      Specified by:
      apply in interface Function<Tuple,Values>
      Parameters:
      input - the input to the function
      Returns:
      the function result