Modifier and Type | Class and Description |
---|---|
class |
AvroWriterFactory<T>
A factory that creates an
AvroBulkWriter . |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
AvroFileSystemFormatFactory.createBulkWriterFactory(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Class and Description |
---|---|
class |
CompressWriterFactory<IN>
A factory that creates for
bulk writers that, when provided with a CompressionCodec , they compress the data they write. |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
CsvFileSystemFormatFactory.createBulkWriterFactory(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
JsonFileSystemFormatFactory.createBulkWriterFactory(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Class and Description |
---|---|
class |
ParquetWriterFactory<T>
A factory that creates a Parquet
BulkWriter . |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
ParquetFileSystemFormatFactory.createBulkWriterFactory(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Class and Description |
---|---|
class |
SequenceFileWriterFactory<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
A factory that creates a SequenceFile
BulkWriter . |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
OrcFileSystemFormatFactory.createBulkWriterFactory(FileSystemFormatFactory.WriterContext context) |
Modifier and Type | Class and Description |
---|---|
class |
OrcNoHiveBulkWriterFactory
A
BulkWriter.Factory from orc no-hive version. |
Modifier and Type | Class and Description |
---|---|
class |
OrcBulkWriterFactory<T>
A factory that creates an ORC
BulkWriter . |
Modifier and Type | Method and Description |
---|---|
static <IN> StreamingFileSink.DefaultBulkFormatBuilder<IN> |
StreamingFileSink.forBulkFormat(Path basePath,
BulkWriter.Factory<IN> writerFactory)
Creates the builder for a
StreamingFileSink with row-encoding format. |
Constructor and Description |
---|
BulkFormatBuilder(Path basePath,
BulkWriter.Factory<IN> writerFactory,
BucketAssigner<IN,BucketID> assigner) |
BulkFormatBuilder(Path basePath,
BulkWriter.Factory<IN> writerFactory,
BucketAssigner<IN,BucketID> assigner,
CheckpointRollingPolicy<IN,BucketID> policy,
long bucketCheckInterval,
BucketFactory<IN,BucketID> bucketFactory,
OutputFileConfig outputFileConfig) |
Modifier and Type | Method and Description |
---|---|
BulkWriter.Factory<RowData> |
HiveShimV200.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes) |
BulkWriter.Factory<RowData> |
HiveShimV100.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes) |
BulkWriter.Factory<RowData> |
HiveShim.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes)
Create orc
BulkWriter.Factory for different hive versions. |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
FileSystemFormatFactory.createBulkWriterFactory(FileSystemFormatFactory.WriterContext context)
Create
BulkWriter.Factory writer. |
Modifier and Type | Class and Description |
---|---|
static class |
FileSystemTableSink.ProjectionBulkFactory
Project row to non-partition fields.
|
Constructor and Description |
---|
ProjectionBulkFactory(BulkWriter.Factory<RowData> factory,
RowDataPartitionComputer computer) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.