public class ServerUtils extends Object
Modifier and Type | Field and Description |
---|---|
static boolean |
IS_ON_WINDOWS |
static org.slf4j.Logger |
LOG |
static int |
SIGKILL |
static int |
SIGTERM |
Constructor and Description |
---|
ServerUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
canUserReadBlob(ReadableBlobMeta meta,
String user,
Map<String,Object> conf) |
static String |
containerFilePath(String dir) |
static String |
currentClasspath()
Returns the value of java.class.path System property.
|
String |
currentClasspathImpl() |
static void |
downloadResourcesAsSupervisor(String key,
String localFile,
ClientBlobStore cb)
Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
|
void |
downloadResourcesAsSupervisorImpl(String key,
String localFile,
ClientBlobStore cb) |
static int |
execCommand(String... command) |
static void |
extractZipFile(ZipFile zipFile,
File toDir,
String prefix)
Extracts the given file to the given directory.
|
static void |
forceKillProcess(String pid) |
static ClientBlobStore |
getClientBlobStoreForSupervisor(Map<String,Object> conf) |
static int |
getComponentParallelism(Map<String,Object> topoConf,
Object component) |
static Map<String,Integer> |
getComponentParallelism(Map<String,Object> topoConf,
StormTopology topology) |
static long |
getDU(File dir)
Takes an input dir or file and returns the disk usage on that local directory.
|
static double |
getEstimatedTotalHeapMemoryRequiredByTopo(Map<String,Object> topoConf,
StormTopology topology) |
static int |
getEstimatedWorkerCountForRASTopo(Map<String,Object> topoConf,
StormTopology topology) |
static String |
getFileOwner(String path) |
static BlobStore |
getNimbusBlobStore(Map<String,Object> conf,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector) |
static BlobStore |
getNimbusBlobStore(Map<String,Object> conf,
String baseDir,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector) |
static <T> List<T> |
interleaveAll(List<List<T>> nodeList) |
static boolean |
isAbsolutePath(String path) |
static boolean |
isRAS(Map<String,Object> conf)
Check if the scheduler is resource aware or not.
|
static void |
killProcessWithSigTerm(String pid) |
static long |
nimbusVersionOfBlob(String key,
ClientBlobStore cb) |
static Subject |
principalNameToSubject(String name) |
static String |
scriptFilePath(String dir) |
static void |
sendSignalToProcess(long lpid,
int signum) |
static ServerUtils |
setInstance(ServerUtils u)
Provide an instance of this class for delegates to use.
|
static String |
shellCmd(List<String> command)
Returns the combined string, escaped for posix shell.
|
static void |
unJar(File jarFile,
File toDir)
Unpack matching files from a jar.
|
static void |
unpack(File localrsrc,
File dst,
boolean symLinksDisabled) |
static void |
unTar(File inFile,
File untarDir,
boolean symlinksDisabled)
Given a Tar File as input it will untar the file in a the untar directory passed as the second parameter This utility will untar “.tar” files and “.tar.gz”,“tgz” files.
|
static void |
unZip(File inFile,
File toDir)
Given a File input it will unzip the file in a the unzip directory passed as the second parameter.
|
static String |
writeScript(String dir,
List<String> command,
Map<String,String> environment)
Writes a posix shell script file to be executed in its own process.
|
static boolean |
zipDoesContainDir(String zipfile,
String target)
Determines if a zip archive contains a particular directory.
|
static long |
zipFileSize(File myFile)
Given a zip File input it will return its size Only works for zip files whose uncompressed size is less than 4 GB, otherwise returns the size module 2^32, per gzip specifications
|
public static final org.slf4j.Logger LOG
public static final boolean IS_ON_WINDOWS
public static final int SIGKILL
public static final int SIGTERM
public static ServerUtils setInstance(ServerUtils u)
Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implementation of the delegated method.
u
- a ServerUtils instancepublic static BlobStore getNimbusBlobStore(Map<String,Object> conf, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
public static BlobStore getNimbusBlobStore(Map<String,Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
public static boolean isAbsolutePath(String path)
public static String shellCmd(List<String> command)
Returns the combined string, escaped for posix shell.
command
- the list of strings to be combinedpublic static long getDU(File dir)
Takes an input dir or file and returns the disk usage on that local directory. Very basic implementation.
dir
- The input dir to get the disk space of this local dirpublic static ClientBlobStore getClientBlobStoreForSupervisor(Map<String,Object> conf)
public static void downloadResourcesAsSupervisor(String key, String localFile, ClientBlobStore cb) throws AuthorizationException, KeyNotFoundException, IOException
Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
key
- localFile
- cb
- AuthorizationException
KeyNotFoundException
IOException
public static String currentClasspath()
Returns the value of java.class.path System property. Kept separate for testing.
public static boolean zipDoesContainDir(String zipfile, String target) throws IOException
Determines if a zip archive contains a particular directory.
zipfile
- path to the zipped filetarget
- directory being looked for in the zip.IOException
public static String getFileOwner(String path) throws IOException
IOException
public static String writeScript(String dir, List<String> command, Map<String,String> environment) throws IOException
Writes a posix shell script file to be executed in its own process.
dir
- the directory under which the script is to be writtencommand
- the command the script is to executeenvironment
- optional environment variables to set before running the script’s command. May be null.IOException
public static int execCommand(String... command) throws org.apache.commons.exec.ExecuteException, IOException
org.apache.commons.exec.ExecuteException
IOException
public static void sendSignalToProcess(long lpid, int signum) throws IOException
IOException
public static void killProcessWithSigTerm(String pid) throws IOException
IOException
public static void forceKillProcess(String pid) throws IOException
IOException
public static long nimbusVersionOfBlob(String key, ClientBlobStore cb) throws AuthorizationException, KeyNotFoundException
public static boolean canUserReadBlob(ReadableBlobMeta meta, String user, Map<String,Object> conf)
public static void unJar(File jarFile, File toDir) throws IOException
Unpack matching files from a jar. Entries inside the jar that do not match the given pattern will be skipped.
jarFile
- the .jar file to unpacktoDir
- the destination directory into which to unpack the jarIOException
public static void unTar(File inFile, File untarDir, boolean symlinksDisabled) throws IOException
Given a Tar File as input it will untar the file in a the untar directory passed as the second parameter
This utility will untar “.tar” files and “.tar.gz”,“tgz” files.inFile
- The tar file as input.untarDir
- The untar directory where to untar the tar file.symlinksDisabled
- true if symlinks should be disabled, else false.IOException
public static void unpack(File localrsrc, File dst, boolean symLinksDisabled) throws IOException
IOException
public static void extractZipFile(ZipFile zipFile, File toDir, String prefix) throws IOException
Extracts the given file to the given directory. Only zip entries starting with the given prefix are extracted. The prefix is stripped off entry names before extraction.
zipFile
- The zip file to extract.toDir
- The directory to extract to.prefix
- The prefix to look for in the zip file. If not null only paths starting with the prefix will be extracted.IOException
public static void unZip(File inFile, File toDir) throws IOException
Given a File input it will unzip the file in a the unzip directory passed as the second parameter.
inFile
- The zip file as inputtoDir
- The unzip directory where to unzip the zip file.IOException
public static long zipFileSize(File myFile) throws IOException
Given a zip File input it will return its size Only works for zip files whose uncompressed size is less than 4 GB, otherwise returns the size module 2^32, per gzip specifications
myFile
- The zip file as inputIOException
public static boolean isRAS(Map<String,Object> conf)
Check if the scheduler is resource aware or not.
conf
- The configurationpublic static int getEstimatedWorkerCountForRASTopo(Map<String,Object> topoConf, StormTopology topology) throws InvalidTopologyException
InvalidTopologyException
public static double getEstimatedTotalHeapMemoryRequiredByTopo(Map<String,Object> topoConf, StormTopology topology) throws InvalidTopologyException
InvalidTopologyException
public static Map<String,Integer> getComponentParallelism(Map<String,Object> topoConf, StormTopology topology) throws InvalidTopologyException
InvalidTopologyException
public static int getComponentParallelism(Map<String,Object> topoConf, Object component) throws InvalidTopologyException
InvalidTopologyException
public String currentClasspathImpl()
public void downloadResourcesAsSupervisorImpl(String key, String localFile, ClientBlobStore cb) throws AuthorizationException, KeyNotFoundException, IOException
Copyright © 2019 The Apache Software Foundation. All rights reserved.