org.apache.drill.exec.hive

Class HiveTestUtilities

java.lang.Object

org.apache.drill.exec.hive.HiveTestUtilities

public class HiveTestUtilities
extends Object

Constructor Summary

Constructors

Constructor and Description
HiveTestUtilities()

Method Summary

Modifier and Type	Method and Description
static void	assertNativeScanUsed(QueryBuilder queryBuilder, String table) Helper method used to ensure that native parquet scan will be used for table selection.
static void	assumeJavaVersion() Checks if current version is supported by Hive.
static File	createDirWithPosixPermissions(File parentDir, String dirName) Creates desired directory structure and adds all posix permissions to created directory.
static void	executeQuery(org.apache.hadoop.hive.ql.Driver hiveDriver, String query) Execute the give query on given hiveDriver instance.
static void	insertData(org.apache.hadoop.hive.ql.Driver driver, String srcTable, String destTable) Performs insert from select.
static boolean	isHive3() Checks whether current version is not less than hive 3.0
static void	loadData(org.apache.hadoop.hive.ql.Driver driver, String tableName, Path relativeTestResourcePath) Load data from test resources file into table.
static boolean	supportedJavaVersion() Current Hive version doesn't support JDK 9+.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveTestUtilities

public HiveTestUtilities()

Method Detail

executeQuery

public static void executeQuery(org.apache.hadoop.hive.ql.Driver hiveDriver,
                                String query)

Execute the give query on given hiveDriver instance.

createDirWithPosixPermissions

public static File createDirWithPosixPermissions(File parentDir,
                                                 String dirName)

Creates desired directory structure and adds all posix permissions to created directory.

Parameters:

parentDir - parent directory

dirName - directory name

Returns:

file representing created dir with all posix permissions

loadData

public static void loadData(org.apache.hadoop.hive.ql.Driver driver,
                            String tableName,
                            Path relativeTestResourcePath)

Load data from test resources file into table.

Parameters:

driver - hive driver

tableName - destination

relativeTestResourcePath - path to test resource

insertData

public static void insertData(org.apache.hadoop.hive.ql.Driver driver,
                              String srcTable,
                              String destTable)

Performs insert from select.

Parameters:

driver - hive driver

srcTable - source

destTable - destination

assertNativeScanUsed

public static void assertNativeScanUsed(QueryBuilder queryBuilder,
                                        String table)
                                 throws Exception

Helper method used to ensure that native parquet scan will be used for table selection.

Parameters:

queryBuilder - test query builder

table - table to check

Throws:

Exception - may be thrown while getting query plan

supportedJavaVersion

public static boolean supportedJavaVersion()

Current Hive version doesn't support JDK 9+. Checks if current version is supported by Hive.

Returns:

true if current version is supported by Hive, false otherwise

isHive3

public static boolean isHive3()

Checks whether current version is not less than hive 3.0

assumeJavaVersion

public static void assumeJavaVersion()
                              throws org.junit.AssumptionViolatedException

Checks if current version is supported by Hive.

Throws:

org.junit.AssumptionViolatedException - if current version is not supported by Hive, so unit tests may be skipped.