Re: Spark Select Statement

2016-05-04 Thread Mich Talebzadeh
which database is that table, a Hive database? Dr Mich Talebzadeh LinkedIn * https://www.linkedin.com/profile/view?id=AAEWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw * http://talebzadehmich.wordpress.com On 4 May

Re: Spark Select Statement

2016-05-04 Thread Ted Yu
Please take a look at sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java : } else if (key.startsWith("use:")) { SessionState.get().setCurrentDatabase(entry.getValue()); bq. no such table winbox_prod_action_logs_1 The above doesn't match

Spark Select Statement

2016-05-04 Thread Sree Eedupuganti
Hello Spark users, can we query the SQL SELECT statement in Spark using Java. if it is possible any suggestions please. I tried like this.How to pass the database name. Here my database name is nimbus and table name is winbox_opens. *Source Code :* *public class Select { public static class