Uploaded image for project: 'Mahout'
  1. Mahout
  2. MAHOUT-1701

Mahout DSL for Flink: implement AtB ABt and AtA operators

    Details

    • Type: Task
    • Status: Closed
    • Priority: Minor
    • Resolution: Implemented
    • Affects Version/s: 0.11.0
    • Fix Version/s: 0.12.0
    • Component/s: None
    • Labels:

      Description

      as a part of MAHOUT-1570 implement the following operators on Flink:

      • AtB
      • ABt
      • AtA

        Issue Links

          Activity

          Hide
          agrigorev Alexey Grigorev added a comment -

          AtB is implemented at https://github.com/alexeygrigorev/mahout/commit/42228d16cf3feabb49beba592bf7299de72637de

          ABt and AtA for now are expressed in terms of AtB

          Show
          agrigorev Alexey Grigorev added a comment - AtB is implemented at https://github.com/alexeygrigorev/mahout/commit/42228d16cf3feabb49beba592bf7299de72637de ABt and AtA for now are expressed in terms of AtB
          Hide
          dlyubimov Dmitriy Lyubimov added a comment -

          Alexey,

          Thank you for doing this!

          next week i will start submitting PRs for distributed bug fixes and new physical operators, there are somewhat a lot of changes there on spark side, maybe it will give you an idea what did not work so well with the existing code base, in case you were more or less closely porting it.

          Show
          dlyubimov Dmitriy Lyubimov added a comment - Alexey, Thank you for doing this! next week i will start submitting PRs for distributed bug fixes and new physical operators, there are somewhat a lot of changes there on spark side, maybe it will give you an idea what did not work so well with the existing code base, in case you were more or less closely porting it.
          Hide
          dlyubimov Dmitriy Lyubimov added a comment -

          BTW incredibly clean Scala & DSL code! I enjoyed reading it.

          Show
          dlyubimov Dmitriy Lyubimov added a comment - BTW incredibly clean Scala & DSL code! I enjoyed reading it.
          Hide
          smarthi Suneel Marthi added a comment -

          Marking this as 'Resolved' .

          Show
          smarthi Suneel Marthi added a comment - Marking this as 'Resolved' .
          Hide
          dlyubimov Dmitriy Lyubimov added a comment -

          bulk-closing resolved issues

          Show
          dlyubimov Dmitriy Lyubimov added a comment - bulk-closing resolved issues
          Hide
          hudson Hudson added a comment -

          FAILURE: Integrated in Mahout-Quality #3324 (See https://builds.apache.org/job/Mahout-Quality/3324/)
          MAHOUT-1701: Flink: AtB implemented, ABt and AtA expressed via AtB (alexey.s.grigoriev: rev f836481b823a1aaaa70d9ab87c030f60c459de0d)

          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAt.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala
          • flink/src/test/scala/org/apache/mahout/flinkbindings/blas/LATestSuit.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAtB.scala
          • flink/src/test/scala/org/apache/mahout/flinkbindings/UseCasesSuite.scala
          • flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala
            MAHOUT-1701: Flink: AtB bug fixed (alexey.s.grigoriev: rev fcc6cf17a7820de9d0edd6bbca023086c84913ee)
          • flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAtB.scala
            MAHOUT-1701: Flink: bug with AtB (alexey.s.grigoriev: rev 137b3b840eff74f0833d5678a55af2dde4a316a7)
          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAtB.scala
          • flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala
          Show
          hudson Hudson added a comment - FAILURE: Integrated in Mahout-Quality #3324 (See https://builds.apache.org/job/Mahout-Quality/3324/ ) MAHOUT-1701 : Flink: AtB implemented, ABt and AtA expressed via AtB (alexey.s.grigoriev: rev f836481b823a1aaaa70d9ab87c030f60c459de0d) flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAt.scala flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala flink/src/test/scala/org/apache/mahout/flinkbindings/blas/LATestSuit.scala flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAtB.scala flink/src/test/scala/org/apache/mahout/flinkbindings/UseCasesSuite.scala flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala MAHOUT-1701 : Flink: AtB bug fixed (alexey.s.grigoriev: rev fcc6cf17a7820de9d0edd6bbca023086c84913ee) flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAtB.scala MAHOUT-1701 : Flink: bug with AtB (alexey.s.grigoriev: rev 137b3b840eff74f0833d5678a55af2dde4a316a7) flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAtB.scala flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala

            People

            • Assignee:
              smarthi Suneel Marthi
              Reporter:
              agrigorev Alexey Grigorev
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development

                  Agile