anchor.diff:  
   open System
   open System.Runtime.Serialization
  -open System.Threading
  -
   open Microsoft.WindowsAzure.Storage.Table
  -
  -open MBrace.Core
   open MBrace.Core.Internals
  -open MBrace.Runtime.Utils
   open MBrace.Azure
  -open MBrace.Azure.Runtime
   open MBrace.Azure.Runtime.Utilities
   open MBrace.Runtime
   
  -type BlobReferenceEntity(partitionKey, rowKey, uri : string) =
  +type BlobReferenceEntity(partitionKey, rowKey, uri : string) = 
       inherit TableEntity(partitionKey, rowKey)
       member val Uri = uri with get, set
  -    new () = BlobReferenceEntity(null, null, null)
  +    new() = BlobReferenceEntity(null, null, null)
  +    static member internal MakeRowKey(rowKey, index) = sprintf "%s:%010d" rowKey index
  +
   
   [<DataContract; Sealed>]
   type ResultAggregator<'T> internal (config : ConfigurationId, partitionKey : string, rowKey : string, size : int) = 
  -    static let mkRowKey name i = sprintf "%s:%010d" name i
   
       [<DataMember(Name = "config")>]
       let config = config
  
positive.code: 
      let getEntities () = async {
          let pkFilter = TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, partitionKey)
          let lower = mkRowKey rowKey 0
          let upper = mkRowKey rowKey size
          let rkFilter = 
              TableQuery.CombineFilters(
                  TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.LessThanOrEqual, upper),
  
negative.code:                     return re
              }
  
  [<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