org.apache.drill.exec.impersonation

Class BaseTestImpersonation

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.test.BaseTestQuery

org.apache.drill.PlanTestBase

org.apache.drill.exec.impersonation.BaseTestImpersonation

Direct Known Subclasses:

BaseTestHiveImpersonation, TestImpersonationDisabledWithMiniDFS, TestImpersonationMetadata, TestImpersonationQueries, TestInboundImpersonation, TestInboundImpersonationPrivileges

public class BaseTestImpersonation
extends PlanTestBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.test.BaseTestQuery

BaseTestQuery.ClassicTestServices, BaseTestQuery.SilentListener, BaseTestQuery.TestResultSet

Nested classes/interfaces inherited from class org.apache.drill.test.DrillTest

DrillTest.MemWatcher

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.hadoop.hdfs.MiniDFSCluster	dfsCluster
protected static org.apache.hadoop.conf.Configuration	dfsConf
protected static org.apache.hadoop.fs.FileSystem	fs
protected static String	MINI_DFS_STORAGE_PLUGIN_NAME
protected static File	miniDfsStoragePath
protected static String[]	org1Groups
protected static String[]	org1Users
protected static String[]	org2Groups
protected static String[]	org2Users
protected static String	processUser

Fields inherited from class org.apache.drill.PlanTestBase

EXPECTED_NOT_FOUND, JSON_FORMAT, OPTIQ_FORMAT, UNEXPECTED_FOUND

Fields inherited from class org.apache.drill.test.BaseTestQuery

allocator, bits, client, config, serviceSet

Fields inherited from class org.apache.drill.exec.ExecTest

c, dirTestWatcher, optionManager

Fields inherited from class org.apache.drill.test.DrillTest

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
BaseTestImpersonation()

Method Summary

Modifier and Type	Method and Description
protected static void	addMiniDfsBasedStorage(Map<String,WorkspaceConfig> workspaces)
protected static void	createAndAddWorkspace(String name, String path, short permissions, String owner, String group, Map<String,WorkspaceConfig> workspaces)
protected static void	createView(String viewOwner, String viewGroup, short viewPerms, String newViewName, String fromSourceSchema, String fromSourceTableName)
protected static void	createView(String viewOwner, String viewGroup, String viewName, String viewDef)
protected static String	getUserHome(String user)
protected static String	getWSSchema(String user)
protected static void	startDrillCluster(boolean isImpersonationEnabled)
protected static void	startDrillCluster(Properties props)
protected static void	startMiniDfsCluster(String testClass) Start a MiniDFS cluster backed Drillbit cluster with impersonation enabled.
protected static void	startMiniDfsCluster(String testClass, boolean isImpersonationEnabled) Start a MiniDFS cluster backed Drillbit cluster
protected static void	stopMiniDfsCluster()

Methods inherited from class org.apache.drill.PlanTestBase

checkForMetadataFile, createMetadataDir, getPhysicalJsonPlan, getPlanInString, testPhysicalPlan, testPhysicalPlanExecutionBasedOnQuery, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanOneExcludedPattern, testPlanOneExpectedPattern, testPlanOneExpectedPatternOneExcluded, testPlanSubstrPatterns, testPlanWithAttributesMatchingPatterns, testRelLogicalJoinOrder, testRelLogicalPlanLevDigest, testRelLogicalPlanLevExplain, testRelPhysicalJoinOrder, testRelPhysicalPlanLevDigest, testRelPhysicalPlanLevExplain

Methods inherited from class org.apache.drill.test.BaseTestQuery

alterSession, cloneDefaultTestConfigProperties, closeClient, errorMsgTestHelper, getAllocator, getDrillbitContext, getFile, getPhysicalFileFromResource, getResultString, getUserPort, logResult, newTest, parseErrorHelper, printResult, resetAllSessionOptions, resetDrillbitCount, resetSessionOption, runSQL, setColumnWidth, setColumnWidths, setSessionOption, setSessionOption, setSessionOption, setSessionOption, setupDefaultTestCluster, test, test, testBuilder, testLogicalWithResults, testNoResult, testNoResult, testPhysical, testPhysicalFromFile, testPhysicalWithResults, testPreparedStatement, testRunAndPrint, testRunAndReturn, testSql, testSqlWithResults, testWithListener, updateClient, updateClient, updateClient, updateTestCluster, updateTestCluster

Methods inherited from class org.apache.drill.exec.ExecTest

clear, getLocalFileSystem, mockDrillbitContext, mockUsDateFormatSymbols, mockUtcDateTimeZone, parseExpr, setupOptionManager

Methods inherited from class org.apache.drill.test.DrillTest

escapeJsonString, finishDrillTest, initDrillTest

Methods inherited from class java.lang.Object

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

Field Detail

MINI_DFS_STORAGE_PLUGIN_NAME

protected static final String MINI_DFS_STORAGE_PLUGIN_NAME

See Also:

Constant Field Values

processUser

protected static final String processUser

dfsCluster

protected static org.apache.hadoop.hdfs.MiniDFSCluster dfsCluster

dfsConf

protected static org.apache.hadoop.conf.Configuration dfsConf

fs

protected static org.apache.hadoop.fs.FileSystem fs

miniDfsStoragePath

protected static File miniDfsStoragePath

org1Users

protected static final String[] org1Users

org1Groups

protected static final String[] org1Groups

org2Users

protected static final String[] org2Users

org2Groups

protected static final String[] org2Groups

Constructor Detail

BaseTestImpersonation

public BaseTestImpersonation()

Method Detail

startMiniDfsCluster

protected static void startMiniDfsCluster(String testClass)
                                   throws Exception

Start a MiniDFS cluster backed Drillbit cluster with impersonation enabled.

Parameters:

testClass - test class

Throws:

Exception - in case of errors during start up

startMiniDfsCluster

protected static void startMiniDfsCluster(String testClass,
                                          boolean isImpersonationEnabled)
                                   throws Exception

Start a MiniDFS cluster backed Drillbit cluster

Parameters:

testClass - test class

isImpersonationEnabled - Enable impersonation in the cluster?

Throws:

Exception - in case of errors during start up

startDrillCluster

protected static void startDrillCluster(boolean isImpersonationEnabled)
                                 throws Exception

Throws:

Exception

startDrillCluster

protected static void startDrillCluster(Properties props)
                                 throws Exception

Throws:

Exception

addMiniDfsBasedStorage

protected static void addMiniDfsBasedStorage(Map<String,WorkspaceConfig> workspaces)
                                      throws Exception

Throws:

Exception

createAndAddWorkspace

protected static void createAndAddWorkspace(String name,
                                            String path,
                                            short permissions,
                                            String owner,
                                            String group,
                                            Map<String,WorkspaceConfig> workspaces)
                                     throws Exception

Throws:

Exception

stopMiniDfsCluster

protected static void stopMiniDfsCluster()

getWSSchema

protected static String getWSSchema(String user)

getUserHome

protected static String getUserHome(String user)

createView

protected static void createView(String viewOwner,
                                 String viewGroup,
                                 short viewPerms,
                                 String newViewName,
                                 String fromSourceSchema,
                                 String fromSourceTableName)
                          throws Exception

Throws:

Exception

createView

protected static void createView(String viewOwner,
                                 String viewGroup,
                                 String viewName,
                                 String viewDef)
                          throws Exception

Throws:

Exception