All Classes
-
All Classes Interface Summary Class Summary Exception Summary Class Description ApplicationConstants AsyncEventCallback Created by Cloudwick, on 8/6/2017.BaseEvent Baseevent class which contains common properties for all eventsBaseEvent.BaseEventBuilder ConfigurationUtils Provides configuration related utilities common to both the producer and consumer.CredentialUtils Provides utilities for retrieving credentials to talk to AWSDataLakeUtils EventBuilderService EventBuilderServiceImpl EventException Common exception class for all eventsEventRecord<T> Common class definition for sending records to Kinesis Created by BHN, on 9/12/2017.EventSenderService EventSenderServiceImpl GPLKinesisProducer Class to send all source events to Kinesis.GplProperties GPLTemporaryCredentialsProvider AWSCredentialsProvider implementation that uses the AWS Security Token Service to assume a Role and create temporary, short-lived sessions to use for authentication.Header POJO for header, supports JSON serialization and de-serializationInitEvent POJO for InitEvent, supports JSON serialization and de-serializationInitializationException Exception class throwed when source application calls initilaize method more than oncePayload<T> POJO for payload, supports JSON serialization and de-serializationProducer Interface which is the entry point for source application and has all the methods for the source system to ingest events into datalakeProducerFactory Factory class to create different types of producersSiteNotAvailableException Exception class, throwable when site specific properties are not given or invalidSiteReliabilityService SiteReliabilty class to get application specific stream config parametersSourceEvent POJO for SourceEvent, supports JSON serialization and de-serializationSystemUtils TemporaryCredentialsAsyncTask Created by BHN, on 9/12/2017.UninitEvent POJO for UninitEvent, supports JSON serialization and de-serializationUninitializationException Exception class throwed when source application calls uninitilaize method without calling initialize methodProducer.uninitialize()ValidationResult Validator