Package org.apache.iceberg.spark.data
Class SparkAvroWriter
- java.lang.Object
-
- org.apache.iceberg.spark.data.SparkAvroWriter
-
- All Implemented Interfaces:
org.apache.avro.io.DatumWriter<org.apache.spark.sql.catalyst.InternalRow>
public class SparkAvroWriter extends java.lang.Object implements org.apache.avro.io.DatumWriter<org.apache.spark.sql.catalyst.InternalRow>
-
-
Constructor Summary
Constructors Constructor Description SparkAvroWriter(org.apache.spark.sql.types.StructType dsSchema)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
setSchema(org.apache.avro.Schema schema)
void
write(org.apache.spark.sql.catalyst.InternalRow datum, org.apache.avro.io.Encoder out)
-
-
-
Method Detail
-
setSchema
public void setSchema(org.apache.avro.Schema schema)
- Specified by:
setSchema
in interfaceorg.apache.avro.io.DatumWriter<org.apache.spark.sql.catalyst.InternalRow>
-
write
public void write(org.apache.spark.sql.catalyst.InternalRow datum, org.apache.avro.io.Encoder out) throws java.io.IOException
- Specified by:
write
in interfaceorg.apache.avro.io.DatumWriter<org.apache.spark.sql.catalyst.InternalRow>
- Throws:
java.io.IOException
-
-