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

Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.12.0
    • 0.14.0
    • None

    Description

      There are a few reasons for that:

      1. it helps to keep the logic StreamGraphImpl only refers to logic stream (i.e. the physical stream properties should be populated by physical ExecutionEnvironment)
      2. it helps to keep the OperatorSpec for sendTo() only containing spec info, not physical implementation, which allows us to swap in collection-based or file-based streams sendTo() function w/o the user program change

      Attachments

        Issue Links

          Is contained by

          Bug - A problem which impairs or prevents the functions of the product. SAMZA-1221 Simplify MessageStreamImpl and OperatorSpec graphs and traversals

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              pmaheshwari Prateek Maheshwari
              nickpan47 Yi Pan
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: