Skip to content

Instantly share code, notes, and snippets.

View sagargangurde's full-sized avatar

Sagar Gangurde sagargangurde

  • India
View GitHub Profile
@sagargangurde
sagargangurde / FilterSongs.java
Last active January 5, 2021 12:37
Flink application to filter list of songs
package com.talentica.flink;
import org.apache.flink.api.common.functions.FilterFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.api.java.utils.ParameterTool;
import java.util.Arrays;
@sagargangurde
sagargangurde / songs.csv
Created January 5, 2021 11:21
List of Songs
id title singers
1 Roar Katy Perry
2 The Best Day Taylor Swift
3 Cant Remember to Forget You Shakira|Rihanna
4 Uptown Funk Mark Ronson|Bruno Mars
5 Sorry Justin Bieber
6 The Only Exception Paramore
7 Back To December Taylor Swift