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

2018-11-20 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_r235277341 ## 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-20 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_r235247765 ## 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-20 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_r235247665 ## 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-20 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_r235247750 ## 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-20 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_r235249217 ## 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-20 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_r235249002 ## 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-20 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_r235249018 ## 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-20 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_r235247573 ## 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-20 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_r235247953 ## 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-19 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_r234865058 ## 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-19 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_r234859767 ## 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-19 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_r234864126 ## 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-19 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_r234864180 ## 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-19 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_r234861735 ## 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-19 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_r234858032 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemory

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

2018-11-19 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_r234859656 ## 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-19 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_r234864153 ## 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-19 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_r234860686 ## 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-19 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_r234863282 ## 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-19 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_r234863944 ## 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-19 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_r234864269 ## 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-19 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_r234860121 ## 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-19 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_r234861508 ## 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-19 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_r234860075 ## 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-19 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_r234859532 ## 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-19 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_r234865097 ## 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-19 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_r234858026 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemory

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

2018-11-19 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_r234865673 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/MultiThreadPare

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

2018-11-19 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_r234858450 ## 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-19 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_r234858926 ## 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-19 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_r234863773 ## 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-19 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_r234858138 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemory

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

2018-11-19 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_r234864892 ## 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-19 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_r234864016 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/Si

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

2018-11-19 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_r234861763 ## 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-19 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_r234864094 ## 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-19 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_r234864727 ## 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-19 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_r234858002 ## File path: compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemory

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

2018-11-19 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_r234864044 ## 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_r234430490 ## 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