Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
MapFunction
✓ org.apache.flink.api.common.functions.MapFunction
Create a simple Flink streaming job that transforms data.
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
public class FlinkExample {
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<String> data = env.fromElements("hello", "world");
data.map(new MapFunction<String, String>() {
@Override
public String map(String value) {
return value.toUpperCase();
}
}).print();
env.execute();
}
}
Debug
Known issues
No known issues recorded.
Audit
Dependencies
No dependency data recorded yet.