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

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)

Method Summary

Methods

Modifier and Type	Method and Description
JavaSchemaRDD	hql(String hqlQuery) Executes a query expressed in HiveQL, returning the result as a JavaSchemaRDD.
HiveContext	sqlContext()

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

applySchema, createParquetFile, jsonFile, jsonRDD, parquetFile, registerRDDAsTable, sql

Methods inherited from class Object

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

Constructor Detail

JavaHiveContext

public JavaHiveContext(JavaSparkContext sparkContext)

Method Detail

sqlContext

public HiveContext sqlContext()

Overrides:

sqlContext in class JavaSQLContext

hql

public JavaSchemaRDD hql(String hqlQuery)

Executes a query expressed in HiveQL, returning the result as a JavaSchemaRDD.