public class RowConverter extends org.apache.parquet.io.api.GroupConverter implements ParentDataHolder
GroupConverter
to convert an nested Parquet Record into Row.Constructor and Description |
---|
RowConverter(org.apache.parquet.schema.GroupType schema,
TypeInformation<?> typeInfo,
ParentDataHolder parent,
int pos) |
RowConverter(org.apache.parquet.schema.MessageType messageType,
TypeInformation<?> typeInfo) |
Modifier and Type | Method and Description |
---|---|
void |
add(int fieldIndex,
Object object) |
void |
end() |
org.apache.parquet.io.api.Converter |
getConverter(int i) |
Row |
getCurrentRow() |
void |
start() |
public RowConverter(org.apache.parquet.schema.MessageType messageType, TypeInformation<?> typeInfo)
public RowConverter(org.apache.parquet.schema.GroupType schema, TypeInformation<?> typeInfo, ParentDataHolder parent, int pos)
public org.apache.parquet.io.api.Converter getConverter(int i)
getConverter
in class org.apache.parquet.io.api.GroupConverter
public void start()
start
in class org.apache.parquet.io.api.GroupConverter
public Row getCurrentRow()
public void end()
end
in class org.apache.parquet.io.api.GroupConverter
public void add(int fieldIndex, Object object)
add
in interface ParentDataHolder
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.