com.northconcepts.datapipeline.parquet

Class ParquetUtil

java.lang.Object

com.northconcepts.datapipeline.parquet.ParquetUtil

public class ParquetUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
ParquetUtil()

Method Summary

Modifier and Type	Method and Description
static String	makeOptionalFieldsRequired(List<ColumnPath> columnPaths, MessageType schema)
static String	makeRequiredFieldsOptional(List<ColumnPath> columnPaths, MessageType schema)
static MessageType	readSchema(File file)
static MessageType	readSchema(Reader reader)
static String	removeSchemaFields(List<ColumnPath> columnPaths, MessageType schema)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetUtil

public ParquetUtil()

Method Detail

readSchema

public static MessageType readSchema(Reader reader)
                              throws IOException

Throws:

IOException

readSchema

public static MessageType readSchema(File file)
                              throws IOException

Throws:

IOException

makeRequiredFieldsOptional

public static String makeRequiredFieldsOptional(List<ColumnPath> columnPaths,
                                                MessageType schema)

makeOptionalFieldsRequired

public static String makeOptionalFieldsRequired(List<ColumnPath> columnPaths,
                                                MessageType schema)

removeSchemaFields

public static String removeSchemaFields(List<ColumnPath> columnPaths,
                                        MessageType schema)