@Test(expected = NullPointerException.class)
  public void testPutAsyncNullValue() {
    CouchbaseTableWriteFunction<JsonObject> writeFunction = createAndInit();
    writeFunction.putAsync("key", null);
  }
This class performs unit tests for CouchbaseTableWriteFunction.
samza-kv-couchbase/src/test/java/org/apache/samza/table/remote/couchbase/TestCouchbaseTableWriteFunction.java