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