anchor.diff:                      return re
               }
   
  -    static member Create<'T>(config, size, pid) = 
  -        let name = guid()
  -        let entities = seq {
  -            for i = 0 to size - 1 do
  -                let name = mkRowKey name i
  -                yield new BlobReferenceEntity(pid, name, String.Empty, EntityType = "AGGR")
  -        }
  -        let ops = entities |> Seq.map TableOperation.Insert
  -        { new TableResourceOperation<ResultAggregator<'T>> with
  -              member this.Operations = ops
  -              member this.Resource = new ResultAggregator<'T>(config, pid, name, size)
  -              
  -        }+[<Sealed>]
  +type ResultAggregatorFactory private (config : ConfigurationId) =
  +    interface ICloudResultAggregatorFactory with
  +        member x.CreateResultAggregator(capacity: int): Async<ICloudResultAggregator<'T>> = 
  +            async {
  +                let key = guid()
  +                let entities = seq {
  +                    for i = 0 to capacity - 1 do
  +                        let rowKey = BlobReferenceEntity.MakeRowKey(key, i)
  +                        yield new BlobReferenceEntity(key, rowKey, null)
  +                }
  +                do! Table.insertBatch config config.RuntimeTable entities
  +                return new ResultAggregator<'T>(config, key, key, capacity) :> ICloudResultAggregator<'T>
  +            }
  +    
  +    static member Create(config) = new ResultAggregatorFactory(config) :> ICloudResultAggregatorFactory
positive.code:             async { 
                  let! bc = Blob.Create(config, partitionKey, guid(), fun () -> value)
                  if overwrite then
                      let e = new BlobReferenceEntity(partitionKey, mkRowKey rowKey index, null, ETag = "*")
                      e.Uri <- bc.Path
                      let! _ = Table.merge config config.RuntimeTable e
                      return! completed()
                  else
                      let entity = Table.read<BlobReferenceEntity> config 
                      let! _ = Table.transact<BlobReferenceEntity> config config.RuntimeTable partitionKey (mkRowKey rowKey index)
                                  (fun e ->
                                      if e.Uri = null then e.Uri <- bc.Path)
                      return! completed()
  
negative.code: 
      let getEntities () = async {
          let pkFilter = TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, partitionKey)
          let lower = BlobReferenceEntity.MakeRowKey(rowKey, 0)
          let upper = BlobReferenceEntity.MakeRowKey(rowKey, size)
          let rkFilter = 
              TableQuery.CombineFilters(
                  TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.LessThanOrEqual, upper),
  