Package | Description |
---|---|
org.apache.drill.exec.coord |
Cluster coordination system based on Apache Zookeeper and Curator.
|
org.apache.drill.exec.coord.local |
A single-node "cluster coordinator" used when running Drill locally.
|
org.apache.drill.exec.coord.store | |
org.apache.drill.exec.coord.zk |
Zookeeper/Curator integration code.
|
org.apache.drill.yarn.zk |
Interface between the Application Master and ZooKeeper.
|
Modifier and Type | Method and Description |
---|---|
abstract <V> TransientStore<V> |
ClusterCoordinator.getOrCreateTransientStore(TransientStoreConfig<V> config)
Returns a
store instance with the given configuration . |
Modifier and Type | Method and Description |
---|---|
<V> TransientStore<V> |
LocalClusterCoordinator.getOrCreateTransientStore(TransientStoreConfig<V> config) |
Constructor and Description |
---|
MapBackedStore(TransientStoreConfig<V> config) |
Modifier and Type | Field and Description |
---|---|
protected TransientStoreConfig<V> |
BaseTransientStore.config |
Modifier and Type | Method and Description |
---|---|
TransientStoreConfig<T> |
TransientStoreConfigBuilder.build() |
TransientStoreConfig<V> |
BaseTransientStore.getConfig() |
Modifier and Type | Method and Description |
---|---|
<V> TransientStore<V> |
CachingTransientStoreFactory.getOrCreateStore(TransientStoreConfig<V> config) |
<V> TransientStore<V> |
TransientStoreFactory.getOrCreateStore(TransientStoreConfig<V> config)
Returns a
transient store instance for the given configuration. |
Constructor and Description |
---|
BaseTransientStore(TransientStoreConfig<V> config) |
Modifier and Type | Method and Description |
---|---|
<V> ZkEphemeralStore<V> |
ZkTransientStoreFactory.getOrCreateStore(TransientStoreConfig<V> config) |
<V> TransientStore<V> |
ZKClusterCoordinator.getOrCreateTransientStore(TransientStoreConfig<V> config) |
Constructor and Description |
---|
ZkEphemeralStore(TransientStoreConfig<V> config,
org.apache.curator.framework.CuratorFramework curator) |
Modifier and Type | Method and Description |
---|---|
<V> TransientStore<V> |
ZKClusterCoordinator.getOrCreateTransientStore(TransientStoreConfig<V> config) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.