adressed code review comments
diff --git a/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/job/JobSpecification.java b/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/job/JobSpecification.java
index 1915a54..f0e8510 100644
--- a/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/job/JobSpecification.java
+++ b/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/job/JobSpecification.java
@@ -38,6 +38,8 @@
public class JobSpecification implements Serializable, IOperatorDescriptorRegistry, IConnectorDescriptorRegistry {
private static final long serialVersionUID = 1L;
+
+ private static final int DEFAULT_FRAME_SIZE = 32768;
private final List<OperatorDescriptorId> roots;
@@ -59,7 +61,7 @@
private IConnectorPolicyAssignmentPolicy connectorPolicyAssignmentPolicy;
- private int frameSize = 32768;
+ private int frameSize;
private int maxReattempts;
@@ -76,6 +78,10 @@
// This constructor uses the default frame size. It is for test purposes only.
// For other use cases, use the one which sets the frame size.
public JobSpecification() {
+ this(DEFAULT_FRAME_SIZE);
+ }
+
+ public JobSpecification(int frameSize) {
roots = new ArrayList<OperatorDescriptorId>();
resultSetIds = new ArrayList<ResultSetId>();
opMap = new HashMap<OperatorDescriptorId, IOperatorDescriptor>();
@@ -89,10 +95,6 @@
connectorIdCounter = 0;
maxReattempts = 2;
useConnectorPolicyForScheduling = true;
- }
-
- public JobSpecification(int frameSize) {
- this();
setFrameSize(frameSize);
}