Package 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 Description ParquetWithFlinkSchemaVisitor()
-
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)
-
-
-
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)
-
-