Class InnerJoinStream