Re: Passing the individual table coilumn values to the local variables

2018-08-07 Thread vino yang
Hi Mich, Here you need to understand that the print call does not print the value of a field, it is actually a call to an output to STDOUT sink. So, what you get here is not the value of a variable, please refer to the hequn recommendation. Thanks, vino. Hequn Cheng 于2018年8月8日周三 上午9:11写道: > Hi

Re: Passing the individual table coilumn values to the local variables

2018-08-07 Thread Hequn Cheng
Hi Mich, We can't convert a DataStream to a value. There are some options: 1. Use a TableSink to write data[1] into Hbase. 2. Use a UDF[2]. Best, Hequn [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sourceSinks.html#define-a-tablesink [2] https://ci.apache.org/projects/flin

Re: Passing the individual table coilumn values to the local variables

2018-08-07 Thread Mich Talebzadeh
I need this operation to stored filtered rows in an Hbase table. I can access an existing Hbase table through flink API My challenge is to put rows into Hbase table. Something like below and I don't seem to be able to extract individual column values from priceTable *val k