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
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
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