sql >> Database >  >> NoSQL >> Redis

Gegevens lezen van Redis naar Flink

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();
  }

}


  1. MongoDB-aggregatieprojecttekenreeks naar ObjectId

  2. Hoe zorg je voor een uniek item in een array op basis van specifieke velden - mongoDB?

  3. Unieke score voor redis leaderboard

  4. Hoe de array in het verzamelingsrecord in MongoDB te sorteren?