This repository was archived by the owner on Nov 11, 2022. It is now read-only.

KafkaIO should return one split for each of partition.#491

Merged

tgroh merged 6 commits into

GoogleCloudPlatform:masterfrom

Dec 10, 2016

Commits on Dec 1, 2016

KafkaIO should return one split for each of partition.
Raghu Angadi
committed
Based on Thomas comment.
Raghu Angadi
committed

Commits on Dec 8, 2016

Simplify diff by handling single split & split per partition cases existing code.
Raghu Angadi
committed

Commits on Dec 9, 2016

review comments. Remove special handling of single partition in
Raghu Angadi
committed
fix indentation
Raghu Angadi
committed
fix unused import
Raghu Angadi
committed