15 lines (10 loc) · 665 Bytes

java-spark-datasets

Spark Dataset wrapper for Java

Features

creating JavaDataset<T> from JavaRDD<T> or DataSet<T>
support for lambdas in transformations (Java 8+)
KeyValueGroupedDataset support
using Class<?> parameters instead of Encoders.bean(clazz)
local maven repository deployment :)