Redis
 sql >> Cơ Sở Dữ Liệu >  >> NoSQL >> Redis

Đọc dữ liệu từ Redis sang Flink

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

}


  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Một giao diện bộ đệm và phụ trợ

  2. Không thể khởi động redis.service:Đơn vị redis-server.service bị che

  3. Khôi phục từ kết nối bị ngắt trong redis pub / sub

  4. Cách sử dụng Redis Hashes

  5. Nén trong node.js