org.apache.spark.sql.hive.execution

Class HiveScriptIOSchema

Object

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

All Implemented Interfaces:

java.io.Serializable, HiveInspectors, scala.Equals, scala.Product

public class HiveScriptIOSchema
extends Object
implements HiveInspectors, scala.Product, scala.Serializable

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, scala.Option<String> inputSerdeClass, scala.Option<String> outputSerdeClass, scala.collection.Seq<scala.Tuple2<String,String>> inputSerdeProps, scala.collection.Seq<scala.Tuple2<String,String>> outputSerdeProps, scala.Option<String> recordReaderClass, scala.Option<String> recordWriterClass, boolean schemaLess)

Method Summary

Modifier and Type	Method and Description
static HiveScriptIOSchema	apply(org.apache.spark.sql.catalyst.plans.logical.ScriptInputOutputSchema input)
scala.Option<scala.Tuple2<org.apache.hadoop.hive.serde2.AbstractSerDe,org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector>>	initInputSerDe(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> input)
scala.Option<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)
scala.collection.Seq<scala.Tuple2<String,String>>	inputRowFormat()
scala.collection.immutable.Map<String,String>	inputRowFormatMap()
scala.Option<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()
scala.Option<String>	outputSerdeClass()
scala.collection.Seq<scala.Tuple2<String,String>>	outputSerdeProps()
scala.Option<org.apache.hadoop.hive.ql.exec.RecordReader>	recordReader(java.io.InputStream inputStream, org.apache.hadoop.conf.Configuration conf)
scala.Option<String>	recordReaderClass()
scala.Option<org.apache.hadoop.hive.ql.exec.RecordWriter>	recordWriter(java.io.OutputStream outputStream, org.apache.hadoop.conf.Configuration conf)
scala.Option<String>	recordWriterClass()
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

decimalTypeInfoToCatalyst, getBinaryWritable, getBinaryWritableConstantObjectInspector, getBooleanWritable, getBooleanWritableConstantObjectInspector, getByteWritable, getByteWritableConstantObjectInspector, getDateWritable, getDateWritableConstantObjectInspector, getDecimalWritable, getDecimalWritableConstantObjectInspector, getDoubleWritable, getDoubleWritableConstantObjectInspector, getFloatWritable, getFloatWritableConstantObjectInspector, getIntWritable, getIntWritableConstantObjectInspector, getLongWritable, getLongWritableConstantObjectInspector, getPrimitiveNullWritableConstantObjectInspector, getShortWritable, getShortWritableConstantObjectInspector, getStringWritable, getStringWritableConstantObjectInspector, getTimestampWritable, getTimestampWritableConstantObjectInspector, inspectorToDataType, isSubClassOf, javaTypeToDataType, toInspector, toInspector, unwrapperFor, unwrapperFor, withNullSafe, wrap, wrap, wrap, wrapperFor

Methods inherited from interface scala.Product

$init$, 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,
                          scala.Option<String> inputSerdeClass,
                          scala.Option<String> outputSerdeClass,
                          scala.collection.Seq<scala.Tuple2<String,String>> inputSerdeProps,
                          scala.collection.Seq<scala.Tuple2<String,String>> outputSerdeProps,
                          scala.Option<String> recordReaderClass,
                          scala.Option<String> recordWriterClass,
                          boolean schemaLess)

Method Detail

apply

public static HiveScriptIOSchema apply(org.apache.spark.sql.catalyst.plans.logical.ScriptInputOutputSchema input)

inputRowFormat

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

outputRowFormat

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

inputSerdeClass

public scala.Option<String> inputSerdeClass()

outputSerdeClass

public scala.Option<String> outputSerdeClass()

inputSerdeProps

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

outputSerdeProps

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

recordReaderClass

public scala.Option<String> recordReaderClass()

recordWriterClass

public scala.Option<String> recordWriterClass()

schemaLess

public boolean schemaLess()

inputRowFormatMap

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

outputRowFormatMap

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

initInputSerDe

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

initOutputSerDe

public scala.Option<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)

recordReader

public scala.Option<org.apache.hadoop.hive.ql.exec.RecordReader> recordReader(java.io.InputStream inputStream,
                                                                              org.apache.hadoop.conf.Configuration conf)

recordWriter

public scala.Option<org.apache.hadoop.hive.ql.exec.RecordWriter> recordWriter(java.io.OutputStream outputStream,
                                                                              org.apache.hadoop.conf.Configuration conf)