flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nragon <nuno.goncal...@wedotechnologies.com>
Subject Re: Flink shaded table API
Date Tue, 25 Jul 2017 11:07:37 GMT
Let's see if I can sample this :P.

--------
First i'm reading from kafka.
--------
FlinkKafkaConsumer010<DataParameterMap> consumer =
KafkaSource.consumer(this.zookeeper, this.sourceName, 5);
     
consumer.assignTimestampsAndWatermarks(KafkaTimestampExtractor.extractor());

--------
Then, converting my object(DataParameterMap) into a Row
--------
return ViewMapFunction.map(env.addSource(consumer), this.entity,
this.typeInfo);

--------
After that, I register the table
--------
tableEnv.registerTableSource("tableX", <previous object>)

--------
and I execute an sql ("SELECT APN, DATA_VOLUME_DOWN, DATA_VOLUME_UP, MSISDN
FROM 
PGW_VIEW_A";)
--------
tableEnv.sql(sql).printSchema();

The error happens here at this point.
I'm using version 1.3.1




--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-shaded-table-API-tp14432p14435.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message