This module contains the Spark support extension, which allows DJL to be used seamlessly with Apache Spark.
Some key features of the DJL Spark Extension include:
Easy integration with Apache Spark: The DJL Spark Extension provides a simple and intuitive API for integrating DJL with Apache Spark, allowing Java developers to easily use DJL in their Spark applications.
Distributed inference: The DJL Spark Extension allows developers to easily scale their deep learning models to large datasets by leveraging the distributed processing power of Apache Spark.
Support for popular deep learning engines: The DJL Spark Extension provides support for popular deep learning frameworks such as MXNet, PyTorch, TensorFlow and ONNXRuntime, allowing developers to use their preferred framework when working with Spark and DJL.
Support for PySpark: The DJL Spark Extension provides support for PySpark, allowing developers to use DJL in their PySpark applications.
Support for other popular libraries and frameworks: The DJL Spark Extension provides support for other popular libraries and frameworks, such as HuggingFace tokenizers.
The latest javadocs can be found on here.
You can also build the latest javadocs locally using the following command:
./gradlew javadoc
You can pull the module from the central Maven repository by including the following dependency in your pom.xml file:
<dependency>
<groupId>ai.djl.spark</groupId>
<artifactId>spark_2.12</artifactId>
<version>0.27.0</version>
</dependency>
Using the DJL Spark Extension is simple and straightforward. Here is an example of how to use it to run image classification on a large dataset using Apache Spark and DJL:
import ai.djl.spark.task.vision.ImageClassifier
val classifier = new ImageClassifier()
.setInputCols(Array("origin", "height", "width", "nChannels", "mode", "data"))
.setOutputCol("prediction")
.setEngine("PyTorch")
.setModelUrl("djl://ai.djl.pytorch/resnet")
.setTopK(2)
var outputDf = classifier.classify(df)
from djl_spark.task.vision import ImageClassifier
classifier = ImageClassifier(input_cols=["origin", "height", "width", "nChannels", "mode", "data"],
output_col="prediction",
engine="PyTorch",
model_url="djl://ai.djl.pytorch/resnet",
top_k=2)
outputDf = classifier.classify(df)
See examples for more details.