private ProtoBlockCollection PlanBlockBatch()

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;
        }