Hiện tại, Trình kết nối Flink Redis không khả dụng nhưng nó có thể được triển khai bằng cách mở rộng lớp RichSinkFunction / SinkFunction.
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();
}
}