Federated¶

class systemds.matrix.Federated(sds_context: systemds.context.systemds_context.SystemDSContext, addresses: Iterable[str], ranges: Iterable[Tuple[Iterable[int], Iterable[int]]], *args, **kwargs: Dict[str, Union[DAGNode, str, int, float, bool]])¶

__init__(sds_context: systemds.context.systemds_context.SystemDSContext, addresses: Iterable[str], ranges: Iterable[Tuple[Iterable[int], Iterable[int]]], *args, **kwargs: Dict[str, Union[DAGNode, str, int, float, bool]]) → systemds.operator.operation_node.OperationNode¶

Create federated matrix object.

Parameters

• sds_context – the SystemDS context

• addresses – addresses of the federated workers

• ranges – for each federated worker a pair of begin and end index of their held matrix

• args – unnamed params

• kwargs – named params

Returns

the OperationNode representing this operation