protected void invoke ( String serviceName , Operation operation , int partitionId ) { try { operationCount ++ ; operationService . invokeOnPartition ( serviceName , operation , partitionId ) . andThen ( mergeCallback ) ; } catch ( Throwable t ) { throw rethrow ( t ) ; } }
Invokes the given merge operation .