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) DEPRECATED: Use sql(...) Instead
void	registerFunction(String name, UDF1<?,?> f, DataType dataType)
void	registerFunction(String name, UDF10<?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF11<?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF12<?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF13<?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF14<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF15<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF16<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF17<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF18<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF19<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF2<?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF20<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF21<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF22<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF3<?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF4<?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF5<?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF6<?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF7<?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF8<?,?,?,?,?,?,?,?,?> f, DataType dataType)
void	registerFunction(String name, UDF9<?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
JavaSchemaRDD	sql(String sqlText) Executes a SQL query using Spark, returning the result as a SchemaRDD.
HiveContext	sqlContext()

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

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

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

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

registerFunction

public void registerFunction(String name,
                    UDF1<?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF2<?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF3<?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF4<?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF5<?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF6<?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF7<?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF8<?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF9<?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF10<?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF11<?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF12<?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF13<?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF14<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF15<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF16<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF17<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF18<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF19<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF20<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF21<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)

registerFunction

public void registerFunction(String name,
                    UDF22<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f,
                    DataType dataType)