Permalink
Browse files

add scalable service project

  • Loading branch information...
1 parent cc03b1c commit 212be98954f6df33623e2aa5f889de4351061206 @leejianwei leejianwei committed Jun 21, 2012
Showing with 8,146 additions and 3 deletions.
  1. +2 −1 build.gradle
  2. +1 −1 gradle.properties
  3. +46 −0 scalable-service/common/build.gradle
  4. +15 −0 scalable-service/common/gradle.properties
  5. +58 −0 ...ervice/common/src/main/java/org/springframework/data/hadoop/admin/SpringHadoopAdminException.java
  6. +96 −0 ...service/common/src/main/java/org/springframework/data/hadoop/admin/entity/BaseWorkflowEntity.java
  7. +24 −0 ...able-service/common/src/main/java/org/springframework/data/hadoop/admin/entity/MessageEntity.java
  8. +83 −0 scalable-service/common/src/main/java/org/springframework/data/hadoop/admin/entity/WorkerNode.java
  9. +24 −0 ...-service/common/src/main/java/org/springframework/data/hadoop/admin/entity/WorkflowExecution.java
  10. +50 −0 ...vice/common/src/main/java/org/springframework/data/hadoop/admin/entity/WorkflowLaunchRequest.java
  11. +30 −0 scalable-service/common/src/main/resources/META-INF/spring/hadoop-admin/rabbit-context.xml
  12. +7 −0 scalable-service/common/src/main/resources/log4j.properties
  13. +6 −0 scalable-service/common/src/main/resources/spring-hadoop-admin.properties
  14. +51 −0 scalable-service/common/src/main/webapp/WEB-INF/web.xml
  15. +88 −0 scalable-service/common/src/main/webapp/WEB-INF/web/manager/templates/html/templates.ftl
  16. +17 −0 scalable-service/common/src/main/webapp/WEB-INF/web/manager/templates/json/templates.ftl
  17. +129 −0 scalable-service/common/src/main/webapp/WEB-INF/web/manager/workflows/html/workflows.ftl
  18. +27 −0 scalable-service/common/src/main/webapp/WEB-INF/web/manager/workflows/json/workflows.ftl
  19. +1 −0 scalable-service/common/src/main/webapp/index.jsp
  20. +17 −0 scalable-service/common/src/test/resources/log4j.properties
  21. +54 −0 scalable-service/master/build.gradle
  22. +1,237 −0 scalable-service/master/example.log
  23. +15 −0 scalable-service/master/gradle.properties
  24. +57 −0 ...aster/src/main/java/org/springframework/data/hadoop/admin/SpringHadoopAdminWorkflowException.java
  25. +117 −0 ...e-service/master/src/main/java/org/springframework/data/hadoop/admin/message/MessageProducer.java
  26. +278 −0 ...e-service/master/src/main/java/org/springframework/data/hadoop/admin/service/BaseFileService.java
  27. +81 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/service/FileInfo.java
  28. +28 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/service/FileRemover.java
  29. +28 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/service/FileSender.java
  30. +46 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/service/FileService.java
  31. +63 −0 ...ice/master/src/main/java/org/springframework/data/hadoop/admin/service/SimpleTemplateService.java
  32. +149 −0 ...ice/master/src/main/java/org/springframework/data/hadoop/admin/service/SimpleWorkflowService.java
  33. +72 −0 ...able-service/master/src/main/java/org/springframework/data/hadoop/admin/service/TemplateInfo.java
  34. +29 −0 ...e-service/master/src/main/java/org/springframework/data/hadoop/admin/service/TemplateService.java
  35. +106 −0 ...able-service/master/src/main/java/org/springframework/data/hadoop/admin/service/WorkflowInfo.java
  36. +31 −0 ...e-service/master/src/main/java/org/springframework/data/hadoop/admin/service/WorkflowService.java
  37. +34 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/util/Constant.java
  38. +195 −0 ...aster/src/main/java/org/springframework/data/hadoop/admin/util/HadoopWorkflowDescriptorUtils.java
  39. +447 −0 ...-service/master/src/main/java/org/springframework/data/hadoop/admin/util/HadoopWorkflowUtils.java
  40. +162 −0 ...le-service/master/src/main/java/org/springframework/data/hadoop/admin/web/TemplateController.java
  41. +27 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/web/TemplateMenu.java
  42. +168 −0 ...le-service/master/src/main/java/org/springframework/data/hadoop/admin/web/WorkflowController.java
  43. +27 −0 scalable-service/master/src/main/java/org/springframework/data/hadoop/admin/web/WorkflowMenu.java
  44. +43 −0 .../master/src/main/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowDirectory.java
  45. +72 −0 ...r/src/main/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowDirectoryFilter.java
  46. +72 −0 .../main/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowLaunchRequestAdapter.java
  47. +93 −0 .../main/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowRemoveRequestAdapter.java
  48. +65 −0 ...aster/src/main/java/org/springframework/data/hadoop/admin/workflow/SimpleSpringHadoopTasklet.java
  49. +287 −0 ...a/org/springframework/data/hadoop/admin/workflow/support/FileSystemApplicationContextFactory.java
  50. +174 −0 .../springframework/data/hadoop/admin/workflow/support/FileSystemApplicationContextsFactoryBean.java
  51. +111 −0 ...org/springframework/data/hadoop/admin/workflow/support/FileSystemWorkflowResourceFactoryBean.java
  52. +71 −0 ...aster/src/main/java/org/springframework/data/hadoop/admin/workflow/support/WorkflowArtifacts.java
  53. +31 −0 ...ces/META-INF/spring/batch/bootstrap/spring-hadoop-admin/spring-hadoop-admin-execution-context.xml
  54. +47 −0 ...ice/master/src/main/resources/META-INF/spring/batch/jobs/spring-hadoop-admin-workflow-context.xml
  55. +53 −0 ...rc/main/resources/META-INF/spring/batch/override/integration/spring-hadoop-admin-file-context.xml
  56. +11 −0 ...c/main/resources/META-INF/spring/batch/servlet/override/spring-hadoo-admin-controller-context.xml
  57. +14 −0 .../src/main/resources/META-INF/spring/batch/servlet/override/spring-hadoo-admin-message-context.xml
  58. +60 −0 ...src/main/resources/META-INF/spring/batch/servlet/override/spring-hadoop-admin-manager-context.xml
  59. 0 scalable-service/master/src/main/resources/batch-admin-dummy-business-schema.sql
  60. +16 −0 scalable-service/master/src/main/resources/batch-hsql.properties
  61. +3 −0 scalable-service/master/src/main/resources/core-site.xml
  62. +7 −0 scalable-service/master/src/main/resources/log4j.properties
  63. +32 −0 scalable-service/master/src/main/resources/ui-messages.properties
  64. +51 −0 scalable-service/master/src/main/webapp/WEB-INF/web.xml
  65. +88 −0 scalable-service/master/src/main/webapp/WEB-INF/web/manager/templates/html/templates.ftl
  66. +17 −0 scalable-service/master/src/main/webapp/WEB-INF/web/manager/templates/json/templates.ftl
  67. +129 −0 scalable-service/master/src/main/webapp/WEB-INF/web/manager/workflows/html/workflows.ftl
  68. +27 −0 scalable-service/master/src/main/webapp/WEB-INF/web/manager/workflows/json/workflows.ftl
  69. +1 −0 scalable-service/master/src/main/webapp/index.jsp
  70. +84 −0 ...rvice/master/src/test/java/org/springframework/data/hadoop/admin/message/MessageProducerTest.java
  71. +130 −0 ...r/src/test/java/org/springframework/data/hadoop/admin/util/HadoopWorkflowDescriptorUtilsTest.java
  72. +293 −0 ...vice/master/src/test/java/org/springframework/data/hadoop/admin/util/HadoopWorkflowUtilsTest.java
  73. +41 −0 scalable-service/master/src/test/java/org/springframework/data/hadoop/admin/util/SimpleBean.java
  74. +100 −0 ...c/test/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowDirectoryFilterTest.java
  75. +67 −0 ...ter/src/test/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowDirectoryTest.java
  76. +73 −0 ...t/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowLaunchRequestAdapterTest.java
  77. +84 −0 ...t/java/org/springframework/data/hadoop/admin/workflow/HadoopWorkflowRemoveRequestAdapterTest.java
  78. +97 −0 ...r/src/test/java/org/springframework/data/hadoop/admin/workflow/SimpleSpringHadoopTaskletTest.java
  79. +136 −0 ...g/springframework/data/hadoop/admin/workflow/support/FileSystemApplicationContextFactoryTest.java
  80. +96 −0 ...ingframework/data/hadoop/admin/workflow/support/FileSystemApplicationContextsFactoryBeanTest.java
  81. +90 −0 ...springframework/data/hadoop/admin/workflow/support/FileSystemWorkflowResourceFactoryBeanTest.java
  82. +96 −0 ...r/src/test/java/org/springframework/data/hadoop/admin/workflow/support/WorkflowArtifactsTest.java
  83. 0 scalable-service/master/src/test/resources/batch-admin-dummy-business-schema.sql
  84. +16 −0 scalable-service/master/src/test/resources/batch-hsql.properties
  85. +11 −0 scalable-service/master/src/test/resources/batch.properties
  86. +17 −0 scalable-service/master/src/test/resources/log4j.properties
  87. +29 −0 ...e-service/master/src/test/resources/org/springframework/data/hadoop/admin/data-source-context.xml
  88. +20 −0 scalable-service/master/src/test/resources/org/springframework/data/hadoop/admin/env-context.xml
  89. +49 −0 ...ble-service/master/src/test/resources/org/springframework/data/hadoop/admin/execution-context.xml
  90. +14 −0 .../src/test/resources/org/springframework/data/hadoop/admin/message/MessageProducerTest-context.xml
  91. +8 −0 scalable-service/master/src/test/resources/org/springframework/data/hadoop/admin/util/context.xml
  92. BIN ...ce/master/src/test/resources/org/springframework/data/hadoop/admin/util/hadoop-examples-1.0.0.jar
  93. +2 −0 ...le-service/master/src/test/resources/org/springframework/data/hadoop/admin/util/hadoop.properties
  94. +10 −0 ...-service/master/src/test/resources/org/springframework/data/hadoop/admin/util/invalid-context.xml
  95. +8 −0 ...ble-service/master/src/test/resources/org/springframework/data/hadoop/admin/util/test/context.xml
  96. BIN ...ster/src/test/resources/org/springframework/data/hadoop/admin/util/test/hadoop-examples-1.0.0.jar
  97. +2 −0 ...rvice/master/src/test/resources/org/springframework/data/hadoop/admin/util/test/hadoop.properties
  98. +24 −0 ...ster/src/test/resources/org/springframework/data/hadoop/admin/util/testSpringBatchJob/context.xml
  99. BIN ...resources/org/springframework/data/hadoop/admin/util/testSpringBatchJob/hadoop-examples-1.0.0.jar
  100. +8 −0 ...rc/test/resources/org/springframework/data/hadoop/admin/util/testSpringBatchJob/hadoop.properties
  101. BIN ...ources/org/springframework/data/hadoop/admin/util/testWithoutDescriptor/hadoop-examples-1.0.0.jar
  102. +2 −0 ...test/resources/org/springframework/data/hadoop/admin/util/testWithoutDescriptor/hadoop.properties
  103. +8 −0 ...r/src/test/resources/org/springframework/data/hadoop/admin/util/testWithoutProperties/context.xml
  104. BIN ...ources/org/springframework/data/hadoop/admin/util/testWithoutProperties/hadoop-examples-1.0.0.jar
  105. +38 −0 ...c/test/resources/org/springframework/data/hadoop/admin/util/testWithoutSpringBatchJob/context.xml
  106. BIN ...es/org/springframework/data/hadoop/admin/util/testWithoutSpringBatchJob/hadoop-examples-1.0.0.jar
  107. +8 −0 .../resources/org/springframework/data/hadoop/admin/util/testWithoutSpringBatchJob/hadoop.properties
  108. +8 −0 ...vice/master/src/test/resources/org/springframework/data/hadoop/admin/util/withoutJars/context.xml
  109. +2 −0 ...aster/src/test/resources/org/springframework/data/hadoop/admin/util/withoutJars/hadoop.properties
  110. +23 −0 ...able-service/master/src/test/resources/org/springframework/data/hadoop/admin/workflow/context.xml
  111. BIN ...aster/src/test/resources/org/springframework/data/hadoop/admin/workflow/hadoop-examples-1.0.0.jar
  112. +8 −0 ...ervice/master/src/test/resources/org/springframework/data/hadoop/admin/workflow/hadoop.properties
  113. +24 −0 ...vice/master/src/test/resources/org/springframework/data/hadoop/admin/workflow/support/context.xml
  114. +23 −0 ...master/src/test/resources/org/springframework/data/hadoop/admin/workflow/support/copy/context.xml
  115. BIN ...t/resources/org/springframework/data/hadoop/admin/workflow/support/copy/hadoop-examples-1.0.0.jar
  116. +8 −0 .../src/test/resources/org/springframework/data/hadoop/admin/workflow/support/copy/hadoop.properties
  117. BIN ...c/test/resources/org/springframework/data/hadoop/admin/workflow/support/hadoop-examples-1.0.0.jar
  118. +8 −0 ...aster/src/test/resources/org/springframework/data/hadoop/admin/workflow/support/hadoop.properties
  119. +47 −0 scalable-service/slave/build.gradle
  120. +15 −0 scalable-service/slave/gradle.properties
  121. +40 −0 ...le-service/slave/src/main/java/org/springframework/data/hadoop/admin/WorkflowLaunchException.java
  122. +30 −0 ...able-service/slave/src/main/java/org/springframework/data/hadoop/admin/launch/LaunchWorkflow.java
  123. +41 −0 ...e/src/main/java/org/springframework/data/hadoop/admin/launch/support/LaunchWorkflowInProcess.java
  124. +77 −0 ...le-service/slave/src/main/java/org/springframework/data/hadoop/admin/message/MessageConsumer.java
  125. +51 −0 scalable-service/slave/src/main/webapp/WEB-INF/web.xml
  126. +88 −0 scalable-service/slave/src/main/webapp/WEB-INF/web/manager/templates/html/templates.ftl
  127. +17 −0 scalable-service/slave/src/main/webapp/WEB-INF/web/manager/templates/json/templates.ftl
  128. +129 −0 scalable-service/slave/src/main/webapp/WEB-INF/web/manager/workflows/html/workflows.ftl
  129. +27 −0 scalable-service/slave/src/main/webapp/WEB-INF/web/manager/workflows/json/workflows.ftl
  130. +1 −0 scalable-service/slave/src/main/webapp/index.jsp
  131. +17 −0 scalable-service/slave/src/test/resources/log4j.properties
  132. +3 −1 settings.gradle
