org.apache.spark.sql.hive

Class HiveContext

Object

org.apache.spark.sql.SQLContext

org.apache.spark.sql.hive.HiveContext

All Implemented Interfaces:

com.typesafe.scalalogging.slf4j.Logging, java.io.Serializable

Direct Known Subclasses:

LocalHiveContext

public class HiveContext
extends SQLContext

An instance of the Spark SQL execution engine that integrates with data stored in Hive. Configuration for Hive is read from hive-site.xml on the classpath.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveContext(SparkContext sc)

Method Summary

Methods

Modifier and Type	Method and Description
<A extends scala.Product> void	createTable(String tableName, boolean allowExisting, scala.reflect.api.TypeTags.TypeTag<A> evidence$1) Creates a table using the schema of the given class.
org.apache.spark.sql.SQLContext.SparkPlanner	hivePlanner()
SchemaRDD	hiveql(String hqlQuery) Executes a query expressed in HiveQL using Spark, returning the result as a SchemaRDD.
SchemaRDD	hql(String hqlQuery) An alias for `hiveql`.

Methods inherited from class org.apache.spark.sql.SQLContext

cacheTable, createParquetFile, createSchemaRDD, logicalPlanToSparkQuery, parquetFile, registerRDDAsTable, sparkContext, sql, table, uncacheTable

Methods inherited from class Object

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

Methods inherited from interface com.typesafe.scalalogging.slf4j.Logging

logger

Constructor Detail

HiveContext

public HiveContext(SparkContext sc)

Method Detail

hiveql

public SchemaRDD hiveql(String hqlQuery)

Executes a query expressed in HiveQL using Spark, returning the result as a SchemaRDD.

hql

public SchemaRDD hql(String hqlQuery)

An alias for `hiveql`.

createTable

public <A extends scala.Product> void createTable(String tableName,
                                         boolean allowExisting,
                                         scala.reflect.api.TypeTags.TypeTag<A> evidence$1)

Creates a table using the schema of the given class.

Parameters:

tableName - The name of the table to create.

allowExisting - When false, an exception will be thrown if the table already exists.

hivePlanner

public org.apache.spark.sql.SQLContext.SparkPlanner hivePlanner()