CoreUtils
Related Doc:
package utils
Create a circular (looping) iterator over a collection.
Create a circular (looping) iterator over a collection.
An iterable over the underlying collection.
A circular iterator over the collection.
Compute the CRC32 of the segment of the byte array given by the specificed size and offset
Compute the CRC32 of the segment of the byte array given by the specificed size and offset
The bytes to checksum
the offset at which to begin checksumming
the number of bytes to checksum
The CRC32
Compute the CRC32 of the byte array
Compute the CRC32 of the byte array
The array to compute the checksum for
The CRC32
Create an instance of the class with the given class name
Create a daemon thread
Create a daemon thread
The name of the thread
The runction to execute in the thread
The unstarted thread
Returns a list of duplicated items
Execute the given function inside the lock
Parse a comma separated string into a sequence of strings.
Parse a comma separated string into a sequence of strings. Whitespace surrounding the comma will be removed.
This method gets comma separated values which contains key,value pairs and returns a map of key value pairs.
This method gets comma separated values which contains key,value pairs and returns a map of key value pairs. the format of allCSVal is key1:val1, key2:val2 .... Also supports strings with multiple ":" such as IpV6 addresses, taking the last occurrence of the ":" in the pair as the split, eg a:b:c:val1, d:e:f:val2 => a:b:c -> val1, d:e:f -> val2
Read some bytes into the provided buffer, and return the number of bytes read.
Read some bytes into the provided buffer, and return the number of bytes read. If the channel has been closed or we get -1 on the read for any reason, throw an EOFException
Read a big-endian integer from a byte array
Register the given mbean with the platform mbean server, unregistering any mbean that was there before.
Register the given mbean with the platform mbean server, unregistering any mbean that was there before. Note, this method will not throw an exception if the registration fails (since there is nothing you can do and it isn't fatal), instead it just returns false indicating the registration failed.
The object to register as an mbean
The name to register this mbean with
true if the registration succeeded
Replace the given string suffix with the new suffix.
Replace the given string suffix with the new suffix. If the string doesn't end with the given suffix throw an exception.
Recursively delete the given file/directory and any subfiles (if any exist)
Recursively delete the given file/directory and any subfiles (if any exist)
The root file at which to begin deleting
Recursively delete the list of files/directories and any subfiles (if any exist)
Recursively delete the list of files/directories and any subfiles (if any exist)
sequence of files to be deleted
Recursively delete the given file/directory and any subfiles (if any exist)
Recursively delete the given file/directory and any subfiles (if any exist)
The root file at which to begin deleting
Wrap the given function in a java.lang.Runnable
Wrap the given function in a java.lang.Runnable
A function
A Runnable that just executes the function
Do the given action and log any exceptions thrown without rethrowing them
Do the given action and log any exceptions thrown without rethrowing them
The log method to use for logging. E.g. logger.warn
The action to execute
Unregister the mbean with the given name, if there is one registered
Unregister the mbean with the given name, if there is one registered
The mbean name to unregister
General helper functions!
This is for general helper functions that aren't specific to Kafka logic. Things that should have been included in the standard library etc.
If you are making a new helper function and want to add it to this class please ensure the following: 1. It has documentation 2. It is the most general possible utility, not just the thing you needed in one particular place 3. You have tests for it if it is nontrivial in any way