Uses of Class
org.apache.sysds.runtime.meta.DataCharacteristics
Packages that use DataCharacteristics
Package
Description
-
Uses of DataCharacteristics in org.apache.sysds.api.mlcontext
Constructors in org.apache.sysds.api.mlcontext with parameters of type DataCharacteristicsModifierConstructorDescriptionFrameMetadata(DataCharacteristics dataCharacteristics) Constructor to create a FrameMetadata object based on a DataCharacteristics object.MatrixMetadata(DataCharacteristics dataCharacteristics) Constructor to create a MatrixMetadata object based on a DataCharacteristics object. -
Uses of DataCharacteristics in org.apache.sysds.hops
Methods in org.apache.sysds.hops that return DataCharacteristicsModifier and TypeMethodDescriptionMemoTable.getAllInputStats(List<Hop> inputs) MemoTable.getAllInputStats(Hop input) Hop.getDataCharacteristics()Methods in org.apache.sysds.hops with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic booleanOptimizerUtils.checkSparkCollectMemoryBudget(DataCharacteristics dc, long memPinned) static booleanOptimizerUtils.checkSparkCollectMemoryBudget(DataCharacteristics dc, long memPinned, boolean checkBP) static booleanOptimizerUtils.checkSparseBlockCSRConversion(DataCharacteristics dcIn) static longOptimizerUtils.estimatePartitionedSizeExactSparsity(DataCharacteristics dc) Estimates the footprint (in bytes) for a partitioned in-memory representation of a matrix with the given matrix characteristicsstatic longOptimizerUtils.estimatePartitionedSizeExactSparsity(DataCharacteristics dc, boolean outputEmptyBlocks) static longOptimizerUtils.estimateSize(DataCharacteristics dc) static longOptimizerUtils.estimateSizeExactSparsity(DataCharacteristics dc) static doubleOptimizerUtils.getSparsity(DataCharacteristics dc) static booleanOptimizerUtils.isIndexingRangeBlockAligned(IndexRange ixrange, DataCharacteristics mc) Indicates if the given indexing range is block aligned, i.e., it does not require global aggregation of blocks.static booleanOptimizerUtils.isValidCPDimensions(DataCharacteristics mc) voidMemoTable.memoizeStatistics(long hopID, DataCharacteristics dc) -
Uses of DataCharacteristics in org.apache.sysds.hops.estim
Methods in org.apache.sysds.hops.estim that return DataCharacteristicsModifier and TypeMethodDescriptionstatic DataCharacteristicsEstimatorMatrixHistogram.MatrixHistogram.deriveOutputCharacteristics(EstimatorMatrixHistogram.MatrixHistogram h1, EstimatorMatrixHistogram.MatrixHistogram h2, double spOut, SparsityEstimator.OpCode op, long[] misc) static DataCharacteristicsEstimatorRowWise.deriveOutputCharacteristics(MMNode node, double spOut) abstract DataCharacteristicsEstimates the output sparsity of a DAG of matrix multiplications for the given operator graph of a single root node.MMNode.getDataCharacteristics()MMNode.setDataCharacteristics(DataCharacteristics mc) Methods in org.apache.sysds.hops.estim with parameters of type DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.hops.recompile
Methods in org.apache.sysds.hops.recompile that return types with arguments of type DataCharacteristicsMethods in org.apache.sysds.hops.recompile with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic booleanRecompiler.checkCPCheckpoint(DataCharacteristics dc) -
Uses of DataCharacteristics in org.apache.sysds.hops.rewrite
Methods in org.apache.sysds.hops.rewrite with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic longHopRewriteUtils.getMaxInputDim(DataCharacteristics[] dc, boolean dim1) static longHopRewriteUtils.getSumValidInputDims(DataCharacteristics[] mc, boolean dim1) static longHopRewriteUtils.getSumValidInputNnz(DataCharacteristics[] mc, boolean worstcase) static booleanHopRewriteUtils.hasValidInputDims(DataCharacteristics[] mc, boolean dim1) static booleanHopRewriteUtils.hasValidInputNnz(DataCharacteristics[] mc, boolean worstcase) -
Uses of DataCharacteristics in org.apache.sysds.lops
Methods in org.apache.sysds.lops with parameters of type DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.resource.cost
Constructors in org.apache.sysds.resource.cost with parameters of type DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.runtime.compress.io
Methods in org.apache.sysds.runtime.compress.io with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic voidWriterCompressed.writeRDDToHDFS(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> src, String path, int blen, DataCharacteristics mc) -
Uses of DataCharacteristics in org.apache.sysds.runtime.controlprogram
Methods in org.apache.sysds.runtime.controlprogram with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionlongParForProgramBlock.PartitionFormat.getNumColumns(DataCharacteristics mc) longParForProgramBlock.PartitionFormat.getNumParts(DataCharacteristics mc) longParForProgramBlock.PartitionFormat.getNumRows(DataCharacteristics mc) -
Uses of DataCharacteristics in org.apache.sysds.runtime.controlprogram.caching
Methods in org.apache.sysds.runtime.controlprogram.caching that return DataCharacteristicsModifier and TypeMethodDescriptionCacheableData.getDataCharacteristics()CacheBlock.getDataCharacteristics()Methods in org.apache.sysds.runtime.controlprogram.caching with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionvoidMatrixObject.updateDataCharacteristics(DataCharacteristics dc) -
Uses of DataCharacteristics in org.apache.sysds.runtime.controlprogram.context
Methods in org.apache.sysds.runtime.controlprogram.context that return DataCharacteristicsMethods in org.apache.sysds.runtime.controlprogram.context with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic FrameObjectExecutionContext.createFrameObject(DataCharacteristics dc) static MatrixObjectExecutionContext.createMatrixObject(DataCharacteristics dc) static TensorBlockSparkExecutionContext.toTensorBlock(org.apache.spark.api.java.JavaPairRDD<TensorIndexes, TensorBlock> rdd, DataCharacteristics dc) -
Uses of DataCharacteristics in org.apache.sysds.runtime.controlprogram.federated
Methods in org.apache.sysds.runtime.controlprogram.federated that return DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.runtime.controlprogram.parfor
Constructors in org.apache.sysds.runtime.controlprogram.parfor with parameters of type DataCharacteristicsModifierConstructorDescriptionDataPartitionerRemoteSparkMapper(DataCharacteristics mc, Types.FileFormat fmt, ParForProgramBlock.PDataPartitionFormat dpf, int n) RemoteDPParForSparkWorker(String program, boolean isLocal, HashMap<String, byte[]> clsMap, String inputVar, String iterVar, boolean cpCaching, DataCharacteristics mc, boolean tSparseCol, ParForProgramBlock.PartitionFormat dpf, Types.FileFormat fmt, org.apache.spark.util.LongAccumulator atasks, org.apache.spark.util.LongAccumulator aiters) -
Uses of DataCharacteristics in org.apache.sysds.runtime.data
Methods in org.apache.sysds.runtime.data that return DataCharacteristicsMethods in org.apache.sysds.runtime.data with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic List<IndexedTensorBlock>LibTensorReorg.reshape(IndexedTensorBlock in, DataCharacteristics mcIn, DataCharacteristics mcOut, boolean rowwise, boolean outputEmptyBlocks) MR/SPARK reshape interface - for reshape we cannot view blocks independently, and hence, there are different CP and MR interfaces. -
Uses of DataCharacteristics in org.apache.sysds.runtime.frame.data
Methods in org.apache.sysds.runtime.frame.data that return DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.runtime.functionobjects
Methods in org.apache.sysds.runtime.functionobjects with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionbooleanDiagIndex.computeDimension(DataCharacteristics in, DataCharacteristics out) abstract booleanIndexFunction.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanOffsetColumnIndex.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanReduceAll.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanReduceCol.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanReduceDiag.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanReduceRow.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanRevIndex.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanRollIndex.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanSortIndex.computeDimension(DataCharacteristics in, DataCharacteristics out) booleanSwapIndex.computeDimension(DataCharacteristics in, DataCharacteristics out) -
Uses of DataCharacteristics in org.apache.sysds.runtime.instructions.cp
Methods in org.apache.sysds.runtime.instructions.cp that return DataCharacteristicsMethods in org.apache.sysds.runtime.instructions.cp with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic InstructionVariableCPInstruction.prepCreatevarInstruction(String varName, String fileName, boolean fNameOverride, Types.DataType dt, String format, DataCharacteristics mc, MatrixObject.UpdateType update) static InstructionVariableCPInstruction.prepCreatevarInstruction(String varName, String fileName, boolean fNameOverride, Types.DataType dt, String format, DataCharacteristics mc, MatrixObject.UpdateType update, boolean hasHeader, String delim, boolean sparse) voidConstructors in org.apache.sysds.runtime.instructions.cp with parameters of type DataCharacteristicsModifierConstructorDescriptionCiphertextMatrix(int[] dims, DataCharacteristics dc, byte[] data) Encrypted(int[] dims, DataCharacteristics dc, byte[] data, Types.DataType dt) PlaintextMatrix(int[] dims, DataCharacteristics dc, byte[] data) -
Uses of DataCharacteristics in org.apache.sysds.runtime.instructions.ooc
Methods in org.apache.sysds.runtime.instructions.ooc that return DataCharacteristicsModifier and TypeMethodDescriptionCachingStream.getDataCharacteristics()OOCStreamable.getDataCharacteristics()PlaybackStream.getDataCharacteristics()SubscribableTaskQueue.getDataCharacteristics() -
Uses of DataCharacteristics in org.apache.sysds.runtime.instructions.spark
Methods in org.apache.sysds.runtime.instructions.spark with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic MatrixBlockMatrixIndexingSPInstruction.inmemoryIndexing(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in1, DataCharacteristics mcIn, DataCharacteristics mcOut, IndexRange ixrange) static booleanMatrixIndexingSPInstruction.isMultiBlockLookup(org.apache.spark.api.java.JavaPairRDD<?, ?> in, DataCharacteristics mcIn, DataCharacteristics mcOut, IndexRange ixrange) Indicates if the given index range and input matrix exhibit the following properties: (1) existing hash partitioner, (2) out-of-core input matrix (larger than aggregated memory), (3) aligned indexing range (which does not required aggregation), and (4) the output fits twice in memory (in order to collect the result).static booleanMatrixIndexingSPInstruction.isSingleBlockLookup(DataCharacteristics mcIn, IndexRange ixrange) Indicates if the given index range only covers a single blocks of the inputs matrix.voidParameterizedBuiltinSPInstruction.setOutputCharacteristicsForGroupedAgg(DataCharacteristics mc1, DataCharacteristics mcOut, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixCell> out) Constructors in org.apache.sysds.runtime.instructions.spark with parameters of type DataCharacteristicsModifierConstructorDescriptionMergeWithShiftedBlocks(DataCharacteristics mc1, DataCharacteristics mc2, boolean cbind) ShiftMatrix(DataCharacteristics mc1, DataCharacteristics mc2, boolean cbind) -
Uses of DataCharacteristics in org.apache.sysds.runtime.instructions.spark.data
Methods in org.apache.sysds.runtime.instructions.spark.data that return DataCharacteristicsModifier and TypeMethodDescriptionPartitionedBroadcast.getDataCharacteristics()RDDObject.getDataCharacteristics()Methods in org.apache.sysds.runtime.instructions.spark.data with parameters of type DataCharacteristicsConstructors in org.apache.sysds.runtime.instructions.spark.data with parameters of type DataCharacteristicsModifierConstructorDescriptionBlockPartitioner(DataCharacteristics mc, int numParts) PartitionedBroadcast(org.apache.spark.broadcast.Broadcast<PartitionedBlock<T>>[] broadcasts, DataCharacteristics dc) -
Uses of DataCharacteristics in org.apache.sysds.runtime.instructions.spark.functions
Constructors in org.apache.sysds.runtime.instructions.spark.functions with parameters of type DataCharacteristicsModifierConstructorDescriptionIsBlockInList(long[] cols, DataCharacteristics mc) IsBlockInRange(long rl, long ru, long cl, long cu, DataCharacteristics mc) IsFrameBlockInRange(long rl, long ru, DataCharacteristics mcOut) -
Uses of DataCharacteristics in org.apache.sysds.runtime.instructions.spark.utils
Methods in org.apache.sysds.runtime.instructions.spark.utils that return DataCharacteristicsModifier and TypeMethodDescriptionstatic DataCharacteristicsSparkUtils.computeDataCharacteristics(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixCell> input) Utility to compute dimensions and non-zeros in a given RDD of binary cells.Methods in org.apache.sysds.runtime.instructions.spark.utils with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.binaryBlockToBinaryBlock(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, DataCharacteristics mcIn, DataCharacteristics mcOut) static org.apache.spark.api.java.JavaRDD<String>FrameRDDConverterUtils.binaryBlockToCsv(org.apache.spark.api.java.JavaPairRDD<Long, FrameBlock> in, DataCharacteristics mcIn, FileFormatPropertiesCSV props, boolean strict) static org.apache.spark.api.java.JavaRDD<String>RDDConverterUtils.binaryBlockToCsv(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, DataCharacteristics mcIn, FileFormatPropertiesCSV props, boolean strict) static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>FrameRDDConverterUtils.binaryBlockToDataFrame(org.apache.spark.sql.SparkSession sparkSession, org.apache.spark.api.java.JavaPairRDD<Long, FrameBlock> in, DataCharacteristics mc, Types.ValueType[] schema) static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>FrameRDDConverterUtils.binaryBlockToDataFrame(org.apache.spark.sql.SQLContext sqlContext, org.apache.spark.api.java.JavaPairRDD<Long, FrameBlock> in, DataCharacteristics mc, Types.ValueType[] schema) Deprecated.static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>RDDConverterUtils.binaryBlockToDataFrame(org.apache.spark.sql.SparkSession sparkSession, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, DataCharacteristics mc, boolean toVector) static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>RDDConverterUtils.binaryBlockToDataFrame(org.apache.spark.sql.SQLContext sqlContext, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, DataCharacteristics mc, boolean toVector) Deprecated.static org.apache.spark.api.java.JavaRDD<String>RDDConverterUtils.binaryBlockToLibsvm(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, DataCharacteristics mcIn, FileFormatPropertiesLIBSVM props, boolean strict) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> FrameRDDConverterUtils.binaryBlockToMatrixBlock(org.apache.spark.api.java.JavaPairRDD<Long, FrameBlock> input, DataCharacteristics mcIn, DataCharacteristics mcOut) static org.apache.spark.api.java.JavaRDD<String>FrameRDDConverterUtils.binaryBlockToTextCell(org.apache.spark.api.java.JavaPairRDD<Long, FrameBlock> input, DataCharacteristics mcIn) static org.apache.spark.api.java.JavaRDD<String>RDDConverterUtils.binaryBlockToTextCell(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, DataCharacteristics mc) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.binaryCellToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixCell> input, DataCharacteristics mcOut, boolean outputEmptyBlocks) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtilsExt.coordinateMatrixToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.mllib.linalg.distributed.CoordinateMatrix input, DataCharacteristics mcIn, boolean outputEmptyBlocks) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtilsExt.coordinateMatrixToBinaryBlock(org.apache.spark.SparkContext sc, org.apache.spark.mllib.linalg.distributed.CoordinateMatrix input, DataCharacteristics mcIn, boolean outputEmptyBlocks) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.csvToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.LongWritable, org.apache.hadoop.io.Text> input, DataCharacteristics mc, Types.ValueType[] schema, boolean hasHeader, String delim, boolean fill, double fillValue, Set<String> naStrings) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.csvToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaRDD<String> input, DataCharacteristics mcOut, Types.ValueType[] schema, boolean hasHeader, String delim, boolean fill, double fillValue, Set<String> naStrings) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.csvToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.LongWritable, org.apache.hadoop.io.Text> input, DataCharacteristics mc, boolean hasHeader, String delim, boolean fill, double fillValue, Set<String> naStrings) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.csvToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaRDD<String> input, DataCharacteristics mcOut, boolean hasHeader, String delim, boolean fill, double fillValue, Set<String> naStrings) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.dataFrameToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> df, DataCharacteristics mc, boolean containsID) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.dataFrameToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> df, DataCharacteristics mc, boolean containsID, Pair<String[], Types.ValueType[]> out) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.dataFrameToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> df, DataCharacteristics mc, boolean containsID, boolean isVector) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> SparkUtils.getEmptyBlockRDD(org.apache.spark.api.java.JavaSparkContext sc, DataCharacteristics mc) Creates an RDD of empty blocks according to the given matrix characteristics.static intSparkUtils.getNumPreferredPartitions(DataCharacteristics dc) static intSparkUtils.getNumPreferredPartitions(DataCharacteristics dc, boolean outputEmptyBlocks) static intSparkUtils.getNumPreferredPartitions(DataCharacteristics dc, org.apache.spark.api.java.JavaPairRDD<?, ?> in) static voidRDDConverterUtils.libsvmToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, String pathIn, String pathX, String pathY, DataCharacteristics mcOutX) Converts a libsvm text input file into two binary block matrices for features and labels, and saves these to the specified output files.static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.libsvmToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.LongWritable, org.apache.hadoop.io.Text> input, DataCharacteristics mc, String delim, String indexDelim) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.matrixBlockToAlignedMatrixBlock(org.apache.spark.api.java.JavaPairRDD<Long, MatrixBlock> input, DataCharacteristics mcIn, DataCharacteristics mcOut) static org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.LongWritable,FrameBlock> FrameRDDConverterUtils.matrixBlockToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> input, DataCharacteristics mcIn) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.matrixBlockToBinaryBlockLongIndex(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> input, DataCharacteristics dcIn) static voidSparkUtils.postprocessUltraSparseOutput(MatrixObject mo, DataCharacteristics mcOut) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.textCellToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.LongWritable, org.apache.hadoop.io.Text> in, DataCharacteristics mcOut, Types.ValueType[] schema) static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> RDDConverterUtils.textCellToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.LongWritable, org.apache.hadoop.io.Text> input, DataCharacteristics mcOut, boolean outputEmptyBlocks, FileFormatPropertiesMM mmProps) static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> FrameRDDConverterUtils.textCellToBinaryBlockLongIndex(org.apache.spark.api.java.JavaSparkContext sc, org.apache.spark.api.java.JavaPairRDD<Long, org.apache.hadoop.io.Text> input, DataCharacteristics mc, Types.ValueType[] schema) Constructors in org.apache.sysds.runtime.instructions.spark.utils with parameters of type DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.runtime.io
Methods in org.apache.sysds.runtime.io with parameters of type DataCharacteristicsModifier 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 -
Uses of DataCharacteristics in org.apache.sysds.runtime.lineage
Methods in org.apache.sysds.runtime.lineage that return DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.runtime.matrix.data
Methods in org.apache.sysds.runtime.matrix.data that return DataCharacteristicsMethods in org.apache.sysds.runtime.matrix.data with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic longMatrixBlock.estimateSizeInMemory(DataCharacteristics dc) static booleanMatrixBlock.evalSparseFormatInMemory(DataCharacteristics dc) static List<IndexedMatrixValue>LibMatrixReorg.reshape(IndexedMatrixValue in, DataCharacteristics mcIn, DataCharacteristics mcOut, boolean rowwise, boolean outputEmptyBlocks) MR/SPARK reshape interface - for reshape we cannot view blocks independently, and hence, there are different CP and MR interfaces. -
Uses of DataCharacteristics in org.apache.sysds.runtime.meta
Subclasses of DataCharacteristics in org.apache.sysds.runtime.metaMethods in org.apache.sysds.runtime.meta that return DataCharacteristicsModifier and TypeMethodDescriptionMetaData.getDataCharacteristics()MetaDataAll.getDataCharacteristics()abstract DataCharacteristicsDataCharacteristics.set(long[] dims, int blocksize) abstract DataCharacteristicsDataCharacteristics.set(long[] dims, int blocksize, long nnz) abstract DataCharacteristicsDataCharacteristics.set(long nr, long nc, int blen) abstract DataCharacteristicsDataCharacteristics.set(long nr, long nc, int blen, long nnz) abstract DataCharacteristicsDataCharacteristics.set(DataCharacteristics that) MatrixCharacteristics.set(long[] dims, int blocksize) MatrixCharacteristics.set(long[] dims, int blocksize, long nnz) MatrixCharacteristics.set(long nr, long nc, int blen) MatrixCharacteristics.set(long nr, long nc, int blen, long nnz) MatrixCharacteristics.set(DataCharacteristics that) TensorCharacteristics.set(long[] dims, int blocksize) TensorCharacteristics.set(long[] dims, int blocksize, long nnz) TensorCharacteristics.set(long nr, long nc, int blen) TensorCharacteristics.set(long nr, long nc, int blen, long nnz) TensorCharacteristics.set(DataCharacteristics that) DataCharacteristics.setBlocksize(int blen) abstract DataCharacteristicsDataCharacteristics.setCols(long clen) MatrixCharacteristics.setCols(long clen) TensorCharacteristics.setCols(long clen) abstract DataCharacteristicsDataCharacteristics.setDim(int i, long dim) MatrixCharacteristics.setDim(int i, long dim) TensorCharacteristics.setDim(int i, long dim) abstract DataCharacteristicsDataCharacteristics.setDimension(long nr, long nc) MatrixCharacteristics.setDimension(long nr, long nc) TensorCharacteristics.setDimension(long nr, long nc) abstract DataCharacteristicsDataCharacteristics.setDims(long[] dims) MatrixCharacteristics.setDims(long[] dims) TensorCharacteristics.setDims(long[] dims) DataCharacteristics.setNoEmptyBlocks(boolean flag) abstract DataCharacteristicsDataCharacteristics.setNonZeros(long nnz) MatrixCharacteristics.setNonZeros(long nnz) TensorCharacteristics.setNonZeros(long nnz) abstract DataCharacteristicsDataCharacteristics.setNonZerosBound(long nnz) MatrixCharacteristics.setNonZerosBound(long nnz) TensorCharacteristics.setNonZerosBound(long nnz) abstract DataCharacteristicsDataCharacteristics.setRows(long rlen) MatrixCharacteristics.setRows(long rlen) TensorCharacteristics.setRows(long rlen) Methods in org.apache.sysds.runtime.meta with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionabstract DataCharacteristicsDataCharacteristics.set(DataCharacteristics that) MatrixCharacteristics.set(DataCharacteristics that) TensorCharacteristics.set(DataCharacteristics that) static voidMetaDataUtils.updateAppendDataCharacteristics(DataCharacteristics mc1, DataCharacteristics mc2, DataCharacteristics mcOut, boolean cbind) Constructors in org.apache.sysds.runtime.meta with parameters of type DataCharacteristicsModifierConstructorDescription -
Uses of DataCharacteristics in org.apache.sysds.runtime.ooc.stream
Methods in org.apache.sysds.runtime.ooc.stream that return DataCharacteristicsModifier and TypeMethodDescriptionFilteredOOCStream.getDataCharacteristics()MergedOOCStream.getDataCharacteristics()SourceOOCStreamable.getDataCharacteristics()SplittingOOCStream.getDataCharacteristics()SubOOCStream.getDataCharacteristics() -
Uses of DataCharacteristics in org.apache.sysds.runtime.ooc.util
Methods in org.apache.sysds.runtime.ooc.util with parameters of type DataCharacteristics -
Uses of DataCharacteristics in org.apache.sysds.runtime.util
Methods in org.apache.sysds.runtime.util with parameters of type DataCharacteristicsModifier and TypeMethodDescriptionstatic IndexedMatrixValueUtilFunctions.createIndexedMatrixBlock(MatrixBlock mb, DataCharacteristics mc, long ix) static StringHDFSTool.metaDataToString(Types.ValueType vt, Types.ValueType[] schema, Types.DataType dt, DataCharacteristics dc, Types.FileFormat fmt, FileFormatProperties formatProperties) static StringHDFSTool.metaDataToString(Types.ValueType vt, Types.ValueType[] schema, Types.DataType dt, DataCharacteristics dc, Types.FileFormat fmt, FileFormatProperties formatProperties, String privacyConstraints) static voidDataConverter.writeMatrixToHDFS(MatrixBlock mat, String dir, Types.FileFormat fmt, DataCharacteristics dc) static voidDataConverter.writeMatrixToHDFS(MatrixBlock mat, String dir, Types.FileFormat fmt, DataCharacteristics dc, int replication, FileFormatProperties formatProperties) static voidDataConverter.writeMatrixToHDFS(MatrixBlock mat, String dir, Types.FileFormat fmt, DataCharacteristics dc, int replication, FileFormatProperties formatProperties, boolean diag) static voidHDFSTool.writeMetaDataFile(String mtdfile, Types.ValueType vt, Types.ValueType[] schema, Types.DataType dt, DataCharacteristics mc, Types.FileFormat fmt) static voidHDFSTool.writeMetaDataFile(String mtdfile, Types.ValueType vt, Types.ValueType[] schema, Types.DataType dt, DataCharacteristics dc, Types.FileFormat fmt, FileFormatProperties formatProperties) static voidHDFSTool.writeMetaDataFile(String mtdfile, Types.ValueType vt, Types.ValueType[] schema, Types.DataType dt, DataCharacteristics dc, Types.FileFormat fmt, FileFormatProperties formatProperties, String privacyConstraints) static voidHDFSTool.writeMetaDataFile(String mtdfile, Types.ValueType vt, DataCharacteristics mc, Types.FileFormat fmt) static voidHDFSTool.writeMetaDataFile(String mtdfile, Types.ValueType vt, DataCharacteristics dc, Types.FileFormat fmt, FileFormatProperties formatProperties) static voidHDFSTool.writeMetaDataFileFrame(String mtdfile, Types.ValueType[] schema, DataCharacteristics dc, Types.FileFormat fmt) static voidDataConverter.writeTensorToHDFS(TensorBlock tensor, String dir, Types.FileFormat fmt, DataCharacteristics dc)