Class StreamsScanTupleValueMapper

java.lang.Object
org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper
All Implemented Interfaces:
Serializable, Function<Tuple,Values>, TupleValueMapper<Values>, Operation

public class StreamsScanTupleValueMapper extends Object implements TupleValueMapper<Values>
See Also:
  • Constructor Details

    • StreamsScanTupleValueMapper

      public StreamsScanTupleValueMapper(List<String> fieldNames)
      Constructor.
      Parameters:
      fieldNames - fields to be added to.
  • 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