Hi Mich, No I have not tried that. My requirement is to insert that from an hourly Spark Batch job. How is it different by trying to insert with Hive CLI or beeline?
Thanks, Swetha On Tue, Jun 14, 2016 at 10:44 AM, Mich Talebzadeh <mich.talebza...@gmail.com > wrote: > Hi Swetha, > > Have you actually tried doing this in Hive using Hive CLI or beeline? > > Thanks > > Dr Mich Talebzadeh > > > > LinkedIn * > https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw > <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* > > > > http://talebzadehmich.wordpress.com > > > > On 14 June 2016 at 18:43, Mich Talebzadeh <mich.talebza...@gmail.com> > wrote: > >> In all probability there is no user database created in Hive >> >> Create a database yourself >> >> sql("create if not exists database test") >> >> It would be helpful if you grasp some concept of Hive databases etc? >> >> HTH >> >> >> Dr Mich Talebzadeh >> >> >> >> LinkedIn * >> https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw >> <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* >> >> >> >> http://talebzadehmich.wordpress.com >> >> >> >> On 14 June 2016 at 15:40, Sree Eedupuganti <s...@inndata.in> wrote: >> >>> Hi Spark users, i am new to spark. I am trying to connect hive using >>> SparkJavaContext. Unable to connect to the database. By executing the below >>> code i can see only "default" database. Can anyone help me out. What i need >>> is a sample program for Querying Hive results using SparkJavaContext. Need >>> to pass any values like this. >>> >>> userDF.registerTempTable("userRecordsTemp") >>> >>> sqlContext.sql("SET hive.default.fileformat=Orc ") >>> sqlContext.sql("set hive.enforce.bucketing = true; ") >>> sqlContext.sql("set hive.enforce.sorting = true; ") >>> >>> public static void main(String[] args ) throws Exception { >>> SparkConf sparkConf = new >>> SparkConf().setAppName("SparkSQL").setMaster("local"); >>> SparkContext ctx=new SparkContext(sparkConf); >>> HiveContext hiveql=new >>> org.apache.spark.sql.hive.HiveContext(ctx); >>> DataFrame df=hiveql.sql("show databases"); >>> df.show(); >>> } >>> >>> Any suggestions please....Thanks. >>> >> >> >
