SQL / Tuple question

Posted by Radu Tudoran on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/SQL-Tuple-question-tp9065.html

Hi,

 

I am trying to create an sql statement that is suppose to return a string and and integer

 

Mytable.sql(“select mystringfield,myintfield …. )

 

I am trying to give the typefinormation as a class to the

 

TypeInformation<Tuple2<String, Long>> tpinf = new TypeHint<Tuple2<String, Long>>(){}.getTypeInfo();

         

.toDataStream( , tpinf.getTypeClass() )

 

However I get the following error shown below.

Can someone give me an example of some working tuples for this case.

 

 

 

Exception in thread "main" org.apache.flink.api.common.functions.InvalidTypesException: Tuple needs to be parameterized by using generics.

     at