रेडिस से फ्लिंक तक डेटा पढ़ें

वर्तमान में, फ्लिंक रेडिस कनेक्टर उपलब्ध नहीं है, लेकिन इसे 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();
  }

}