Modifier and Type | Class and Description |
---|---|
class |
SimpleStringEncoder<IN>
A simple
Encoder that uses toString() on the input elements and writes them to
the output bucket file separated by newline. |
Modifier and Type | Method and Description |
---|---|
Optional<Encoder<RowData>> |
AvroFileSystemFormatFactory.createEncoder(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Method and Description |
---|---|
Optional<Encoder<RowData>> |
CsvFileSystemFormatFactory.createEncoder(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Class and Description |
---|---|
static class |
JsonFileSystemFormatFactory.JsonRowDataEncoder
A
JsonFileSystemFormatFactory.JsonRowDataEncoder is responsible to encode a RowData to OutputStream with json format. |
Modifier and Type | Method and Description |
---|---|
Optional<Encoder<RowData>> |
JsonFileSystemFormatFactory.createEncoder(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Method and Description |
---|---|
Optional<Encoder<RowData>> |
ParquetFileSystemFormatFactory.createEncoder(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Method and Description |
---|---|
Optional<Encoder<RowData>> |
OrcFileSystemFormatFactory.createEncoder(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Method and Description |
---|---|
static <IN> StreamingFileSink.DefaultRowFormatBuilder<IN> |
StreamingFileSink.forRowFormat(Path basePath,
Encoder<IN> encoder)
Creates the builder for a
StreamingFileSink with row-encoding format. |
Constructor and Description |
---|
RowFormatBuilder(Path basePath,
Encoder<IN> encoder,
BucketAssigner<IN,BucketID> bucketAssigner) |
RowFormatBuilder(Path basePath,
Encoder<IN> encoder,
BucketAssigner<IN,BucketID> assigner,
RollingPolicy<IN,BucketID> policy,
long bucketCheckInterval,
BucketFactory<IN,BucketID> bucketFactory,
OutputFileConfig outputFileConfig) |
Modifier and Type | Method and Description |
---|---|
Optional<Encoder<RowData>> |
FileSystemFormatFactory.createEncoder(FileSystemFormatFactory.WriterContext context)
Create
Encoder writer. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.