[kafka] branch trunk updated (9da32b6 -> 85b6545)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 9da32b6 KAFKA-9924: Add RocksDB metric num-entries-active-mem-table
(#9177)
add 85b6545 KAFKA-5636: SlidingWindows (KIP-450) (#9039)
No new revisions were added by this update.
Summary of changes:
.../kafka/streams/kstream/CogroupedKStream.java| 9 +
.../kafka/streams/kstream/KGroupedStream.java | 7 +
.../kafka/streams/kstream/SlidingWindows.java | 140 +
.../kstream/internals/CogroupedKStreamImpl.java| 14 +
.../internals/CogroupedStreamAggregateBuilder.java | 75 ++-
.../kstream/internals/KGroupedStreamImpl.java | 16 +
.../internals/KStreamSlidingWindowAggregate.java | 307 +
.../SessionWindowedCogroupedKStreamImpl.java | 42 +-
...va => SlidingWindowedCogroupedKStreamImpl.java} | 118 ++--
...amImpl.java => SlidingWindowedKStreamImpl.java} | 144 ++---
.../TimeWindowedCogroupedKStreamImpl.java | 52 +-
.../kstream/internals/TimeWindowedKStreamImpl.java | 45 +-
.../internals/graph/GraphGraceSearchUtil.java | 6 +
.../KStreamAggregationIntegrationTest.java | 204 ++
.../kafka/streams/kstream/SlidingWindowsTest.java | 82 +++
.../internals/CogroupedKStreamImplTest.java| 55 +-
.../kstream/internals/KGroupedStreamImplTest.java | 317 +++---
.../KStreamSlidingWindowAggregateTest.java | 692 +
...> SlidingWindowedCogroupedKStreamImplTest.java} | 258 +++-
.../internals/SlidingWindowedKStreamImplTest.java | 439 +
.../kstream/internals/SuppressScenarioTest.java| 84 +++
21 files changed, 2566 insertions(+), 540 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedCogroupedKStreamImpl.java
=> SlidingWindowedCogroupedKStreamImpl.java} (50%)
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedKStreamImpl.java
=> SlidingWindowedKStreamImpl.java} (61%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
copy
streams/src/test/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedCogroupedKStreamImplTest.java
=> SlidingWindowedCogroupedKStreamImplTest.java} (53%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java
[kafka-site] branch asf-site updated: [MINOR] adding Itau Unibanco and OTICS to the powered-by page (#300)
This is an automated email from the ASF dual-hosted git repository.
ewencp pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/kafka-site.git
The following commit(s) were added to refs/heads/asf-site by this push:
new f85f951 [MINOR] adding Itau Unibanco and OTICS to the powered-by page
(#300)
f85f951 is described below
commit f85f9511dd367ef3be5717e7c23868e2bf6cb0ad
Author: scott-confluent <66280178+scott-conflu...@users.noreply.github.com>
AuthorDate: Mon Aug 31 12:41:26 2020 -0700
[MINOR] adding Itau Unibanco and OTICS to the powered-by page (#300)
---
images/powered-by/itau.png | Bin 0 -> 8432 bytes
images/powered-by/otics.png | Bin 0 -> 25835 bytes
powered-by.html | 10 ++
3 files changed, 10 insertions(+)
diff --git a/images/powered-by/itau.png b/images/powered-by/itau.png
new file mode 100644
index 000..0898605
Binary files /dev/null and b/images/powered-by/itau.png differ
diff --git a/images/powered-by/otics.png b/images/powered-by/otics.png
new file mode 100644
index 000..e6392c7
Binary files /dev/null and b/images/powered-by/otics.png differ
diff --git a/powered-by.html b/powered-by.html
index 73cee12..725d42f 100644
--- a/powered-by.html
+++ b/powered-by.html
@@ -238,6 +238,11 @@
"logoBgColor": "#007bb6",
"description": "Apache Kafka is used at LinkedIn for activity stream
data and operational metrics. This powers various products like LinkedIn
Newsfeed, LinkedIn Today in addition to our offline analytics systems like
Hadoop."
}, {
+"link": "https://www.itau.com.br";,
+"logo": "itau.png",
+"logoBgColor": "#ff",
+"description": "Itaú Unibanco uses Apache Kafka for integrations,
decoupling and application modernization. This kind of technology help us on
digital strategies and enable us to deliver new solutions applied to the
business, through application streaming and data pipelines, accelerating our
digital transformation and evolving our technology architecture."
+}, {
"link": "http://www.liveperson.com/";,
"logo": "liveperson.png",
"logoBgColor": "#ff",
@@ -313,6 +318,11 @@
"logoBgColor": "#ff",
"description": "Kafka is used as the primary high speed message queue
to power Storm and our real-time analytics/event ingestion pipelines."
}, {
+"link": "http://www.otics.ca/";,
+"logo": "otics.png",
+"logoBgColor": "#ff",
+"description": "We use Apache Kafka with our MAADS-VIPER product to
manage the distribution of insights from thousands of machine learning
algorithms that allow users or machines to publish and consume these insights
for decision-making. We also use Kafka for Real-Time Machine Learning to
create micro machine learning models that provide clients with transactional
learnings very fast."
+}, {
"link": "http://www.ovh.com/us/index.xml";,
"logo": "ovh.png",
"logoBgColor": "#ff",
