Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1067

Physical execution plan for logic expressions written in fluent API

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.13.0
    • None

    Description

      Users can use fluent APIs (from SAMZA-914, SAMZA-915) to describe a logic expression to describe the full stream processing in DAG. We need to define a serializable version of DAG as the physical execution plan s.t. it can be distributed to all jobs and containers be instantiate the Samza processes in a distributed environment.

      Attachments

        1. SAMZA-1067.0.pdf
          62 kB
          Xinyu Liu

        Issue Links

          is depended upon by

          New Feature - A new feature of the product, which has yet to be developed. SAMZA-1130 ApplicationRunner for running StreamApplication

          • Major - Major loss of function.
          • Resolved
          is related to

          Sub-task - The sub-task of the issue SAMZA-561 Translate query plan generated by Calcite to Samza OperatorRouter

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

          Web Link GitHub Pull Request #75

          Activity

            People

              xinyu Xinyu Liu
              nickpan47 Yi Pan
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: