Looks like you need a window
On Tue, Jul 16, 2019, 9:24 PM sri hari kali charan Tummala <
kali.tumm...@gmail.com> wrote:
> Hi All,
>
> I am trying to write toRetractSream to CSV which is kind of working ok but
> I get extra values like True and then my output data values.
>
> Question1 :-
> I dont want true in my output data how to achieve this?
>
> Scree
>
> Question 2:-
> in the output file (CSV) I am missing data in the last line is the
> toRetractStram closing before writing to file?
>
> Screen Shot attached
>
> Code:-
>
> val data = kinesis.map(mapFunction)
> tEnv.registerDataStream("transactions",data,"cc_num,first_column,last_column,trans_num,trans_time,category_column,merchant_column,amt_column,merch_lat,merch_long")
> val query = "SELECT distinct
> cc_num,first_column,last_column,trans_num,trans_time,category_column,merchant_column,amt_column,merch_lat,merch_long
> FROM transactions where cc_num not in ('cc_num')"
> val table = tEnv.sqlQuery(query)
> tEnv.toRetractStream(table, classOf[org.apache.flink.types.Row])
>
> .writeAsCsv("/Users/kalit_000/Downloads/FlinkStreamAndSql/src/main/resources/csvOut8",
> FileSystem.WriteMode.OVERWRITE,"\n","|")
>
>
>
> --
> Thanks & Regards
> Sri Tummala
>
>
