Package | Description |
---|---|
org.apache.flink.table.runtime.io | |
org.apache.flink.table.runtime.util |
Modifier and Type | Class and Description |
---|---|
class |
CompressedHeaderlessChannelWriterOutputView
A
DataOutputView that is backed by a FileIOChannel ,
making it effectively a data output stream. |
class |
HeaderlessChannelWriterOutputView
A
DataOutputView that is backed by a BlockChannelWriter , making it effectively a data output stream. |
Modifier and Type | Method and Description |
---|---|
static AbstractChannelWriterOutputView |
FileChannelUtil.createOutputView(IOManager ioManager,
FileIOChannel.ID channel,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize,
int segmentSize) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.