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