Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19239#discussion_r139025554
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala
---
@@ -39,7 +39,7 @@ class IncrementalExecution(
val checkpointLocation: String,
val runId: UUID,
val currentBatchId: Long,
- offsetSeqMetadata: OffsetSeqMetadata)
+ private[sql] val offsetSeqMetadata: OffsetSeqMetadata)
--- End diff --
just make it val. Anything inside sql.execution does not show up in docs,
and therefore we just keep to val so that we can debug when we need to dig deep.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
