| Package | Description | 
|---|---|
| org.apache.sysds.runtime.data | |
| org.apache.sysds.runtime.instructions.spark.functions | |
| org.apache.sysds.runtime.instructions.spark.utils | 
| Modifier and Type | Method and Description | 
|---|---|
| BasicTensorBlock | BasicTensorBlock. aggregateUnaryOperations(AggregateUnaryOperator op,
                        BasicTensorBlock result)Aggregate a unary operation on this tensor. | 
| BasicTensorBlock | BasicTensorBlock. allocateBlock() | 
| BasicTensorBlock | BasicTensorBlock. allocateDenseBlock() | 
| BasicTensorBlock | BasicTensorBlock. copyShallow(BasicTensorBlock that) | 
| BasicTensorBlock | TensorBlock. getBasicTensor() | 
| static BasicTensorBlock | LibTensorReorg. reshape(BasicTensorBlock in,
       BasicTensorBlock out,
       int[] dims)CP reshape operation (single input, single output tensor) | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | LibTensorAgg. aggregateBinaryTensor(BasicTensorBlock in,
                     BasicTensorBlock aggVal,
                     AggregateOperator aop)Core incremental tensor aggregate (ak+) as used for uack+ and acrk+. | 
| BasicTensorBlock | BasicTensorBlock. aggregateUnaryOperations(AggregateUnaryOperator op,
                        BasicTensorBlock result)Aggregate a unary operation on this tensor. | 
| static void | LibTensorAgg. aggregateUnaryTensor(BasicTensorBlock in,
                    BasicTensorBlock out,
                    AggregateUnaryOperator uaop)Aggregate a tensor-block with the given unary operator. | 
| void | BasicTensorBlock. copy(BasicTensorBlock that) | 
| void | BasicTensorBlock. copy(int[] lower,
    int[] upper,
    BasicTensorBlock src)Copy a part of another  BasicTensorBlock | 
| BasicTensorBlock | BasicTensorBlock. copyShallow(BasicTensorBlock that) | 
| long | TensorBlock. getExactBlockDataSerializedSize(BasicTensorBlock bt)Get the exact serialized size of a  BasicTensorBlockif written byTensorBlock.writeBlockData(DataOutput,BasicTensorBlock). | 
| void | BasicTensorBlock. incrementalAggregate(AggregateOperator aggOp,
                    BasicTensorBlock partialResult) | 
| static BasicTensorBlock | LibTensorReorg. reshape(BasicTensorBlock in,
       BasicTensorBlock out,
       int[] dims)CP reshape operation (single input, single output tensor) | 
| static boolean | LibTensorAgg. satisfiesMultiThreadingConstraints(BasicTensorBlock in,
                                  int k)Check if a aggregation fulfills the constraints to be split to multiple threads. | 
| void | BasicTensorBlock. set(BasicTensorBlock other) | 
| void | TensorBlock. writeBlockData(DataOutput out,
              BasicTensorBlock bt)Write a  BasicTensorBlock. | 
| Constructor and Description | 
|---|
| BasicTensorBlock(BasicTensorBlock that) | 
| DataTensorBlock(BasicTensorBlock that) | 
| TensorBlock(BasicTensorBlock basicTensor)Wrap the given  BasicTensorBlockinside aTensorBlock. | 
| Modifier and Type | Method and Description | 
|---|---|
| BasicTensorBlock | CopyTensorBlockFunction. call(BasicTensorBlock arg0) | 
| Modifier and Type | Method and Description | 
|---|---|
| LazyIterableIterator<scala.Tuple2<TensorIndexes,BasicTensorBlock>> | CopyTensorBlockPairFunction. call(Iterator<scala.Tuple2<TensorIndexes,BasicTensorBlock>> arg0) | 
| Modifier and Type | Method and Description | 
|---|---|
| BasicTensorBlock | CopyTensorBlockFunction. call(BasicTensorBlock arg0) | 
| Modifier and Type | Method and Description | 
|---|---|
| LazyIterableIterator<scala.Tuple2<TensorIndexes,BasicTensorBlock>> | CopyTensorBlockPairFunction. call(Iterator<scala.Tuple2<TensorIndexes,BasicTensorBlock>> arg0) | 
| Modifier and Type | Method and Description | 
|---|---|
| static org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> | SparkUtils. copyBinaryBlockTensor(org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> in)Creates a partitioning-preserving deep copy of the input tensor RDD, where
 the indexes and values are copied. | 
| static org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> | SparkUtils. copyBinaryBlockTensor(org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> in,
                     boolean deep)Creates a partitioning-preserving copy of the input tensor RDD. | 
| Modifier and Type | Method and Description | 
|---|---|
| static org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> | SparkUtils. copyBinaryBlockTensor(org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> in)Creates a partitioning-preserving deep copy of the input tensor RDD, where
 the indexes and values are copied. | 
| static org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> | SparkUtils. copyBinaryBlockTensor(org.apache.spark.api.java.JavaPairRDD<TensorIndexes,BasicTensorBlock> in,
                     boolean deep)Creates a partitioning-preserving copy of the input tensor RDD. | 
Copyright © 2020 The Apache Software Foundation. All rights reserved.