Automatic functional lifting, mapping and folding.
Joins for skewed datasets in Spark
Scala Aggregators used for ML Model metrics monitoring
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Scala API for distributed closures on Apache Ignite
Spark RDD based implementation of word2phrase algorithm
Library for building data products