{"push_id":624214810,"size":8,"distinct_size":8,"ref":"refs/heads/flink-storm-compatibility","head":"806ca4de92e0fcd6dbaffe63dd5672a5c921489a","before":"c31c032beb041766fa969e8edb0f68c4a8b23e98","commits":[{"sha":"e914d410e3c6eb9bbb280ff8d9f572961edcc32e","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"added raw output type support\n - previously, only record types Tuple1, Tuple2,... Tuple25 were supported\n - now, single attribute records, can have 'raw' record type\n -> ie, output records with type AttributeType can be used instead of Tuple1<AttributeType>","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/e914d410e3c6eb9bbb280ff8d9f572961edcc32e"},{"sha":"f5bf3e8c477380d985fa7e04e94289c84e48f272","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"added StormSpoutWrapper including JUnit and ITCase\nfixed bugs and improved existing tests","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/f5bf3e8c477380d985fa7e04e94289c84e48f272"},{"sha":"36bc2123d5395c0f437b7809041dae475b1fd358","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"extracted Storm Spouts and Bolt to seperate package\nimproved StormFinitSpoutWrapper\nadded support for Storm sink-bolts\nimproved integration of Flink and Storm configuration","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/36bc2123d5395c0f437b7809041dae475b1fd358"},{"sha":"6f4fb6fb8d8f1e23e6b5a3b50a0ed7408ab08a5e","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"added Storm API compatiblity classes\n - FlinkTopologyBuilder, FlinkLocalCluster, FlinkTopology can now mimic the behavior of Storm's TopologyBuilder, LocalCluster, and Topology class","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/6f4fb6fb8d8f1e23e6b5a3b50a0ed7408ab08a5e"},{"sha":"9ff3793fb5eea487bdf34b9c37a9a1a2dfd61982","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"added isRunning flag to spout wrappers","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/9ff3793fb5eea487bdf34b9c37a9a1a2dfd61982"},{"sha":"cb441f414e5753e17335cb85fd55e6c5f84b08f5","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"worked on LocalCluster shutdown for integration tests","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/cb441f414e5753e17335cb85fd55e6c5f84b08f5"},{"sha":"64649f07138a36624f6bf8d7cc08ae34749f9273","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"Added Storm clients that connect to Flink\nadded a submit-remote-example","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/64649f07138a36624f6bf8d7cc08ae34749f9273"},{"sha":"806ca4de92e0fcd6dbaffe63dd5672a5c921489a","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"added new JUnit test\nimproved existing tests\nrenamed package org.apache.flink.stormcompatibility.operators to org.apache.flink.stormcompatibility.wrappers\n\nadded missing license header\n\nremoved author tags\nremoved unnecessary try-catch-block","distinct":true,"url":"https://api.github.com/repos/mjsax/flink/commits/806ca4de92e0fcd6dbaffe63dd5672a5c921489a"}]}