[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234430490 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] johnyangk commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
johnyangk commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234430415 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDat

[GitHub] johnyangk commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
johnyangk commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234429188 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] johnyangk commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
johnyangk commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234429067 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/Pipeline

[GitHub] johnyangk commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
johnyangk commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234429082 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInpu

[GitHub] johnyangk commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
johnyangk commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234429271 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] johnyangk commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
johnyangk commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234429437 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427629 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInpu

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427574 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/Material

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427604 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/Pipeline

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427647 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInpu

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427656 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInpu

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427743 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDat

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427632 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInpu

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427723 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427557 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/Material

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427532 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/Material

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427669 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427699 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427549 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/Material

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427729 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partitioner/Ded

[GitHub] taegeonum commented on a change in pull request #159: [NEMO-216, 251, 259] Support side inputs and windowing

2018-11-17 Thread GitBox
taegeonum commented on a change in pull request #159: [NEMO-216,251,259] Support side inputs and windowing URL: https://github.com/apache/incubator-nemo/pull/159#discussion_r234427709 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transfor

[GitHub] johnyangk opened a new pull request #159: [NEMO-216, 251, 259] Implement ReadyCheckingSideInputReader

2018-11-17 Thread GitBox
johnyangk opened a new pull request #159: [NEMO-216,251,259] Implement ReadyCheckingSideInputReader URL: https://github.com/apache/incubator-nemo/pull/159 JIRA: [NEMO-216: Support side inputs and windowing](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-216) (+ NEMO-251, NEMO-