Document Vector Hashing Applier Streamable

Creates a document vector for each document using a hash function.

Spark to DB 

Writes a Spark DataFrame/RDD into a database table

Database to Spark Deprecated

Reads a database query/table into a Spark DataFrame/RDD

Document Vector Hashing Streamable

Creates a document vector for each document using a hash function.

Register a New Service Hook 

Moving Average 

Adds a column with moving average values.

Document vector hashing StreamableDeprecated

Creates a document vector for each document using a hash function.

DB to Spark 

Reads a database query/table into a Spark RDD/DataFrame

Time Shifter Streamable

Shifts a time by a duration or granularity.

Row Aggregator Streamable

Aggregate columns.