File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed
external/kafka/src/main/scala/org/apache/spark/streaming/kafka Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Original file line number Diff line number Diff line change @@ -58,17 +58,19 @@ class ReliableKafkaReceiver[
58
58
59
59
private val AUTO_OFFSET_COMMIT = " auto.commit.enable"
60
60
61
- /** A HashMap to manage the offset for each topic/partition, this HashMap is called in
62
- * synchronized block, so mutable HashMap will not meet concurrency issue.
63
- */
61
+ /**
62
+ * A HashMap to manage the offset for each topic/partition, this HashMap is called in
63
+ * synchronized block, so mutable HashMap will not meet concurrency issue.
64
+ */
64
65
private var topicPartitionOffsetMap : mutable.HashMap [TopicAndPartition , Long ] = null
65
66
66
67
/** A concurrent HashMap to store the stream block id and related offset snapshot. */
67
68
private var blockOffsetMap : ConcurrentHashMap [StreamBlockId , Map [TopicAndPartition , Long ]] = null
68
69
69
- /** Manage the BlockGenerator in receiver itself for better managing block store and offset
70
- * commit.
71
- */
70
+ /**
71
+ * Manage the BlockGenerator in receiver itself for better managing block store and offset
72
+ * commit.
73
+ */
72
74
private var blockGenerator : BlockGenerator = null
73
75
74
76
/** Kafka offsets checkpoint listener to register into BlockGenerator for offsets checkpoint. */
You can’t perform that action at this time.
0 commit comments