[dr][api] OPSAPS-45083 Add Hive stats in ApiHiveReplicationResult to CM API

Added the Hive stats to ApiHiveReplicationResult.

Testing Done:
1. Added the unit tests
2. make clean dist

(cherry picked from commit 1f71d5a)

Author: ankuriitg

python/src/cm_api/endpoints/types.py

@@ -826,6 +826,19 @@ class ApiHiveReplicationResult(BaseApiObject):
     'runAsUser'             : ROAttr(),
     'runOnSourceAsUser'     : ROAttr(),
     'phase'                 : ROAttr(),
+    'statsAvailable'        : ROAttr(),
+    'dbProcessed'           : ROAttr(),
+    'tableProcessed'        : ROAttr(),
+    'partitionProcessed'    : ROAttr(),
+    'functionProcessed'     : ROAttr(),
+    'indexProcessed'        : ROAttr(),
+    'statsProcessed'        : ROAttr(),
+    'dbExpected'            : ROAttr(),
+    'tableExpected'         : ROAttr(),
+    'partitionExpected'     : ROAttr(),
+    'functionExpected'      : ROAttr(),
+    'indexExpected'         : ROAttr(),
+    'statsExpected'         : ROAttr(),
   }
 
 class ApiReplicationCommand(ApiCommand):

python/src/cm_api_tests/test_replication.py

@@ -148,7 +148,8 @@ def test_hive_arguments(self):
         { "database" : "db1", "tableName" : "table1" }
       ],
       "dryRun" : false,
-      "replicateImpalaMetadata" : true
+      "replicateImpalaMetadata" : true,
+      "numThreads" : 4
     }'''
     args = utils.deserialize(RAW, ApiHiveReplicationArguments)
     self.assertEquals('vst2', args.sourceService.peerName)
@@ -163,6 +164,7 @@ def test_hive_arguments(self):
     self.assertEquals("db1", args.tableFilters[0].database)
     self.assertEquals("table1", args.tableFilters[0].tableName)
     self.assertTrue(args.replicateImpalaMetadata)
+    self.assertEquals(4, args.numThreads)
 
   def test_hive_cloud_arguments(self):
     RAW = '''{
@@ -239,7 +241,20 @@ def test_hive_results(self):
       },
       "dryRun" : false,
       "runAsUser" : "systest",
-      "runOnSourceAsUser" : "hdfs"
+      "runOnSourceAsUser" : "hdfs",
+      "statsAvailable" : true,
+      "dbProcessed" : 1,
+      "tableProcessed" : 10,
+      "partitionProcessed" : 100,
+      "functionProcessed" : 1,
+      "indexProcessed" : 1,
+      "statsProcessed" : 100,
+      "dbExpected" : 10,
+      "tableExpected" : 100,
+      "partitionExpected" : 1000,
+      "functionExpected" : 10,
+      "indexExpected" : 10,
+      "statsExpected" : 1000
     }'''
     res = utils.deserialize(RAW, ApiHiveReplicationResult)
     self.assertEquals('EXPORT', res.phase)
@@ -266,6 +281,19 @@ def test_hive_results(self):
     self.assertFalse(res.dryRun)
     self.assertEquals(res.runAsUser, 'systest')
     self.assertEquals(res.runOnSourceAsUser, 'hdfs')
+    self.assertTrue(res.statsAvailable)
+    self.assertEquals(1, res.dbProcessed)
+    self.assertEquals(10, res.tableProcessed)
+    self.assertEquals(100, res.partitionProcessed)
+    self.assertEquals(1, res.functionProcessed)
+    self.assertEquals(1, res.indexProcessed)
+    self.assertEquals(100, res.statsProcessed)
+    self.assertEquals(10, res.dbExpected)
+    self.assertEquals(100, res.tableExpected)
+    self.assertEquals(1000, res.partitionExpected)
+    self.assertEquals(10, res.functionExpected)
+    self.assertEquals(10, res.indexExpected)
+    self.assertEquals(1000, res.statsExpected)
 
   def test_schedule(self):
     RAW = '''{