Modifier and Type | Method and Description |
---|---|
PositionOutputStream |
FlinkFileIO.newOutputStream(Path path,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
FormatWriter |
FormatWriterFactory.create(PositionOutputStream out,
String compression)
Creates a writer that writes to the given stream.
|
Modifier and Type | Method and Description |
---|---|
AvroBulkWriter<T> |
AvroWriterFactory.create(PositionOutputStream out,
String compression) |
Modifier and Type | Method and Description |
---|---|
FormatWriter |
OrcWriterFactory.create(PositionOutputStream out,
String compression) |
Constructor and Description |
---|
OrcBulkWriter(Vectorizer<InternalRow> vectorizer,
org.apache.orc.Writer writer,
PositionOutputStream underlyingStream,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
FormatWriter |
ParquetWriterFactory.create(PositionOutputStream stream,
String compression) |
Constructor and Description |
---|
StreamOutputFile(PositionOutputStream stream)
Creates a new StreamOutputFile.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncPositionOutputStream
A
PositionOutputStream which uses a async thread to write data. |
class |
PositionOutputStreamWrapper
Wrap a
PositionOutputStream . |
Modifier and Type | Field and Description |
---|---|
protected PositionOutputStream |
PositionOutputStreamWrapper.out |
Modifier and Type | Method and Description |
---|---|
PositionOutputStream |
PluginFileIO.newOutputStream(Path path,
boolean overwrite) |
PositionOutputStream |
FileIO.newOutputStream(Path path,
boolean overwrite)
Opens an PositionOutputStream at the indicated Path.
|
Constructor and Description |
---|
AsyncPositionOutputStream(PositionOutputStream out) |
PositionOutputStreamWrapper(PositionOutputStream out) |
Modifier and Type | Method and Description |
---|---|
PositionOutputStream |
HadoopFileIO.newOutputStream(Path path,
boolean overwrite) |
Modifier and Type | Class and Description |
---|---|
static class |
LocalFileIO.LocalPositionOutputStream
Local
PositionOutputStream . |
Modifier and Type | Method and Description |
---|---|
PositionOutputStream |
LocalFileIO.newOutputStream(Path path,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
PositionOutputStream |
HadoopCompliantFileIO.newOutputStream(Path path,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
PositionOutputStream |
HadoopCompliantFileIO.newOutputStream(Path path,
boolean overwrite) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.