Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-263 Create SystemConsumer and SystemProducer for HDFS
  3. SAMZA-1034

Support LATEST path and single file as the input of HDFSSystemConsumer

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Incomplete
    • None
    • None
    • None
    • None

    Description

      Right now users have to specify a directory of the HDFS to be consumed. Many other systems support the idea of "LATEST" file/directory. For example, if we have:

      /data/database/db1/snapshot-2016-09-10
      /data/database/db1/snapshot-2016-09-11

      Then "/data/database/db1/#LATEST" will automatically point to "/data/database/db1/snapshot-2016-09-11"

      We want to implement such a feature.

      Plus, we also want to support the consumption of single file.

      Attachments

        Activity

          People

            lhaiesp Hai Lu
            lhaiesp Hai Lu
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: