{"action":"created","issue":{"url":"https://api.github.com/repos/apache/storm/issues/694","labels_url":"https://api.github.com/repos/apache/storm/issues/694/labels{/name}","comments_url":"https://api.github.com/repos/apache/storm/issues/694/comments","events_url":"https://api.github.com/repos/apache/storm/issues/694/events","html_url":"https://github.com/apache/storm/pull/694","id":102238633,"number":694,"title":"[STORM-855] Add tuple batching","user":{"login":"mjsax","id":8959638,"avatar_url":"https://avatars.githubusercontent.com/u/8959638?v=3","gravatar_id":"","url":"https://api.github.com/users/mjsax","html_url":"https://github.com/mjsax","followers_url":"https://api.github.com/users/mjsax/followers","following_url":"https://api.github.com/users/mjsax/following{/other_user}","gists_url":"https://api.github.com/users/mjsax/gists{/gist_id}","starred_url":"https://api.github.com/users/mjsax/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mjsax/subscriptions","organizations_url":"https://api.github.com/users/mjsax/orgs","repos_url":"https://api.github.com/users/mjsax/repos","events_url":"https://api.github.com/users/mjsax/events{/privacy}","received_events_url":"https://api.github.com/users/mjsax/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":32,"created_at":"2015-08-20T21:12:54Z","updated_at":"2015-10-05T14:08:58Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/storm/pulls/694","html_url":"https://github.com/apache/storm/pull/694","diff_url":"https://github.com/apache/storm/pull/694.diff","patch_url":"https://github.com/apache/storm/pull/694.patch"},"body":"added new parameters to TopologyBuilder\r\n - batch_size (int): set the same batch size for all UDF declared output streams\r\n - batch_sizes (Map<String,Number>): sets the batch sizer for individual streams (including system streams)\r\n\r\nadded Batch type (as alternative to Tuple)\r\n - extended Kryo (de)serialization for Batch\r\n - integrated Tuple and Batch (de)serialization\r\n\r\nadd tuple batching\r\n - added internal tuple buffers (one for each output stream)\r\n - added Spout/Bolt output batching\r\n - added Bolt input debatching\r\n - added batching of \"acks\""},"comment":{"url":"https://api.github.com/repos/apache/storm/issues/comments/145539778","html_url":"https://github.com/apache/storm/pull/694#issuecomment-145539778","issue_url":"https://api.github.com/repos/apache/storm/issues/694","id":145539778,"user":{"login":"mjsax","id":8959638,"avatar_url":"https://avatars.githubusercontent.com/u/8959638?v=3","gravatar_id":"","url":"https://api.github.com/users/mjsax","html_url":"https://github.com/mjsax","followers_url":"https://api.github.com/users/mjsax/followers","following_url":"https://api.github.com/users/mjsax/following{/other_user}","gists_url":"https://api.github.com/users/mjsax/gists{/gist_id}","starred_url":"https://api.github.com/users/mjsax/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mjsax/subscriptions","organizations_url":"https://api.github.com/users/mjsax/orgs","repos_url":"https://api.github.com/users/mjsax/repos","events_url":"https://api.github.com/users/mjsax/events{/privacy}","received_events_url":"https://api.github.com/users/mjsax/received_events","type":"User","site_admin":false},"created_at":"2015-10-05T14:08:58Z","updated_at":"2015-10-05T14:08:58Z","body":"Thx. Take your time; there is actually no rush. I was just curious :)"}}