Modifier and Type | Method and Description |
---|---|
void |
Compactor.compact(List<TableReader> inputs,
TableWriter output)
Compacts a list of inputs to the output.
|
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 |
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 |
BytesCommitter.shouldCommit(TableWriter writer) |
boolean |
RowsCommitter.shouldCommit(TableWriter writer) |
boolean |
Committer.shouldCommit(TableWriter writer) |
Copyright © 2023. All Rights Reserved.