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 |
---|---|
static <IN> FileSink.DefaultRowFormatBuilder<IN> |
FileSink.forRowFormat(Path basePath,
Encoder<IN> encoder) |
Constructor and Description |
---|
RowFormatBuilder(Path basePath,
Encoder<IN> encoder,
BucketAssigner<IN,String> bucketAssigner) |
RowFormatBuilder(Path basePath,
long bucketCheckInterval,
Encoder<IN> encoder,
BucketAssigner<IN,String> assigner,
RollingPolicy<IN,String> policy,
FileWriterBucketFactory<IN> bucketFactory,
OutputFileConfig outputFileConfig) |
Modifier and Type | Class and Description |
---|---|
class |
SerializationSchemaAdapter
Adapter to turn a
SerializationSchema into a Encoder . |
Modifier and Type | Method and Description |
---|---|
static <IN> StreamingFileSink.DefaultRowFormatBuilder<IN> |
StreamingFileSink.forRowFormat(Path basePath,
Encoder<IN> encoder)
Deprecated.
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) |
RowWiseBucketWriter(RecoverableWriter recoverableWriter,
Encoder<IN> encoder) |
RowWisePartWriter(BucketID bucketId,
Path path,
RecoverableFsDataOutputStream currentPartStream,
Encoder<IN> encoder,
long creationTime) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.