You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by we...@apache.org on 2019/05/28 17:46:50 UTC
[samza-hello-samza] branch latest updated: SAMZA-2223: Update
Couchbase example to use NoOpTableReadFunction
This is an automated email from the ASF dual-hosted git repository.
weisong44 pushed a commit to branch latest
in repository https://gitbox.apache.org/repos/asf/samza-hello-samza.git
The following commit(s) were added to refs/heads/latest by this push:
new fd13056 SAMZA-2223: Update Couchbase example to use NoOpTableReadFunction
fd13056 is described below
commit fd1305699392edfec0bfab250b05f4bd6a58fe58
Author: Wei Song <ws...@linkedin.com>
AuthorDate: Tue May 28 10:46:46 2019 -0700
SAMZA-2223: Update Couchbase example to use NoOpTableReadFunction
---
src/main/java/samza/examples/cookbook/CouchbaseTableExample.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/samza/examples/cookbook/CouchbaseTableExample.java b/src/main/java/samza/examples/cookbook/CouchbaseTableExample.java
index 4923110..a6b2dee 100644
--- a/src/main/java/samza/examples/cookbook/CouchbaseTableExample.java
+++ b/src/main/java/samza/examples/cookbook/CouchbaseTableExample.java
@@ -42,7 +42,7 @@ import org.apache.samza.system.kafka.descriptors.KafkaInputDescriptor;
import org.apache.samza.system.kafka.descriptors.KafkaOutputDescriptor;
import org.apache.samza.system.kafka.descriptors.KafkaSystemDescriptor;
import org.apache.samza.table.descriptors.RemoteTableDescriptor;
-import org.apache.samza.table.remote.DummyTableReadFunction;
+import org.apache.samza.table.remote.NoOpTableReadFunction;
import org.apache.samza.table.remote.RemoteTable;
import org.apache.samza.table.remote.couchbase.CouchbaseTableWriteFunction;
import org.apache.samza.table.retry.TableRetryPolicy;
@@ -169,7 +169,7 @@ public class CouchbaseTableExample implements StreamApplication {
.withStopAfterAttempts(3);
RemoteTableDescriptor couchbaseTableDescriptor = new RemoteTableDescriptor("couchbase-table")
- .withReadFunction(new DummyTableReadFunction())
+ .withReadFunction(new NoOpTableReadFunction())
.withReadRateLimiterDisabled()
.withWriteFunction(writeFn)
.withWriteRetryPolicy(retryPolicy)