aboutsummaryrefslogtreecommitdiffstats
path: root/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java
diff options
context:
space:
mode:
Diffstat (limited to 'ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java')
-rw-r--r--ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java23
1 files changed, 23 insertions, 0 deletions
diff --git a/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java b/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java
index 84ce4a3..737a98c 100644
--- a/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java
+++ b/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java
@@ -444,4 +444,27 @@ public class CdapCdapClusterProvider extends BasicAdaptorProvider {
+ serviceId);
}
+ public String suspendSchedule(String namespace, String appId, String scheduleId) {
+ return customRunCDAPcliCommand(namespace, "suspend schedule " + appId + "." + scheduleId);
+ }
+
+ public String resumeSchedule(String namespace, String appId, String scheduleId) {
+ return customRunCDAPcliCommand(namespace, "resume schedule " + appId + "." + scheduleId);
+ }
+
+ public String loadArtifactWithConfig(String namespace, String artifactName, String jarfile, String version,
+ String config) {
+ Date now = new Date();
+ String filename = "/tmp/"+ now.getTime() + ".appConfig";
+ try {
+ OutputStreamWriter w = FileUtils.filename2writer(filename);
+ w.append(config);
+ w.close();
+ } catch (Exception e) {
+ ManagementServerUtils.printStackTrace(e);
+ logger.fatal("configurationChanged" + e);
+ }
+ return customRunCDAPcliCommand(namespace, "load artifact " + jarfile + " config-file " + filename + " name " + artifactName + " version " + version);
+ }
+
}