convert {@link SupervisorWorkerHeartbeat} to nimbus local report executor heartbeats.

convert thrift ExecutorBeat into a java HashMap.

corsFilterHandle. @return corsFilterHandle

Check if resources might be able to fit. @see NormalizedResources#couldHoldIgnoringSharedMemory(org.apache.storm.scheduler.resource.normalization.Norm

A simple sanity check to see if all of the resources in this would be large enough to hold the resources in other ignoring memory. It does not check m

Create one supervisor and add to the supervisors list. @param rack rack-number @param superInRack supervisor number in the rack @param cpu percentage

Create symlink from the containers directory/artifacts to the artifacts directory. @throws IOException on any error

Utility method for creating a template for Spout stats. @return Empty template map for Spout statistics.

Client facing API to create a blob. @param key blob key name @param meta contains ACL information @return AtomicOutputStream returns an output strea

Create symlinks for each of the blobs from the container's directory to corresponding links in the storm dist directory. @throws IOException on any e

create a cgroup.

Create an IConfigLoader implementation if the scheme of the URI is supported; otherwise returns null. @param uri The URI of the config location. @pa

Creates the Callback to send to the Producer. Using this Callback will also execute the user defined Callback, if provided.

Create an instance of {@link SchedulingSearcherState}. This method is called by {@link #prepareForScheduling(Cluster, TopologyDetails)} and depends on

Create supervisors based on a predefined supervisor distribution modeled after an existing large cluster in use. @param testClusterName cluster for w

Returns the value of java.class.path System property. Kept separate for testing. @return the classpath

Maps to Subject.current() if available, otherwise maps to Subject.getSubject(). @return the current subject @see SubjectCompat#currentSubject()

declare what are the fields that this code will output.

Decode key to convert encoded type of key to state key type. @param key raw type of encoded key @return Decoded value of key

Parse the first byte of a vint/vlong to determine the number of bytes. @param value the first byte of the vint/vlong @return the total number of bytes

Decode value to convert encoded type of value to state value type. @param value raw type of encoded value @return Decoded value of value

Decorate the Kryo instance with custom serializations. @deprecated use {@link #decorate(Kryo, Map)} instead.

delete a cgroup.

Delete a key from the blob store. @param key the key to delete @throws IOException on any error