added comments

Author: SravanThotakura05

src/main/java/com/solacecoe/connectors/spark/streaming/solace/SolaceBroker.java

@@ -420,6 +420,8 @@ public XMLMessage createMessage(String applicationMessageId, String partitionKey
         xmlMessage.setCorrelationId(applicationMessageId);
         xmlMessage.setApplicationMessageId(applicationMessageId);
         if (timestamp > 0L) {
+            // Spark TimestampType by default return's in microseconds(https://spark.apache.org/docs/latest/api/java/org/apache/spark/sql/types/TimestampType.html) whether it is millis or seconds. So division by 1000 is required
+            // as microseconds format will be too long to parse
             long senderTimestamp = timestamp/1000;
             xmlMessage.setSenderTimestamp(senderTimestamp);
         }

src/main/java/com/solacecoe/connectors/spark/streaming/write/SolaceDataWriter.java

@@ -83,6 +83,7 @@ private void publishMessages(UnsafeRow projectedRow) {
         }
         long timestamp = 0L;
         if(projectedRow.get(4, DataTypes.TimestampType) != null) {
+            // TimestampType always returns long. So safe to use getLong
             timestamp = projectedRow.getLong(4);
         }
         UnsafeMapData headersMap = new UnsafeMapData();