{"action":"opened","issue":{"url":"https://api.github.com/repos/hortonworks/streamline/issues/538","repository_url":"https://api.github.com/repos/hortonworks/streamline","labels_url":"https://api.github.com/repos/hortonworks/streamline/issues/538/labels{/name}","comments_url":"https://api.github.com/repos/hortonworks/streamline/issues/538/comments","events_url":"https://api.github.com/repos/hortonworks/streamline/issues/538/events","html_url":"https://github.com/hortonworks/streamline/issues/538","id":220892153,"number":538,"title":"Streamline - Flink Runner - FlinkDataStreamGenerator","user":{"login":"arunmahadevan","id":6792890,"avatar_url":"https://avatars3.githubusercontent.com/u/6792890?v=3","gravatar_id":"","url":"https://api.github.com/users/arunmahadevan","html_url":"https://github.com/arunmahadevan","followers_url":"https://api.github.com/users/arunmahadevan/followers","following_url":"https://api.github.com/users/arunmahadevan/following{/other_user}","gists_url":"https://api.github.com/users/arunmahadevan/gists{/gist_id}","starred_url":"https://api.github.com/users/arunmahadevan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/arunmahadevan/subscriptions","organizations_url":"https://api.github.com/users/arunmahadevan/orgs","repos_url":"https://api.github.com/users/arunmahadevan/repos","events_url":"https://api.github.com/users/arunmahadevan/events{/privacy}","received_events_url":"https://api.github.com/users/arunmahadevan/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2017-04-11T09:32:20Z","updated_at":"2017-04-11T09:32:20Z","closed_at":null,"body":"This is a subtask of https://github.com/hortonworks/streamline/issues/535\r\n\r\nThe topology DAG has a traverse method that accepts a TopologyDagVisitor and will call back the appropriate visit methods as the different components in the topology DAG are traversed. In case of storm this is StormTopologyFluxGenerator. Similar implementation will have to be provided for Flink (E.g. FlinkDataStreamGenerator).\r\n\r\nRefer: [StormTopologyFluxGenerator](https://github.com/hortonworks/streamline/blob/master/streams/runners/storm/layout/src/main/java/com/hortonworks/streamline/streams/layout/storm/StormTopologyFluxGenerator.java)"}}
{"actor":{"display_login":"arunmahadevan"}}