org.apache.spark.sql.hive.execution

Class HiveOptions

Object

org.apache.spark.sql.hive.execution.HiveOptions

All Implemented Interfaces:

java.io.Serializable

public class HiveOptions
extends Object
implements scala.Serializable

Options for the Hive data source. Note that rule DetermineHiveSerde will extract Hive serde/format information from these options.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveOptions(org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> parameters)
HiveOptions(scala.collection.immutable.Map<String,String> parameters)

Method Summary

Modifier and Type	Method and Description
boolean	containsDelimiters()
static scala.collection.immutable.Map<String,String>	delimiterOptions()
static String	FILE_FORMAT()
scala.Option<String>	fileFormat()
static scala.Option<scala.Tuple2<String,String>>	getHiveWriteCompression(org.apache.hadoop.hive.ql.plan.TableDesc tableInfo, org.apache.spark.sql.internal.SQLConf sqlConf)
boolean	hasInputOutputFormat()
static String	INPUT_FORMAT()
scala.Option<String>	inputFormat()
static String	OUTPUT_FORMAT()
scala.Option<String>	outputFormat()
scala.Option<String>	serde()
static String	SERDE()
scala.collection.immutable.Map<String,String>	serdeProperties()

Methods inherited from class Object

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

Constructor Detail

HiveOptions

public HiveOptions(org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> parameters)

HiveOptions

public HiveOptions(scala.collection.immutable.Map<String,String> parameters)

Method Detail

FILE_FORMAT

public static String FILE_FORMAT()

INPUT_FORMAT

public static String INPUT_FORMAT()

OUTPUT_FORMAT

public static String OUTPUT_FORMAT()

SERDE

public static String SERDE()

delimiterOptions

public static scala.collection.immutable.Map<String,String> delimiterOptions()

getHiveWriteCompression

public static scala.Option<scala.Tuple2<String,String>> getHiveWriteCompression(org.apache.hadoop.hive.ql.plan.TableDesc tableInfo,
                                                                                org.apache.spark.sql.internal.SQLConf sqlConf)

fileFormat

public scala.Option<String> fileFormat()

inputFormat

public scala.Option<String> inputFormat()

outputFormat

public scala.Option<String> outputFormat()

hasInputOutputFormat

public boolean hasInputOutputFormat()

serde

public scala.Option<String> serde()

containsDelimiters

public boolean containsDelimiters()

serdeProperties

public scala.collection.immutable.Map<String,String> serdeProperties()