private BucketConfiguration configBucket(String bucketName) {
    BucketConfiguration config = new BucketConfiguration();
    config.numNodes = 1;
    config.numReplicas = 1;
    config.name = bucketName;
    return config;
  }
This class does an end to end testing for Couchbase table functions. It puts some data to an in-memory stream and a
mocked Couchbase bucket. Then it does a join between the stream and the Couchbase table. Finally it writes the
result to another mocked Couchbase bucket and assert the result to be what we expect. Due to the problem of
CouchbaseMock library, closing a mocked bucket would throw exceptions like: java.lang.ArithmeticException: / by zero.
Please ignore those exception.
samza-test/src/test/java/org/apache/samza/test/table/TestCouchbaseRemoteTableEndToEnd.java