Modifier and Type | Method and Description |
---|---|
PartitionInfo |
CompactConfig.getInputPartitionInfo() |
PartitionInfo |
CompactConfig.getOutputPartitionInfo() |
Constructor and Description |
---|
CompactConfig(PartitionInfo inputPartitionInfo,
String input,
PartitionInfo outputPartitionInfo,
String output,
Integer maxNumFiles,
Long minFileSize) |
Modifier and Type | Method and Description |
---|---|
static TableReader |
TableReader.create(AlluxioURI uri,
PartitionInfo pInfo) |
static TableWriter |
TableWriter.create(TableSchema schema,
AlluxioURI uri,
PartitionInfo partitionInfo) |
Modifier and Type | Method and Description |
---|---|
static CsvReader |
CsvReader.create(AlluxioURI uri,
PartitionInfo pInfo)
Creates a CSV reader.
|
Modifier and Type | Method and Description |
---|---|
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 PartitionInfo |
TransformActionUtils.generatePartitionInfo(Layout layout) |
Copyright © 2023. All Rights Reserved.