T
- public class SplitStreamMapper<T> extends Object implements MapFunction<SplitStreamType<T>,T>
SplitStreamType
<T>
away, ie, extracts the wrapped record of type T
. Can be used to get
a "clean" stream from a Spout/Bolt that declared multiple output streams (after the streams got separated using
.split(...)
and
.select(...)
).Constructor and Description |
---|
SplitStreamMapper() |
public T map(SplitStreamType<T> value) throws Exception
MapFunction
map
in interface MapFunction<SplitStreamType<T>,T>
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–2018 The Apache Software Foundation. All rights reserved.