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 Summary
-
Method Summary
-
Constructor Details
-
StreamInsertMapToPairFunction
public StreamInsertMapToPairFunction(int primaryKeyIndex)
-
-
Method Details