Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.common

Class TieredStorageUtils

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.common.TieredStorageUtils

public class TieredStorageUtils
extends Object

Utils for reading from or writing to tiered storage.

Constructor Summary

Constructors

Constructor	Description
TieredStorageUtils()

Method Summary

Modifier and Type	Method	Description
static ByteBuffer[]	generateBufferWithHeaders(List<org.apache.flink.api.java.tuple.Tuple2<Buffer,Integer>> bufferWithIndexes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TieredStorageUtils

public TieredStorageUtils()

Method Detail

generateBufferWithHeaders

public static ByteBuffer[] generateBufferWithHeaders(List<org.apache.flink.api.java.tuple.Tuple2<Buffer,Integer>> bufferWithIndexes)