btw, same case when I remove BeamDeltaRule from ruleset, the error message is a little different as https://gist.github.com/XuMingmin/b4e4eb40f3d8169cf9d11e10a6da92a8
On Tue, Feb 28, 2017 at 9:08 PM, Mingmin Xu <[email protected]> wrote: > Thanks, that can help to generate the RelNode. However it brings a new > issue, not sure it's related. > > Briefly I'm testing to replace RelNode with my own RelNode, to build a > pipeline based on the RelNode tree. When running planner.transform(), an > error message is thrown as https://gist.github.com/XuMingmin/ > 491ff85011d2312acf086c2c0b7343c8. > > ---- > The converter can work without the monotonic column with output: > > SQL>: > select stream * from SOJ_EVENT > SQLPlan> > LogicalDelta > LogicalProject(EVENTTIMESTAMP=[$0], ITEMID=[$1], SITEID=[$2], > PAGEID=[$3], PAGENAME=[$4]) > LogicalTableScan(table=[[SOJ_EVENT]]) > > beamPlan> > BeamProjectRel(EVENTTIMESTAMP=[$0], ITEMID=[$1], SITEID=[$2], > PAGEID=[$3], PAGENAME=[$4]) > BeamStreamScanRel(table=[[SOJ_EVENT, (STREAM)]]) > > > Also paste my DeltaRule at https://gist.github.com/XuMingmin/ > 402cb9b3969763ee6b1efc80016c9a3f, Table schema class here > https://gist.github.com/XuMingmin/0f0efa51be7e5567a7b2d93c206f2275. > > Mingmin > > > > > On Tue, Feb 28, 2017 at 7:26 PM, 陈江枫 <[email protected]> wrote: > >> implement >> >> Statistic getStatistic() in table interface should work. >> >> >> @Override >> public Statistic getStatistic() { >> return Statistics.of(100d, >> ImmutableList.<ImmutableBitSet>of(), >> RelCollations.createSingleton(0)); >> } >> >> is a simple implementation declaring the first field to be ascending >> >> >> 2017-03-01 9:56 GMT+08:00 Mingmin Xu <[email protected]>: >> >> > Hello all, >> > >> > I'm writing some examples to understand the execution plan(more exactly >> > RelNode) of Calcite Streaming, and meet the error 'Streaming aggregation >> > requires at least one monotonic expression in GROUP BY clause' with >> > GROUP-BY. Can anybody share an Java example on how to declare a column >> > monotonic in a StreamableTable? And, can I disable this check rule? >> > >> > Thank you! >> > -- >> > ---- >> > Mingmin >> > >> > > > > -- > ---- > Mingmin > -- ---- Mingmin
