org.apache.iceberg.flink.data

Class ParquetWithFlinkSchemaVisitor<T>

java.lang.Object

org.apache.iceberg.flink.data.ParquetWithFlinkSchemaVisitor<T>

public class ParquetWithFlinkSchemaVisitor<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ParquetWithFlinkSchemaVisitor()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String[]	currentPath()
T	list(org.apache.flink.table.types.logical.ArrayType sArray, org.apache.parquet.schema.GroupType array, T element)
T	map(org.apache.flink.table.types.logical.MapType sMap, org.apache.parquet.schema.GroupType map, T key, T value)
T	message(org.apache.flink.table.types.logical.RowType sStruct, org.apache.parquet.schema.MessageType message, java.util.List<T> fields)
protected java.lang.String[]	path(java.lang.String name)
T	primitive(org.apache.flink.table.types.logical.LogicalType sPrimitive, org.apache.parquet.schema.PrimitiveType primitive)
T	struct(org.apache.flink.table.types.logical.RowType sStruct, org.apache.parquet.schema.GroupType struct, java.util.List<T> fields)
static <T> T	visit(org.apache.flink.table.types.logical.LogicalType sType, org.apache.parquet.schema.Type type, ParquetWithFlinkSchemaVisitor<T> visitor)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetWithFlinkSchemaVisitor

public ParquetWithFlinkSchemaVisitor()

Method Detail

visit

public static <T> T visit(org.apache.flink.table.types.logical.LogicalType sType,
                          org.apache.parquet.schema.Type type,
                          ParquetWithFlinkSchemaVisitor<T> visitor)

message

public T message(org.apache.flink.table.types.logical.RowType sStruct,
                 org.apache.parquet.schema.MessageType message,
                 java.util.List<T> fields)

struct

public T struct(org.apache.flink.table.types.logical.RowType sStruct,
                org.apache.parquet.schema.GroupType struct,
                java.util.List<T> fields)

list

public T list(org.apache.flink.table.types.logical.ArrayType sArray,
              org.apache.parquet.schema.GroupType array,
              T element)

map

public T map(org.apache.flink.table.types.logical.MapType sMap,
             org.apache.parquet.schema.GroupType map,
             T key,
             T value)

primitive

public T primitive(org.apache.flink.table.types.logical.LogicalType sPrimitive,
                   org.apache.parquet.schema.PrimitiveType primitive)

currentPath

protected java.lang.String[] currentPath()

path

protected java.lang.String[] path(java.lang.String name)