File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010 Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -36,7 +36,7 @@ import org.apache.spark.annotation.Experimental
36
36
* @tparam V type of Kafka message value
37
37
*/
38
38
@ Experimental
39
- trait ConsumerStrategy [K , V ] {
39
+ abstract class ConsumerStrategy [K , V ] {
40
40
/**
41
41
* Kafka <a href="http://kafka.apache.org/documentation.htmll#newconsumerconfigs">
42
42
* configuration parameters</a> to be used on executors. Requires "bootstrap.servers" to be set
Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ import org.apache.spark.annotation.Experimental
34
34
* Choice of location is only a preference, not an absolute; partitions may be scheduled elsewhere.
35
35
*/
36
36
@ Experimental
37
- sealed trait LocationStrategy
37
+ sealed abstract class LocationStrategy
38
38
39
39
private case object PreferBrokers extends LocationStrategy
40
40
You can’t perform that action at this time.
0 commit comments