in code/KustoCopyConsole/Runner/PlanningRunner.cs [304:333]
private ProtoBlockCollection PlanBlockBatch(
ProtoBlockCollection protoBlocks,
bool includeIncompleteBlock,
string activityName,
long iterationId,
long lastBlockId)
{
(var blocks, var newProtoBlocks) =
protoBlocks.PopCompletedBlocks(includeIncompleteBlock);
foreach (var block in blocks)
{
var blockItem = new BlockRowItem
{
State = BlockState.Planned,
ActivityName = activityName,
IterationId = iterationId,
BlockId = ++lastBlockId,
IngestionTimeStart = block.IngestionTimeStart,
IngestionTimeEnd = block.IngestionTimeEnd,
MinCreationTime = block.MinCreationTime,
MaxCreationTime = block.MaxCreationTime,
PlannedRowCount = block.RowCount
};
RowItemGateway.Append(blockItem);
}
return newProtoBlocks;
}