Mock nifi endpoint - writes posted data to disk.

UCFS Claimant Kafka Consumer

Decrypts and delivers mongo exports created by hbase-to-mongo-export

An EMR Security Configuration plugin implementing transparent client-side encryption and decryption between EMR and data persisted in S3 (via EMRFS)

Read from Kafka topic and store in S3

Simple shovel utility to move messages from a Kafka topic to Hbase with versioning

historic_data_loader

corporate_data_loader

Simple kafka queue trawler that lists records on the queue.

The service orchestrator for providing remote access into the analytical environment

Reconciliation to confirm that messages written from Kafka have been successfully written to HBase

Import UC mongo backup into hbase.

Retrieves records from HBase

A repo for dataworks data egress application code

hbase_table_provisioner

Kotlin utility library to be used in Dataworks applications to ensure common logging format.