jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r189774748
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/JobStateManager.java
#
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r189777512
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/ExecutorRegis
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r189777669
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/ExecutorRegis
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r189683185
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/BatchSingleJo
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r189775205
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/BatchSingleJo
seojangho opened a new pull request #22: [Nemo-68] Restrict the number of
parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22
JIRA: [NEMO-68: Restrict the number of parallel connections between
executors](https://issues.apache.org/jira/projects/NEMO
seojangho opened a new pull request #23: [NEMO-67] Fix Communication Pattern
for Beam CoGroupByKey transform
URL: https://github.com/apache/incubator-nemo/pull/23
JIRA: [NEMO-67: Support Beam CoGroupByKey
transform](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-67)
**Majo
johnyangk commented on issue #21: [NEMO-46] Make the operations on
ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#issuecomment-391552787
@jeongyooneo Thanks! I've addressed your comments.
This i
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r18975
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/JobStateManager.java
#
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r190453736
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/BatchSingleJo
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r190453145
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/JobStateManager.java
#
johnyangk commented on issue #21: [NEMO-46] Make the operations on
ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#issuecomment-391575534
@jeongyooneo Good catch. I've update the branch to reflect your comments.
bgchun commented on issue #21: [NEMO-46] Make the operations on
ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#issuecomment-391582976
@johnyangk Do we have good tests to check the code in the `runtime.master`
package?
johnyangk commented on issue #21: [NEMO-46] Make the operations on
ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#issuecomment-391586301
@bgchun We have some good tests, but they can be improved. The `scheduler`
package is covered relatively well. We also hav
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r190453736
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/BatchSingleJo
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r190453736
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/BatchSingleJo
jeongyooneo closed pull request #21: [NEMO-46] Make the operations on
ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
wonook commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r190471382
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVe
wonook commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r189497103
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/SparkLauncher.java
##
@@
sanha commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r190481637
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/SparkLauncher.java
##
@@
sanha commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r190483000
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVer
sanha commented on issue #18: [NEMO-45] Distributed Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#issuecomment-391610537
@wonook Thanks for your review! Unfortunately, I cannot remove
`SparkLauncher.java` because it is used in `SparkSession`.
---
wonook commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r190494100
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/SparkLauncher.java
##
@@
wonook commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r190495764
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/SparkSession.java
##
wonook commented on a change in pull request #18: [NEMO-45] Distributed
Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#discussion_r190495950
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/SparkSession.java
##
sanha commented on issue #18: [NEMO-45] Distributed Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18#issuecomment-391627991
@wonook Thanks! Your comments are addressed.
This is an automated message from the Apa
wonook closed pull request #18: [NEMO-45] Distributed Nemo-Spark
URL: https://github.com/apache/incubator-nemo/pull/18
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull requ
jeongyooneo commented on a change in pull request #21: [NEMO-46] Make the
operations on ExecutorRegistry atomic
URL: https://github.com/apache/incubator-nemo/pull/21#discussion_r18975
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/JobStateManager.java
#
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190522859
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190579092
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190521924
##
File path: conf/src/main/java/edu/snu/nemo/conf/JobConf.java
##
@@
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190531465
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190526159
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190584189
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190584189
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190579092
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
jeongyooneo commented on a change in pull request #22: [NEMO-68] Restrict the
number of parallel connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#discussion_r190579092
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data
wonook commented on a change in pull request #23: [NEMO-67] Fix Communication
Pattern for Beam CoGroupByKey transform
URL: https://github.com/apache/incubator-nemo/pull/23#discussion_r190807947
##
File path:
compiler/frontend/beam/src/main/java/edu/snu/nemo/compiler/frontend/beam/N
wonook commented on a change in pull request #23: [NEMO-67] Fix Communication
Pattern for Beam CoGroupByKey transform
URL: https://github.com/apache/incubator-nemo/pull/23#discussion_r190808251
##
File path:
compiler/frontend/beam/src/main/java/edu/snu/nemo/compiler/frontend/beam/N
seojangho commented on a change in pull request #23: [NEMO-67] Fix
Communication Pattern for Beam CoGroupByKey transform
URL: https://github.com/apache/incubator-nemo/pull/23#discussion_r191112708
##
File path:
compiler/frontend/beam/src/main/java/edu/snu/nemo/compiler/frontend/bea
seojangho commented on issue #22: [NEMO-68] Restrict the number of parallel
connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22#issuecomment-392423704
@jeongyooneo Thanks for the comment! Please check the updates.
wonook closed pull request #23: [NEMO-67] Fix Communication Pattern for Beam
CoGroupByKey transform
URL: https://github.com/apache/incubator-nemo/pull/23
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provena
jeongyooneo closed pull request #22: [NEMO-68] Restrict the number of parallel
connections between executors
URL: https://github.com/apache/incubator-nemo/pull/22
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake o
johnyangk opened a new pull request #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24
JIRA: [NEMO-79: Clean up the legacy
Task](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-79)
**Major changes:**
- Removes the legacy Task int
johnyangk commented on issue #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#issuecomment-392669064
@jeongyooneo Sorry, let me resolve the conflicts first. I'll let you know
when the branch is ready to be reviewed.
-
johnyangk commented on issue #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#issuecomment-393010390
@jeongyooneo The branch is now ready for your review. 😄
This is an automated me
seojangho commented on issue #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#issuecomment-393052415
Hi @johnyangk, thanks for the work!
It seems that changes in this PR makes the visualzer unable to display
source information in physical plan
johnyangk commented on issue #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#issuecomment-393058182
Thanks @seojangho! Yes, I'll see if I can come up with something better than
`SourceVertex#clearInternalStates` to avoid attaching all of the inp
wonook commented on a change in pull request #24: [NEMO-79] Clean up the legacy
Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r191667494
##
File path: bin/json2dot.py
##
@@ -64,8 +64,8 @@ def __init__(self, data):
self.id = data['id']
wonook commented on a change in pull request #24: [NEMO-79] Clean up the legacy
Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r191672052
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/RuntimeIdGenerator.java
##
@@ -76,36 +79
wonook commented on a change in pull request #24: [NEMO-79] Clean up the legacy
Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r191671729
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/RuntimeIdGenerator.java
##
@@ -76,36 +79
johnyangk commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r191732056
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/RuntimeIdGenerator.java
##
@@ -76,36
johnyangk commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r191733983
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/RuntimeIdGenerator.java
##
@@ -76,36
johnyangk commented on issue #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#issuecomment-393131163
@seojangho @wonook I've addressed your comments.
The issue with the visualizer has been fixed. This visualization of
MapReduceITCase shows
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r192001641
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/TaskExecutor.java
##
@@ -246,64
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r192001937
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/TaskExecutor.java
##
@@ -374,22
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r192003647
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/BatchSingleJobScheduler.java
#
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r191996204
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/plan/physical/PhysicalPlanGenerator.java
###
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r192000745
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/TaskExecutor.java
##
@@ -41,79
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r192005437
##
File path: common/src/main/java/edu/snu/nemo/common/ir/vertex/SourceVertex.java
##
@@ -34,4 +34,9 @@
jeongyooneo commented on a change in pull request #24: [NEMO-79] Clean up the
legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#discussion_r192001967
##
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/TaskExecutor.java
##
@@ -374,22
johnyangk commented on issue #24: [NEMO-79] Clean up the legacy Task
URL: https://github.com/apache/incubator-nemo/pull/24#issuecomment-393720952
@jeongyooneo Thanks. I've addressed your comments.
This is an automated message
johnyangk opened a new pull request #25: [Nemo-78] Rename PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/25
JIRA: [NEMO-78: Rename PhysicalStage to
Stage](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-78)
**Major changes:**
- Remove the existi
johnyangk closed pull request #25: [Nemo-78] Rename PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/25
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign
johnyangk opened a new pull request #26: [NEMO-78] Rename PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/26
JIRA: [NEMO-78: Rename PhysicalStage to
Stage](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-78)
**Major changes:**
- Remove the existi
johnyangk opened a new pull request #27: [NEMO-49] Replace failed executor with
a new executor
URL: https://github.com/apache/incubator-nemo/pull/27
JIRA: [NEMO-49: Replace failed executor with a new
executor](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-49)
**Major chan
sanha opened a new pull request #28: [NEMO-12] Frontend support for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28
JIRA: [NEMO-12: Frontend support for Scala
Spark](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-12)
**Major changes:**
- Implement Scala
jeongyooneo commented on a change in pull request #27: [NEMO-49] Replace failed
executor with a new executor
URL: https://github.com/apache/incubator-nemo/pull/27#discussion_r192939528
##
File path:
runtime/master/src/test/java/edu/snu/nemo/runtime/master/ContainerManagerTest.java
jeongyooneo commented on a change in pull request #27: [NEMO-49] Replace failed
executor with a new executor
URL: https://github.com/apache/incubator-nemo/pull/27#discussion_r192939052
##
File path:
runtime/master/src/test/java/edu/snu/nemo/runtime/master/ContainerManagerTest.java
jeongyooneo commented on a change in pull request #27: [NEMO-49] Replace failed
executor with a new executor
URL: https://github.com/apache/incubator-nemo/pull/27#discussion_r192946662
##
File path: runtime/driver/src/main/java/edu/snu/nemo/driver/NemoDriver.java
##
@@ -15
jeongyooneo commented on a change in pull request #27: [NEMO-49] Replace failed
executor with a new executor
URL: https://github.com/apache/incubator-nemo/pull/27#discussion_r192936650
##
File path:
runtime/master/src/main/java/edu/snu/nemo/runtime/master/resource/ContainerManager.
jeongyooneo commented on a change in pull request #27: [NEMO-49] Replace failed
executor with a new executor
URL: https://github.com/apache/incubator-nemo/pull/27#discussion_r192946662
##
File path: runtime/driver/src/main/java/edu/snu/nemo/driver/NemoDriver.java
##
@@ -15
johnyangk commented on a change in pull request #27: [NEMO-49] Replace failed
executor with a new executor
URL: https://github.com/apache/incubator-nemo/pull/27#discussion_r192950066
##
File path: runtime/driver/src/main/java/edu/snu/nemo/driver/NemoDriver.java
##
@@ -153,
johnyangk commented on issue #27: [NEMO-49] Replace failed executor with a new
executor
URL: https://github.com/apache/incubator-nemo/pull/27#issuecomment-394586994
@jeongyooneo I've addressed your comments. 😄
This is an aut
jeongyooneo closed pull request #27: [NEMO-49] Replace failed executor with a
new executor
URL: https://github.com/apache/incubator-nemo/pull/27
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
johnyangk commented on issue #26: [NEMO-78] Rename PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/26#issuecomment-394589550
@jeongyooneo @wonook @seojangho I've resolved the conflicts. 😄
This is an
jeongyooneo commented on a change in pull request #26: [NEMO-78] Rename
PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/26#discussion_r192966782
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/plan/StageEdge.java
##
@@ -57,
johnyangk commented on a change in pull request #26: [NEMO-78] Rename
PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/26#discussion_r192972809
##
File path:
runtime/common/src/main/java/edu/snu/nemo/runtime/common/plan/StageEdge.java
##
@@ -57,14
johnyangk commented on issue #26: [NEMO-78] Rename PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/26#issuecomment-394611019
@jeongyooneo Thanks! I've addressed your comment.
This is an automated mess
jeongyooneo closed pull request #26: [NEMO-78] Rename PhysicalStage to Stage
URL: https://github.com/apache/incubator-nemo/pull/26
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a forei
johnyangk opened a new pull request #29: [NEMO-95] Rename ExecutableTask to Task
URL: https://github.com/apache/incubator-nemo/pull/29
JIRA: [NEMO-95: Rename ExecutableTask to
Task](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-95)
**Major changes:**
- Rename Executable
jeongyooneo closed pull request #29: [NEMO-95] Rename ExecutableTask to Task
URL: https://github.com/apache/incubator-nemo/pull/29
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a forei
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193319477
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/transform/CollectTransfo
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193324652
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/core/SparkFrontendUtils.
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193322788
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/Dataset.java
##
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193308930
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/core/rdd/PairRDDFunction
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193309027
##
File path:
examples/spark/src/main/scala/edu/snu/nemo/examples/spark/SparkWordCount.scala
##
@@ -0,0
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193308953
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/core/rdd/RDD.scala
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193322876
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/Dataset.java
##
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193324461
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/core/SparkFrontendUtils.
sanha commented on a change in pull request #28: [NEMO-12] Frontend support for
Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193611278
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/transform/CollectTransfor
sanha commented on a change in pull request #28: [NEMO-12] Frontend support for
Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193612102
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/Dataset.java
###
sanha commented on a change in pull request #28: [NEMO-12] Frontend support for
Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193616828
##
File path:
examples/spark/src/main/scala/edu/snu/nemo/examples/spark/SparkWordCount.scala
##
@@ -0,0
sanha commented on issue #28: [NEMO-12] Frontend support for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#issuecomment-395280900
@wonook Thanks for your review! I've addressed or answered to your comments.
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193639621
##
File path:
examples/spark/src/main/scala/edu/snu/nemo/examples/spark/SparkWordCount.scala
##
@@ -0,0
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193647591
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/core/SparkFrontendUtils.
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193647652
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/transform/CollectTransfo
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193641579
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/Dataset.java
##
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193648153
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/Dataset.java
##
wonook commented on a change in pull request #28: [NEMO-12] Frontend support
for Scala Spark
URL: https://github.com/apache/incubator-nemo/pull/28#discussion_r193648971
##
File path:
compiler/frontend/spark/src/main/java/edu/snu/nemo/compiler/frontend/spark/sql/Dataset.java
##
301 - 400 of 1748 matches
Mail list logo
