public class TestHFileOutputFormat
extends java.lang.Object
KeyValueSortReducer
and HFileOutputFormat
.
Sets up and runs a mapreduce job that writes hfile output.
Creates a few inner classes to implement splits and an inputformat that
emits keys and values like those of PerformanceEvaluation
.Constructor and Description |
---|
TestHFileOutputFormat() |
public void test_LATEST_TIMESTAMP_isReplaced() throws java.lang.Exception
HFileOutputFormat
RecordWriter amends timestamps if
passed a keyvalue whose timestamp is HConstants.LATEST_TIMESTAMP
.java.lang.Exception
public void test_TIMERANGE() throws java.lang.Exception
java.lang.Exception
public void testWritingPEData() throws java.lang.Exception
java.lang.Exception
public void testJobConfiguration() throws java.lang.Exception
java.lang.Exception
public void testMRIncrementalLoad() throws java.lang.Exception
java.lang.Exception
public void testMRIncrementalLoadWithSplit() throws java.lang.Exception
java.lang.Exception
public void testSerializeDeserializeFamilyCompressionMap() throws java.io.IOException
HFileOutputFormat.configureCompression(org.apache.hadoop.hbase.client.Table,
Configuration)
and (Configuration)
.
Tests that the compression map is correctly serialized into
and deserialized from configurationjava.io.IOException
public void testSerializeDeserializeFamilyBloomTypeMap() throws java.io.IOException
HFileOutputFormat.configureBloomType(org.apache.hadoop.hbase.client.Table,
Configuration)
and (Configuration)
.
Tests that the compression map is correctly serialized into
and deserialized from configurationjava.io.IOException
public void testSerializeDeserializeFamilyBlockSizeMap() throws java.io.IOException
HFileOutputFormat.configureBlockSize(org.apache.hadoop.hbase.client.Table,
Configuration)
and (Configuration)
.
Tests that the compression map is correctly serialized into
and deserialized from configurationjava.io.IOException
public void testSerializeDeserializeFamilyDataBlockEncodingMap() throws java.io.IOException
HFileOutputFormat.configureDataBlockEncoding(org.apache.hadoop.hbase.client.Table,
Configuration)
and (Configuration)
.
Tests that the compression map is correctly serialized into
and deserialized from configurationjava.io.IOException
public void testColumnFamilySettings() throws java.lang.Exception
HFileOutputFormat
RecordWriter uses compression and
bloom filter settings from the column family descriptorjava.lang.Exception
public void testExcludeAllFromMinorCompaction() throws java.lang.Exception
java.lang.Exception
public void testExcludeMinorCompaction() throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public void manualTest(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception