Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-6999

Add streaming mode to PTFs

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.11.0, 0.12.0, 0.13.0
    • 0.14.0
    • None

    Description

      There are a set of use cases where the Table Function can operate on a Partition row by row or on a subset(window) of rows as it is being streamed to it.

      • Windowing has couple of use cases of this:processing of Rank functions, processing of Window Aggregations.
      • But this is a generic concept: any analysis that operates on an Ordered partition maybe able to operate in Streaming mode.

      This patch introduces streaming mode in PTFs and provides the mechanics to handle PTF chains that contain both modes of PTFs.
      Subsequent patches will introduce Streaming mode for Windowing.

      Attachments

        1. HIVE-6999.1.patch
          71 kB
          Harish Butani
        2. HIVE-6999.2.patch
          73 kB
          Harish Butani
        3. HIVE-6999.3.patch
          73 kB
          Harish Butani
        4. HIVE-6999.4.patch
          73 kB
          Brock Noland
        5. HIVE-6999.4.patch
          73 kB
          Harish Butani

        Issue Links

          Activity

            People

              rhbutani Harish Butani
              rhbutani Harish Butani
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: