public class MapToTupleFunction<K,V> extends java.lang.Object implements edu.iu.dsc.tws.api.tset.fn.MapFunc<edu.iu.dsc.tws.api.comms.structs.Tuple<byte[],byte[]>,WindowedValue<KV<K,V>>>
Constructor and Description |
---|
MapToTupleFunction() |
MapToTupleFunction(Coder<K> inputKeyCoder,
WindowedValues.WindowedValueCoder<V> wvCoder) |
Modifier and Type | Method and Description |
---|---|
edu.iu.dsc.tws.api.comms.structs.Tuple<byte[],byte[]> |
map(WindowedValue<KV<K,V>> input) |
void |
prepare(edu.iu.dsc.tws.api.tset.TSetContext context) |
protected java.lang.Object |
readResolve() |
public MapToTupleFunction()
public MapToTupleFunction(Coder<K> inputKeyCoder, WindowedValues.WindowedValueCoder<V> wvCoder)
public edu.iu.dsc.tws.api.comms.structs.Tuple<byte[],byte[]> map(WindowedValue<KV<K,V>> input)
map
in interface edu.iu.dsc.tws.api.tset.fn.MapFunc<edu.iu.dsc.tws.api.comms.structs.Tuple<byte[],byte[]>,WindowedValue<KV<K,V>>>
public void prepare(edu.iu.dsc.tws.api.tset.TSetContext context)
prepare
in interface edu.iu.dsc.tws.api.tset.fn.TFunction<edu.iu.dsc.tws.api.comms.structs.Tuple<byte[],byte[]>,WindowedValue<KV<K,V>>>
protected java.lang.Object readResolve() throws java.io.ObjectStreamException
java.io.ObjectStreamException