org.apache.iceberg.spark.data

Class AvroWithSparkSchemaVisitor<T>

java.lang.Object

org.apache.iceberg.spark.data.AvroWithSparkSchemaVisitor<T>

public abstract class AvroWithSparkSchemaVisitor<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
AvroWithSparkSchemaVisitor()

Method Summary

Modifier and Type	Method and Description
T	array(org.apache.spark.sql.types.ArrayType sArray, org.apache.avro.Schema array, T element)
T	map(org.apache.spark.sql.types.MapType sMap, org.apache.avro.Schema map, T value)
T	map(org.apache.spark.sql.types.MapType sMap, org.apache.avro.Schema map, T key, T value)
T	primitive(org.apache.spark.sql.types.DataType type, org.apache.avro.Schema primitive)
T	record(org.apache.spark.sql.types.StructType struct, org.apache.avro.Schema record, java.util.List<java.lang.String> names, java.util.List<T> fields)
T	union(org.apache.spark.sql.types.DataType type, org.apache.avro.Schema union, java.util.List<T> options)
static <T> T	visit(org.apache.spark.sql.types.DataType type, org.apache.avro.Schema schema, AvroWithSparkSchemaVisitor<T> visitor)
static <T> T	visit(org.apache.spark.sql.types.StructType struct, org.apache.avro.Schema schema, AvroWithSparkSchemaVisitor<T> visitor)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroWithSparkSchemaVisitor

public AvroWithSparkSchemaVisitor()

Method Detail

visit

public static <T> T visit(org.apache.spark.sql.types.StructType struct,
                          org.apache.avro.Schema schema,
                          AvroWithSparkSchemaVisitor<T> visitor)

visit

public static <T> T visit(org.apache.spark.sql.types.DataType type,
                          org.apache.avro.Schema schema,
                          AvroWithSparkSchemaVisitor<T> visitor)

record

public T record(org.apache.spark.sql.types.StructType struct,
                org.apache.avro.Schema record,
                java.util.List<java.lang.String> names,
                java.util.List<T> fields)

union

public T union(org.apache.spark.sql.types.DataType type,
               org.apache.avro.Schema union,
               java.util.List<T> options)

array

public T array(org.apache.spark.sql.types.ArrayType sArray,
               org.apache.avro.Schema array,
               T element)

map

public T map(org.apache.spark.sql.types.MapType sMap,
             org.apache.avro.Schema map,
             T key,
             T value)

map

public T map(org.apache.spark.sql.types.MapType sMap,
             org.apache.avro.Schema map,
             T value)

primitive

public T primitive(org.apache.spark.sql.types.DataType type,
                   org.apache.avro.Schema primitive)