如何自動推斷給定查詢的行類型信息

import org.apache.flink.api.scala._ 
import org.apache.flink.table.api.TableEnvironment 
import org.apache.flink.api.java.io.jdbc.JDBCInputFormat 
import org.apache.flink.api.java.typeutils.RowTypeInfo 
import org.apache.flink.api.common.typeinfo.TypeInformation 

var fieldTypes: Array[TypeInformation[_]] = Array(createTypeInformation[String],createTypeInformation[String],createTypeInformation[String]) 

var fieldNames: Array[String] = Array("UUID", "Name","instanceid") 

val rowTypeInfo = new RowTypeInfo(fieldTypes, fieldNames) 

val inputFormat = JDBCInputFormat.buildJDBCInputFormat().setDrivername("com.vertica.jdbc.Driver").setDBUrl("jdbc:vertica://x.x.x.x:5433/hfdb").setUsername("user").setPassword("password").setQuery("select * from test").setRowTypeInfo(rowTypeInfo).finish() 

val dataset = benv.createInput(inputFormat) 

dataset.print()

所以在上面的代碼中，我們必須指定我們得到的行的類型。有沒有辦法在不設置行類型的情況下獲得答案？如何自動推斷給定查詢的行類型信息

來源

2017-03-17 Naveen Holla

不，這是不可能的。 JDBCInputFormat要求您指定結果類型。

來源

2017-03-21 20:26:07

我得到了解決辦法。我用準備好的語句來獲取給出列類型和列名的列的元數據。 –

如何自動推斷給定查詢的行類型信息

回答

相關問題