This is an automated email from the ASF dual-hosted git repository.
reiabreu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
from 8f876533f Merge pull request #8793 from
apache/dependabot/npm_and_yarn/storm-webapp/form-data-4.0.6
add 3a39aca87 feat: add DetachedTuple, a serializable Tuple snapshot
add 4fdd1dc35 fix: emit late tuples as DetachedTuple in
WindowedBoltExecutor
add 50becd9e5 docs: document late tuple stream serialization contract
add 5baee16ea test: cover null values, typed getters, equals and transient
fields in DetachedTuple
add c55a572be docs: document late tuple value behavior change
new 30621226e Merge pull request #8790 from dpol1/fix/7782
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/Windowing.md | 9 +-
.../storm/serialization/SerializationFactory.java | 2 +
.../storm/streams/windowing/SlidingWindows.java | 3 +
.../storm/streams/windowing/TumblingWindows.java | 3 +
.../storm/topology/WindowedBoltExecutor.java | 8 +-
.../storm/topology/base/BaseWindowedBolt.java | 3 +
.../tuple/{TupleImpl.java => DetachedTuple.java} | 184 ++++++++++-----------
.../PersistentWindowedBoltExecutorTest.java | 6 +-
.../storm/topology/WindowedBoltExecutorTest.java | 52 +++++-
.../org/apache/storm/tuple/DetachedTupleTest.java | 183 ++++++++++++++++++++
10 files changed, 352 insertions(+), 101 deletions(-)
copy storm-client/src/jvm/org/apache/storm/tuple/{TupleImpl.java =>
DetachedTuple.java} (56%)
create mode 100644
storm-client/test/jvm/org/apache/storm/tuple/DetachedTupleTest.java
