org.apache.spark.sql.parquet

Class RowWriteSupport

Object

parquet.hadoop.api.WriteSupport<Row>

org.apache.spark.sql.parquet.RowWriteSupport

All Implemented Interfaces:

Logging

Direct Known Subclasses:

MutableRowWriteSupport

public class RowWriteSupport
extends parquet.hadoop.api.WriteSupport<Row>
implements Logging

A parquet.hadoop.api.WriteSupport for Row ojects.

Nested Class Summary

Nested classes/interfaces inherited from class parquet.hadoop.api.WriteSupport

parquet.hadoop.api.WriteSupport.FinalizedWriteContext, parquet.hadoop.api.WriteSupport.WriteContext

Constructor Summary

Constructors

Constructor and Description
RowWriteSupport()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.expressions.Attribute[]	attributes()
static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	getSchema(org.apache.hadoop.conf.Configuration configuration)
parquet.hadoop.api.WriteSupport.WriteContext	init(org.apache.hadoop.conf.Configuration configuration)
void	prepareForWrite(parquet.io.api.RecordConsumer recordConsumer)
static void	setSchema(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> schema, org.apache.hadoop.conf.Configuration configuration)
static String	SPARK_ROW_SCHEMA()
void	write(Row record)
void	writeArray(ArrayType schema, scala.collection.Seq<Object> array)
void	writeDecimal(Decimal decimal, int precision)
void	writeMap(MapType schema, scala.collection.immutable.Map<?,Object> map)
void	writePrimitive(DataType schema, Object value)
parquet.io.api.RecordConsumer	writer()
void	writeStruct(StructType schema, Row struct)
void	writeTimestamp(java.sql.Timestamp ts)
void	writeValue(DataType schema, Object value)

Methods inherited from class parquet.hadoop.api.WriteSupport

finalizeWrite

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

RowWriteSupport

public RowWriteSupport()

Method Detail

SPARK_ROW_SCHEMA

public static String SPARK_ROW_SCHEMA()

getSchema

public static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> getSchema(org.apache.hadoop.conf.Configuration configuration)

setSchema

public static void setSchema(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> schema,
             org.apache.hadoop.conf.Configuration configuration)

writer

public parquet.io.api.RecordConsumer writer()

attributes

public org.apache.spark.sql.catalyst.expressions.Attribute[] attributes()

init

public parquet.hadoop.api.WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)

Specified by:

init in class parquet.hadoop.api.WriteSupport<Row>

prepareForWrite

public void prepareForWrite(parquet.io.api.RecordConsumer recordConsumer)

Specified by:

prepareForWrite in class parquet.hadoop.api.WriteSupport<Row>

write

public void write(Row record)

Specified by:

write in class parquet.hadoop.api.WriteSupport<Row>

writeValue

public void writeValue(DataType schema,
              Object value)

writePrimitive

public void writePrimitive(DataType schema,
                  Object value)

writeStruct

public void writeStruct(StructType schema,
               Row struct)

writeArray

public void writeArray(ArrayType schema,
              scala.collection.Seq<Object> array)

writeMap

public void writeMap(MapType schema,
            scala.collection.immutable.Map<?,Object> map)

writeDecimal

public void writeDecimal(Decimal decimal,
                int precision)

writeTimestamp

public void writeTimestamp(java.sql.Timestamp ts)