Skip to content

Commit a531687

Browse files
authored
Merge pull request #100339 from sidramadoss/patch-59
Update repartition.md
2 parents 5fae5d6 + a082fd6 commit a531687

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

articles/stream-analytics/repartition.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,12 @@ This article shows you how to use repartitioning to scale your Azure Stream Anal
1616
You might not be able to use [parallelization](stream-analytics-parallelization.md) if:
1717

1818
* You don't control the partition key for your input stream.
19-
* Your source "sprays" input across multiple partitions that later need to be merged.
20-
21-
## How to repartition
19+
* Your source "sprays" input across multiple partitions that later need to be merged.
2220

2321
Repartitioning, or reshuffling, is required when you process data on a stream that's not sharded according to a natural input scheme, such as **PartitionId** for Event Hubs. When you repartition, each shard can be processed independently, which allows you to linearly scale out your streaming pipeline.
2422

23+
## How to repartition
24+
2525
To repartition, use the keyword **INTO** after a **PARTITION BY** statement in your query. The following example partitions the data by **DeviceID** into a partition count of 10. Hashing of **DeviceID** is used to determine which partition shall accept which substream. The data is flushed independently for each partitioned stream, assuming the output supports partitioned writes, and has 10 partitions.
2626

2727
```sql

0 commit comments

Comments
 (0)