File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1946,10 +1946,10 @@ creates a single receiver (running on a worker machine) that receives a single s
19461946Receiving multiple data streams can therefore be achieved by creating multiple input DStreams
19471947and configuring them to receive different partitions of the data stream from the source(s).
19481948For example, a single Kafka input DStream receiving two topics of data can be split into two
1949- Kafka input streams, each receiving only one topic. This would run two receivers on two workers ,
1950- thus allowing data to be received in parallel, and increasing overall throughput. These multiple
1951- DStream can be unioned together to create a single DStream. Then the transformations that was
1952- being applied on the single input DStream can applied on the unified stream. This is done as follows.
1949+ Kafka input streams, each receiving only one topic. This would run two receivers,
1950+ allowing data to be received in parallel, and increasing overall throughput. These multiple
1951+ DStreams can be unioned together to create a single DStream. Then the transformations that were
1952+ being applied on a single input DStream can be applied on the unified stream. This is done as follows.
19531953
19541954<div class =" codetabs " >
19551955<div data-lang =" scala " markdown =" 1 " >
You can’t perform that action at this time.
0 commit comments