org.datavec.spark.transform

Class CSVSparkTransform

java.lang.Object

org.datavec.spark.transform.CSVSparkTransform

public class CSVSparkTransform
extends java.lang.Object

CSVSpark Transform runs the actual TransformProcess

Constructor Summary

Constructors

Constructor and Description
CSVSparkTransform()

Method Summary

Modifier and Type	Method and Description
Base64NDArrayBody	toArray(BatchRecord batch) Convert a raw record via the TransformProcess to a base 64ed ndarray
Base64NDArrayBody	toArray(CSVRecord record) Convert a raw record via the TransformProcess to a base 64ed ndarray
BatchRecord	transform(BatchRecord batch) Runs the transform process for the CSVSparkTransformServer
CSVRecord	transform(CSVRecord record) Runs the transform process for the CSVSparkTransformServer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CSVSparkTransform

public CSVSparkTransform()

Method Detail

toArray

public Base64NDArrayBody toArray(BatchRecord batch)
                          throws java.io.IOException

Convert a raw record via the TransformProcess to a base 64ed ndarray

Parameters:

batch - the record to convert

Returns:

teh base 64ed ndarray

Throws:

java.io.IOException

toArray

public Base64NDArrayBody toArray(CSVRecord record)
                          throws java.io.IOException

Convert a raw record via the TransformProcess to a base 64ed ndarray

Parameters:

record - the record to convert

Returns:

teh base 64ed ndarray

Throws:

java.io.IOException

transform

public BatchRecord transform(BatchRecord batch)

Runs the transform process for the CSVSparkTransformServer

Parameters:

batch - the record to transform

Returns:

the transformed record

transform

public CSVRecord transform(CSVRecord record)

Runs the transform process for the CSVSparkTransformServer

Parameters:

record - the record to transform

Returns:

the transformed record