Uploaded image for project: 'Apache Nemo'
  1. Apache Nemo
  2. NEMO-213

Use Beam's DoFnRunners to execute DoFn

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.1

    Description

      Beam provides default implementation for executing DoFns. Using this code can prevent implementing the same functionalities. Also, it supports WindowedValue so we can easily support Beam streaming operations.

      Attachments

        Issue Links

          causes

          Task - A task that needs to be done. NEMO-220 Move PIPELINE variable to TranslationContext in PipelineTranslator

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved
          is a parent of

          Task - A task that needs to be done. NEMO-215 Add beam-runners-core-java package to nemo/compiler/frontend/beam

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved
          is related to

          Umbrella - An overarching type made of sub-tasks NEMO-157 Support Nemo Streaming

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #122

          Activity

            People

              Unassigned Unassigned
              taegeonum Tae-Geon Um
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: