)]}' { "commit": "099f5a042233ddfdb0c74df689da8593086d373a", "tree": "e4fb4ce97899895d67732df1dafd76ac74f49b62", "parents": [ "3619588e858da436a5d8ff89083fe0e507305edf" ], "author": { "name": "Ning Wang", "email": "nwang@twitter.com", "time": "Mon Nov 26 10:37:46 2018 -0800" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Mon Nov 26 10:37:46 2018 -0800" }, "message": "Add withStream() in Streamlet to support stream selection (#3109)\n\n* Add withStream() in Streamlet to support stream selection\r\n\r\n* Add split() function into Streamlet API", "tree_diff": [ { "type": "modify", "old_id": "821fa5143acf2a9f0ddde53300f02d7bf85a1b64", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/Streamlet.java", "new_id": "e1f061638c3be59d05c4cd249993afea45bdb662", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/Streamlet.java" }, { "type": "modify", "old_id": "e76cd264cfc90faa82271f3f8fb8f55e1f370c39", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/StreamletImpl.java", "new_id": "6b09de2a94f96cbca35c42875af2431af942d073", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/StreamletImpl.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "56d0c644822af8e7f00fe15ec117f739e933db23", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/StreamletShadow.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "c07893ec6688450d3322a211dfde5e85da5ac514", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/operators/SplitOperator.java" }, { "type": "modify", "old_id": "0b08478559bc21618418faf8fc696341afae8c82", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/operators/StreamletOperator.java", "new_id": "0114a010f5fc039ecee654a100ffc71f825d8003", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/operators/StreamletOperator.java" }, { "type": "modify", "old_id": "98bb8466ee172ec8068418c8a34bc9e0e6c6270d", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/ConsumerStreamlet.java", "new_id": "f71b71fe5ac49909608da55388434896fdca8a37", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/ConsumerStreamlet.java" }, { "type": "modify", "old_id": "d09b1344bb611dd3ed165e2b698d28e936130d8e", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/CustomStreamlet.java", "new_id": "df3639d1fa5948c7652dd43b129de7c550599d87", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/CustomStreamlet.java" }, { "type": "modify", "old_id": "b31423852ee7d936f6783dc7f719b80caca313a0", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/FilterStreamlet.java", "new_id": "4f2566911827272b42b1d964a4f35a9f3018f351", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/FilterStreamlet.java" }, { "type": "modify", "old_id": "30a050071443606f05b03c616038d78bcb2a6026", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/FlatMapStreamlet.java", "new_id": "95c057dfb41e67621b904ca99e00776a5babd418", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/FlatMapStreamlet.java" }, { "type": "modify", "old_id": "2bc6bf0667ae3f96877d79fa8b09296cae05d241", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/GeneralReduceByKeyAndWindowStreamlet.java", "new_id": "3f0abd89c2705081350dfe2500bb4d40462eb8b0", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/GeneralReduceByKeyAndWindowStreamlet.java" }, { "type": "modify", "old_id": "0dcab51caa635f95824783e596dd37ea3d5695bb", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/JoinStreamlet.java", "new_id": "89c6de9187474eab384a28cc6293bcdf260afee8", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/JoinStreamlet.java" }, { "type": "modify", "old_id": "f29215bbf9c0afb77a68d5ff3034faadd2f9a21e", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/LogStreamlet.java", "new_id": "9f68ff9a690b7ee16f504fc4020df58f9765dadc", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/LogStreamlet.java" }, { "type": "modify", "old_id": "96c34b9edff515f6c845277e13fa2dd5699d7ef4", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/MapStreamlet.java", "new_id": "900c0e94031c9c2dfb89c58ad36150edda6ca2d6", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/MapStreamlet.java" }, { "type": "modify", "old_id": "33a5b7513e13e6d513b347501d9eb73228495989", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/ReduceByKeyAndWindowStreamlet.java", "new_id": "7e7a7e1f882e6c031825125cb1a65c1430b6f076", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/ReduceByKeyAndWindowStreamlet.java" }, { "type": "modify", "old_id": "fed815f7197936e3dc867b19c874ac266f807efd", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/RemapStreamlet.java", "new_id": "b18980a78adc5e61fef2d36e4c94aded4c0804e2", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/RemapStreamlet.java" }, { "type": "modify", "old_id": "9b24cf8aebc67ea946727f68c1e09e557d81c7ea", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/SinkStreamlet.java", "new_id": "42e5d031f7c9696a20e7de0101a425da73db4417", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/SinkStreamlet.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "81283532391d25b657eb8515726b6daf3941e6b6", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/SplitStreamlet.java" }, { "type": "modify", "old_id": "fffd4e0ddfc82920db1c7075e5fe3fcec81d7018", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/TransformStreamlet.java", "new_id": "1f206c7207098f69af60973e7134f891861e87d8", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/TransformStreamlet.java" }, { "type": "modify", "old_id": "8c6e9a6dc7d95f9841e6a5721e265ed5eef65d07", "old_mode": 33188, "old_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/UnionStreamlet.java", "new_id": "a1ecbcfebc737616087c309315edded3c7175cec", "new_mode": 33188, "new_path": "heron/api/src/java/org/apache/heron/streamlet/impl/streamlets/UnionStreamlet.java" }, { "type": "modify", "old_id": "8200316f7bbdb4864f46a892bab052d5c74f4c96", "old_mode": 33188, "old_path": "heron/api/src/scala/org/apache/heron/streamlet/scala/Streamlet.scala", "new_id": "9945852f554a3ee552b49a85dca8c49d8f1eda04", "new_mode": 33188, "new_path": "heron/api/src/scala/org/apache/heron/streamlet/scala/Streamlet.scala" }, { "type": "modify", "old_id": "50c655efb265aee6a3a019f1b4f4d9f4fe42c3e9", "old_mode": 33188, "old_path": "heron/api/src/scala/org/apache/heron/streamlet/scala/impl/StreamletImpl.scala", "new_id": "fc308b5cbd82b184e5114956988db305db432bc3", "new_mode": 33188, "new_path": "heron/api/src/scala/org/apache/heron/streamlet/scala/impl/StreamletImpl.scala" }, { "type": "modify", "old_id": "33f3a9c9dce77a4362084c72388a320fea2a5d27", "old_mode": 33188, "old_path": "heron/api/tests/java/org/apache/heron/streamlet/impl/StreamletImplTest.java", "new_id": "5d9053a0309cb9b2df1891e251a021da5e98e14c", "new_mode": 33188, "new_path": "heron/api/tests/java/org/apache/heron/streamlet/impl/StreamletImplTest.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "4cc70d2ada725466918731500c7ebb5fb95503af", "new_mode": 33188, "new_path": "heron/api/tests/java/org/apache/heron/streamlet/impl/StreamletShadowTest.java" }, { "type": "modify", "old_id": "b8437327ff95fc0c0928597e22dd3127a79ed82a", "old_mode": 33188, "old_path": "heron/api/tests/scala/org/apache/heron/streamlet/scala/impl/StreamletImplTest.scala", "new_id": "5664d6441115ff7923f99e11807ee4d554f02519", "new_mode": 33188, "new_path": "heron/api/tests/scala/org/apache/heron/streamlet/scala/impl/StreamletImplTest.scala" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "0e787ff04a2c3058f54524c2fe1d64af3d157006", "new_mode": 33188, "new_path": "integration_test/src/java/org/apache/heron/integration_test/topology/streamlet_with_split_and_with_stream/StreamletWithSplitAndWithStream.java" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "a401e62bfc1eb07c85bc44c63fcab9a8eb25ab2f", "new_mode": 33188, "new_path": "integration_test/src/java/org/apache/heron/integration_test/topology/streamlet_with_split_and_with_stream/StreamletWithSplitAndWithStreamResults.json" }, { "type": "modify", "old_id": "762b2f6c161fa4a9e6bf287086427bab2d19e6de", "old_mode": 33188, "old_path": "integration_test/src/python/test_runner/resources/test.json", "new_id": "62cc92f28a7e09f444de172ce147590514417b69", "new_mode": 33188, "new_path": "integration_test/src/python/test_runner/resources/test.json" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "307a03778cba6a6242c737ed26a17801f410f894", "new_mode": 33188, "new_path": "integration_test/src/scala/org/apache/heron/integration_test/topology/scala_streamlet_with_split_and_with_stream/ScalaStreamletWithSplitAndWithStream.scala" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "4df41be2a5538b29befa88a560c2c605150ff3e5", "new_mode": 33188, "new_path": "integration_test/src/scala/org/apache/heron/integration_test/topology/scala_streamlet_with_split_and_with_stream/ScalaStreamletWithSplitAndWithStreamResults.json" } ] }