Momenteel is Flink Redis Connector niet beschikbaar, maar het kan worden geïmplementeerd door de RichSinkFunction/SinkFunction-klasse uit te breiden.
public class RedisSink extends RichSinkFunction<String> {
@Override
public void open(Configuration parameters) throws Exception {
//open redis connection
}
@Override
public void invoke(String map) throws Exception {
//sink data to redis
}
@Override
public void close() throws Exception {
super.close();
}
}