RE: Some questions about Table API and FlinkSQL

2016-10-05 Thread Anton Mushin
tions about Table API and FlinkSQL Hi Anton, 1) according to org.apache.calcite.sql.fun.SqlAvgAggFunction " the result is the same type" so I think this is standard SQL behavior. 2) This seems to be a code generation bug. The sqrt/power function seems not accept the data types. Would

Re: Some questions about Table API and FlinkSQL

2016-10-04 Thread Timo Walther
Hi Anton, 1) according to org.apache.calcite.sql.fun.SqlAvgAggFunction " the result is the same type" so I think this is standard SQL behavior. 2) This seems to be a code generation bug. The sqrt/power function seems not accept the data types. Would be great if you could open an issue if it do

Some questions about Table API and FlinkSQL

2016-10-04 Thread Anton Mushin
Hello all, I have some questions about work with FlinkSQL. 1)I'm want calculate average for column values: val env = ExecutionEnvironment.getExecutionEnvironment val tEnv = TableEnvironment.getTableEnvironment(env, config) val ds = env.fromElements( (1.0f, 1), (2.0f, 2)).toTa