Class ParquetWithFlinkSchemaVisitor<T>


  • public class ParquetWithFlinkSchemaVisitor<T>
    extends java.lang.Object
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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)