{"action":"created","issue":{"url":"https://api.github.com/repos/confluentinc/examples/issues/74","repository_url":"https://api.github.com/repos/confluentinc/examples","labels_url":"https://api.github.com/repos/confluentinc/examples/issues/74/labels{/name}","comments_url":"https://api.github.com/repos/confluentinc/examples/issues/74/comments","events_url":"https://api.github.com/repos/confluentinc/examples/issues/74/events","html_url":"https://github.com/confluentinc/examples/issues/74","id":183641804,"number":74,"title":"join of Kstreams","user":{"login":"mazorigal","id":15340875,"avatar_url":"https://avatars.githubusercontent.com/u/15340875?v=3","gravatar_id":"","url":"https://api.github.com/users/mazorigal","html_url":"https://github.com/mazorigal","followers_url":"https://api.github.com/users/mazorigal/followers","following_url":"https://api.github.com/users/mazorigal/following{/other_user}","gists_url":"https://api.github.com/users/mazorigal/gists{/gist_id}","starred_url":"https://api.github.com/users/mazorigal/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mazorigal/subscriptions","organizations_url":"https://api.github.com/users/mazorigal/orgs","repos_url":"https://api.github.com/users/mazorigal/repos","events_url":"https://api.github.com/users/mazorigal/events{/privacy}","received_events_url":"https://api.github.com/users/mazorigal/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/confluentinc/examples/labels/question","name":"question","color":"cc317c"}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":6,"created_at":"2016-10-18T10:01:27Z","updated_at":"2016-10-19T18:07:24Z","closed_at":null,"body":"Hi,\r\n\r\nI would like to understand the implementation used for join between Kstreams.\r\nIs the implementation a simple hash join that builds a hash table on one side (until the window is full) and buffers data on the other input. Once the window is complete, the buffered data is joined against the window ? \r\n\r\nAlso, is the restriction for having same number of partitions and partition on the same key applies also for the join between Kstream and a KTable ? (I assume that yes, but want to be sure)\r\n\r\nIn case when one of the streams have much higher volumes of data (for example click stream and location of the user stream), the click stream should have more topic partitions then the user location stream, how streams joins can be achieved in such case ? would you still force same number of partitions for each topic ?\r\n\r\nThanks,   "},"comment":{"url":"https://api.github.com/repos/confluentinc/examples/issues/comments/254894156","html_url":"https://github.com/confluentinc/examples/issues/74#issuecomment-254894156","issue_url":"https://api.github.com/repos/confluentinc/examples/issues/74","id":254894156,"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":"2016-10-19T18:07:24Z","updated_at":"2016-10-19T18:07:24Z","body":"Want to add to @miguno answer.\r\n\r\nYes, you number of windows you describe is correct for you example. And yes, we keep the window start/end time for each window to do the lookup."}}
{"actor":{"display_login":"mjsax"}}