Uses of Class
org.apache.storm.LocalCluster.Builder

Packages that use LocalCluster.Builder

Package	Description
org.apache.storm

Uses of LocalCluster.Builder in org.apache.storm

Methods in org.apache.storm that return LocalCluster.Builder

Modifier and Type	Method and Description
LocalCluster.Builder	LocalCluster.Builder.withBlobStore(BlobStore store) Use the following blobstore instead of the one in the config.
LocalCluster.Builder	LocalCluster.Builder.withClusterState(IStormClusterState clusterState) Use the following clusterState instead of the one in the config.
LocalCluster.Builder	LocalCluster.Builder.withDaemonConf(Map<String,Object> conf) Set the base config that the daemons should use.
LocalCluster.Builder	LocalCluster.Builder.withDaemonConf(String key, Object value) Add an single key/value config to the daemon conf.
LocalCluster.Builder	LocalCluster.Builder.withGroupMapper(IGroupMappingServiceProvider groupMapper) Override the code that maps users to groups for authorization.
LocalCluster.Builder	LocalCluster.Builder.withINimbus(INimbus inimbus) Override the INimbus instance that nimbus will use.
LocalCluster.Builder	LocalCluster.Builder.withLeaderElector(ILeaderElector leaderElector) Use the following leaderElector instead of the one in the config.
LocalCluster.Builder	LocalCluster.Builder.withNimbusDaemon() Have the local nimbus actually launch a thrift server.
LocalCluster.Builder	LocalCluster.Builder.withNimbusDaemon(Boolean nimbusDaemon) If nimbusDaemon is true the local nimbus will launch a thrift server.
LocalCluster.Builder	LocalCluster.Builder.withNimbusWrapper(UnaryOperator<Nimbus> nimbusWrapper) Before nimbus is created/used call nimbusWrapper on it first and use the result instead.
LocalCluster.Builder	LocalCluster.Builder.withPortsPerSupervisor(int portsPerSupervisor) Set the number of slots/ports each supervisor should have.
LocalCluster.Builder	LocalCluster.Builder.withSimulatedTime() Turn on simulated time in the cluster.
LocalCluster.Builder	LocalCluster.Builder.withSimulatedTime(boolean simulateTime) Turn on simulated time in the cluster.
LocalCluster.Builder	LocalCluster.Builder.withSupervisors(int supervisors) Set the number of supervisors the cluster should have.
LocalCluster.Builder	LocalCluster.Builder.withSupervisorSlotPortMin(Number minPort) When assigning ports to worker slots start at minPort.
LocalCluster.Builder	LocalCluster.Builder.withTopoCache(TopoCache topoCache) Use the following topo cache instead of creating out own.
LocalCluster.Builder	LocalCluster.Builder.withTracked() A tracked cluster can run tracked topologies.
LocalCluster.Builder	LocalCluster.Builder.withTracked(String trackId) A tracked cluster can run tracked topologies.