Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[SPARK-11270][STREAMING] Add improved equality testing for TopicAndPa…
…rtition from the Kafka Streaming API jerryshao tdas I know this is kind of minor, and I know you all are busy, but this brings this class in line with the `OffsetRange` class, and makes tests a little more concise. Instead of doing something like: ``` assert topic_and_partition_instance._topic == "foo" assert topic_and_partition_instance._partition == 0 ``` You can do something like: ``` assert topic_and_partition_instance == TopicAndPartition("foo", 0) ``` Before: ``` >>> from pyspark.streaming.kafka import TopicAndPartition >>> TopicAndPartition("foo", 0) == TopicAndPartition("foo", 0) False ``` After: ``` >>> from pyspark.streaming.kafka import TopicAndPartition >>> TopicAndPartition("foo", 0) == TopicAndPartition("foo", 0) True ``` I couldn't find any tests - am I missing something? Author: Nick Evans <me@nicolasevans.org> Closes apache#9236 from manygrams/topic_and_partition_equality. (cherry picked from commit 8f888ee) Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
- Loading branch information