public final class WebMonitorUtils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
WebMonitorUtils.LogFileLocation
Singleton to hold the log and stdout file
|
Modifier and Type | Method and Description |
---|---|
static JobDetails |
createDetailsForJob(AccessExecutionGraph job) |
static Map<String,String> |
fromKeyValueJsonArray(String jsonString) |
static JsonArchivist[] |
getJsonArchivists() |
static WebMonitor |
startWebRuntimeMonitor(Configuration config,
HighAvailabilityServices highAvailabilityServices,
akka.actor.ActorSystem actorSystem)
Starts the web runtime monitor.
|
static Path |
validateAndNormalizeUri(URI archiveDirUri)
Checks and normalizes the given URI.
|
public static WebMonitor startWebRuntimeMonitor(Configuration config, HighAvailabilityServices highAvailabilityServices, akka.actor.ActorSystem actorSystem)
Because failure to start the web runtime monitor is not considered fatal, this method does not throw any exceptions, but only logs them.
config
- The configuration for the runtime monitor.highAvailabilityServices
- HighAvailabilityServices used to start the WebRuntimeMonitoractorSystem
- ActorSystem used to connect to the JobManagerpublic static JsonArchivist[] getJsonArchivists()
public static JobDetails createDetailsForJob(AccessExecutionGraph job)
public static Path validateAndNormalizeUri(URI archiveDirUri)
archiveDirUri
- The URI to check and normalize.IllegalArgumentException
- Thrown, if the URI misses scheme or path.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.