Modifier and Type | Method and Description |
---|---|
static DrillConfig |
DrillConfig.create()
Creates a DrillConfig object using the default config file name
and with server-specific configuration options enabled.
|
static DrillConfig |
DrillConfig.create(com.typesafe.config.Config config)
Creates a drill configuration using the provided config file.
|
static DrillConfig |
DrillConfig.create(Properties testConfigurations)
Do not use this method outside of test code.
|
static DrillConfig |
DrillConfig.create(String overrideFileResourcePathname)
DrillConfig loads up Drill configuration information.
|
static DrillConfig |
DrillConfig.create(String overrideFileResourcePathname,
boolean enableServerConfigs) |
static DrillConfig |
DrillConfig.create(String overrideFileResourcePathname,
Properties overriderProps,
boolean enableServerConfigs,
ConfigFileInfo configInfo,
com.typesafe.config.ConfigMergeable fallbackConfig) |
static DrillConfig |
DrillConfig.createForRM()
Merged DrillConfig object for all the RM Configurations provided through various resource files.
|
static DrillConfig |
DrillConfig.forClient()
Creates a
configuration using the default config file
name and with server-specific configuration options disabled. |
Constructor and Description |
---|
LogicalPlanPersistence(DrillConfig conf,
ScanResult scanResult) |
LogicalPlanPersistence(DrillConfig conf,
ScanResult scanResult,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
Constructor and Description |
---|
De(DrillConfig config) |
Modifier and Type | Method and Description |
---|---|
static ScanResult |
RunTimeScan.dynamicPackageScan(DrillConfig config,
Set<URL> markedPath)
Scans packages retrieved from config.
|
static ScanResult |
ClassPathScanner.fromPrescan(DrillConfig config) |
static ScanResult |
RunTimeScan.fromPrescan(DrillConfig config)
Loads prescanned classpath info and scans for extra ones based on configuration.
|
Modifier and Type | Method and Description |
---|---|
DrillConfig |
DrillClient.getConfig() |
Constructor and Description |
---|
DrillClient(DrillConfig config) |
DrillClient(DrillConfig config,
boolean isDirect) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator,
boolean isDirect) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator,
BufferAllocator allocator) |
DrillClient(DrillConfig config,
ClusterCoordinator coordinator,
BufferAllocator allocator,
boolean isDirect) |
LoggingResultsListener(DrillConfig config,
QuerySubmitter.Format format,
int columnWidth) |
Modifier and Type | Method and Description |
---|---|
static Class<?> |
ClassBuilder.getCompiledClass(String code,
String className,
DrillConfig config,
OptionSet options) |
Constructor and Description |
---|
ClassBuilder(DrillConfig config,
OptionSet optionManager) |
ClassCompilerSelector(ClassLoader classLoader,
DrillConfig config,
OptionSet sessionOptions) |
ClassTransformer(DrillConfig config,
OptionSet optionManager) |
CodeCompiler(DrillConfig config,
OptionSet optionManager) |
CodeGenCompiler(DrillConfig config,
OptionSet optionManager) |
QueryClassLoader(DrillConfig config,
OptionSet sessionOptions) |
Modifier and Type | Method and Description |
---|---|
static ZKACLProviderDelegate |
ZKACLProviderFactory.findACLProvider(DrillConfig config,
ZKACLContextProvider contextProvider,
BootStrapContext context) |
static ZKACLProviderDelegate |
ZKACLProviderFactory.getACLProvider(DrillConfig config,
String drillClusterPath,
BootStrapContext context) |
Constructor and Description |
---|
ZKClusterCoordinator(DrillConfig config,
org.apache.curator.framework.api.ACLProvider aclProvider) |
ZKClusterCoordinator(DrillConfig config,
String connect) |
ZKClusterCoordinator(DrillConfig config,
String connect,
boolean createNamespace,
org.apache.curator.framework.api.ACLProvider aclProvider) |
Constructor and Description |
---|
FunctionImplementationRegistry(DrillConfig config) |
FunctionImplementationRegistry(DrillConfig config,
ScanResult classpathScan) |
FunctionImplementationRegistry(DrillConfig config,
ScanResult classpathScan,
OptionManager optionManager) |
FunctionImplementationRegistry(DrillConfig config,
ScanResult classpathScan,
OptionSet optionManager) |
HiveFunctionRegistry(DrillConfig config)
Scan the classpath for implementation of GenericUDF/UDF interfaces,
extracts function annotation and store the
(function name) --> (implementation class) mappings.
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteFunctionRegistry.init(DrillConfig config,
PersistentStoreProvider storeProvider,
ClusterCoordinator coordinator) |
Modifier and Type | Method and Description |
---|---|
static BufferAllocator |
RootAllocatorFactory.newRoot(DrillConfig drillConfig)
Create a new Root Allocator
|
Modifier and Type | Method and Description |
---|---|
DrillConfig |
FragmentContextInterface.getConfig()
Returns the Drill configuration for this run.
|
DrillConfig |
FragmentContext.getConfig()
Returns the Drill configuration for this run.
|
DrillConfig |
FragmentContextImpl.getConfig() |
DrillConfig |
QueryContext.getConfig() |
Constructor and Description |
---|
ViewExpansionContext(DrillConfig config,
SchemaConfig.SchemaConfigInfoProvider schemaConfigInfoProvider) |
Modifier and Type | Method and Description |
---|---|
static Optimizer |
Optimizer.getOptimizer(DrillConfig config) |
void |
IdentityOptimizer.init(DrillConfig config) |
abstract void |
Optimizer.init(DrillConfig config) |
void |
BasicOptimizer.init(DrillConfig config) |
Constructor and Description |
---|
SpillSet(DrillConfig config,
ExecProtos.FragmentHandle handle,
PhysicalOperator popConfig) |
Constructor and Description |
---|
SortConfig(DrillConfig config,
OptionManager options) |
Constructor and Description |
---|
PhysicalPlanReader(DrillConfig config,
ScanResult scanResult,
LogicalPlanPersistence lpPersistance,
CoordinationProtos.DrillbitEndpoint endpoint,
StoragePluginRegistry pluginRegistry) |
Modifier and Type | Method and Description |
---|---|
static AbstractSchema |
SchemaUtilites.getTemporaryWorkspace(org.apache.calcite.schema.SchemaPlus defaultSchema,
DrillConfig config)
Looks in schema tree for default temporary workspace instance.
|
static boolean |
SchemaUtilites.isTemporaryWorkspace(String schemaPath,
DrillConfig config)
Checks that passed schema path is the same as temporary workspace path.
|
static AbstractSchema |
SchemaUtilites.resolveToTemporarySchema(List<String> tableSchema,
org.apache.calcite.schema.SchemaPlus defaultSchema,
DrillConfig config)
If table schema is not indicated in sql call, returns temporary workspace.
|
static WorkspaceSchemaFactory.WorkspaceSchema |
SchemaUtilites.resolveToValidTemporaryWorkspace(AbstractSchema schema,
DrillConfig config)
Makes sure that passed workspace exists, is default temporary workspace, mutable and file-based
(instance of
WorkspaceSchemaFactory.WorkspaceSchema ). |
Modifier and Type | Method and Description |
---|---|
DrillConfig |
SqlConverter.getDrillConfig() |
Modifier and Type | Method and Description |
---|---|
static RpcConfig |
ControlRpcConfig.getMapping(DrillConfig config,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
static RpcConfig |
DataRpcConfig.getMapping(DrillConfig config,
Executor executor) |
Constructor and Description |
---|
AuthenticatorProviderImpl(DrillConfig config,
ScanResult scan) |
Modifier and Type | Method and Description |
---|---|
static RpcConfig |
UserRpcConfig.getMapping(DrillConfig config,
Executor executor) |
boolean |
UserSession.isTemporaryTable(AbstractSchema drillSchema,
DrillConfig config,
String tableName)
Checks if passed table is temporary, table name is case-insensitive.
|
String |
UserSession.registerTemporaryTable(AbstractSchema schema,
String tableName,
DrillConfig config)
Creates and adds session temporary location if absent using schema configuration.
|
void |
UserSession.removeTemporaryTable(AbstractSchema schema,
String tableName,
DrillConfig config)
Removes temporary table name from the list of session temporary tables.
|
Constructor and Description |
---|
UserClient(String clientName,
DrillConfig config,
Properties properties,
boolean supportComplexTypes,
BufferAllocator allocator,
io.netty.channel.EventLoopGroup eventLoopGroup,
Executor eventExecutor,
CoordinationProtos.DrillbitEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
static UserAuthenticator |
UserAuthenticatorFactory.createAuthenticator(DrillConfig config,
ScanResult scan)
Create a
UserAuthenticator implementation based on BOOT settings in
given drillConfig. |
void |
Pam4jUserAuthenticator.setup(DrillConfig drillConfig) |
void |
PamUserAuthenticator.setup(DrillConfig drillConfig) |
void |
HtpasswdFileUserAuthenticator.setup(DrillConfig drillConfig) |
void |
UserAuthenticator.setup(DrillConfig drillConfig)
Setup for authenticating user credentials.
|
void |
VaultUserAuthenticator.setup(DrillConfig config)
Reads Drill BOOT options and uses them to set up a Vault client.
|
Modifier and Type | Method and Description |
---|---|
DrillConfig |
BootStrapContext.getConfig() |
DrillConfig |
DrillbitContext.getConfig() |
Modifier and Type | Method and Description |
---|---|
static Drillbit |
Drillbit.start(DrillConfig config) |
static Drillbit |
Drillbit.start(DrillConfig config,
CaseInsensitiveMap<OptionDefinition> validators,
RemoteServiceSet remoteServiceSet) |
static Drillbit |
Drillbit.start(DrillConfig config,
RemoteServiceSet remoteServiceSet) |
Constructor and Description |
---|
BootStrapContext(DrillConfig config,
CaseInsensitiveMap<OptionDefinition> definitions,
ScanResult classpathScan) |
Drillbit(DrillConfig config,
CaseInsensitiveMap<OptionDefinition> definitions,
RemoteServiceSet serviceSet) |
Drillbit(DrillConfig config,
CaseInsensitiveMap<OptionDefinition> definitions,
RemoteServiceSet serviceSet,
ScanResult classpathScan) |
Drillbit(DrillConfig config,
RemoteServiceSet serviceSet) |
Drillbit(DrillConfig config,
RemoteServiceSet serviceSet,
ScanResult classpathScan) |
QueryProfileStoreContext(DrillConfig config,
PersistentStoreProvider storeProvider,
ClusterCoordinator coordinator) |
Constructor and Description |
---|
DrillConfigIterator(DrillConfig c) |
Iter(DrillConfig c) |
SystemOptionManager(DrillConfig bootConfig)
Test-only, in-memory version of the system option manager.
|
SystemOptionManager(LogicalPlanPersistence lpPersistence,
PersistentStoreProvider provider,
DrillConfig bootConfig) |
SystemOptionManager(LogicalPlanPersistence lpPersistence,
PersistentStoreProvider provider,
DrillConfig bootConfig,
CaseInsensitiveMap<OptionDefinition> definitions) |
Modifier and Type | Method and Description |
---|---|
static boolean |
WebServer.isOnlyImpersonationEnabled(DrillConfig config)
Checks if only impersonation is enabled.
|
Modifier and Type | Method and Description |
---|---|
static Set<String> |
DrillHttpSecurityHandlerProvider.getHttpAuthMechanisms(DrillConfig config)
Returns a list of configured mechanisms for HTTP authentication.
|
Constructor and Description |
---|
DrillHttpSecurityHandlerProvider(DrillConfig config,
DrillbitContext drillContext) |
SpnegoConfig(DrillConfig config) |
Modifier and Type | Method and Description |
---|---|
static Map<String,String> |
ResponseHeadersSettingFilter.retrieveResponseHeaders(DrillConfig config) |
Constructor and Description |
---|
FragmentWrapper(UserBitShared.MajorFragmentProfile major,
long start,
DrillConfig config) |
OperatorWrapper(int major,
List<org.apache.commons.lang3.tuple.ImmutablePair<org.apache.commons.lang3.tuple.ImmutablePair<UserBitShared.OperatorProfile,Integer>,String>> opsAndHostsList,
Map<String,String> phyOperMap,
DrillConfig config) |
ProfileInfo(DrillConfig drillConfig,
String queryId,
long startTime,
long endTime,
String foreman,
String query,
String state,
String user,
double totalCost,
String queueName) |
ProfileWrapper(UserBitShared.QueryProfile profile,
DrillConfig drillConfig,
javax.servlet.http.HttpServletRequest request) |
Constructor and Description |
---|
SslContextFactoryConfigurator(DrillConfig config,
String drillbitEndpointAddress) |
Modifier and Type | Method and Description |
---|---|
SSLConfigBuilder |
SSLConfigBuilder.config(DrillConfig config) |
Constructor and Description |
---|
SSLConfigServer(DrillConfig config,
org.apache.hadoop.conf.Configuration hadoopConfig) |
Modifier and Type | Method and Description |
---|---|
DrillConfig |
DrillbitPluginRegistryContext.config() |
DrillConfig |
PluginRegistryContext.config() |
Constructor and Description |
---|
TableStatsCalculator(org.apache.hadoop.hbase.client.Connection connection,
HBaseScanSpec hbaseScanSpec,
DrillConfig config,
HBaseStoragePluginConfig storageConfig)
Computes size of each region for table.
|
Constructor and Description |
---|
MapRDBCost(DrillConfig config,
String mediaType) |
MapRDBTableCache(DrillConfig config) |
Constructor and Description |
---|
VaultCredentialsProvider(String secretPath,
Map<String,String> propertyNames,
DrillConfig config) |
Modifier and Type | Method and Description |
---|---|
DrillConfig |
PersistentStoreRegistry.getConfig() |
Constructor and Description |
---|
PersistentStoreRegistry(C coordinator,
DrillConfig config) |
Modifier and Type | Method and Description |
---|---|
static DrillFileSystem |
LocalPersistentStore.getFileSystem(DrillConfig config,
org.apache.hadoop.fs.Path root) |
Constructor and Description |
---|
LocalPersistentStoreProvider(DrillConfig config) |
ZookeeperPersistentStoreProvider(DrillConfig config,
org.apache.curator.framework.CuratorFramework curator) |
Modifier and Type | Method and Description |
---|---|
static long |
MemoryAllocationUtilities.computeQueryMemory(DrillConfig config,
OptionSet optionManager,
long directMemory)
Per-node memory calculations based on a number of constraints.
|
Constructor and Description |
---|
MetastoreRegistry(DrillConfig config) |
Constructor and Description |
---|
IcebergMetastore(DrillConfig config) |
Constructor and Description |
---|
MongoMetastore(DrillConfig config) |
Constructor and Description |
---|
RdbmsMetastore(DrillConfig config) |
Modifier and Type | Method and Description |
---|---|
static DbHelper |
DbHelper.init(DrillConfig config)
Initializes
DbHelper implementation based on SQLDialect . |
Constructor and Description |
---|
SQLiteHelper(DrillConfig config) |
Modifier and Type | Method and Description |
---|---|
DrillConfig |
DrillOnYarnConfig.getDrillConfig() |
Copyright © 1970 The Apache Software Foundation. All rights reserved.