public class KeyDiscarder<T> extends Object implements MapFunction<Tuple2<T,byte[]>,byte[]>
Constructor and Description |
---|
KeyDiscarder() |
public byte[] map(Tuple2<T,byte[]> value) throws Exception
MapFunction
map
in interface MapFunction<Tuple2<T,byte[]>,byte[]>
value
- The input value.Exception
- This method may throw exceptions. Throwing an exception will cause the operation
to fail and may trigger recovery.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.