org.apache.iceberg.avro

Class AvroSchemaUtil

java.lang.Object

org.apache.iceberg.avro.AvroSchemaUtil

public class AvroSchemaUtil
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ADJUST_TO_UTC_PROP
static java.lang.String	ELEMENT_ID_PROP
static java.lang.String	FIELD_ID_PROP
static java.lang.String	ICEBERG_FIELD_NAME_PROP
static java.lang.String	KEY_ID_PROP
static java.lang.String	VALUE_ID_PROP

Method Summary

Modifier and Type	Method and Description
static org.apache.avro.Schema	buildAvroProjection(org.apache.avro.Schema schema, Schema expected, java.util.Map<java.lang.String,java.lang.String> renames)
static Type	convert(org.apache.avro.Schema schema)
static org.apache.avro.Schema	convert(Schema schema, java.util.Map<Types.StructType,java.lang.String> names)
static org.apache.avro.Schema	convert(Schema schema, java.lang.String tableName)
static org.apache.avro.Schema	convert(Type type)
static org.apache.avro.Schema	convert(Type type, java.util.Map<Types.StructType,java.lang.String> names)
static org.apache.avro.Schema	convert(Types.StructType type, java.lang.String name)
static java.util.Map<Type,org.apache.avro.Schema>	convertTypes(Types.StructType type, java.lang.String name)
static int	getElementId(org.apache.avro.Schema schema)
static int	getFieldId(org.apache.avro.Schema.Field field)
static int	getKeyId(org.apache.avro.Schema schema)
static int	getValueId(org.apache.avro.Schema schema)
static boolean	isTimestamptz(org.apache.avro.Schema schema)
static org.apache.avro.Schema	pruneColumns(org.apache.avro.Schema schema, java.util.Set<java.lang.Integer> selectedIds)

Methods inherited from class java.lang.Object

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

Field Detail

ICEBERG_FIELD_NAME_PROP

public static final java.lang.String ICEBERG_FIELD_NAME_PROP

See Also:

Constant Field Values

FIELD_ID_PROP

public static final java.lang.String FIELD_ID_PROP

See Also:

Constant Field Values

KEY_ID_PROP

public static final java.lang.String KEY_ID_PROP

See Also:

Constant Field Values

VALUE_ID_PROP

public static final java.lang.String VALUE_ID_PROP

See Also:

Constant Field Values

ELEMENT_ID_PROP

public static final java.lang.String ELEMENT_ID_PROP

See Also:

Constant Field Values

ADJUST_TO_UTC_PROP

public static final java.lang.String ADJUST_TO_UTC_PROP

See Also:

Constant Field Values

Method Detail

convert

public static org.apache.avro.Schema convert(Schema schema,
                                             java.lang.String tableName)

convert

public static org.apache.avro.Schema convert(Schema schema,
                                             java.util.Map<Types.StructType,java.lang.String> names)

convert

public static org.apache.avro.Schema convert(Type type)

convert

public static org.apache.avro.Schema convert(Types.StructType type,
                                             java.lang.String name)

convert

public static org.apache.avro.Schema convert(Type type,
                                             java.util.Map<Types.StructType,java.lang.String> names)

convert

public static Type convert(org.apache.avro.Schema schema)

convertTypes

public static java.util.Map<Type,org.apache.avro.Schema> convertTypes(Types.StructType type,
                                                                      java.lang.String name)

pruneColumns

public static org.apache.avro.Schema pruneColumns(org.apache.avro.Schema schema,
                                                  java.util.Set<java.lang.Integer> selectedIds)

buildAvroProjection

public static org.apache.avro.Schema buildAvroProjection(org.apache.avro.Schema schema,
                                                         Schema expected,
                                                         java.util.Map<java.lang.String,java.lang.String> renames)

isTimestamptz

public static boolean isTimestamptz(org.apache.avro.Schema schema)

getKeyId

public static int getKeyId(org.apache.avro.Schema schema)

getValueId

public static int getValueId(org.apache.avro.Schema schema)

getElementId

public static int getElementId(org.apache.avro.Schema schema)

getFieldId

public static int getFieldId(org.apache.avro.Schema.Field field)