Group: com.hotels.road - All Dependencies

Utility classes for Offramp integration with Kafka

S3 library for the creation and manipulation of Data Highway Hive tables in the Hive metastore.

Weigh Bridge module of Data Highway

Common class related to UserAgent

Utility class for Truck Park integration testing

Application that consumes a batch of a road's data from Kafka up to a given set of partition offsets and stream it to S3 in Avro format.

Data Highway agent for managing Kafka.

Data Highway agent to back up road models to S3

Data Highway agent to apply patches of road models

Data Highway module that applies updates to road models.

Mock up of Data Highway core which mocks Kafka in-memory

Data Highway edge service to perform operation on road models

The Data Highway is a service that allows data to be easily landed and consumed via REST interfaces which accept and produce JSON messages. The data is first defined using a schema and a "road" is created which will accept data messages that conform to this schema. Producers of data sets thus only need to define the structure of their data and are then able to send their data to a REST endpoint and not be too concerned with what happens next. The Data Highway will ensure that this data is made available for downstream streaming consumption and also stored reliably in a "data lake" in the cloud for access by various end users.

Data Highway edge service to load data to Kafka

Offramp integration tests

Data Highway edge consumer service

Common classes for notifications of Data Highway events

Functionality for Data Highway state representation

Data Highway agent for managing the landing of road data to S3 and Hive.

Loading bay agent of Data Highway for the creation and manipulation of Data Highway Hive tables in the Hive metastore.

Kafka Offset Metrics module of Data Highway to monitor Kafka Offsets

Utilities for the creation and manipulation of Data Highway Hive tables in the Hive metastore.

Highway Patrol of Data Highway that monitors service level

Utilities for health checking Kafka