Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.blobstore | |
org.apache.storm.hdfs.blobstore | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
static String |
StormSubmitter.submitJarAs(Map<String,Object> conf,
String localJar,
StormSubmitter.ProgressListener listener,
NimbusClient client) |
Modifier and Type | Method and Description |
---|---|
boolean |
NimbusBlobStore.setClient(Map<String,Object> conf,
NimbusClient client) |
boolean |
LocalModeClientBlobStore.setClient(Map<String,Object> conf,
NimbusClient client) |
abstract boolean |
ClientBlobStore.setClient(Map<String,Object> conf,
NimbusClient client)
Client facing API to set a nimbus client.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HdfsClientBlobStore.setClient(Map<String,Object> conf,
NimbusClient client) |
Modifier and Type | Method and Description |
---|---|
static NimbusClient |
NimbusClient.getConfiguredClient(Map<String,Object> conf)
Get a nimbus client as configured by conf.
|
static NimbusClient |
NimbusClient.getConfiguredClient(Map<String,Object> conf,
Integer timeout)
Get a nimbus client as configured by conf.
|
static NimbusClient |
NimbusClient.getConfiguredClientAs(Map<String,Object> conf,
String asUser)
Get a nimbus client as configured by conf.
|
static NimbusClient |
NimbusClient.getConfiguredClientAs(Map<String,Object> conf,
String asUser,
Integer timeout)
Get a nimbus client as configured by conf.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.