@Test
  public void testIsRetriable() {
    CouchbaseTableWriteFunction writeFunction = createAndInit();
    assertTrue(writeFunction.isRetriable(new TemporaryFailureException()));
    assertTrue(writeFunction.isRetriable(new TemporaryLockFailureException()));
    assertTrue(writeFunction.isRetriable(new SamzaException(new TemporaryLockFailureException())));
    assertTrue(writeFunction.isRetriable(new SamzaException(new TemporaryFailureException())));
    assertTrue(writeFunction.isRetriable(
        new RuntimeException(new SamzaException(new RuntimeException(new TemporaryFailureException())))));
  }
This class performs unit tests for CouchbaseTableWriteFunction.
samza-kv-couchbase/src/test/java/org/apache/samza/table/remote/couchbase/TestCouchbaseTableWriteFunction.java