Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-8274 Refactoring SparkPlan and SparkPlanGeneration [Spark Branch]
  3. HIVE-8262

Create CacheTran that transforms the input RDD by caching it [Spark Branch]

Log workAgile BoardRank to TopRank to BottomVotersWatch issueWatchersConvert to IssueMoveLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Won't Fix
    • None
    • None
    • Spark
    • None

    Description

      In a few cases we need to cache a RDD to avoid recompute it for better performance. However, caching a map input RDD is different from caching a regular RDD due to SPARK-3693. The way to cache a Hadoop RDD, which is the input to MapWork, is to cache, the result RDD that is transformed from the original Hadoop RDD by applying a map function, in which <key, value> pairs are copied. To cache intermediate RDDs, such as that from a shuffle, is just calling .cache().

      This task is to create a CacheTran to capture this, which can be used to plug in Spark Plan when caching is desirable.

      Attachments

        1. HIVE-8262.1-spark.patch
          3 kB
          Chao Sun

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            csun Chao Sun Assign to me
            xuefuz Xuefu Zhang
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Issue deployment