public class JavaHiveContext extends JavaSQLContext
Constructor and Description |
---|
JavaHiveContext(JavaSparkContext sparkContext) |
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() |
applySchema, applySchema, createParquetFile, jsonFile, jsonFile, jsonRDD, jsonRDD, parquetFile, registerRDDAsTable
public JavaHiveContext(JavaSparkContext sparkContext)
public HiveContext sqlContext()
sqlContext
in class JavaSQLContext
public JavaSchemaRDD sql(String sqlText)
JavaSQLContext
sql
in class JavaSQLContext
public JavaSchemaRDD hql(String hqlQuery)
public void registerFunction(String name, UDF6<?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF7<?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF8<?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF9<?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF10<?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF11<?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF12<?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF13<?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF14<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF15<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF16<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF17<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF18<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF19<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF20<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)
public void registerFunction(String name, UDF21<?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?> f, DataType dataType)