org.apache.spark.sql.hive

Class HiveShim

Object

org.apache.spark.sql.hive.HiveShim

public class HiveShim
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveShim.HiveFunctionWrapper$

Constructor Summary

Constructors

Constructor and Description
HiveShim()

Method Summary

Modifier and Type	Method and Description
static void	appendReadColumns(org.apache.hadoop.conf.Configuration conf, scala.collection.Seq<Integer> ids, scala.collection.Seq<String> names)
static String	HIVE_GENERIC_UDF_MACRO_CLS()
static org.apache.hadoop.io.Writable	prepareWritable(org.apache.hadoop.io.Writable w, scala.collection.Seq<scala.Tuple2<String,String>> serDeProps)
static Decimal	toCatalystDecimal(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveDecimalObjectInspector hdoi, Object data)
static int	UNLIMITED_DECIMAL_PRECISION()
static int	UNLIMITED_DECIMAL_SCALE()
static org.apache.hadoop.hive.ql.plan.FileSinkDesc	wrapperToFileSinkDesc(org.apache.spark.sql.hive.HiveShim.ShimFileSinkDesc w)

Methods inherited from class Object

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

Constructor Detail

HiveShim

public HiveShim()

Method Detail

UNLIMITED_DECIMAL_PRECISION

public static int UNLIMITED_DECIMAL_PRECISION()

UNLIMITED_DECIMAL_SCALE

public static int UNLIMITED_DECIMAL_SCALE()

HIVE_GENERIC_UDF_MACRO_CLS

public static String HIVE_GENERIC_UDF_MACRO_CLS()

appendReadColumns

public static void appendReadColumns(org.apache.hadoop.conf.Configuration conf,
                                     scala.collection.Seq<Integer> ids,
                                     scala.collection.Seq<String> names)

prepareWritable

public static org.apache.hadoop.io.Writable prepareWritable(org.apache.hadoop.io.Writable w,
                                                            scala.collection.Seq<scala.Tuple2<String,String>> serDeProps)

toCatalystDecimal

public static Decimal toCatalystDecimal(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveDecimalObjectInspector hdoi,
                                        Object data)

wrapperToFileSinkDesc

public static org.apache.hadoop.hive.ql.plan.FileSinkDesc wrapperToFileSinkDesc(org.apache.spark.sql.hive.HiveShim.ShimFileSinkDesc w)