{"push_id":538040896,"size":24,"distinct_size":0,"ref":"refs/heads/master","head":"f71b0c42f0bb7850a5a7df4050fbc87358e59609","before":"561eaf047a56596174395637db27883693dca89a","commits":[{"sha":"87d699d7025f6ceadeb64fe972b7185079b6ec22","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] Time trigger preNotify fix","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/87d699d7025f6ceadeb64fe972b7185079b6ec22"},{"sha":"34353f6658e9a4dd50ad860e17eee94804b76ccb","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Base functionality added for streaming scala api","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/34353f6658e9a4dd50ad860e17eee94804b76ccb"},{"sha":"c123e11a01a801419f2ed53814b22d0ad638f98c","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Extended scala data stream functionality to include simple operators","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/c123e11a01a801419f2ed53814b22d0ad638f98c"},{"sha":"de06d9589cfab83183458d18eeeadd4d604c8a65","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/de06d9589cfab83183458d18eeeadd4d604c8a65"},{"sha":"80393c4a1901e2672349b76cb7b3476dcb674edb","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Windowing functionality added to scala api","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/80393c4a1901e2672349b76cb7b3476dcb674edb"},{"sha":"7aa682982b980dd80955c243797d97f2c083ae7c","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[scala] [streaming] Added SplitDataStream functionality\n\nConflicts:\n\tflink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/7aa682982b980dd80955c243797d97f2c083ae7c"},{"sha":"f165c353c6b41396eaecb11b6cda274d818cb553","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Added support for iterative streams for scala api","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/f165c353c6b41396eaecb11b6cda274d818cb553"},{"sha":"1c87d8bcf07ea8a4f6c4bf0d7b39b20aea36b225","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] Temporal join and cross rework for consistence and extended features","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/1c87d8bcf07ea8a4f6c4bf0d7b39b20aea36b225"},{"sha":"555837cd6da98b0311a7f752a3b2523f6efbf6a1","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Temporal join operator added","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/555837cd6da98b0311a7f752a3b2523f6efbf6a1"},{"sha":"e37ec793928442ca7ebe08f3edc318999745f226","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Temporal cross operator added","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/e37ec793928442ca7ebe08f3edc318999745f226"},{"sha":"75dd021ad4f4e1a2b1171e852abd5576588b1629","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Modified aggregations to work on scala tuples","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/75dd021ad4f4e1a2b1171e852abd5576588b1629"},{"sha":"6f215b5044b193d1443b941cc8848c1896d7cc88","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Fixed scala formatting","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/6f215b5044b193d1443b941cc8848c1896d7cc88"},{"sha":"a75198878979d16c8bcd394dcea71108c10b0593","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Added groupBy support for case class fields","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/a75198878979d16c8bcd394dcea71108c10b0593"},{"sha":"1d019b9b7b0582fd4dca57f8d582f1e0b8762027","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] WindowJoin scala example added","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/1d019b9b7b0582fd4dca57f8d582f1e0b8762027"},{"sha":"8bf9416d37ae43d868ffaaf7b1fac0fe9fb43c03","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] Streaming API grouping rework to use batch api Keys","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/8bf9416d37ae43d868ffaaf7b1fac0fe9fb43c03"},{"sha":"fac773488a77c0c70ed74a2dca09224f275ec77a","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Added scala window helpers + timestamp rework for lambda support","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/fac773488a77c0c70ed74a2dca09224f275ec77a"},{"sha":"d4ec0095c253d7b8b2b99226f42dab4ce3555aef","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[scala] [streaming] Added implicit conversions from java to scala streams","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/d4ec0095c253d7b8b2b99226f42dab4ce3555aef"},{"sha":"a761cdcb7186a8eb565de2d6313cf2087b3ee087","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"senorcarbone"},"message":"[scala] [streaming] added group windowing example with different policy types\n\n[scala] [streaming] updated example with scala delta helper usage","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/a761cdcb7186a8eb565de2d6313cf2087b3ee087"},{"sha":"55ef7954bfbcc33ac1367b93762918055d496495","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"carbone"},"message":"[scala] [streaming] added initial ConnectedDataStream support (no windowing,batching) for the scala api","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/55ef7954bfbcc33ac1367b93762918055d496495"},{"sha":"b9d0241f333ea8ab8fcf31fc2e189888c0315513","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"carbone"},"message":"[scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams\n\n[scala] [streaming] Changed return types to implicits","distinct":false,"url":"https://api.github.com/repos/mbalassi/incubator-flink/commits/b9d0241f333ea8ab8fcf31fc2e189888c0315513"}]}