org.apache.spark.sql.hive

Class HiveShim

java.lang.Object

org.apache.spark.sql.hive.HiveShim

public class HiveShim
extends java.lang.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

Methods

Modifier and Type	Method and Description
static void	appendReadColumns(org.apache.hadoop.conf.Configuration conf, scala.collection.Seq<java.lang.Integer> ids, scala.collection.Seq<java.lang.String> names)
static java.lang.String	HIVE_GENERIC_UDF_MACRO_CLS()
static org.apache.hadoop.io.Writable	prepareWritable(org.apache.hadoop.io.Writable w, scala.collection.Seq<scala.Tuple2<java.lang.String,java.lang.String>> serDeProps)
static Decimal	toCatalystDecimal(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveDecimalObjectInspector hdoi, java.lang.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 java.lang.Object

clone, equals, finalize, 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 java.lang.String HIVE_GENERIC_UDF_MACRO_CLS()

appendReadColumns

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

prepareWritable

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

toCatalystDecimal

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

wrapperToFileSinkDesc

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