org.apache.flink.formats.avro

Class AvroToRowDataConverters

java.lang.Object

org.apache.flink.formats.avro.AvroToRowDataConverters

@Internal
public class AvroToRowDataConverters
extends Object

Tool class used to convert from Avro GenericRecord to RowData. *

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AvroToRowDataConverters.AvroToRowDataConverter Runtime converter that converts Avro data structures into objects of Flink Table & SQL internal data structures.

Constructor Summary

Constructors

Constructor and Description
AvroToRowDataConverters()

Method Summary

Modifier and Type	Method and Description
static AvroToRowDataConverters.AvroToRowDataConverter	createRowConverter(org.apache.flink.table.types.logical.RowType rowType)
static AvroToRowDataConverters.AvroToRowDataConverter	createRowConverter(org.apache.flink.table.types.logical.RowType rowType, boolean legacyTimestampMapping)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroToRowDataConverters

public AvroToRowDataConverters()

Method Detail

createRowConverter

public static AvroToRowDataConverters.AvroToRowDataConverter createRowConverter(org.apache.flink.table.types.logical.RowType rowType)

createRowConverter

public static AvroToRowDataConverters.AvroToRowDataConverter createRowConverter(org.apache.flink.table.types.logical.RowType rowType,
                                                                                boolean legacyTimestampMapping)