Uses of Class
org.apache.sysds.runtime.controlprogram.federated.FederatedRange
Packages that use FederatedRange
Package
Description
-
Uses of FederatedRange in org.apache.sysds.hops.fedplanner
Method parameters in org.apache.sysds.hops.fedplanner with type arguments of type FederatedRangeModifier and TypeMethodDescriptionstatic voidFederatedPlanRewireTransTable.rewireFunctionDynamic(FunctionStatementBlock function, Map<Long, List<Hop>> rewireTable, Map<Long, FederatedMemoTable.HopCommon> hopCommonTable, Map<Long, FTypes.Privacy> privacyConstraintMap, Map<Long, FTypes.FType> fTypeMap, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> fedMap, Set<Long> unRefTwriteSet, Set<Long> unRefSet, Set<Hop> progRootHopSet) static voidFederatedPlanRewireTransTable.rewireProgram(DMLProgram prog, Map<Long, List<Hop>> rewireTable, Map<Long, FederatedMemoTable.HopCommon> hopCommonTable, Map<Long, FTypes.Privacy> privacyConstraintMap, Map<Long, FTypes.FType> fTypeMap, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> fedMap, Set<Long> unRefTwriteSet, Set<Long> unRefSet, Set<Hop> progRootHopSet) -
Uses of FederatedRange in org.apache.sysds.runtime.controlprogram.federated
Methods in org.apache.sysds.runtime.controlprogram.federated that return FederatedRangeModifier and TypeMethodDescriptionFederationMap.getFederatedRanges()FederatedRange.shift(long rshift, long cshift) FederatedRange.transpose()Methods in org.apache.sysds.runtime.controlprogram.federated that return types with arguments of type FederatedRangeModifier and TypeMethodDescriptionList<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> FederationMap.getMap()List<org.apache.commons.lang3.tuple.Pair<FederatedRange,Future<FederatedResponse>>> FederationMap.requestFederatedData()Methods in org.apache.sysds.runtime.controlprogram.federated with parameters of type FederatedRangeModifier and TypeMethodDescriptionintFederatedRange.compareTo(FederatedRange o) FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest[] frSlices1, FederatedRequest[] frSlices2, FederatedRequest... fr) FederationMap.execute(long tid, boolean wait, FederatedRange[] fedRange1, FederatedRequest elseFr, FederatedRequest frSlice1, FederatedRequest frSlice2, FederatedRequest fr) Method parameters in org.apache.sysds.runtime.controlprogram.federated with type arguments of type FederatedRangeModifier and TypeMethodDescriptionstatic MatrixBlockFederationUtils.aggregateResponses(List<org.apache.commons.lang3.tuple.Pair<FederatedRange, Future<FederatedResponse>>> readResponses) Aggregate partially aggregated data from federated workers by adding values with the same index in different federated locations.static MatrixBlockFederationUtils.bindResponses(List<org.apache.commons.lang3.tuple.Pair<FederatedRange, Future<FederatedResponse>>> readResponses, long[] dims) Bind data from federated workers based on non-overlapping federated ranges.voidFederationMap.forEachParallel(BiFunction<FederatedRange, FederatedData, Void> forEachFunction) Execute a function for eachFederatedRange+FederatedDatapair.FederationMap.mapParallel(long newVarID, BiFunction<FederatedRange, FederatedData, Void> mappingFunction) Execute a function for eachFederatedRange+FederatedDatapair mapping the pairs to their new form by directly changing bothFederatedRangeandFederatedData.Constructors in org.apache.sysds.runtime.controlprogram.federated with parameters of type FederatedRangeModifierConstructorDescriptionFederatedRange(FederatedRange other) Does a deep copy of anotherFederatedRangeobject.FederatedRange(FederatedRange other, long clen) Constructor parameters in org.apache.sysds.runtime.controlprogram.federated with type arguments of type FederatedRangeModifierConstructorDescriptionFederationMap(long ID, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> fedMap) FederationMap(long ID, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> fedMap, FTypes.FType type) FederationMap(List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> fedMap) -
Uses of FederatedRange in org.apache.sysds.runtime.instructions.fed
Method parameters in org.apache.sysds.runtime.instructions.fed with type arguments of type FederatedRangeModifier and TypeMethodDescriptionstatic voidInitFEDInstruction.federateFrame(FrameObject output, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> workers) static voidInitFEDInstruction.federateFrame(FrameObject output, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> workers, CacheBlock<?>[] blocks) static voidInitFEDInstruction.federateMatrix(CacheableData<?> output, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> workers) static voidInitFEDInstruction.federateMatrix(CacheableData<?> output, List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> workers, CacheBlock<?>[] blocks) org.apache.commons.lang3.tuple.Pair<FederationMap,Long> ReorgFEDInstruction.rollFedMap(List<org.apache.commons.lang3.tuple.Pair<FederatedRange, FederatedData>> oldMap, long inID, long outEndID, long outStartID, long shift, long rlen, FTypes.FType type) -
Uses of FederatedRange in org.apache.sysds.runtime.io
Methods in org.apache.sysds.runtime.io that return types with arguments of type FederatedRangeModifier and TypeMethodDescriptionstatic List<org.apache.commons.lang3.tuple.Pair<FederatedRange,FederatedData>> ReaderWriterFederated.read(String file, DataCharacteristics mc) Read a federated map from disk, It is not initialized before it is used in: org.apache.sysds.runtime.instructions.fed.InitFEDInstruction