After solved some issues, I connected with Kylin, but I can't read data
import org.apache.flink.api.scala._
import org.apache.flink.api.java.io.jdbc.JDBCInputFormat
import org.apache.flink.api.table.Row
import org.apache.flink.api.table.typeutils.RowTypeInfo
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation}
var stringColum: TypeInformation[Int] = createTypeInformation[Int]
val DB_ROWTYPE = new RowTypeInfo(Seq(stringColum))
val inputFormat = JDBCInputFormat.buildJDBCInputFormat()
.setDrivername("org.apache.kylin.jdbc.Driver")
.setDBUrl("jdbc:kylin://172.17.0.2:7070/learn_kylin")
.setUsername("ADMIN")
.setPassword("KYLIN")
.setQuery("select count(distinct seller_id) as sellers from
kylin_sales group by part_dt order by part_dt")
.setRowTypeInfo(DB_ROWTYPE)
.finish()
val dataset =env.createInput(inputFormat)
dataset.print()
The error is:
[image: Imágenes integradas 1]
(I checked that queries and config are correct with SQuirriel)
(Isn't a connection problem, Because if I turn off database the error
is different "Reused Connection")
Can you see a problem in my code? (I found Flink 4108 unsolved
issue,I don't know if is related)
BR, Alberto
2016-10-07 21:46 GMT+02:00 Fabian Hueske <fhue...@gmail.com>:
> As the exception says the class
> org.apache.flink.api.scala.io.jdbc.JDBCInputFormat
> does not exist.
>
> You have to do:
>
> import org.apache.flink.api.java.io.jdbc.JDBCInputFormat
>
> There is no Scala implementation of this class but you can also use Java
> classes in Scala.
>
> 2016-10-07 21:38 GMT+02:00 Alberto Ramón <a.ramonporto...@gmail.com>:
>
>>
>> I want use CreateInput + buildJDBCInputFormat to acces to database on
>> SCALA
>>
>> PB1:
>>
>> import org.apache.flink.api.scala.io.jdbc.JDBCInputFormat
>> Error:(25, 37) object jdbc is not a member of package
>> org.apache.flink.api.java.io
>> import org.apache.flink.api.java.io.jdbc.JDBCInputFormat
>>
>> Then, I can't use:
>> [image: Imágenes integradas 1]
>>
>> I tried to download code from git and recompile, also
>>
>>
>
