Class StreamInsertMapToPairFunction

java.lang.Object
org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunction
All Implemented Interfaces:
Serializable, Function<Values,Pair<Object,Values>>, Operation, PairFunction<Values,Object,Values>

public class StreamInsertMapToPairFunction extends Object implements PairFunction<Values,Object,Values>
See Also:
  • Constructor Details

    • StreamInsertMapToPairFunction

      public StreamInsertMapToPairFunction(int primaryKeyIndex)
  • Method Details