Package 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 Description AvroWithSparkSchemaVisitor()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
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)
-
primitive
public T primitive(org.apache.spark.sql.types.DataType type, org.apache.avro.Schema primitive)
-
-