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