Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
// Convert each record to an InputData object; each new line is considered a new record
DataStream<InputData> inputDataObjectStream
= dataStream
.map((MapFunction<String, InputData>) inputStr -> {
System.out.println("--- Received Record : " + inputStr);
return InputData.getDataObject(inputStr);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment