Flume
  1. Flume
  2. FLUME-949

Collapse PollableSink into Sink interface.

    Details

    • Type: Task Task
    • Status: Resolved
    • Priority: Critical Critical
    • Resolution: Fixed
    • Affects Version/s: v1.0.0
    • Fix Version/s: v1.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.

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

        Issue Links

          Activity

          No work has yet been logged on this issue.

            People

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

              Dates

              • Created:
                Updated:
                Resolved:

                Development