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