You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/09/07 07:36:04 UTC
[flink] branch master updated (71ffab6 -> 899a701)
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 71ffab6 [FLINK-19097][python] Support add_jars() in Python StreamExecutionEnvironment.
add c99e206 [FLINK-19035] Remove fold from DataStream API
add 899a701 [FLINK-19035] Remove DataStream#fold references from docs
No new revisions were added by this update.
Summary of changes:
docs/dev/scala_api_extensions.md | 23 -
docs/dev/scala_api_extensions.zh.md | 23 -
docs/dev/stream/operators/index.md | 66 ---
docs/dev/stream/operators/index.zh.md | 66 ---
docs/dev/stream/operators/windows.md | 120 +---
docs/dev/stream/operators/windows.zh.md | 120 +---
docs/dev/stream/state/queryable_state.md | 9 +-
docs/dev/stream/state/queryable_state.zh.md | 5 -
docs/ops/upgrading.md | 1 -
docs/ops/upgrading.zh.md | 1 -
flink-core/pom.xml | 4 +
.../flink/api/common/functions/FoldFunction.java | 61 ---
.../api/common/functions/RichFoldFunction.java | 42 --
.../flink/api/common/state/FoldingState.java | 43 --
.../api/common/state/FoldingStateDescriptor.java | 111 ----
.../flink/api/common/state/KeyedStateStore.java | 43 --
.../flink/api/java/typeutils/TypeExtractor.java | 29 -
.../tests/verify/TtlFoldingStateVerifier.java | 87 ---
.../streaming/tests/verify/TtlStateVerifier.java | 3 +-
.../apache/flink/cep/utils/TestSharedBuffer.java | 7 -
.../client/QueryableStateClient.java | 5 +-
.../client/state/ImmutableFoldingState.java | 70 ---
.../client/state/ImmutableFoldingStateTest.java | 94 ----
.../itcases/AbstractQueryableStateTestBase.java | 91 ----
.../runtime/state/DefaultKeyedStateStore.java | 13 -
.../flink/runtime/state/heap/HeapFoldingState.java | 137 -----
.../runtime/state/heap/HeapKeyedStateBackend.java | 4 +-
.../state/internal/InternalFoldingState.java | 36 --
.../flink/runtime/state/ttl/TtlFoldFunction.java | 50 --
.../flink/runtime/state/ttl/TtlFoldingState.java | 75 ---
.../flink/runtime/state/ttl/TtlStateFactory.java | 18 +-
.../flink/runtime/state/StateBackendTestBase.java | 171 ------
.../state/ttl/TtlFoldingStateTestContext.java | 67 ---
.../flink/runtime/state/ttl/TtlStateTestBase.java | 3 +-
.../state/ttl/mock/MockInternalFoldingState.java | 55 --
.../state/ttl/mock/MockKeyedStateBackend.java | 5 +-
.../streaming/state/RocksDBFoldingState.java | 116 ----
.../streaming/state/RocksDBKeyedStateBackend.java | 4 +-
flink-streaming-java/pom.xml | 11 +
.../api/datastream/AllWindowedStream.java | 375 -------------
.../streaming/api/datastream/KeyedStream.java | 56 +-
.../streaming/api/datastream/WindowedStream.java | 227 --------
.../windowing/FoldApplyAllWindowFunction.java | 117 ----
.../FoldApplyProcessAllWindowFunction.java | 137 -----
.../windowing/FoldApplyProcessWindowFunction.java | 136 -----
.../windowing/FoldApplyWindowFunction.java | 114 ----
.../streaming/api/operators/StreamGroupedFold.java | 116 ----
.../operators/windowing/WindowOperator.java | 7 -
.../operators/windowing/WindowOperatorBuilder.java | 68 ---
.../apache/flink/streaming/api/DataStreamTest.java | 40 +-
.../api/operators/StateDescriptorPassingTest.java | 49 --
.../api/operators/StreamGroupedFoldTest.java | 161 ------
.../windowing/AllWindowTranslationTest.java | 472 ++--------------
.../RegularWindowOperatorContractTest.java | 66 ---
.../windowing/TimeWindowTranslationTest.java | 37 --
.../windowing/WindowOperatorContractTest.java | 7 -
.../operators/windowing/WindowOperatorTest.java | 112 ----
.../operators/windowing/WindowTranslationTest.java | 446 ---------------
flink-streaming-scala/pom.xml | 16 +
.../streaming/api/scala/AllWindowedStream.scala | 251 +--------
.../flink/streaming/api/scala/KeyedStream.scala | 68 +--
.../flink/streaming/api/scala/WindowedStream.scala | 240 +-------
.../acceptPartialFunctions/OnKeyedStream.scala | 12 -
.../acceptPartialFunctions/OnWindowedStream.scala | 37 +-
.../scala/function/util/ScalaFoldFunction.scala | 33 --
.../api/scala/AllWindowTranslationTest.scala | 500 +----------------
.../flink/streaming/api/scala/DataStreamTest.scala | 58 +-
.../api/scala/StreamingOperatorsITCase.scala | 74 +--
.../api/scala/TimeWindowTranslationTest.scala | 33 +-
.../streaming/api/scala/WindowFoldITCase.scala | 390 -------------
.../api/scala/WindowTranslationTest.scala | 601 +--------------------
.../OnKeyedDataStreamTest.scala | 21 -
.../OnWindowedStreamTest.scala | 49 --
.../EventTimeAllWindowCheckpointingITCase.java | 68 ---
.../StreamFaultToleranceTestBase.java | 2 +-
.../UdfStreamOperatorCheckpointingITCase.java | 47 +-
.../streaming/api/StreamingOperatorsITCase.java | 159 ------
.../test/streaming/runtime/WindowFoldITCase.java | 342 ------------
78 files changed, 188 insertions(+), 7445 deletions(-)
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/functions/FoldFunction.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/functions/RichFoldFunction.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/state/FoldingState.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/state/FoldingStateDescriptor.java
delete mode 100644 flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/verify/TtlFoldingStateVerifier.java
delete mode 100644 flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/state/ImmutableFoldingState.java
delete mode 100644 flink-queryable-state/flink-queryable-state-client-java/src/test/java/org/apache/flink/queryablestate/client/state/ImmutableFoldingStateTest.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalFoldingState.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldingState.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlFoldingStateTestContext.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/mock/MockInternalFoldingState.java
delete mode 100644 flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java
delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java
delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java
delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java
delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java
delete mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamGroupedFoldTest.java
delete mode 100644 flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/function/util/ScalaFoldFunction.scala
delete mode 100644 flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowFoldITCase.scala
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/WindowFoldITCase.java