public class ParquetSchemaConverter extends Object
Modifier and Type | Field and Description |
---|---|
static String |
LIST_ARRAY_TYPE |
static String |
LIST_ELEMENT |
static String |
LIST_GROUP_NAME |
static String |
MAP_VALUE |
static String |
MESSAGE_ROOT |
Constructor and Description |
---|
ParquetSchemaConverter() |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<?> |
convertFields(List<org.apache.parquet.schema.Type> parquetFields) |
static TypeInformation<?> |
convertParquetTypeToTypeInfo(org.apache.parquet.schema.Type fieldType) |
static TypeInformation<?> |
fromParquetType(org.apache.parquet.schema.MessageType type)
Converts Parquet schema to Flink Internal Type.
|
static org.apache.parquet.schema.MessageType |
toParquetType(TypeInformation<?> typeInformation,
boolean legacyMode)
Converts Flink Internal Type to Parquet schema.
|
public static final String MAP_VALUE
public static final String LIST_ARRAY_TYPE
public static final String LIST_ELEMENT
public static final String LIST_GROUP_NAME
public static final String MESSAGE_ROOT
public static TypeInformation<?> fromParquetType(org.apache.parquet.schema.MessageType type)
type
- Parquet schemapublic static org.apache.parquet.schema.MessageType toParquetType(TypeInformation<?> typeInformation, boolean legacyMode)
typeInformation
- Flink type informationlegacyMode
- is standard LIST and MAP schema or back-compatible schemapublic static TypeInformation<?> convertFields(List<org.apache.parquet.schema.Type> parquetFields)
public static TypeInformation<?> convertParquetTypeToTypeInfo(org.apache.parquet.schema.Type fieldType)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.