/
githubmirror
/
spark
ОбзорДокументацияВойти
/
githubmirror
/
spark
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
ДокументацияПоддержка
Политика конфиденциальностиПользовательское соглашениеПолитика использования «cookies»Согласие субъекта персональных данных
2026 ©
spark/
.../resources/structured-streaming/
..
checkpoint-test-offsetId-commitId-inconsistent

[SPARK-38033][SS] The SS processing cannot be started because the com…

4 года назад
checkpoint-version-2.1.0

[SPARK-19873][SS] Record num shuffle partitions in offset log and enforce in next batch.

9 лет назад
checkpoint-version-2.3.1-flatMapGroupsWithState-state-format-1

[SPARK-22187][SS] Update unsaferow format for saved state in flatMapGroupsWithState to allow timeouts with deleted state

8 лет назад
checkpoint-version-2.3.1-for-multi-watermark-policy

[SPARK-24730][SS] Add policy to choose max as global watermark when streaming query has multiple watermarks

8 лет назад
checkpoint-version-2.3.1-streaming-aggregate-state-format-1

[SPARK-24763][SS] Remove redundant key data from value in streaming aggregation

8 лет назад
checkpoint-version-2.3.1-without-commit-log-metadata

[SPARK-24699][SS] Make watermarks work with Trigger.Once by saving updated watermark to commit log

8 лет назад
checkpoint-version-2.4.0-streaming-join

[SPARK-26154][SS] Streaming left/right outer join should not return outer nulls for already matched rows

7 лет назад
checkpoint-version-2.4.5-for-compatibility-test-common-functions

[SPARK-31905][SS] Add compatibility tests for streaming state store format

6 лет назад
checkpoint-version-2.4.5-for-compatibility-test-deduplicate

[SPARK-31905][SS] Add compatibility tests for streaming state store format

6 лет назад
checkpoint-version-2.4.5-for-compatibility-test-statistical-functions

[SPARK-31905][SS] Add compatibility tests for streaming state store format

6 лет назад
checkpoint-version-2.4.5-for-compatibility-test-sum-decimal

[SPARK-31905][SS] Add compatibility tests for streaming state store format

6 лет назад
checkpoint-version-3.0.0-streaming-statestore-codec

[SPARK-33263][SS] Configurable StateStore compression codec

6 лет назад
checkpoint-version-3.1.0-flatmapgroupswithstate-repartition

[SPARK-38204][SS] Use StatefulOpClusteredDistribution for stateful operators with respecting backward compatibility

4 года назад
checkpoint-version-3.2.0-deduplication-with-repartition

[SPARK-38204][SS] Use StatefulOpClusteredDistribution for stateful operators with respecting backward compatibility

4 года назад
checkpoint-version-3.2.0-flatmapgroupswithstate1-repartition

[SPARK-38204][SS] Use StatefulOpClusteredDistribution for stateful operators with respecting backward compatibility

4 года назад
checkpoint-version-3.2.0-flatmapgroupswithstate2-repartition

[SPARK-38204][SS] Use StatefulOpClusteredDistribution for stateful operators with respecting backward compatibility

4 года назад
checkpoint-version-3.2.0-session-window-with-repartition

[SPARK-38204][SS] Use StatefulOpClusteredDistribution for stateful operators with respecting backward compatibility

4 года назад
checkpoint-version-3.2.0-streaming-aggregate-with-repartition

[SPARK-38204][SS] Use StatefulOpClusteredDistribution for stateful operators with respecting backward compatibility

4 года назад
checkpoint-version-3.3.0-streaming-deduplication

[SPARK-39650][SS] Fix incorrect value schema in streaming deduplication with backward compatibility

4 года назад
checkpoint-version-3.5.1-streaming-deduplication

[SPARK-48687][SS] Add change to perform state schema validation and update on driver in planning phase for stateful queries

2 года назад
checkpoint-version-3.5.1-streaming-join

[SPARK-48687][SS] Add change to perform state schema validation and update on driver in planning phase for stateful queries

2 года назад
checkpoint-version-4.0.0-checkpoint-v2

[SPARK-53332][SS] Enable StateDataSource with state checkpoint v2 (only snapshotStartBatchId option)

год назад
checkpoint-version-4.0.0-tws-avro

[SPARK-51172][SS] Rename to spark.sql.optimizer.pruneFiltersCanPruneStreamingSubplan

год назад
checkpoint-version-4.0.0-tws-unsaferow

[SPARK-51172][SS] Rename to spark.sql.optimizer.pruneFiltersCanPruneStreamingSubplan

год назад
checkpoint-version-4.0.0

[SPARK-48589][SQL][SS] Add option snapshotStartBatchId and snapshotPartitionId to state data source

2 года назад
checkpoint-version-4.0.1-dedup-spark-53942

[SPARK-53942][SS] Support changing stateless shuffle partitions upon restart of streaming query

10 месяцев назад
escaped-path-2.4.0

[SPARK-26824][SS] Fix the checkpoint location and _spark_metadata when it contains special chars

7 лет назад
file-sink-log-version-2.1.0

[SPARK-30462][SS] Streamline the logic on file stream source and sink metadata log to avoid memory issue

6 лет назад
file-source-log-version-2.1.0

[SPARK-18671][SS][TEST] Added tests to ensure stability of that all Structured Streaming log formats

10 лет назад
offset-log-version-2.1.0

[SPARK-18776][SS] Make Offset for FileStreamSource corrected formatted in json

10 лет назад
offset-map

[SPARK-54423][SS] Introducing OffsetMap to enable Named Streaming Sources

8 месяцев назад
partition-tests

[SPARK-48060][SS][TESTS] Fix `StreamingQueryHashPartitionVerifySuite` to update golden files correctly

2 года назад
testCommitLogV1

[SPARK-50654][SS] CommitMetadata should set stateUniqueIds to None in V1

2 года назад
testCommitLogV2-empty-unique-id

[SPARK-50654][SS] CommitMetadata should set stateUniqueIds to None in V1

2 года назад
testCommitLogV2

[SPARK-50654][SS] CommitMetadata should set stateUniqueIds to None in V1

2 года назад
file-source-offset-version-2.1.0-json.txt

[SPARK-18776][SS] Make Offset for FileStreamSource corrected formatted in json

10 лет назад
file-source-offset-version-2.1.0-long.txt

[SPARK-18776][SS] Make Offset for FileStreamSource corrected formatted in json

10 лет назад
query-event-logs-version-2.0.0.txt

[SPARK-18143][SQL] Ignore Structured Streaming event logs to avoid breaking history server

10 лет назад
query-event-logs-version-2.0.1.txt

[SPARK-18143][SQL] Ignore Structured Streaming event logs to avoid breaking history server

10 лет назад
query-event-logs-version-2.0.2.txt

[SPARK-18655][SS] Ignore Structured Streaming 2.0.2 logs in history server

10 лет назад
query-metadata-logs-version-2.1.0.txt

[SPARK-18657][SPARK-18668] Make StreamingQuery.id persists across restart and not auto-generate StreamingQuery.name

10 лет назад