我以键值格式存储数据,示例键是UserId,UserInfo是值。写在下面的代码里。redisSink = new RedisSink[(String, String)](conf, new RedisExampleMapper)12 "UserInfo12“14 "UserInfo14“
我想使用基于键的Flink从redis<
我正在使用flink从Azure数据湖中读取数据。但flink无法找到Azure数据湖文件系统。我已经实现了spark来读取Azure Data Lake文件系统文件。因此,我尝试从flink中触发火花,从Azure数据湖中读取数据,并执行一些逻辑操作,然后将列表返回给flink。所以flink可以使用这些<e