org.apache.spark.sql.hive.execution

Class HiveOutputWriter

Object

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

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

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

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

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