An application that illustrates the use of time-partitioned file sets by the example of periodic stream conversion.
MapReduce job that reads events from a stream over a given time interval and writes the events out to a FileSet in avro format.
Mapper that reads events from a stream and writes them out as Avro.
A workflow that only runs the stream conversion MapReduce.
Copyright © 2018 Cask Data, Inc.. All rights reserved.