THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Here is an example topology of an inner join and how it gets rewritten:
| Code Block |
|---|
Topologies: |
...
Sub-topology: 0 |
...
Source: KSTREAM-SOURCE-0000000000 (topics: [topic2]) |
...
--> KSTREAM-WINDOWED-0000000001, KSTREAM-WINDOWED-0000000002 |
...
Processor: KSTREAM-WINDOWED-0000000001 (stores: [KSTREAM-JOINTHIS-0000000003-store]) |
...
--> KSTREAM-JOINTHIS-0000000003 |
...
<-- KSTREAM-SOURCE-0000000000 |
...
Processor: KSTREAM-WINDOWED-0000000002 (stores: [KSTREAM-JOINOTHER-0000000004-store]) |
...
--> KSTREAM-JOINOTHER-0000000004 |
...
<-- KSTREAM-SOURCE-0000000000 |
...
Processor: KSTREAM-JOINOTHER-0000000004 (stores: [KSTREAM-JOINTHIS-0000000003-store]) |
...
--> KSTREAM-MERGE-0000000005 |
...
<-- KSTREAM-WINDOWED-0000000002 |
...
Processor: KSTREAM-JOINTHIS-0000000003 (stores: [KSTREAM-JOINOTHER-0000000004-store]) |
...
--> KSTREAM-MERGE-0000000005 |
...
<-- KSTREAM-WINDOWED-0000000001 |
...
Processor: KSTREAM-MERGE-0000000005 (stores: []) |
...
--> KSTREAM-PROCESSOR-0000000006 |
...
<-- KSTREAM-JOINTHIS-0000000003, KSTREAM-JOINOTHER-0000000004 |
...
Processor: KSTREAM-PROCESSOR-0000000006 (stores: []) |
...
--> none |
...
<-- KSTREAM-MERGE-0000000005 |
Self-join topology:
| Code Block |
|---|
Topologies: Sub-topology: 0 Source: KSTREAM-SOURCE-0000000000 (topics: [topic1]) --> KSTREAM-WINDOWED-0000000001 Processor: KSTREAM-WINDOWED-0000000001 (stores: [KSTREAM-JOINTHIS-0000000003-store]) --> KSTREAM-MERGE-0000000005 <-- KSTREAM-SOURCE-0000000000 Processor: KSTREAM-MERGE-0000000005 (stores: [KSTREAM-JOINTHIS-0000000003-store]) --> KSTREAM-PROCESSOR-0000000006 <-- KSTREAM-WINDOWED-0000000001 Processor: KSTREAM-PROCESSOR-0000000006 (stores: []) --> none <-- KSTREAM-MERGE-0000000005 |
...
As you can see, none of the indices or names of the process is affected.
...