Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
BulkWriter.Factory.create(FSDataOutputStream out)
Creates a writer that writes to the given stream.
|
Modifier and Type | Method and Description |
---|---|
BulkWriter<RowData> |
FileSystemTableSink.ProjectionBulkFactory.create(FSDataOutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
AvroBulkWriter<T>
A simple
BulkWriter implementation that wraps an Avro DataFileWriter . |
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
AvroWriterFactory.create(FSDataOutputStream out) |
Modifier and Type | Method and Description |
---|---|
BulkWriter<IN> |
CompressWriterFactory.create(FSDataOutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopCompressionBulkWriter<T>
A
BulkWriter implementation that writes data that have been compressed using Hadoop
CompressionCodec . |
class |
NoCompressionBulkWriter<T>
A
BulkWriter implementation that does not compress data. |
Modifier and Type | Interface and Description |
---|---|
interface |
HadoopPathBasedBulkWriter<T>
Specialized
BulkWriter which is expected to write to specified Path . |
Modifier and Type | Class and Description |
---|---|
class |
ParquetBulkWriter<T>
A simple
BulkWriter implementation that wraps a ParquetWriter . |
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
ParquetWriterFactory.create(FSDataOutputStream stream) |
Modifier and Type | Class and Description |
---|---|
class |
SequenceFileWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
A
BulkWriter implementation that wraps a SequenceFile.Writer . |
Modifier and Type | Method and Description |
---|---|
BulkWriter<RowData> |
OrcNoHiveBulkWriterFactory.create(FSDataOutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
OrcBulkWriter<T>
A
BulkWriter implementation that writes data in ORC format. |
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
OrcBulkWriterFactory.create(FSDataOutputStream out) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.