org.apache.paimon.format.avro

Class FieldReaderFactory

java.lang.Object

org.apache.paimon.format.avro.FieldReaderFactory

All Implemented Interfaces:

AvroSchemaVisitor<FieldReader>

public class FieldReaderFactory
extends Object
implements AvroSchemaVisitor<FieldReader>

Factory to create FieldReader.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FieldReaderFactory.RowReader A FieldReader to read InternalRow.

Constructor Summary

Constructors

Constructor and Description
FieldReaderFactory()

Method Summary

Modifier and Type	Method and Description
FieldReaderFactory.RowReader	createRowReader(org.apache.avro.Schema schema, List<DataField> fields)
FieldReader	visitArray(org.apache.avro.Schema schema, DataType elementType)
FieldReader	visitArrayMap(org.apache.avro.Schema schema, DataType keyType, DataType valueType)
FieldReader	visitBigInt()
FieldReader	visitBoolean()
FieldReader	visitBytes()
FieldReader	visitDecimal(Integer precision, Integer scale)
FieldReader	visitDouble()
FieldReader	visitFloat()
FieldReader	visitInt()
FieldReader	visitMap(org.apache.avro.Schema schema, DataType valueType)
FieldReader	visitRecord(org.apache.avro.Schema schema, @NotNull List<DataField> fields)
FieldReader	visitSmallInt()
FieldReader	visitString()
FieldReader	visitTimestampMicros(Integer precision)
FieldReader	visitTimestampMillis(Integer precision)
FieldReader	visitTinyInt()
FieldReader	visitUnion(org.apache.avro.Schema schema, DataType type)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.format.avro.AvroSchemaVisitor

primitive, visit

Constructor Detail

FieldReaderFactory

public FieldReaderFactory()

Method Detail

visitUnion

public FieldReader visitUnion(org.apache.avro.Schema schema,
                              @Nullable
                              DataType type)

Specified by:

visitUnion in interface AvroSchemaVisitor<FieldReader>

visitString

public FieldReader visitString()

Specified by:

visitString in interface AvroSchemaVisitor<FieldReader>

visitBytes

public FieldReader visitBytes()

Specified by:

visitBytes in interface AvroSchemaVisitor<FieldReader>

visitInt

public FieldReader visitInt()

Specified by:

visitInt in interface AvroSchemaVisitor<FieldReader>

visitTinyInt

public FieldReader visitTinyInt()

Specified by:

visitTinyInt in interface AvroSchemaVisitor<FieldReader>

visitSmallInt

public FieldReader visitSmallInt()

Specified by:

visitSmallInt in interface AvroSchemaVisitor<FieldReader>

visitBoolean

public FieldReader visitBoolean()

Specified by:

visitBoolean in interface AvroSchemaVisitor<FieldReader>

visitBigInt

public FieldReader visitBigInt()

Specified by:

visitBigInt in interface AvroSchemaVisitor<FieldReader>

visitFloat

public FieldReader visitFloat()

Specified by:

visitFloat in interface AvroSchemaVisitor<FieldReader>

visitDouble

public FieldReader visitDouble()

Specified by:

visitDouble in interface AvroSchemaVisitor<FieldReader>

visitTimestampMillis

public FieldReader visitTimestampMillis(@Nullable
                                        Integer precision)

Specified by:

visitTimestampMillis in interface AvroSchemaVisitor<FieldReader>

visitTimestampMicros

public FieldReader visitTimestampMicros(@Nullable
                                        Integer precision)

Specified by:

visitTimestampMicros in interface AvroSchemaVisitor<FieldReader>

visitDecimal

public FieldReader visitDecimal(@Nullable
                                Integer precision,
                                @Nullable
                                Integer scale)

Specified by:

visitDecimal in interface AvroSchemaVisitor<FieldReader>

visitArray

public FieldReader visitArray(org.apache.avro.Schema schema,
                              @Nullable
                              DataType elementType)

Specified by:

visitArray in interface AvroSchemaVisitor<FieldReader>

visitArrayMap

public FieldReader visitArrayMap(org.apache.avro.Schema schema,
                                 DataType keyType,
                                 DataType valueType)

Specified by:

visitArrayMap in interface AvroSchemaVisitor<FieldReader>

visitMap

public FieldReader visitMap(org.apache.avro.Schema schema,
                            @Nullable
                            DataType valueType)

Specified by:

visitMap in interface AvroSchemaVisitor<FieldReader>

visitRecord

public FieldReader visitRecord(org.apache.avro.Schema schema,
                               @NotNull
                               @NotNull List<DataField> fields)

Specified by:

visitRecord in interface AvroSchemaVisitor<FieldReader>

createRowReader

public FieldReaderFactory.RowReader createRowReader(org.apache.avro.Schema schema,
                                                    List<DataField> fields)