View
@@ -7,6 +7,7 @@ allprojects {
apply plugin: 'java'
repositories {
+ mavenLocal()
mavenCentral()
maven { url "http://repo.springsource.org/snapshot" }
maven { url "http://repo.springsource.org/release" }
@@ -22,7 +23,7 @@ allprojects {
compile "org.apache.hadoop:hadoop-core:$hadoopVersion"
testCompile "junit:junit:$junitVersion"
-
+ testCompile "org.springframework:spring-test:$springVersion"
}
}
View
@@ -2,7 +2,7 @@ hadoopVersion = 1.0.0
jacksonVersion = 1.9.6
commonsConfigVersion = 1.8
springBatchAdminVersion = 1.2.1.RELEASE
-#springBatchAdminVersion = 1.2.2.BUILD-SNAPSHOT
+springVersion = 3.1.1.RELEASE
junitVersion = 4.8.1
@@ -0,0 +1,46 @@
+description = 'Scalable Spring Hadoop Admin Service:Common'
+
+apply plugin: 'eclipse'
+
+repositories {
+ maven { url "http://www.datanucleus.org/downloads/maven2/" }
+}
+
+dependencies {
+ compile "org.springframework.data:spring-data-hadoop:$springHadoopVersion"
+ compile "org.springframework.amqp:spring-amqp:$springAmqpVersion"
+ compile "org.springframework.amqp:spring-rabbit:$springAmqpVersion"
+ compile "org.springframework.integration:spring-integration-core:$springIntegrationVersion"
+
+ runtime "org.codehaus.jackson:jackson-core-asl:$jacksonVersion"
+ runtime "org.codehaus.jackson:jackson-mapper-asl:$jacksonVersion"
+ runtime "commons-lang:commons-lang:$commonsLangVersion"
+ runtime "org.codehaus.groovy:groovy:$groovyVersion"
+ runtime "hsqldb:hsqldb:$hsqldbVersion"
+
+ //pig
+ runtime "org.apache.pig:pig:$pigVersion"
+ runtime "jline:jline:$jlineVersion"
+ runtime "org.antlr:antlr:$antlrVersion"
+
+ //hive
+ runtime "javax.jdo:jdo2-api:$jdoVersion"
+ runtime "org.apache.hive:hive-service:$hiveVersion"
+ runtime "org.apache.hive:hive-metastore:$hiveVersion"
+ runtime "org.apache.hive:hive-jdbc:$hiveVersion"
+
+ //log
+ runtime "org.slf4j:slf4j-api:$slf4jVersion"
+ runtime "org.slf4j:slf4j-log4j12:$slf4jVersion"
+ runtime "org.slf4j:jcl-over-slf4j:$slf4jVersion"
+
+}
+
+
+eclipse {
+ project {
+ name = "spring-hadoop-admin-service-common"
+ }
+}
+
+defaultTasks 'clean', 'build'
@@ -0,0 +1,15 @@
+jacksonVersion = 1.9.6
+pigVersion = 0.9.2
+jlineVersion = 1.0
+antlrVersion = 3.1.1
+hiveVersion = 0.8.1
+jdoVersion = 2.3-ec
+groovyVersion = 1.8.5
+hsqldbVersion=1.8.0.7
+commonsLangVersion = 2.4
+springHadoopVersion = 1.0.0.BUILD-SNAPSHOT
+springAmqpVersion = 1.1.1.RELEASE
+springIntegrationVersion = 2.1.2.RELEASE
+slf4jVersion = 1.6.1
+
+
@@ -0,0 +1,58 @@
+/*
+ * Copyright 2011-2012 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.hadoop.admin;
+
+/**
+ * Base class for Spring Hadoop Admin exception handling
+ *
+ * @author Jarred Li
+ *
+ */
+public class SpringHadoopAdminException extends Exception {
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = -2954725715945849099L;
+
+
+ /**
+ * Default constructor
+ *
+ */
+ public SpringHadoopAdminException() {
+ super();
+ }
+
+ /**
+ * constructor with message
+ *
+ * @param message The message for this exception
+ */
+ public SpringHadoopAdminException(String message) {
+ super(message);
+ }
+
+ /**
+ * constructor with message and throwable
+ *
+ * @param message The message for this exception
+ * @param t
+ */
+ public SpringHadoopAdminException(String message, Throwable t) {
+ super(message, t);
+ }
+}
@@ -0,0 +1,96 @@
+/*
+ * Copyright 2011-2012 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.hadoop.admin.entity;
+
+import java.io.Serializable;
+
+import org.springframework.core.io.Resource;
+
+/**
+ * @author Jarred Li
+ *
+ */
+public class BaseWorkflowEntity implements Serializable{
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = 2228483633653338928L;
+
+ private Resource[] jars;
+
+ private Resource descriptor;
+
+ private Resource propertyFile;
+
+ private String name;
+
+ /**
+ * @return the jars
+ */
+ public Resource[] getJars() {
+ return jars;
+ }
+
+ /**
+ * @param jars the jars to set
+ */
+ public void setJars(Resource[] jars) {
+ this.jars = jars;
+ }
+
+ /**
+ * @return the descriptor
+ */
+ public Resource getDescriptor() {
+ return descriptor;
+ }
+
+ /**
+ * @param descriptor the descriptor to set
+ */
+ public void setDescriptor(Resource descriptor) {
+ this.descriptor = descriptor;
+ }
+
+ /**
+ * @return the propertyFile
+ */
+ public Resource getPropertyFile() {
+ return propertyFile;
+ }
+
+ /**
+ * @param propertyFile the propertyFile to set
+ */
+ public void setPropertyFile(Resource propertyFile) {
+ this.propertyFile = propertyFile;
+ }
+
+ /**
+ * @return the name
+ */
+ public String getName() {
+ return name;
+ }
+
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name) {
+ this.name = name;
+ }
+}
@@ -0,0 +1,24 @@
+/*
+ * Copyright 2011-2012 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.hadoop.admin.entity;
+
+/**
+ * @author Jarred Li
+ *
+ */
+public interface MessageEntity {
+
+}
@@ -0,0 +1,83 @@
+/*
+ * Copyright 2011-2012 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.hadoop.admin.entity;
+
+import java.io.Serializable;
+
+/**
+ * @author Jarred Li
+ *
+ */
+public class WorkerNode implements Serializable{
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = -8565024494353394914L;
+
+
+ private String name;
+
+ private String hostName;
+
+ private String queueName;
+
+ /**
+ * @return the name
+ */
+ public String getName() {
+ return name;
+ }
+
+ /**
+ * @param name the name to set
+ */
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ /**
+ * @return the hostName
+ */
+ public String getHostName() {
+ return hostName;
+ }
+
+ /**
+ * @param hostName the hostName to set
+ */
+ public void setHostName(String hostName) {
+ this.hostName = hostName;
+ }
+
+ /**
+ * @return the queueName
+ */
+ public String getQueueName() {
+ return queueName;
+ }
+
+ /**
+ * @param queueName the queueName to set
+ */
+ public void setQueueName(String queueName) {
+ this.queueName = queueName;
+ }
+
+
+
+
+}
@@ -0,0 +1,24 @@
+/*
+ * Copyright 2011-2012 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.hadoop.admin.entity;
+
+/**
+ * @author Jarred Li
+ *
+ */
+public class WorkflowExecution {
+
+}
Oops, something went wrong.

0 comments on commit 212be98

Please sign in to comment.