Package org.apache.iceberg.flink.data

Class ParquetWithFlinkSchemaVisitor<T>

java.lang.Object
org.apache.iceberg.flink.data.ParquetWithFlinkSchemaVisitor<T>
public class ParquetWithFlinkSchemaVisitor<T> extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    ParquetWithFlinkSchemaVisitor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected 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, List<T> fields)
     
    protected String[]
    path(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, 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 Details

    • ParquetWithFlinkSchemaVisitor

      public ParquetWithFlinkSchemaVisitor()

  • Method Details

    • 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, List<T> fields)

    • struct

      public T struct(org.apache.flink.table.types.logical.RowType sStruct, org.apache.parquet.schema.GroupType struct, 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 String[] currentPath()

    • path

      protected String[] path(String name)