public static class WindowJoin.MySourceMap extends RichMapFunction<String,Tuple3<Long,String,Integer>>
Constructor and Description |
---|
MySourceMap() |
Modifier and Type | Method and Description |
---|---|
Tuple3<Long,String,Integer> |
map(String line)
The mapping method.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public Tuple3<Long,String,Integer> map(String line) throws Exception
MapFunction
map
in interface MapFunction<String,Tuple3<Long,String,Integer>>
map
in class RichMapFunction<String,Tuple3<Long,String,Integer>>
line
- 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.