Architecture Diagrams for /oryxproject/oryx[edit]
Packages / Module oryx-lambda / com.cloudera.oryx.lambda / UpdateOffsetsFn

class UpdateOffsetsFn

Function that reads offset range from latest RDD in a streaming job, and updates Zookeeper/Kafka with the latest offset consumed.
Class fields and methods
class UpdateOffsetsFn
Function that reads offset range from latest RDD in a streaming job, an...
constructor UpdateOffsetsFn(group,inputTopicLockMaster)