@Test(expected = IllegalArgumentException.class)
  public void testConstructorInvalidClusterNodes() {
    new CouchbaseTableReadFunction<>(DEFAULT_BUCKET_NAME, String.class);
  }
This class performs unit tests for CouchbaseTableReadFunction.
samza-kv-couchbase/src/test/java/org/apache/samza/table/remote/couchbase/TestCouchbaseTableReadFunction.java