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

Mahout DSL for Flink: implement operators At, Ax, Atx

    Details

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

      Description

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

      • At
      • Ax
      • Atx

        Issue Links

          Activity

          Hide
          agrigorev Alexey Grigorev added a comment -

          At and Ax implemented at https://github.com/alexeygrigorev/mahout/commit/5144a665a54c1861bbf29b7f7e466ae60eb66945

          Atx now is expressed via At and Ax

          Show
          agrigorev Alexey Grigorev added a comment - At and Ax implemented at https://github.com/alexeygrigorev/mahout/commit/5144a665a54c1861bbf29b7f7e466ae60eb66945 Atx now is expressed via At and Ax
          Hide
          smarthi Suneel Marthi added a comment -

          there's no implementation of Atx, but that's lacking even in the Spark backend. Marking this as 'Resolved' for now.

          Show
          smarthi Suneel Marthi added a comment - there's no implementation of Atx, but that's lacking even in the Spark backend. Marking this as 'Resolved' for now.
          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-1712: Flink: Ax, At, Atx operators (alexey.s.grigoriev: rev 98d4ff0312e6228c7f34d6030a493d2aec794e03)

          • flink/src/main/scala/org/apache/mahout/flinkbindings/package.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkDistributedContext.scala
          • flink/src/test/scala/org/apache/mahout/flinkbindings/DistributedFlinkSuit.scala
          • flink/src/test/scala/org/apache/mahout/flinkbindings/blas/LATestSuit.scala
          • flink/pom.xml
          • flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala
          • pom.xml
          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAt.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/drm/FlinkDrm.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
          • flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAx.scala
          Show
          hudson Hudson added a comment - FAILURE: Integrated in Mahout-Quality #3324 (See https://builds.apache.org/job/Mahout-Quality/3324/ ) MAHOUT-1712 : Flink: Ax, At, Atx operators (alexey.s.grigoriev: rev 98d4ff0312e6228c7f34d6030a493d2aec794e03) flink/src/main/scala/org/apache/mahout/flinkbindings/package.scala flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkDistributedContext.scala flink/src/test/scala/org/apache/mahout/flinkbindings/DistributedFlinkSuit.scala flink/src/test/scala/org/apache/mahout/flinkbindings/blas/LATestSuit.scala flink/pom.xml flink/src/test/scala/org/apache/mahout/flinkbindings/RLikeOpsSuite.scala pom.xml flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAt.scala flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala flink/src/main/scala/org/apache/mahout/flinkbindings/drm/FlinkDrm.scala flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala flink/src/main/scala/org/apache/mahout/flinkbindings/blas/FlinkOpAx.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