想实现over窗口每条记录生成多行结果怎么做?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

想实现over窗口每条记录生成多行结果怎么做?

jiangwan
比如Top2问题,自定义一个Top2函数,想了一下2种方法不可行,
想法一,用flinksql实现,官网没有给如何在flinksql引用Table Aggregate
Functions的示例,只给出了在tableapi中的引用,所以不会写了
// call function "inline" without registration in Table API
env
  .from("MyTable")
  .groupBy($("myField"))
  .flatAggregate(call(Top2.class, $("value")))
  .select($("myField"), $("f0"), $("f1"));

// call function "inline" without registration in Table API
// but use an alias for a better naming of Tuple2's fields
env
  .from("MyTable")
  .groupBy($("myField"))
  .flatAggregate(call(Top2.class, $("value")).as("value", "rank"))
  .select($("myField"), $("value"), $("rank"));

// register function
env.createTemporarySystemFunction("Top2", Top2.class);

// call registered function in Table API
env
  .from("MyTable")
  .groupBy($("myField"))
  .flatAggregate(call("Top2", $("value")).as("value", "rank"))
  .select($("myField"), $("value"), $("rank"));
想法二:用tableapi实现,尝试发现over window的后面只能接select,不能接flatAggregate,所以不会写了
       transactions
               
.window(Over.partitionBy($("CUST_NO")).orderBy($("TRADE_TIME")).preceding(lit(10).minutes()).as("w"))
        .select();


请问下,有什么解决方案吗?还是说暂时不支持over窗口的多条输出




--
Sent from: http://apache-flink.147419.n8.nabble.com/