Uses of Class
org.apache.sysds.runtime.controlprogram.federated.FederationMap
Packages that use FederationMap
Package
Description
-
Uses of FederationMap in org.apache.sysds.runtime.controlprogram.caching
Methods in org.apache.sysds.runtime.controlprogram.caching that return FederationMapModifier and TypeMethodDescriptionCacheableData.getFedMapping()Gets the mapping of indices ranges to federated objects.Methods in org.apache.sysds.runtime.controlprogram.caching with parameters of type FederationMapModifier and TypeMethodDescriptionvoidCacheableData.setFedMapping(FederationMap fedMapping) Sets the mapping of indices ranges to federated objects. -
Uses of FederationMap in org.apache.sysds.runtime.controlprogram.federated
Methods in org.apache.sysds.runtime.controlprogram.federated that return FederationMapModifier and TypeMethodDescriptionFederationMap.bind(long rOffset, long cOffset, FederationMap that) FederationMap.clone()FederationMap.copyWithNewID()Copy the federation map with the next available federated ID as reference to the federated data.FederationMap.copyWithNewID(long id) Copy the federation map with the given ID as reference to the federated data.FederationMap.copyWithNewID(long id, long clen) Copy the federation map with the given ID as reference to the federated data and with given clen as end dimension for the columns in the range.FederationMap.copyWithNewIDAndRange(int[][] ix, long outputID, FTypes.FType type) FederationMap.copyWithNewIDAndRange(long rowRangeEnd, long colRangeEnd, long outputID) Copy federated mapping while giving the federated data new IDs and setting the ranges from zero to row and column ends specified.FederationMap.copyWithNewIDAndRange(long rowRangeEnd, long colRangeEnd, long outputID, FTypes.FType type) static FederationMapFederationUtils.federateLocalData(CacheableData<?> data) FederationMap.filter(IndexRange ixrange) MatrixLineagePair.getFedMapping()FederationMap.identCopy(long tid, long id) 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.FederationMap.modifyFedRanges(long value, int dim) Take the federated mapping and sets one dimension of all federated ranges to the specified value.FederationMap.transpose()Methods in org.apache.sysds.runtime.controlprogram.federated with parameters of type FederationMapModifier and TypeMethodDescriptionstatic MatrixBlockFederationUtils.aggMatrix(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, Future<FederatedResponse>[] meanFfr, FederationMap map) static MatrixBlockFederationUtils.aggMatrix(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, FederationMap map) static MatrixBlockFederationUtils.aggMean(Future<FederatedResponse>[] ffr, FederationMap map) static MatrixBlockFederationUtils.aggMinMaxIndex(Future<FederatedResponse>[] ffr, boolean isMin, FederationMap map) static MatrixBlockFederationUtils.aggProd(Future<FederatedResponse>[] ffr, FederationMap fedMap, AggregateUnaryOperator aop) static ScalarObjectFederationUtils.aggScalar(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, Future<FederatedResponse>[] meanFfr, FederationMap map) static ScalarObjectFederationUtils.aggScalar(AggregateUnaryOperator aop, Future<FederatedResponse>[] ffr, FederationMap map) static MatrixBlockFederationUtils.aggVar(Future<FederatedResponse>[] ffr, Future<FederatedResponse>[] meanFfr, FederationMap map, boolean isRowAggregate, boolean isScalar) FederationMap.bind(long rOffset, long cOffset, FederationMap that) booleanFederationMap.isAligned(FederationMap that, boolean transposed) Determines if the two federation maps are aligned row/column partitions at the same federated sites (which allows for purely federated operation)booleanFederationMap.isAligned(FederationMap that, boolean transposed, boolean equalRows, boolean equalCols) determines if the two federated data are aligned row/column partitions (depending on parameters equalRows/equalCols) at the same federated site (which often allows for purely federated operations)booleanFederationMap.isAligned(FederationMap that, FTypes.AlignType... alignTypes) helper function for checking multiple allowed alignment types -
Uses of FederationMap in org.apache.sysds.runtime.instructions.fed
Methods in org.apache.sysds.runtime.instructions.fed that return types with arguments of type FederationMapModifier and TypeMethodDescriptionorg.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) Methods in org.apache.sysds.runtime.instructions.fed with parameters of type FederationMapModifier and TypeMethodDescriptionstatic voidMultiReturnParameterizedBuiltinFEDInstruction.encodeFederatedFrames(FederationMap fedMapping, MultiColumnEncoder globalencoder, MatrixObject transformedMat) -
Uses of FederationMap in org.apache.sysds.runtime.io
Methods in org.apache.sysds.runtime.io with parameters of type FederationMapModifier and TypeMethodDescriptionstatic voidReaderWriterFederated.write(String file, FederationMap fedMap) TODO add writing to each of the federated locations so that they also save their matrices.