Package org.apache.iceberg.avro

Class AvroSchemaUtil

java.lang.Object

org.apache.iceberg.avro.AvroSchemaUtil

public class AvroSchemaUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADJUST_TO_UTC_PROP
static final String	ELEMENT_ID_PROP
static final String	FIELD_ID_PROP
static final String	ICEBERG_FIELD_NAME_PROP
static final String	KEY_ID_PROP
static final String	VALUE_ID_PROP

Method Summary

Modifier and Type	Method	Description
static org.apache.avro.Schema	applyNameMapping(org.apache.avro.Schema fileSchema, NameMapping nameMapping)
static org.apache.avro.Schema	buildAvroProjection(org.apache.avro.Schema schema, Schema expected, Map<String,String> renames)
static Type	convert(org.apache.avro.Schema schema)
static org.apache.avro.Schema	convert(Schema schema, String tableName)
static org.apache.avro.Schema	convert(Schema schema, Map<Types.StructType,String> names)
static org.apache.avro.Schema	convert(Type type)
static org.apache.avro.Schema	convert(Type type, BiFunction<Integer,Types.StructType,String> namesFunction)
static org.apache.avro.Schema	convert(Type type, Map<Types.StructType,String> names)
static org.apache.avro.Schema	convert(Types.StructType type, String name)
static Map<Type,org.apache.avro.Schema>	convertTypes(Types.StructType type, 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	hasFieldId(org.apache.avro.Schema.Field field)
static boolean	isKeyValueSchema(org.apache.avro.Schema schema)
static boolean	isOptionSchema(org.apache.avro.Schema schema)
static boolean	isTimestamptz(org.apache.avro.Schema schema)
static String	makeCompatibleName(String name)
static org.apache.avro.Schema	pruneColumns(org.apache.avro.Schema schema, Set<Integer> selectedIds)
static org.apache.avro.Schema	pruneColumns(org.apache.avro.Schema schema, Set<Integer> selectedIds, NameMapping nameMapping)	Deprecated. will be removed in 2.0.0; use applyNameMapping and pruneColumns(Schema, Set) instead.
static Schema	toIceberg(org.apache.avro.Schema schema)

Methods inherited from class java.lang.Object

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

Field Details

ICEBERG_FIELD_NAME_PROP

public static final String ICEBERG_FIELD_NAME_PROP

See Also:

• Constant Field Values

FIELD_ID_PROP

public static final String FIELD_ID_PROP

See Also:

• Constant Field Values

KEY_ID_PROP

public static final String KEY_ID_PROP

See Also:

• Constant Field Values

VALUE_ID_PROP

public static final String VALUE_ID_PROP

See Also:

• Constant Field Values

ELEMENT_ID_PROP

public static final String ELEMENT_ID_PROP

See Also:

• Constant Field Values

ADJUST_TO_UTC_PROP

public static final String ADJUST_TO_UTC_PROP

See Also:

• Constant Field Values

Method Details

convert

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

convert

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

convert

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

convert

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

convert

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

convert

public static org.apache.avro.Schema convert(Type type,
 BiFunction<Integer,Types.StructType,String> namesFunction)

convert

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

toIceberg

public static Schema toIceberg(org.apache.avro.Schema schema)

convertTypes

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

pruneColumns

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

pruneColumns

@Deprecated
public static org.apache.avro.Schema pruneColumns(org.apache.avro.Schema schema,
 Set<Integer> selectedIds,
 NameMapping nameMapping)

Deprecated.

will be removed in 2.0.0; use applyNameMapping and pruneColumns(Schema, Set) instead.

buildAvroProjection

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

applyNameMapping

public static org.apache.avro.Schema applyNameMapping(org.apache.avro.Schema fileSchema,
 NameMapping nameMapping)

isTimestamptz

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

isOptionSchema

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

isKeyValueSchema

public static boolean isKeyValueSchema(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)

hasFieldId

public static boolean hasFieldId(org.apache.avro.Schema.Field field)

makeCompatibleName

public static String makeCompatibleName(String name)