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