Modifier and Type | Method and Description |
---|---|
TableSchema |
TableReader.getSchema() |
Modifier and Type | Method and Description |
---|---|
static TableWriter |
TableWriter.create(TableSchema schema,
AlluxioURI uri) |
static TableWriter |
TableWriter.create(TableSchema schema,
AlluxioURI uri,
PartitionInfo partitionInfo) |
Modifier and Type | Class and Description |
---|---|
class |
CsvSchema
CSV table schema in Avro format.
|
Modifier and Type | Method and Description |
---|---|
TableSchema |
CsvReader.getSchema() |
Modifier and Type | Class and Description |
---|---|
class |
OrcSchema
The Orc Schema.
|
Modifier and Type | Method and Description |
---|---|
TableSchema |
OrcReader.getSchema() |
Modifier and Type | Class and Description |
---|---|
class |
ParquetSchema
Parquet table schema in Avro format.
|
Modifier and Type | Method and Description |
---|---|
TableSchema |
ParquetReader.getSchema() |
Modifier and Type | Method and Description |
---|---|
static ParquetWriter |
ParquetWriter.create(TableSchema schema,
AlluxioURI uri)
Creates a Parquet writer.
|
static ParquetWriter |
ParquetWriter.create(TableSchema schema,
AlluxioURI uri,
int rowGroupSize,
boolean enableDictionary)
Creates a Parquet writer specifying a row group size and whether to have dictionary enabled.
|
static ParquetWriter |
ParquetWriter.create(TableSchema schema,
AlluxioURI uri,
int rowGroupSize,
boolean enableDictionary,
String compressionCodec)
Creates a Parquet writer specifying a row group size.
|
static ParquetWriter |
ParquetWriter.create(TableSchema schema,
AlluxioURI uri,
PartitionInfo partitionInfo)
Creates a parquet writer based on the partitionInfo.
|
Modifier and Type | Method and Description |
---|---|
static TablesWriter |
TablesWriter.create(TableSchema schema,
Committer committer,
AlluxioURI outputDir) |
Copyright © 2023. All Rights Reserved.