org.apache.spark.sql.hive.api.java

Class JavaHiveContext

Object

org.apache.spark.sql.api.java.JavaSQLContext

org.apache.spark.sql.hive.api.java.JavaHiveContext

All Implemented Interfaces:

UDFRegistration

public class JavaHiveContext
extends JavaSQLContext

The entry point for executing Spark SQL queries from a Java program.

Constructor Summary

Constructors

Constructor and Description
JavaHiveContext(JavaSparkContext sparkContext)
JavaHiveContext(SQLContext sqlContext)

Method Summary

Methods

Modifier and Type	Method and Description
JavaSchemaRDD	hql(String hqlQuery) DEPRECATED: Use sql(...) Instead
JavaSchemaRDD	sql(String sqlText) Executes a SQL query using Spark, returning the result as a SchemaRDD.

Methods inherited from class org.apache.spark.sql.api.java.JavaSQLContext

applySchema, applySchema, baseRelationToSchemaRDD, createParquetFile, jsonFile, jsonFile, jsonRDD, jsonRDD, parquetFile, registerRDDAsTable, sqlContext

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.api.java.UDFRegistration

registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction, registerFunction

Constructor Detail

JavaHiveContext

public JavaHiveContext(SQLContext sqlContext)

JavaHiveContext

public JavaHiveContext(JavaSparkContext sparkContext)

Method Detail

sql

public JavaSchemaRDD sql(String sqlText)

Description copied from class: JavaSQLContext

Executes a SQL query using Spark, returning the result as a SchemaRDD. The dialect that is used for SQL parsing can be configured with 'spark.sql.dialect'.

Overrides:

sql in class JavaSQLContext

hql

public JavaSchemaRDD hql(String hqlQuery)

DEPRECATED: Use sql(...) Instead