Search *

deeplearning4j/datavec

ETL Library for Machine Learning - data pipelines, data munging and wrangling

etl pipeline schema machine-learning spark transformations formatter writables hadoop-ecosystem data-munging svmlight datapipeline

219 162 37

streamnative/pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink

Scala (JVM): 2.11 2.12

flink batch-processing flink-connector catalog schema-registry data-processing apache-pulsar apache-flink pulsar stream-processing sql schema flink-stream-processing

197 83 27

carueda/tscfg

Boilerplate-free, type safe access to configuration properties in Java and Scala

Scala (JVM): 2.11 2.12 2.13

pojo immutable scala configuration typesafe-config java schema typesafe

87 13 6

weso/shaclex

SHACL/ShEx implementation

Scala (JVM): 2.12 2.13 scala3

scala schema earl-report shacl rdf-library shex

65 14 10

samelamin/spark-bigquery

Google BigQuery support for Spark, Structured Streaming, SQL, and DataFrames with easy Databricks integration.

Scala (JVM): 2.11

bigquery data-frame schema spark

63 29 5

durban/seals

Tools for schema evolution and language-integrated schemata

Scala (JVM): 2.10 2.11 2.12 2.13

Sbt: 0.13 1.0

schema-evolution scala generic-programming generic-derivation schema serialization

50 7 3

absaoss/spark-hats

Nested array transformation helper extensions for Apache Spark

Scala (JVM): 2.11 2.12

scala spark nested-structures schema arrays

10 0 3

vectos/formulation

formulation is a EDSL (embedded domain specific language) for describing Avro data types.

Scala (JVM): 2.11 2.12

edsl avro scala schema

7 1 2

carueda/cfg

Type safety all the way from configuration spec to configuration access in Scala

Scala (JVM): 2.11 2.12

typesafe-configuration scala configuration typesafe-config scalameta schema typesafe

3 1 1

Sorting

Filters

deeplearning4j/datavec

streamnative/pulsar-flink

carueda/tscfg

weso/shaclex

samelamin/spark-bigquery

durban/seals

absaoss/spark-hats

vectos/formulation

carueda/cfg