org.apache.spark.sql.hive.execution

Class HiveOutputWriter

Object

org.apache.spark.sql.execution.datasources.OutputWriter

org.apache.spark.sql.hive.execution.HiveOutputWriter

All Implemented Interfaces:

HiveInspectors

public class HiveOutputWriter
extends org.apache.spark.sql.execution.datasources.OutputWriter
implements HiveInspectors

Nested Class Summary

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

HiveInspectors.typeInfoConversions

Constructor Summary

Constructors

Constructor and Description
HiveOutputWriter(String path, org.apache.spark.sql.hive.HiveShim.ShimFileSinkDesc fileSinkConf, org.apache.hadoop.mapred.JobConf jobConf, StructType dataSchema)

Method Summary

Modifier and Type	Method and Description
void	close()
void	write(org.apache.spark.sql.catalyst.InternalRow row)

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

Constructor Detail

HiveOutputWriter

public HiveOutputWriter(String path,
                        org.apache.spark.sql.hive.HiveShim.ShimFileSinkDesc fileSinkConf,
                        org.apache.hadoop.mapred.JobConf jobConf,
                        StructType dataSchema)

Method Detail

close

public void close()

Specified by:

close in class org.apache.spark.sql.execution.datasources.OutputWriter

write

public void write(org.apache.spark.sql.catalyst.InternalRow row)

Specified by:

write in class org.apache.spark.sql.execution.datasources.OutputWriter