{"action":"created","issue":{"url":"https://api.github.com/repos/apache/flink/issues/594","labels_url":"https://api.github.com/repos/apache/flink/issues/594/labels{/name}","comments_url":"https://api.github.com/repos/apache/flink/issues/594/comments","events_url":"https://api.github.com/repos/apache/flink/issues/594/events","html_url":"https://github.com/apache/flink/pull/594","id":68133174,"number":594,"title":"Stream graph + internal refactor","user":{"login":"gyfora","id":5880972,"avatar_url":"https://avatars.githubusercontent.com/u/5880972?v=3","gravatar_id":"","url":"https://api.github.com/users/gyfora","html_url":"https://github.com/gyfora","followers_url":"https://api.github.com/users/gyfora/followers","following_url":"https://api.github.com/users/gyfora/following{/other_user}","gists_url":"https://api.github.com/users/gyfora/gists{/gist_id}","starred_url":"https://api.github.com/users/gyfora/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/gyfora/subscriptions","organizations_url":"https://api.github.com/users/gyfora/orgs","repos_url":"https://api.github.com/users/gyfora/repos","events_url":"https://api.github.com/users/gyfora/events{/privacy}","received_events_url":"https://api.github.com/users/gyfora/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":8,"created_at":"2015-04-13T16:01:01Z","updated_at":"2015-04-14T13:57:49Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/flink/pulls/594","html_url":"https://github.com/apache/flink/pull/594","diff_url":"https://github.com/apache/flink/pull/594.diff","patch_url":"https://github.com/apache/flink/pull/594.patch"},"body":"This is a refactor for the internal representation of the streaming topologies + a major refactor of the streaming internals"},"comment":{"url":"https://api.github.com/repos/apache/flink/issues/comments/92860931","html_url":"https://github.com/apache/flink/pull/594#issuecomment-92860931","issue_url":"https://api.github.com/repos/apache/flink/issues/594","id":92860931,"user":{"login":"aljoscha","id":68551,"avatar_url":"https://avatars.githubusercontent.com/u/68551?v=3","gravatar_id":"","url":"https://api.github.com/users/aljoscha","html_url":"https://github.com/aljoscha","followers_url":"https://api.github.com/users/aljoscha/followers","following_url":"https://api.github.com/users/aljoscha/following{/other_user}","gists_url":"https://api.github.com/users/aljoscha/gists{/gist_id}","starred_url":"https://api.github.com/users/aljoscha/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/aljoscha/subscriptions","organizations_url":"https://api.github.com/users/aljoscha/orgs","repos_url":"https://api.github.com/users/aljoscha/repos","events_url":"https://api.github.com/users/aljoscha/events{/privacy}","received_events_url":"https://api.github.com/users/aljoscha/received_events","type":"User","site_admin":false},"created_at":"2015-04-14T13:57:49Z","updated_at":"2015-04-14T13:57:49Z","body":"Also, there are packages streamgraph and streamoperator which could be renamed to graph and operators, to improve consistency.\r\n\r\nFurther, there are two concepts we call operators here, this might lead to confusion. There are the actual operator implementations in streamoperator and there are things like SingleOutputStreamOperator and StreamCrossOperator. I know that the batch API is also very messy in naming these things but maybe we can find better names for the streaming API while we still have a chance to change things. :smile:  "}}