public abstract class oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder extends oadd.org.apache.hadoop.conf.Configured implements oadd.org.apache.hadoop.io.erasurecode.coder.ErasureCoder
{
private final int numDataUnits;
private final int numParityUnits;
private final oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions options;
public void <init>(oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions)
{
int v, v;
oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configured: void <init>()>();
v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions options> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions: int getNumDataUnits()>();
v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: int numDataUnits> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions: int getNumParityUnits()>();
v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: int numParityUnits> = v;
return;
}
public oadd.org.apache.hadoop.io.erasurecode.coder.ErasureCodingStep calculateCoding(oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup)
{
oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureCodingStep v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureCodingStep prepareEncodingStep(oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup)>(v);
return v;
}
public int getNumDataUnits()
{
int v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v = v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: int numDataUnits>;
return v;
}
public int getNumParityUnits()
{
int v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v = v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: int numParityUnits>;
return v;
}
public oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions getOptions()
{
oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v = v.<oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder: oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions options>;
return v;
}
protected oadd.org.apache.hadoop.io.erasurecode.ECBlock[] getInputBlocks(oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup)
{
oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup v;
oadd.org.apache.hadoop.io.erasurecode.ECBlock[] v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup: oadd.org.apache.hadoop.io.erasurecode.ECBlock[] getDataBlocks()>();
return v;
}
protected oadd.org.apache.hadoop.io.erasurecode.ECBlock[] getOutputBlocks(oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup)
{
oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup v;
oadd.org.apache.hadoop.io.erasurecode.ECBlock[] v;
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup: oadd.org.apache.hadoop.io.erasurecode.ECBlock[] getParityBlocks()>();
return v;
}
public boolean preferDirectBuffer()
{
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
return 0;
}
public void release()
{
oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.coder.ErasureEncoder;
return;
}
protected abstract oadd.org.apache.hadoop.io.erasurecode.coder.ErasureCodingStep prepareEncodingStep(oadd.org.apache.hadoop.io.erasurecode.ECBlockGroup);
}