public class MLContextConversionUtil extends Object
Constructor and Description |
---|
MLContextConversionUtil() |
Modifier and Type | Method and Description |
---|---|
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
binaryBlocksToFrameObject(String variableName,
org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> binaryBlocks)
Convert a
JavaPairRDD<Long, FrameBlock> to a FrameObject . |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
binaryBlocksToFrameObject(String variableName,
org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> binaryBlocks,
FrameMetadata frameMetadata)
Convert a
JavaPairRDD<Long, FrameBlock> to a FrameObject . |
static MatrixBlock |
binaryBlocksToMatrixBlock(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> binaryBlocks,
MatrixMetadata matrixMetadata)
Convert a
JavaPairRDD<MatrixIndexes, MatrixBlock> to a
MatrixBlock |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
binaryBlocksToMatrixObject(String variableName,
org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> binaryBlocks)
Convert a
JavaPairRDD<MatrixIndexes, MatrixBlock> to a
MatrixObject . |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
binaryBlocksToMatrixObject(String variableName,
org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> binaryBlocks,
MatrixMetadata matrixMetadata)
Convert a
JavaPairRDD<MatrixIndexes, MatrixBlock> to a
MatrixObject . |
static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> |
dataFrameToFrameBinaryBlocks(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
FrameMetadata frameMetadata)
Convert a
DataFrame to a JavaPairRDD<Long, FrameBlock>
binary-block frame. |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
dataFrameToFrameObject(String variableName,
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)
Convert a
DataFrame to a FrameObject . |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
dataFrameToFrameObject(String variableName,
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
FrameMetadata frameMetadata)
Convert a
DataFrame to a FrameObject . |
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
dataFrameToMatrixBinaryBlocks(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)
Convert a
DataFrame to a
JavaPairRDD<MatrixIndexes, MatrixBlock> binary-block matrix. |
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
dataFrameToMatrixBinaryBlocks(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
MatrixMetadata matrixMetadata)
Convert a
DataFrame to a
JavaPairRDD<MatrixIndexes, MatrixBlock> binary-block matrix. |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
dataFrameToMatrixObject(String variableName,
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)
Convert a
DataFrame to a MatrixObject . |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
dataFrameToMatrixObject(String variableName,
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
MatrixMetadata matrixMetadata)
Convert a
DataFrame to a MatrixObject . |
static void |
determineFrameFormatIfNeeded(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
FrameMetadata frameMetadata)
If the FrameFormat of the DataFrame has not been explicitly specified,
attempt to determine the proper FrameFormat.
|
static void |
determineMatrixFormatIfNeeded(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
MatrixMetadata matrixMetadata)
If the MatrixFormat of the DataFrame has not been explicitly specified,
attempt to determine the proper MatrixFormat.
|
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
doubleMatrixToMatrixObject(String variableName,
double[][] doubleMatrix)
Convert a two-dimensional double array to a
MatrixObject . |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
doubleMatrixToMatrixObject(String variableName,
double[][] doubleMatrix,
MatrixMetadata matrixMetadata)
Convert a two-dimensional double array to a
MatrixObject . |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
frameBlockToFrameObject(String variableName,
FrameBlock frameBlock,
FrameMetadata frameMetadata)
Convert a
FrameBlock to a FrameObject . |
static String[][] |
frameObjectTo2DStringArray(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
Convert a
FrameObject to a two-dimensional string array. |
static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> |
frameObjectToBinaryBlocks(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject,
org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext)
Convert a
FrameObject to a JavaPairRDD<Long, FrameBlock> . |
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> |
frameObjectToDataFrame(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject,
org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext)
Convert a
FrameObject to a DataFrame . |
static org.apache.spark.api.java.JavaRDD<String> |
frameObjectToJavaRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject,
String delimiter)
Convert a
FrameObject to a JavaRDD<String> in CSV format. |
static org.apache.spark.api.java.JavaRDD<String> |
frameObjectToJavaRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
Convert a
FrameObject to a JavaRDD<String> in IJV format. |
static List<String> |
frameObjectToListStringCSV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject,
String delimiter)
Convert a
FrameObject to a List<String> in CSV format. |
static List<String> |
frameObjectToListStringIJV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
Convert a
FrameObject to a List<String> in IJV format. |
static org.apache.spark.rdd.RDD<String> |
frameObjectToRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject,
String delimiter)
Convert a
FrameObject to a RDD<String> in CSV format. |
static org.apache.spark.rdd.RDD<String> |
frameObjectToRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
Convert a
FrameObject to a RDD<String> in IJV format. |
static boolean |
isDataFrameWithIDColumn(FrameMetadata frameMetadata)
Return whether or not the DataFrame has an ID column.
|
static boolean |
isDataFrameWithIDColumn(MatrixMetadata matrixMetadata)
Return whether or not the DataFrame has an ID column.
|
static boolean |
isVectorBasedDataFrame(MatrixMetadata matrixMetadata)
Return whether or not the DataFrame is vector-based.
|
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
javaRDDStringCSVToFrameObject(String variableName,
org.apache.spark.api.java.JavaRDD<String> javaRDD)
Convert a
JavaRDD<String> in CSV format to a FrameObject |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
javaRDDStringCSVToFrameObject(String variableName,
org.apache.spark.api.java.JavaRDD<String> javaRDD,
FrameMetadata frameMetadata)
Convert a
JavaRDD<String> in CSV format to a FrameObject |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
javaRDDStringCSVToMatrixObject(String variableName,
org.apache.spark.api.java.JavaRDD<String> javaRDD)
Convert a
JavaRDD<String> in CSV format to a MatrixObject |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
javaRDDStringCSVToMatrixObject(String variableName,
org.apache.spark.api.java.JavaRDD<String> javaRDD,
MatrixMetadata matrixMetadata)
Convert a
JavaRDD<String> in CSV format to a MatrixObject |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
javaRDDStringIJVToFrameObject(String variableName,
org.apache.spark.api.java.JavaRDD<String> javaRDD,
FrameMetadata frameMetadata)
Convert a
JavaRDD<String> in IJV format to a FrameObject
. |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
javaRDDStringIJVToMatrixObject(String variableName,
org.apache.spark.api.java.JavaRDD<String> javaRDD,
MatrixMetadata matrixMetadata)
Convert a
JavaRDD<String> in IJV format to a MatrixObject
. |
static org.apache.spark.api.java.JavaSparkContext |
jsc()
Obtain JavaSparkContext from MLContextProxy.
|
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
matrixBlockToMatrixObject(String variableName,
MatrixBlock matrixBlock,
MatrixMetadata matrixMetadata)
Convert a
MatrixBlock to a MatrixObject . |
static double[][] |
matrixObjectTo2DDoubleArray(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a two-dimensional double array. |
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
matrixObjectToBinaryBlocks(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject,
org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext)
Convert a
MatrixObject to a
JavaPairRDD<MatrixIndexes, MatrixBlock> . |
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> |
matrixObjectToDataFrame(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject,
org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext,
boolean isVectorDF)
Convert a
MatrixObject to a DataFrame . |
static org.apache.spark.api.java.JavaRDD<String> |
matrixObjectToJavaRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a JavaRDD<String> in CSV
format. |
static org.apache.spark.api.java.JavaRDD<String> |
matrixObjectToJavaRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a JavaRDD<String> in IJV
format. |
static List<String> |
matrixObjectToListStringCSV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a List<String> in CSV format. |
static List<String> |
matrixObjectToListStringIJV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a List<String> in IJV format. |
static org.apache.spark.rdd.RDD<String> |
matrixObjectToRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a RDD<String> in CSV format. |
static org.apache.spark.rdd.RDD<String> |
matrixObjectToRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
Convert a
MatrixObject to a RDD<String> in IJV format. |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
rddStringCSVToFrameObject(String variableName,
org.apache.spark.rdd.RDD<String> rdd)
Convert a
RDD<String> in CSV format to a FrameObject |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
rddStringCSVToFrameObject(String variableName,
org.apache.spark.rdd.RDD<String> rdd,
FrameMetadata frameMetadata)
Convert a
RDD<String> in CSV format to a FrameObject |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
rddStringCSVToMatrixObject(String variableName,
org.apache.spark.rdd.RDD<String> rdd)
Convert a
RDD<String> in CSV format to a MatrixObject |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
rddStringCSVToMatrixObject(String variableName,
org.apache.spark.rdd.RDD<String> rdd,
MatrixMetadata matrixMetadata)
Convert a
RDD<String> in CSV format to a MatrixObject |
static org.apache.sysml.runtime.controlprogram.caching.FrameObject |
rddStringIJVToFrameObject(String variableName,
org.apache.spark.rdd.RDD<String> rdd,
FrameMetadata frameMetadata)
Convert a
RDD<String> in IJV format to a FrameObject . |
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
rddStringIJVToMatrixObject(String variableName,
org.apache.spark.rdd.RDD<String> rdd,
MatrixMetadata matrixMetadata)
Convert a
RDD<String> in IJV format to a MatrixObject . |
static org.apache.spark.SparkContext |
sc()
Obtain SparkContext from MLContextProxy.
|
static org.apache.spark.sql.SparkSession |
spark()
Obtain SparkSession from MLContextProxy.
|
static org.apache.sysml.runtime.controlprogram.caching.MatrixObject |
urlToMatrixObject(String variableName,
URL url,
MatrixMetadata matrixMetadata)
Convert a matrix at a URL to a
MatrixObject . |
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject doubleMatrixToMatrixObject(String variableName, double[][] doubleMatrix)
MatrixObject
.variableName
- name of the variable associated with the matrixdoubleMatrix
- matrix of double valuesMatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject doubleMatrixToMatrixObject(String variableName, double[][] doubleMatrix, MatrixMetadata matrixMetadata)
MatrixObject
.variableName
- name of the variable associated with the matrixdoubleMatrix
- matrix of double valuesmatrixMetadata
- the matrix metadataMatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject urlToMatrixObject(String variableName, URL url, MatrixMetadata matrixMetadata)
MatrixObject
.variableName
- name of the variable associated with the matrixurl
- the URL to a matrix (in CSV or IJV format)matrixMetadata
- the matrix metadataMatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixBlockToMatrixObject(String variableName, MatrixBlock matrixBlock, MatrixMetadata matrixMetadata)
MatrixBlock
to a MatrixObject
.variableName
- name of the variable associated with the matrixmatrixBlock
- matrix as a MatrixBlockmatrixMetadata
- the matrix metadataMatrixBlock
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject frameBlockToFrameObject(String variableName, FrameBlock frameBlock, FrameMetadata frameMetadata)
FrameBlock
to a FrameObject
.variableName
- name of the variable associated with the frameframeBlock
- frame as a FrameBlockframeMetadata
- the frame metadataFrameBlock
converted to a FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject binaryBlocksToMatrixObject(String variableName, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> binaryBlocks)
JavaPairRDD<MatrixIndexes, MatrixBlock>
to a
MatrixObject
.variableName
- name of the variable associated with the matrixbinaryBlocks
- JavaPairRDD<MatrixIndexes, MatrixBlock>
representation
of a binary-block matrixJavaPairRDD<MatrixIndexes, MatrixBlock>
matrix
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject binaryBlocksToMatrixObject(String variableName, org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> binaryBlocks, MatrixMetadata matrixMetadata)
JavaPairRDD<MatrixIndexes, MatrixBlock>
to a
MatrixObject
.variableName
- name of the variable associated with the matrixbinaryBlocks
- JavaPairRDD<MatrixIndexes, MatrixBlock>
representation
of a binary-block matrixmatrixMetadata
- the matrix metadataJavaPairRDD<MatrixIndexes, MatrixBlock>
matrix
converted to a MatrixObject
public static MatrixBlock binaryBlocksToMatrixBlock(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> binaryBlocks, MatrixMetadata matrixMetadata)
JavaPairRDD<MatrixIndexes, MatrixBlock>
to a
MatrixBlock
binaryBlocks
- JavaPairRDD<MatrixIndexes, MatrixBlock>
representation
of a binary-block matrixmatrixMetadata
- the matrix metadataJavaPairRDD<MatrixIndexes, MatrixBlock>
matrix
converted to a MatrixBlock
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject binaryBlocksToFrameObject(String variableName, org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> binaryBlocks)
JavaPairRDD<Long, FrameBlock>
to a FrameObject
.variableName
- name of the variable associated with the framebinaryBlocks
- JavaPairRDD<Long, FrameBlock>
representation of a
binary-block frameJavaPairRDD<Long, FrameBlock>
frame converted to a
FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject binaryBlocksToFrameObject(String variableName, org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> binaryBlocks, FrameMetadata frameMetadata)
JavaPairRDD<Long, FrameBlock>
to a FrameObject
.variableName
- name of the variable associated with the framebinaryBlocks
- JavaPairRDD<Long, FrameBlock>
representation of a
binary-block frameframeMetadata
- the frame metadataJavaPairRDD<Long, FrameBlock>
frame converted to a
FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject dataFrameToMatrixObject(String variableName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)
DataFrame
to a MatrixObject
.variableName
- name of the variable associated with the matrixdataFrame
- the Spark DataFrame
DataFrame
matrix converted to a converted to a
MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject dataFrameToMatrixObject(String variableName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, MatrixMetadata matrixMetadata)
DataFrame
to a MatrixObject
.variableName
- name of the variable associated with the matrixdataFrame
- the Spark DataFrame
matrixMetadata
- the matrix metadataDataFrame
matrix converted to a converted to a
MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject dataFrameToFrameObject(String variableName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)
DataFrame
to a FrameObject
.variableName
- name of the variable associated with the framedataFrame
- the Spark DataFrame
DataFrame
matrix converted to a converted to a
FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject dataFrameToFrameObject(String variableName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, FrameMetadata frameMetadata)
DataFrame
to a FrameObject
.variableName
- name of the variable associated with the framedataFrame
- the Spark DataFrame
frameMetadata
- the frame metadataDataFrame
frame converted to a converted to a
FrameObject
public static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> dataFrameToMatrixBinaryBlocks(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)
DataFrame
to a
JavaPairRDD<MatrixIndexes, MatrixBlock>
binary-block matrix.dataFrame
- the Spark DataFrame
DataFrame
matrix converted to a
JavaPairRDD<MatrixIndexes,
MatrixBlock>
binary-block matrixpublic static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> dataFrameToMatrixBinaryBlocks(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, MatrixMetadata matrixMetadata)
DataFrame
to a
JavaPairRDD<MatrixIndexes, MatrixBlock>
binary-block matrix.dataFrame
- the Spark DataFrame
matrixMetadata
- the matrix metadataDataFrame
matrix converted to a
JavaPairRDD<MatrixIndexes,
MatrixBlock>
binary-block matrixpublic static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> dataFrameToFrameBinaryBlocks(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, FrameMetadata frameMetadata)
DataFrame
to a JavaPairRDD<Long, FrameBlock>
binary-block frame.dataFrame
- the Spark DataFrame
frameMetadata
- the frame metadataDataFrame
matrix converted to a
JavaPairRDD<Long,
FrameBlock>
binary-block framepublic static void determineMatrixFormatIfNeeded(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, MatrixMetadata matrixMetadata)
dataFrame
- the Spark DataFrame
matrixMetadata
- the matrix metadata, if availablepublic static void determineFrameFormatIfNeeded(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, FrameMetadata frameMetadata)
dataFrame
- the Spark DataFrame
frameMetadata
- the frame metadata, if availablepublic static boolean isDataFrameWithIDColumn(MatrixMetadata matrixMetadata)
matrixMetadata
- the matrix metadatatrue
if the DataFrame has an ID column, false
otherwise.public static boolean isDataFrameWithIDColumn(FrameMetadata frameMetadata)
frameMetadata
- the frame metadatatrue
if the DataFrame has an ID column, false
otherwise.public static boolean isVectorBasedDataFrame(MatrixMetadata matrixMetadata)
matrixMetadata
- the matrix metadatatrue
if the DataFrame is vector-based, false
otherwise.public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject javaRDDStringCSVToMatrixObject(String variableName, org.apache.spark.api.java.JavaRDD<String> javaRDD)
JavaRDD<String>
in CSV format to a MatrixObject
variableName
- name of the variable associated with the matrixjavaRDD
- the Java RDD of stringsJavaRDD<String>
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject javaRDDStringCSVToMatrixObject(String variableName, org.apache.spark.api.java.JavaRDD<String> javaRDD, MatrixMetadata matrixMetadata)
JavaRDD<String>
in CSV format to a MatrixObject
variableName
- name of the variable associated with the matrixjavaRDD
- the Java RDD of stringsmatrixMetadata
- matrix metadataJavaRDD<String>
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject javaRDDStringCSVToFrameObject(String variableName, org.apache.spark.api.java.JavaRDD<String> javaRDD)
JavaRDD<String>
in CSV format to a FrameObject
variableName
- name of the variable associated with the framejavaRDD
- the Java RDD of stringsJavaRDD<String>
converted to a FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject javaRDDStringCSVToFrameObject(String variableName, org.apache.spark.api.java.JavaRDD<String> javaRDD, FrameMetadata frameMetadata)
JavaRDD<String>
in CSV format to a FrameObject
variableName
- name of the variable associated with the framejavaRDD
- the Java RDD of stringsframeMetadata
- frame metadataJavaRDD<String>
converted to a FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject javaRDDStringIJVToMatrixObject(String variableName, org.apache.spark.api.java.JavaRDD<String> javaRDD, MatrixMetadata matrixMetadata)
JavaRDD<String>
in IJV format to a MatrixObject
. Note that metadata is required for IJV format.variableName
- name of the variable associated with the matrixjavaRDD
- the Java RDD of stringsmatrixMetadata
- matrix metadataJavaRDD<String>
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject javaRDDStringIJVToFrameObject(String variableName, org.apache.spark.api.java.JavaRDD<String> javaRDD, FrameMetadata frameMetadata)
JavaRDD<String>
in IJV format to a FrameObject
. Note that metadata is required for IJV format.variableName
- name of the variable associated with the framejavaRDD
- the Java RDD of stringsframeMetadata
- frame metadataJavaRDD<String>
converted to a FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject rddStringCSVToMatrixObject(String variableName, org.apache.spark.rdd.RDD<String> rdd)
RDD<String>
in CSV format to a MatrixObject
variableName
- name of the variable associated with the matrixrdd
- the RDD of stringsRDD<String>
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject rddStringCSVToMatrixObject(String variableName, org.apache.spark.rdd.RDD<String> rdd, MatrixMetadata matrixMetadata)
RDD<String>
in CSV format to a MatrixObject
variableName
- name of the variable associated with the matrixrdd
- the RDD of stringsmatrixMetadata
- matrix metadataRDD<String>
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject rddStringCSVToFrameObject(String variableName, org.apache.spark.rdd.RDD<String> rdd)
RDD<String>
in CSV format to a FrameObject
variableName
- name of the variable associated with the framerdd
- the RDD of stringsRDD<String>
converted to a FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject rddStringCSVToFrameObject(String variableName, org.apache.spark.rdd.RDD<String> rdd, FrameMetadata frameMetadata)
RDD<String>
in CSV format to a FrameObject
variableName
- name of the variable associated with the framerdd
- the RDD of stringsframeMetadata
- frame metadataRDD<String>
converted to a FrameObject
public static org.apache.sysml.runtime.controlprogram.caching.MatrixObject rddStringIJVToMatrixObject(String variableName, org.apache.spark.rdd.RDD<String> rdd, MatrixMetadata matrixMetadata)
RDD<String>
in IJV format to a MatrixObject
.
Note that metadata is required for IJV format.variableName
- name of the variable associated with the matrixrdd
- the RDD of stringsmatrixMetadata
- matrix metadataRDD<String>
converted to a MatrixObject
public static org.apache.sysml.runtime.controlprogram.caching.FrameObject rddStringIJVToFrameObject(String variableName, org.apache.spark.rdd.RDD<String> rdd, FrameMetadata frameMetadata)
RDD<String>
in IJV format to a FrameObject
.
Note that metadata is required for IJV format.variableName
- name of the variable associated with the framerdd
- the RDD of stringsframeMetadata
- frame metadataRDD<String>
converted to a FrameObject
public static org.apache.spark.api.java.JavaRDD<String> matrixObjectToJavaRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a JavaRDD<String>
in CSV
format.matrixObject
- the MatrixObject
MatrixObject
converted to a JavaRDD<String>
public static org.apache.spark.api.java.JavaRDD<String> frameObjectToJavaRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject, String delimiter)
FrameObject
to a JavaRDD<String>
in CSV format.frameObject
- the FrameObject
delimiter
- the delimiterFrameObject
converted to a JavaRDD<String>
public static org.apache.spark.api.java.JavaRDD<String> matrixObjectToJavaRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a JavaRDD<String>
in IJV
format.matrixObject
- the MatrixObject
MatrixObject
converted to a JavaRDD<String>
public static org.apache.spark.api.java.JavaRDD<String> frameObjectToJavaRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
FrameObject
to a JavaRDD<String>
in IJV format.frameObject
- the FrameObject
FrameObject
converted to a JavaRDD<String>
public static org.apache.spark.rdd.RDD<String> matrixObjectToRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a RDD<String>
in IJV format.matrixObject
- the MatrixObject
MatrixObject
converted to a RDD<String>
public static org.apache.spark.rdd.RDD<String> frameObjectToRDDStringIJV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
FrameObject
to a RDD<String>
in IJV format.frameObject
- the FrameObject
FrameObject
converted to a RDD<String>
public static org.apache.spark.rdd.RDD<String> matrixObjectToRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a RDD<String>
in CSV format.matrixObject
- the MatrixObject
MatrixObject
converted to a RDD<String>
public static org.apache.spark.rdd.RDD<String> frameObjectToRDDStringCSV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject, String delimiter)
FrameObject
to a RDD<String>
in CSV format.frameObject
- the FrameObject
delimiter
- the delimiterFrameObject
converted to a RDD<String>
public static List<String> matrixObjectToListStringCSV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a List<String>
in CSV format.matrixObject
- the MatrixObject
MatrixObject
converted to a List<String>
public static List<String> frameObjectToListStringCSV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject, String delimiter)
FrameObject
to a List<String>
in CSV format.frameObject
- the FrameObject
delimiter
- the delimiterFrameObject
converted to a List<String>
public static List<String> matrixObjectToListStringIJV(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a List<String>
in IJV format.matrixObject
- the MatrixObject
MatrixObject
converted to a List<String>
public static List<String> frameObjectToListStringIJV(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
FrameObject
to a List<String>
in IJV format.frameObject
- the FrameObject
FrameObject
converted to a List<String>
public static double[][] matrixObjectTo2DDoubleArray(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject)
MatrixObject
to a two-dimensional double array.matrixObject
- the MatrixObject
MatrixObject
converted to a double[][]
public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> matrixObjectToDataFrame(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject, org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext, boolean isVectorDF)
MatrixObject
to a DataFrame
.matrixObject
- the MatrixObject
sparkExecutionContext
- the Spark execution contextisVectorDF
- is the DataFrame a vector DataFrame?MatrixObject
converted to a DataFrame
public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> frameObjectToDataFrame(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject, org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext)
FrameObject
to a DataFrame
.frameObject
- the FrameObject
sparkExecutionContext
- the Spark execution contextFrameObject
converted to a DataFrame
public static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> matrixObjectToBinaryBlocks(org.apache.sysml.runtime.controlprogram.caching.MatrixObject matrixObject, org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext)
MatrixObject
to a
JavaPairRDD<MatrixIndexes, MatrixBlock>
.matrixObject
- the MatrixObject
sparkExecutionContext
- the Spark execution contextMatrixObject
converted to a
JavaPairRDD<MatrixIndexes, MatrixBlock>
public static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> frameObjectToBinaryBlocks(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject, org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sparkExecutionContext)
FrameObject
to a JavaPairRDD<Long, FrameBlock>
.frameObject
- the FrameObject
sparkExecutionContext
- the Spark execution contextFrameObject
converted to a
JavaPairRDD<Long, FrameBlock>
public static String[][] frameObjectTo2DStringArray(org.apache.sysml.runtime.controlprogram.caching.FrameObject frameObject)
FrameObject
to a two-dimensional string array.frameObject
- the FrameObject
FrameObject
converted to a String[][]
public static org.apache.spark.api.java.JavaSparkContext jsc()
public static org.apache.spark.SparkContext sc()
public static org.apache.spark.sql.SparkSession spark()
Copyright © 2017 The Apache Software Foundation. All rights reserved.