Repository: asterixdb Updated Branches: refs/heads/master f086893b9 -> 81a346c68
Set GlobalJobDataFactory on JobSpec Change-Id: I9707dceb9b74c6342cef713cd70902eb07f6c575 Reviewed-on: https://asterix-gerrit.ics.uci.edu/1726 Sonar-Qube: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu> BAD: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Reviewed-by: Preston Carman <prest...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/81a346c6 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/81a346c6 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/81a346c6 Branch: refs/heads/master Commit: 81a346c68f2e2feeede52bb37b33e37d7ab689d7 Parents: f086893 Author: Till Westmann <ti...@apache.org> Authored: Sun May 7 01:30:22 2017 -0700 Committer: Till Westmann <ti...@apache.org> Committed: Sun May 7 22:19:53 2017 -0700 ---------------------------------------------------------------------- ...SpecificationActivityClusterGraphGeneratorFactory.java | 1 + .../java/org/apache/hyracks/api/job/JobSpecification.java | 10 ++++++++++ 2 files changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/81a346c6/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/impl/JobSpecificationActivityClusterGraphGeneratorFactory.java ---------------------------------------------------------------------- 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 @@ public class JobSpecificationActivityClusterGraphGeneratorFactory implements IAc 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<>(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/81a346c6/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/JobSpecification.java ---------------------------------------------------------------------- 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 @@ public class JobSpecification implements Serializable, IOperatorDescriptorRegist private IJobletEventListenerFactory jobletEventListenerFactory; + private IGlobalJobDataFactory globalJobDataFactory; + private boolean useConnectorPolicyForScheduling; private IClusterCapacity requiredClusterCapacity; @@ -281,6 +283,14 @@ public class JobSpecification implements Serializable, IOperatorDescriptorRegist this.jobletEventListenerFactory = jobletEventListenerFactory; } + public IGlobalJobDataFactory getGlobalJobDataFactory() { + return globalJobDataFactory; + } + + public void setGlobalJobDataFactory(IGlobalJobDataFactory globalJobDataFactory) { + this.globalJobDataFactory = globalJobDataFactory; + } + public boolean isUseConnectorPolicyForScheduling() { return useConnectorPolicyForScheduling; }
