Contains utility methods for finding latest message id to process from and also construct
Copy of Notification, used to deserialize from message and get the program properties
Class used to deserialize artifactId from ProgramDescriptor
Program run fields
Fields provided at program start
Maintains map of namespace to output stream and handles operations to add, flush, sync to stream and closing during cleanup.
log warning with interval count
spark main class, starts and waits for the tms subscriber thread to read run record meta and write to files
Transfer records from programstatusrecordevent topic to files
The type of the notification.
Copyright © 2018 Cask Data, Inc.. All rights reserved.