Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-949

Collapse PollableSink into Sink interface.

    Details

    • Type: Task
    • Status: Resolved
    • Priority: Critical
    • Resolution: Fixed
    • Affects Version/s: 1.0.0
    • Fix Version/s: 1.1.0
    • Component/s: None
    • Labels:
      None

      Description

      See the discussion thread:
      http://markmail.org/thread/e5rfcm2mwg54ofjo

      Summary: We do not have any non-pollable sink types and in order to keep the infrastructure and implementation simple, we want to standardize on the pollable sink model. Hence it makes sense to remove the explicit notion of PollableSink and move the process() method directly into the Sink definition.

        Attachments

        1. FLUME-949.patch
          21 kB
          Jarek Jarcec Cecho
        2. FLUME-949.patch
          12 kB
          Jarek Jarcec Cecho

          Issue Links

            Activity

              People

              • Assignee:
                jarcec Jarek Jarcec Cecho
                Reporter:
                aprabhakar Arvind Prabhakar
              • Votes:
                0 Vote for this issue
                Watchers:
                0 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: