org.datavec.spark.inference.server

Class SparkTransformServer

java.lang.Object

org.datavec.spark.inference.server.SparkTransformServer

All Implemented Interfaces:

DataVecTransformService

Direct Known Subclasses:

CSVSparkTransformServer, ImageSparkTransformServer

public abstract class SparkTransformServer
extends Object
implements DataVecTransformService

Created by kepricon on 17. 6. 20.

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	contentType
protected String	jsonPath
protected static org.nd4j.shade.jackson.databind.ObjectMapper	objectMapper
protected int	port
protected play.server.Server	server

Fields inherited from interface org.datavec.spark.inference.model.service.DataVecTransformService

SEQUENCE_OR_NOT_HEADER

Constructor Summary

Constructors

Constructor and Description
SparkTransformServer()

Method Summary

Modifier and Type	Method and Description
protected String	getJsonText(play.mvc.Http.Request request)
protected boolean	isSequence(play.mvc.Http.Request request)
abstract void	runMain(String[] args)
void	stop() Stop the server
abstract Base64NDArrayBody	transformSequenceArrayIncremental(BatchCSVRecord singleCsvRecord)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.datavec.spark.inference.model.service.DataVecTransformService

getCSVTransformProcess, getImageTransformProcess, setCSVTransformProcess, setImageTransformProcess, transform, transform, transformArray, transformArray, transformArrayIncremental, transformIncremental, transformIncrementalArray, transformSequence, transformSequenceArray, transformSequenceIncremental

Field Detail

jsonPath

protected String jsonPath

port

protected int port

server

protected play.server.Server server

objectMapper

protected static org.nd4j.shade.jackson.databind.ObjectMapper objectMapper

contentType

protected static String contentType

Constructor Detail

SparkTransformServer

public SparkTransformServer()

Method Detail

runMain

public abstract void runMain(String[] args)
                      throws Exception

Throws:

Exception

stop

public void stop()

Stop the server

isSequence

protected boolean isSequence(play.mvc.Http.Request request)

getJsonText

protected String getJsonText(play.mvc.Http.Request request)

transformSequenceArrayIncremental

public abstract Base64NDArrayBody transformSequenceArrayIncremental(BatchCSVRecord singleCsvRecord)

Specified by:

transformSequenceArrayIncremental in interface DataVecTransformService

Returns: