org.apache.beam.sdk.io.hcatalog.test

Class HCatalogIOTestUtils

java.lang.Object

org.apache.beam.sdk.io.hcatalog.test.HCatalogIOTestUtils

public class HCatalogIOTestUtils
extends java.lang.Object

Utility class for HCatalogIOTest and HCatalogIOIT.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TEST_DATABASE
static java.lang.String	TEST_FILTER
static int	TEST_RECORDS_COUNT
static java.lang.String	TEST_TABLE

Constructor Summary

Constructors

Constructor and Description
HCatalogIOTestUtils()

Method Summary

Modifier and Type	Method and Description
static java.util.List<org.apache.hive.hcatalog.data.HCatRecord>	buildHCatRecords(int size) Returns a list of HCatRecords of passed size.
static java.util.Map<java.lang.String,java.lang.String>	getConfigPropertiesAsMap(org.apache.hadoop.hive.conf.HiveConf hiveConf) Returns config params for the test datastore as a Map.
static java.util.List<java.lang.String>	getExpectedRecords(int count) Returns a list of strings containing 'expected' test data for verification.
static java.util.List<KV<java.lang.String,java.lang.Integer>>	getExpectedRecordsAsKV(int count) Returns a list of KV<String, Integer> containing 'expected' test data for verification.
static org.apache.hive.hcatalog.data.transfer.ReaderContext	getReaderContext(java.util.Map<java.lang.String,java.lang.String> config) Returns a ReaderContext instance for the passed datastore config params.
static void	insertTestData(java.util.Map<java.lang.String,java.lang.String> configMap) Inserts data into test datastore.

Methods inherited from class java.lang.Object

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

Field Detail

TEST_DATABASE

public static final java.lang.String TEST_DATABASE

See Also:

Constant Field Values

TEST_TABLE

public static final java.lang.String TEST_TABLE

See Also:

Constant Field Values

TEST_FILTER

public static final java.lang.String TEST_FILTER

See Also:

Constant Field Values

TEST_RECORDS_COUNT

public static final int TEST_RECORDS_COUNT

See Also:

Constant Field Values

Constructor Detail

HCatalogIOTestUtils

public HCatalogIOTestUtils()

Method Detail

getReaderContext

public static org.apache.hive.hcatalog.data.transfer.ReaderContext getReaderContext(java.util.Map<java.lang.String,java.lang.String> config)
                                                                             throws org.apache.hive.hcatalog.common.HCatException

Returns a ReaderContext instance for the passed datastore config params.

Throws:

org.apache.hive.hcatalog.common.HCatException

getExpectedRecords

public static java.util.List<java.lang.String> getExpectedRecords(int count)

Returns a list of strings containing 'expected' test data for verification.

getExpectedRecordsAsKV

public static java.util.List<KV<java.lang.String,java.lang.Integer>> getExpectedRecordsAsKV(int count)

Returns a list of KV<String, Integer> containing 'expected' test data for verification.

buildHCatRecords

public static java.util.List<org.apache.hive.hcatalog.data.HCatRecord> buildHCatRecords(int size)

Returns a list of HCatRecords of passed size.

insertTestData

public static void insertTestData(java.util.Map<java.lang.String,java.lang.String> configMap)
                           throws java.lang.Exception

Inserts data into test datastore.

Throws:

java.lang.Exception

getConfigPropertiesAsMap

public static java.util.Map<java.lang.String,java.lang.String> getConfigPropertiesAsMap(org.apache.hadoop.hive.conf.HiveConf hiveConf)

Returns config params for the test datastore as a Map.