| commit | 81a346c68f2e2feeede52bb37b33e37d7ab689d7 | [log] [tgz] |
|---|---|---|
| author | Till Westmann <tillw@apache.org> | Sun May 07 01:30:22 2017 -0700 |
| committer | Till Westmann <tillw@apache.org> | Sun May 07 22:19:53 2017 -0700 |
| tree | 80d4089b6390bc3c09e2c10ed745aaf066876935 | |
| parent | f086893b900bd070fb9da8a905569b86fdf5346f [diff] |
Set GlobalJobDataFactory on JobSpec Change-Id: I9707dceb9b74c6342cef713cd70902eb07f6c575 Reviewed-on: https://asterix-gerrit.ics.uci.edu/1726 Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> BAD: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Preston Carman <prestonc@apache.org>
diff --git a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/impl/JobSpecificationActivityClusterGraphGeneratorFactory.java b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/impl/JobSpecificationActivityClusterGraphGeneratorFactory.java index 61b4b4e..c712b36 100644 --- a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/impl/JobSpecificationActivityClusterGraphGeneratorFactory.java +++ b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/impl/JobSpecificationActivityClusterGraphGeneratorFactory.java
@@ -74,6 +74,7 @@ acg.setFrameSize(spec.getFrameSize()); acg.setMaxReattempts(spec.getMaxReattempts()); acg.setJobletEventListenerFactory(spec.getJobletEventListenerFactory()); + acg.setGlobalJobDataFactory(spec.getGlobalJobDataFactory()); acg.setConnectorPolicyAssignmentPolicy(spec.getConnectorPolicyAssignmentPolicy()); acg.setUseConnectorPolicyForScheduling(spec.isUseConnectorPolicyForScheduling()); final Set<Constraint> constraints = new HashSet<>();
diff --git a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/JobSpecification.java b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/JobSpecification.java index 5787c72..a7d3864 100644 --- a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/JobSpecification.java +++ b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/JobSpecification.java
@@ -78,6 +78,8 @@ private IJobletEventListenerFactory jobletEventListenerFactory; + private IGlobalJobDataFactory globalJobDataFactory; + private boolean useConnectorPolicyForScheduling; private IClusterCapacity requiredClusterCapacity; @@ -281,6 +283,14 @@ this.jobletEventListenerFactory = jobletEventListenerFactory; } + public IGlobalJobDataFactory getGlobalJobDataFactory() { + return globalJobDataFactory; + } + + public void setGlobalJobDataFactory(IGlobalJobDataFactory globalJobDataFactory) { + this.globalJobDataFactory = globalJobDataFactory; + } + public boolean isUseConnectorPolicyForScheduling() { return useConnectorPolicyForScheduling; }