Package org.apache.hadoop.io.erasurecode.coder.util

Class HHUtil

java.lang.Object

org.apache.hadoop.io.erasurecode.coder.util.HHUtil

@Private
public final class HHUtil
extends Object

Some utilities for Hitchhiker coding.

Method Summary

Modifier and Type	Method	Description
static ByteBuffer	allocateByteBuffer(boolean useDirectBuffer, int bufSize)
static <T> T	findFirstValidInput(T[] inputs)	Find the valid input from all the inputs.
static ByteBuffer	getPiggyBackForDecode(ByteBuffer[][] inputs, ByteBuffer[][] outputs, int pbParityIndex, int numDataUnits, int numParityUnits, int pbIndex)
static ByteBuffer[]	getPiggyBacksFromInput(ByteBuffer[] inputs, int[] piggyBackIndex, int numParityUnits, int pgIndex, RawErasureEncoder encoder)
static int[]	initPiggyBackFullIndexVec(int numDataUnits, int[] piggyBackIndex)
static int[]	initPiggyBackIndexWithoutPBVec(int numDataUnits, int numParityUnits)

Methods inherited from class java.lang.Object

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

Method Details

initPiggyBackIndexWithoutPBVec

public static int[] initPiggyBackIndexWithoutPBVec(int numDataUnits,
 int numParityUnits)

initPiggyBackFullIndexVec

public static int[] initPiggyBackFullIndexVec(int numDataUnits,
 int[] piggyBackIndex)

getPiggyBacksFromInput

public static ByteBuffer[] getPiggyBacksFromInput(ByteBuffer[] inputs,
 int[] piggyBackIndex,
 int numParityUnits,
 int pgIndex,
 RawErasureEncoder encoder)
                                           throws IOException

Throws:

IOException

allocateByteBuffer

public static ByteBuffer allocateByteBuffer(boolean useDirectBuffer,
 int bufSize)

getPiggyBackForDecode

public static ByteBuffer getPiggyBackForDecode(ByteBuffer[][] inputs,
 ByteBuffer[][] outputs,
 int pbParityIndex,
 int numDataUnits,
 int numParityUnits,
 int pbIndex)

findFirstValidInput

public static <T> T findFirstValidInput(T[] inputs)

Find the valid input from all the inputs.

Type Parameters:

T - Generics Type T.

Parameters:

inputs - input buffers to look for valid input

Returns:

the first valid input