Saturday, November 12, 2016

Spark 2 - select in dbtable





Dataset tabs = ss.read()
 .format("jdbc")
 .option("url", "jdbc:oracle:thin:@localhost:1521:orcl")
 .option("dbtable", "(select s.owner,t.table_name, s.bytes, s.blocks from sparkdt.segments s, sparkdt.tables t where s.owner=t.owner and s.segment_name=t.table_name) tabisegs")
 .option("user", "sparkdt")
 .option("password", "sparkdt")
 .load();

No comments:

Post a Comment