SAMZA-975 - Initial Samza REST Implementation
authorJacob Maes <jacob.maes@gmail.com>
Tue, 23 Aug 2016 06:38:13 +0000 (23:38 -0700)
committerNavina Ramesh <nramesh@linkedin.com>
Tue, 23 Aug 2016 06:38:13 +0000 (23:38 -0700)
commit260d1ff963eaa6ea6b0eb57ea9585a4751f40ddd
tree4bb42d5007d2103c680911b1d4bfddb05136574c
parent17e65d1cbdda1ad436f47c15fa4c86332e229a93
SAMZA-975 - Initial Samza REST Implementation
45 files changed:
LICENSE
build.gradle
gradle/dependency-versions.gradle
samza-rest/src/main/bash/run-samza-rest-service.sh [new file with mode: 0755]
samza-rest/src/main/config/samza-rest.properties [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/monitor/Monitor.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/monitor/MonitorLoader.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/monitor/SamzaMonitorService.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/monitor/ScheduledExecutorSchedulingProvider.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/monitor/SchedulingProvider.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/SamzaRestApplication.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/SamzaRestConfig.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/model/Job.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/model/JobStatus.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/InstallationFinder.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/InstallationRecord.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/SimpleInstallationFinder.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/AbstractJobProxy.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobInstance.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobProxy.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobProxyFactory.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobStatusProvider.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/ScriptJobProxy.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxy.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxyFactory.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/YarnCliJobStatusProvider.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/resources/DefaultResourceFactory.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResource.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResourceConfig.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/resources/ResourceFactory.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/script/ScriptOutputHandler.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/script/ScriptPathProvider.java [new file with mode: 0644]
samza-rest/src/main/java/org/apache/samza/rest/script/ScriptRunner.java [new file with mode: 0644]
samza-rest/src/main/resources/log4j.xml [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/monitor/TestMonitorService.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/monitor/mock/DummyMonitor.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/monitor/mock/ExceptionThrowingMonitor.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/monitor/mock/InstantSchedulingProvider.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/rest/resources/TestJobsResource.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockJobProxy.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockJobProxyFactory.java [new file with mode: 0644]
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockJobStatusProvider.java [new file with mode: 0644]
samza-shell/src/main/bash/kill-yarn-job-by-name.sh [new file with mode: 0755]
settings.gradle