Package | Description |
---|---|
alluxio.job.transform.compact | |
alluxio.job.transform.format | |
alluxio.job.transform.format.csv | |
alluxio.job.transform.format.parquet | |
alluxio.job.transform.format.tables |
Modifier and Type | Method and Description |
---|---|
void |
SequentialCompactor.compact(List<TableReader> inputs,
TableWriter output) |
void |
Compactor.compact(List<TableReader> inputs,
TableWriter output)
Compacts a list of inputs to the output.
|
void |
HeapCompactor.compact(List<TableReader> inputs,
TableWriter output) |
Modifier and Type | Method and Description |
---|---|
static TableWriter |
TableWriter.create(TableSchema schema,
AlluxioURI uri) |
Modifier and Type | Class and Description |
---|---|
class |
CsvWriter
A writer for writing
CsvRow . |
Modifier and Type | Class and Description |
---|---|
class |
ParquetWriter
A writer for writing
ParquetRow . |
Modifier and Type | Class and Description |
---|---|
class |
TablesWriter
Writes a stream of rows to a list of tables, when
Committer determines that the current
table should be committed/completed, the table file is completed and a new table file is created. |
Modifier and Type | Method and Description |
---|---|
boolean |
RowsCommitter.shouldCommit(TableWriter writer) |
boolean |
Committer.shouldCommit(TableWriter writer) |
boolean |
BytesCommitter.shouldCommit(TableWriter writer) |
Copyright © 2023. All Rights Reserved.