Major Description
'sql/core/src/main/scala/org/apache/spark/sql/execution/streaming'
| Filename | Count |
|---|---|
| CheckpointFileManager.scala | 3 |
| CommitLog.scala | 1 |
| CompactibleFileStreamLog.scala | 2 |
| FileStreamOptions.scala | 1 |
| FileStreamSink.scala | 1 |
| GroupStateImpl.scala | 5 |
| HDFSMetadataLog.scala | 4 |
| ManifestFileCommitProtocol.scala | 1 |
| MicroBatchExecution.scala | 5 |
| OffsetSeqLog.scala | 1 |
| Sink.scala | 3 |
| Source.scala | 3 |
| StreamingQueryWrapper.scala | 1 |
| StreamingRelation.scala | 1 |
| StreamingSymmetricHashJoinExec.scala | 2 |
| Triggers.scala | 1 |
| WatermarkTracker.scala | 1 |
| memory.scala | 4 |
| statefulOperators.scala | 2 |
