anchor.diff:      recorder.incMetric( "<%= entity.data_module.name %>.<%= entity.name %>.RemoveDuration", (int) ( entityEndAt - entityStartAt ) );
     }
   <% end -%>
  -<% data_module.sync.entities_to_synchronize.each do |entity| -%>
  +<% data_module.sync.entities_to_synchronize.each do |entity|
  +  bulk_sync = entity.sync.supports_bulk_sync? -%>
   
     private void sync<%= entity.data_module.name %><%= entity.name %>Updates(
         @javax.annotation.Nonnull final String mappingSourceCode,
  -      @javax.annotation.Nonnull final iris.syncrecord.server.service.SynchronizationRecorder recorder,
  -      final boolean isBulkSync )
  +      @javax.annotation.Nonnull final iris.syncrecord.server.service.SynchronizationRecorder recorder<% if bulk_sync -%>,
  +      final boolean isBulkSync<% end -%> )
       throws Exception
     {
       final long entityStartAt = System.currentTimeMillis();
  -    log( mappingSourceCode, ( isBulkSync ? "Bulk " : "" ) + "Synchronizing <%= entity.qualified_name %> adds and updates" );
  -    synchronize<%= entity.data_module.name %><%= entity.name %>Updates( mappingSourceCode, recorder, isBulkSync );
  +    log( mappingSourceCode, <% if bulk_sync -%>( isBulkSync ? "Bulk " : "" ) + <% end -%>"Synchronizing <%= entity.qualified_name %> adds and updates" );
  +    synchronize<%= entity.data_module.name %><%= entity.name %>Updates( mappingSourceCode, recorder<% if bulk_sync -%>, isBulkSync<% end -%> );
       final int addCount = recorder.getMetricValue( "<%= entity.data_module.name %>.<%= entity.name %>.AddCount" ).get();
       log( mappingSourceCode, "Added " + addCount + " <%= entity.data_module.name %>.<%= entity.name %> instances" );
   <% if entity.sync.update_via_sync? -%>
  
positive.code: <% end -%>
  
    private void synchronize<%= entity.data_module.name %><%= entity.name %>Updates( @javax.annotation.Nonnull final String mappingSourceCode,
        @javax.annotation.Nonnull final iris.syncrecord.server.service.SynchronizationRecorder recorder,
        final boolean isBulkSync )
      throws Exception
    {
  <% if entity.sync.supports_bulk_sync? %>
  
negative.code:       sync<%= entity.data_module.name %><%= entity.name %>Removals( mappingSourceCode, recorder );
  <% end -%>
  <% data_module.sync.entities_to_synchronize.each do |entity| -%>
        sync<%= entity.data_module.name %><%= entity.name %>Updates( mappingSourceCode, recorder<% if entity.sync.supports_bulk_sync? -%>, isBulkSync<% end -%> );
  <% end -%>
  
        if ( isBulkSync )
  