Skip to content

Commit d2f1c84

Browse files
committed
Fix compile errors caused by merge (rebase)
1 parent 39cc6bd commit d2f1c84

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

src/main/java/org/apache/sysds/hops/fedplanner/FederatedMemoTable.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,6 @@ public class FederatedMemoTable {
4141
// Maps Hop ID and fedOutType pairs to their plan variants
4242
private final Map<Pair<Long, FederatedOutput>, FedPlanVariants> hopMemoTable = new HashMap<>();
4343

44-
public void addFedPlanVariants(long hopID, FederatedOutput fedOutType, FedPlanVariants fedPlanVariants) {
45-
hopMemoTable.put(new ImmutablePair<>(hopID, fedOutType), fedPlanVariants);
4644
public void addFedPlanVariants(long hopID, FederatedOutput fedOutType, FedPlanVariants fedPlanVariants) {
4745
hopMemoTable.put(new ImmutablePair<>(hopID, fedOutType), fedPlanVariants);
4846
}
@@ -136,15 +134,12 @@ public static class FedPlanVariants {
136134
private final FederatedOutput fedOutType; // Output type (FOUT/LOUT)
137135
protected List<FedPlan> _fedPlanVariants; // List of plan variants
138136

139-
public FedPlanVariants(HopCommon hopCommon, FederatedOutput fedOutType) {
140-
this.hopCommon = hopCommon;
141137
public FedPlanVariants(HopCommon hopCommon, FederatedOutput fedOutType) {
142138
this.hopCommon = hopCommon;
143139
this.fedOutType = fedOutType;
144140
this._fedPlanVariants = new ArrayList<>();
145141
}
146142

147-
public boolean isEmpty() {return _fedPlanVariants.isEmpty();}
148143
public boolean isEmpty() {return _fedPlanVariants.isEmpty();}
149144
public void addFedPlan(FedPlan fedPlan) {_fedPlanVariants.add(fedPlan);}
150145
public List<FedPlan> getFedPlanVariants() {return _fedPlanVariants;}
@@ -154,7 +149,6 @@ public boolean pruneFedPlans() {
154149
if (!_fedPlanVariants.isEmpty()) {
155150
// Find the FedPlan with the minimum cumulative cost
156151
FedPlan minCostPlan = _fedPlanVariants.stream()
157-
.min(Comparator.comparingDouble(FedPlan::getCumulativeCost))
158152
.min(Comparator.comparingDouble(FedPlan::getCumulativeCost))
159153
.orElse(null);
160154

src/main/java/org/apache/sysds/hops/fedplanner/FederatedMemoTablePrinter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ private static void printFedPlan(FederatedMemoTable.FedPlan plan, int depth, boo
169169
plan.getCumulativeCost(),
170170
plan.getSelfCost(),
171171
plan.getForwardingCost(),
172-
plan.getWeight()));
172+
plan.getComputeWeight()));
173173

174174
// Add matrix characteristics
175175
sb.append(" [")

src/main/java/org/apache/sysds/runtime/instructions/FEDInstructionParser.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919

2020
package org.apache.sysds.runtime.instructions;
2121

22+
import java.util.HashMap;
23+
2224
import org.apache.sysds.common.InstructionType;
2325
import org.apache.sysds.runtime.DMLRuntimeException;
2426
import org.apache.sysds.runtime.instructions.fed.AggregateBinaryFEDInstruction;
@@ -29,13 +31,17 @@
2931
import org.apache.sysds.runtime.instructions.fed.CentralMomentFEDInstruction;
3032
import org.apache.sysds.runtime.instructions.fed.CovarianceFEDInstruction;
3133
import org.apache.sysds.runtime.instructions.fed.FEDInstruction;
34+
import org.apache.sysds.runtime.instructions.fed.FEDInstruction.FEDType;
3235
import org.apache.sysds.runtime.instructions.fed.IndexingFEDInstruction;
3336
import org.apache.sysds.runtime.instructions.fed.InitFEDInstruction;
3437
import org.apache.sysds.runtime.instructions.fed.QuantilePickFEDInstruction;
3538
import org.apache.sysds.runtime.instructions.fed.QuantileSortFEDInstruction;
3639
import org.apache.sysds.runtime.instructions.fed.ReorgFEDInstruction;
3740
import org.apache.sysds.runtime.instructions.fed.TernaryFEDInstruction;
3841
import org.apache.sysds.runtime.instructions.fed.TsmmFEDInstruction;
42+
import org.apache.sysds.lops.RightIndex;
43+
import org.apache.sysds.lops.LeftIndex;
44+
import org.apache.sysds.lops.Append;
3945

4046
public class FEDInstructionParser extends InstructionParser
4147
{

0 commit comments

Comments
 (0)