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
BasicTensorBlock if written by
TensorBlock.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
BasicTensorBlock inside a TensorBlock . |
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.