Java 类org.apache.hadoop.io.erasurecode.rawcoder.RSRawErasureCoderFactory 实例源码

项目：hadoop-oss 文件：TestHHXORErasureCoder.java

@Test
public void testCodingDirectBufferWithConf_10x4_erasing_d0() {
  /**
   * This tests if the configuration items work or not.
   */
  Configuration conf = new Configuration();
  conf.set(CommonConfigurationKeys.IO_ERASURECODE_CODEC_RS_RAWCODER_KEY,
      RSRawErasureCoderFactory.class.getCanonicalName());
  prepare(conf, 10, 4, new int[]{0}, new int[0]);

  testCoding(true);
  testCoding(true);
}

项目：hadoop-oss 文件：TestRSErasureCoder.java

@Test
public void testCodingDirectBufferWithConf_10x4_erasing_d0() {
  /**
   * This tests if the configuration items work or not.
   */
  Configuration conf = new Configuration();
  conf.set(CommonConfigurationKeys.IO_ERASURECODE_CODEC_RS_RAWCODER_KEY,
      RSRawErasureCoderFactory.class.getCanonicalName());
  prepare(conf, 10, 4, new int[]{0}, new int[0]);

  testCoding(true);
  testCoding(true);
}

项目：aliyun-oss-hadoop-fs 文件：TestRSErasureCoder.java

@Test
public void testCodingDirectBufferWithConf_10x4_erasing_d0() {
  /**
   * This tests if the configuration items work or not.
   */
  Configuration conf = new Configuration();
  conf.set(CommonConfigurationKeys.IO_ERASURECODE_CODEC_RS_RAWCODER_KEY,
      RSRawErasureCoderFactory.class.getCanonicalName());
  prepare(conf, 10, 4, new int[]{0}, new int[0]);

  testCoding(true);
  testCoding(true);
}

项目：hops 文件：TestHHXORErasureCoder.java

@Test
public void testCodingDirectBufferWithConf_10x4_erasing_d0() {
  /**
   * This tests if the configuration items work or not.
   */
  Configuration conf = new Configuration();
  conf.set(CommonConfigurationKeys.IO_ERASURECODE_CODEC_RS_DEFAULT_RAWCODER_KEY,
      RSRawErasureCoderFactory.class.getCanonicalName());
  prepare(conf, 10, 4, new int[]{0}, new int[0]);

  testCoding(true);
  testCoding(true);
}

项目：hops 文件：TestRSErasureCoder.java

@Test
public void testCodingDirectBufferWithConf_10x4_erasing_d0() {
  /**
   * This tests if the configuration items work or not.
   */
  Configuration conf = new Configuration();
  conf.set(CommonConfigurationKeys.IO_ERASURECODE_CODEC_RS_DEFAULT_RAWCODER_KEY,
      RSRawErasureCoderFactory.class.getCanonicalName());
  prepare(conf, 10, 4, new int[]{0}, new int[0]);

  testCoding(true);
  testCoding(true);
}