org.apache.paimon.format.avro

Class FieldWriterFactory

java.lang.Object

org.apache.paimon.format.avro.FieldWriterFactory

All Implemented Interfaces:

AvroSchemaVisitor<FieldWriter>

public class FieldWriterFactory
extends Object
implements AvroSchemaVisitor<FieldWriter>

Factory to create FieldWriter.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FieldWriterFactory.RowWriter A FieldWriter to write InternalRow.

Constructor Summary

Constructors

Constructor and Description
FieldWriterFactory()

Method Summary

Modifier and Type	Method and Description
FieldWriterFactory.RowWriter	createRowWriter(org.apache.avro.Schema schema, List<DataField> fields)
FieldWriter	visitArray(org.apache.avro.Schema schema, DataType elementType)
FieldWriter	visitArrayMap(org.apache.avro.Schema schema, DataType keyType, DataType valueType)
FieldWriter	visitBigInt()
FieldWriter	visitBoolean()
FieldWriter	visitBytes()
FieldWriter	visitDecimal(Integer precision, Integer scale)
FieldWriter	visitDouble()
FieldWriter	visitFloat()
FieldWriter	visitInt()
FieldWriter	visitMap(org.apache.avro.Schema schema, DataType valueType)
FieldWriter	visitRecord(org.apache.avro.Schema schema, @NotNull List<DataField> fields)
FieldWriter	visitSmallInt()
FieldWriter	visitString()
FieldWriter	visitTimestampMicros(Integer precision)
FieldWriter	visitTimestampMillis(Integer precision)
FieldWriter	visitTinyInt()
FieldWriter	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

FieldWriterFactory

public FieldWriterFactory()

Method Detail

visitUnion

public FieldWriter visitUnion(org.apache.avro.Schema schema,
                              DataType type)

Specified by:

visitUnion in interface AvroSchemaVisitor<FieldWriter>

visitString

public FieldWriter visitString()

Specified by:

visitString in interface AvroSchemaVisitor<FieldWriter>

visitBytes

public FieldWriter visitBytes()

Specified by:

visitBytes in interface AvroSchemaVisitor<FieldWriter>

visitInt

public FieldWriter visitInt()

Specified by:

visitInt in interface AvroSchemaVisitor<FieldWriter>

visitTinyInt

public FieldWriter visitTinyInt()

Specified by:

visitTinyInt in interface AvroSchemaVisitor<FieldWriter>

visitSmallInt

public FieldWriter visitSmallInt()

Specified by:

visitSmallInt in interface AvroSchemaVisitor<FieldWriter>

visitBoolean

public FieldWriter visitBoolean()

Specified by:

visitBoolean in interface AvroSchemaVisitor<FieldWriter>

visitBigInt

public FieldWriter visitBigInt()

Specified by:

visitBigInt in interface AvroSchemaVisitor<FieldWriter>

visitFloat

public FieldWriter visitFloat()

Specified by:

visitFloat in interface AvroSchemaVisitor<FieldWriter>

visitDouble

public FieldWriter visitDouble()

Specified by:

visitDouble in interface AvroSchemaVisitor<FieldWriter>

visitTimestampMillis

public FieldWriter visitTimestampMillis(Integer precision)

Specified by:

visitTimestampMillis in interface AvroSchemaVisitor<FieldWriter>

visitTimestampMicros

public FieldWriter visitTimestampMicros(Integer precision)

Specified by:

visitTimestampMicros in interface AvroSchemaVisitor<FieldWriter>

visitDecimal

public FieldWriter visitDecimal(Integer precision,
                                Integer scale)

Specified by:

visitDecimal in interface AvroSchemaVisitor<FieldWriter>

visitArray

public FieldWriter visitArray(org.apache.avro.Schema schema,
                              DataType elementType)

Specified by:

visitArray in interface AvroSchemaVisitor<FieldWriter>

visitArrayMap

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

Specified by:

visitArrayMap in interface AvroSchemaVisitor<FieldWriter>

visitMap

public FieldWriter visitMap(org.apache.avro.Schema schema,
                            DataType valueType)

Specified by:

visitMap in interface AvroSchemaVisitor<FieldWriter>

visitRecord

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

Specified by:

visitRecord in interface AvroSchemaVisitor<FieldWriter>

createRowWriter

public FieldWriterFactory.RowWriter createRowWriter(org.apache.avro.Schema schema,
                                                    List<DataField> fields)