in code/KustoCopyConsole/Runner/AwaitIngestRunner.cs [271:291]
private IEnumerable<ActivityFlatHierarchy> TakeMovingBlocks(
IEnumerable<ActivityFlatHierarchy> items)
{
var i = 0;
var totalExtents = 0;
foreach (var item in items)
{
if (totalExtents + item.Extents.Count() > MAXIMUM_EXTENT_MOVING)
{
return items.Take(Math.Max(1, i));
}
else
{
totalExtents += item.Extents.Count();
++i;
}
}
return items;
}