| Package | Description |
|---|---|
| org.apache.drill.test |
Provides a variety of test framework tools to simplify Drill unit
tests and ad-hoc tests created while developing features.
|
| Modifier and Type | Method and Description |
|---|---|
static ClusterFixtureBuilder |
ClusterFixture.bareBuilder(BaseDirTestWatcher dirTestWatcher)
Return a cluster builder without any of the usual defaults.
|
static ClusterFixtureBuilder |
ClusterFixture.builder(BaseDirTestWatcher dirTestWatcher) |
ClusterFixtureBuilder |
ClusterFixtureBuilder.clusterSize(int n)
The number of Drillbits to start in the cluster.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.configClientProperty(String key,
Object value)
Add an additional property for the client connection URL.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.configProperty(String key,
Object value)
Add an additional boot-time property for the embedded Drillbit.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.configResource(String configResource)
Use the given configuration file, stored as a resource, to start the
embedded Drillbit.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.maxParallelization(int n)
Set the maximum parallelization (max width per node).
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.putDefinition(OptionDefinition definition) |
ClusterFixtureBuilder |
ClusterFixtureBuilder.saveProfiles()
Enable saving of query profiles.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.sessionOption(String key,
Object value)
Provide a session option to be set once the Drillbit
is started.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.setOptionDefault(String key,
Object value) |
ClusterFixtureBuilder |
ClusterFixtureBuilder.systemOption(String key,
Object value)
Provide a system option to be set once the Drillbit
is started.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.withBits(String... bitNames)
Define a cluster by providing names to the Drillbits.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.withLocalZk()
By default the embedded Drillbits use an in-memory cluster coordinator.
|
ClusterFixtureBuilder |
ClusterFixtureBuilder.withLocalZk(int count) |
ClusterFixtureBuilder |
ClusterFixtureBuilder.withRemoteZk(String connStr) |
ClusterFixtureBuilder |
ClusterFixtureBuilder.withZk(ZookeeperHelper zk)
Run the cluster using a Zookeeper started externally.
|
| Modifier and Type | Method and Description |
|---|---|
protected static void |
ClusterTest.startCluster(ClusterFixtureBuilder builder) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.