improve logging (#153)

chaoqin-li1123 · web-flow · commit 67d5c5835a2b · 2023-08-23T23:29:48.000-07:00
* improve logging

* improve logging
diff --git a/src/main/scala/org/apache/spark/sql/pulsar/PulsarSources.scala b/src/main/scala/org/apache/spark/sql/pulsar/PulsarSources.scala
@@ -172,7 +172,7 @@ class PulsarSourceInitialOffsetWriter(sparkSession: SparkSession, metadataPath:
   }
 }
 
-private[pulsar] class PulsarOffsetRange private (
+private[pulsar] case class PulsarOffsetRange private (
     private var topic_ : String,
     private var fromOffset_ : MessageId,
     private var untilOffset_ : MessageId,

Original file line number	Diff line number	Diff line change
`@@ -172,7 +172,7 @@ class PulsarSourceInitialOffsetWriter(sparkSession: SparkSession, metadataPath:`
`172`	`172`	`}`
`173`	`173`	`}`
`174`	`174`
`175`		`-private[pulsar] class PulsarOffsetRange private (`
	`175`	`+private[pulsar] case class PulsarOffsetRange private (`
`176`	`176`	`private var topic_ : String,`
`177`	`177`	`private var fromOffset_ : MessageId,`
`178`	`178`	`private var untilOffset_ : MessageId,`