added getPendingMutationSize to Mutator

core/src/main/java/me/prettyprint/cassandra/model/MutatorImpl.java

@@ -265,6 +265,11 @@ public String toString() {
     return "Mutator(" + keyspace.toString() + ")";
   }
 
+  @Override
+  public int getPendingMutationCount() {
+    return getPendingMutations().getSize();
+  }
+
   private BatchMutation<K> getPendingMutations() {
     if (pendingMutations == null) {
       pendingMutations = new BatchMutation<K>(keySerializer, sizeHint);

core/src/main/java/me/prettyprint/cassandra/service/BatchMutation.java

@@ -155,4 +155,12 @@ public BatchMutation<K> makeCopy() {
   public boolean isEmpty() {
     return mutationMap.isEmpty() ;
   }
+
+  /**
+   * Return the current size of the underlying map
+   * @return
+   */
+  public int getSize() {
+    return mutationMap.size();
+  }
 }

core/src/main/java/me/prettyprint/hector/api/mutation/Mutator.java

@@ -218,4 +218,9 @@ <SN, N> MutationResult subDeleteCounter(final K key, final String cf, final SN s
    */
   <SN,N> Mutator<K> addCounterSubDeletion(K key, String cf, HCounterSuperColumn<SN,N> sc);
 
+  /**
+   * Get the size of the pending mutations map
+   */
+  int getPendingMutationCount();
+
 }

core/src/test/java/me/prettyprint/cassandra/model/MutatorTest.java

@@ -150,6 +150,7 @@ public void testBatchMutationManagement() {
     for (int i = 0; i < 5; i++) {
       m.addInsertion("k" + i, cf, createColumn("name", "value" + i, se, se));
     }
+    assertEquals(5, m.getPendingMutationCount());
     MutationResult r = m.execute();
     assertTrue("Execute time should be > 0", r.getExecutionTimeMicro() > 0);
     assertTrue("Should have operated on a host", r.getHostUsed() != null);