ParquetOptions#

public class ParquetOptions extends ColumnFilterOptions#

Options for reading a parquet file.

Field Summary

Method Summary

Static Fields

public static ParquetOptions DEFAULT#

Static Methods

public static ParquetOptions.Builder builder()#
public static class Builder extends ColumnFilterOptions.Builder<Builder>#

Method Summary

build()

includeColumn(Collection<String> names)

Include one or more specific columns.

includeColumn(String name, boolean isBinary)

Include this column.

includeColumn(String... names)

Include one or more specific columns.

withTimeUnit(DType unit)

Specify the time unit to use when returning timestamps.

Methods

public Builder withTimeUnit(DType unit)#

Specify the time unit to use when returning timestamps.

Parameters:

unit – default unit of time specified by the user

Returns:

builder for chaining

public Builder includeColumn(String... names)#

Include one or more specific columns.

Any column not included will not be read.

Parameters:

names – the name of the column, or more than one if you want.

public Builder includeColumn(String name, boolean isBinary)#

Include this column.

Parameters:
  • name – the name of the column

  • isBinary – whether this column is to be read in as binary

public Builder includeColumn(Collection<String> names)#

Include one or more specific columns.

Any column not included will not be read.

Parameters:

names – the name of the column, or more than one if you want.

public ParquetOptions build()#