org.apache.spark.sql.hive.execution

Class HiveScriptIOSchema

Object

org.apache.spark.sql.hive.execution.HiveScriptIOSchema

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.sql.catalyst.plans.logical.ScriptInputOutputSchema, HiveInspectors, scala.Equals, scala.Product

public class HiveScriptIOSchema
extends Object
implements org.apache.spark.sql.catalyst.plans.logical.ScriptInputOutputSchema, HiveInspectors, scala.Product, scala.Serializable

The wrapper class of Hive input and output schema properties

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.sql.hive.HiveInspectors

HiveInspectors.typeInfoConversions

Constructor Summary

Constructors

Constructor and Description
HiveScriptIOSchema(scala.collection.Seq<scala.Tuple2<String,String>> inputRowFormat, scala.collection.Seq<scala.Tuple2<String,String>> outputRowFormat, String inputSerdeClass, String outputSerdeClass, scala.collection.Seq<scala.Tuple2<String,String>> inputSerdeProps, scala.collection.Seq<scala.Tuple2<String,String>> outputSerdeProps, boolean schemaLess)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.immutable.Map<String,String>	defaultFormat()
scala.Tuple2<org.apache.hadoop.hive.serde2.AbstractSerDe,org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector>	initInputSerDe(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> input)
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	initInputSoi(org.apache.hadoop.hive.serde2.AbstractSerDe inputSerde, scala.collection.Seq<String> columns, scala.collection.Seq<DataType> columnTypes)
org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector	initOutputputSoi(org.apache.hadoop.hive.serde2.AbstractSerDe outputSerde)
scala.Tuple2<org.apache.hadoop.hive.serde2.AbstractSerDe,org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector>	initOutputSerDe(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output)
org.apache.hadoop.hive.serde2.AbstractSerDe	initSerDe(String serdeClassName, scala.collection.Seq<String> columns, scala.collection.Seq<DataType> columnTypes, scala.collection.Seq<scala.Tuple2<String,String>> serdeProps)
scala.collection.Seq<scala.Tuple2<String,String>>	inputRowFormat()
scala.collection.immutable.Map<String,String>	inputRowFormatMap()
String	inputSerdeClass()
scala.collection.Seq<scala.Tuple2<String,String>>	inputSerdeProps()
scala.collection.Seq<scala.Tuple2<String,String>>	outputRowFormat()
scala.collection.immutable.Map<String,String>	outputRowFormatMap()
String	outputSerdeClass()
scala.collection.Seq<scala.Tuple2<String,String>>	outputSerdeProps()
scala.Tuple2<scala.collection.Seq<String>,scala.collection.Seq<DataType>>	parseAttrs(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> attrs)
boolean	schemaLess()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.sql.hive.HiveInspectors

inspectorToDataType, javaClassToDataType, toInspector, toInspector, unwrap, wrap, wrap, wrap, wrapperFor

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

HiveScriptIOSchema

public HiveScriptIOSchema(scala.collection.Seq<scala.Tuple2<String,String>> inputRowFormat,
                  scala.collection.Seq<scala.Tuple2<String,String>> outputRowFormat,
                  String inputSerdeClass,
                  String outputSerdeClass,
                  scala.collection.Seq<scala.Tuple2<String,String>> inputSerdeProps,
                  scala.collection.Seq<scala.Tuple2<String,String>> outputSerdeProps,
                  boolean schemaLess)

Method Detail

inputRowFormat

public scala.collection.Seq<scala.Tuple2<String,String>> inputRowFormat()

outputRowFormat

public scala.collection.Seq<scala.Tuple2<String,String>> outputRowFormat()

inputSerdeClass

public String inputSerdeClass()

outputSerdeClass

public String outputSerdeClass()

inputSerdeProps

public scala.collection.Seq<scala.Tuple2<String,String>> inputSerdeProps()

outputSerdeProps

public scala.collection.Seq<scala.Tuple2<String,String>> outputSerdeProps()

schemaLess

public boolean schemaLess()

defaultFormat

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

inputRowFormatMap

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

outputRowFormatMap

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

initInputSerDe

public scala.Tuple2<org.apache.hadoop.hive.serde2.AbstractSerDe,org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector> initInputSerDe(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> input)

initOutputSerDe

public scala.Tuple2<org.apache.hadoop.hive.serde2.AbstractSerDe,org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector> initOutputSerDe(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output)

parseAttrs

public scala.Tuple2<scala.collection.Seq<String>,scala.collection.Seq<DataType>> parseAttrs(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> attrs)

initSerDe

public org.apache.hadoop.hive.serde2.AbstractSerDe initSerDe(String serdeClassName,
                                                    scala.collection.Seq<String> columns,
                                                    scala.collection.Seq<DataType> columnTypes,
                                                    scala.collection.Seq<scala.Tuple2<String,String>> serdeProps)

initInputSoi

public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector initInputSoi(org.apache.hadoop.hive.serde2.AbstractSerDe inputSerde,
                                                                         scala.collection.Seq<String> columns,
                                                                         scala.collection.Seq<DataType> columnTypes)

initOutputputSoi

public org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector initOutputputSoi(org.apache.hadoop.hive.serde2.AbstractSerDe outputSerde)