update to samza 1.2.0
diff --git a/README.md b/README.md
index 3f2a7b5..ea5113a 100644
--- a/README.md
+++ b/README.md
@@ -67,7 +67,7 @@
Once the job is started, we can tail the kafka topic by:
```
-./deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wikipedia-stats
+./deploy/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wikipedia-stats
```
A code walkthrough of this application can be found [here](http://samza.apache.org/learn/tutorials/latest/hello-samza-high-level-code.html).
diff --git a/bin/deploy.sh b/bin/deploy.sh
index d6ce59c..a03d5bb 100755
--- a/bin/deploy.sh
+++ b/bin/deploy.sh
@@ -23,4 +23,4 @@
mvn clean package
mkdir -p $base_dir/deploy/samza
-tar -xvf $base_dir/target/hello-samza-1.0.0-dist.tar.gz -C $base_dir/deploy/samza
+tar -xvf $base_dir/target/hello-samza-1.2.0-dist.tar.gz -C $base_dir/deploy/samza
diff --git a/build.gradle b/build.gradle
index 143995d..7aba4c8 100644
--- a/build.gradle
+++ b/build.gradle
@@ -60,11 +60,12 @@
compile(group: 'org.apache.samza', name: 'samza-test_2.11', version: "$SAMZA_VERSION")
compile(group: 'org.apache.samza', name: 'samza-kafka_2.11', version: "$SAMZA_VERSION")
compile(group: 'org.apache.samza', name: 'samza-kv-rocksdb_2.11', version: "$SAMZA_VERSION")
- compile(group: 'org.apache.samza', name: 'samza-azure', version: "$SAMZA_VERSION")
+ compile(group: 'org.apache.samza', name: 'samza-azure_2.11', version: "$SAMZA_VERSION")
+ compile(group: 'org.apache.samza', name: 'samza-aws_2.11', version: "$SAMZA_VERSION")
testCompile(group: 'junit', name: 'junit', version: "4.12")
explode (group: 'org.apache.samza', name: 'samza-shell', ext: 'tgz', classifier: 'dist', version: "$SAMZA_VERSION")
runtime(group: 'org.apache.samza', name: 'samza-core_2.11', version: "$SAMZA_VERSION")
- runtime(group: 'org.apache.samza', name: 'samza-log4j', version: "$SAMZA_VERSION")
+ runtime(group: 'org.apache.samza', name: 'samza-log4j_2.11', version: "$SAMZA_VERSION")
runtime(group: 'org.apache.samza', name: 'samza-shell', version: "$SAMZA_VERSION")
runtime(group: 'org.apache.samza', name: 'samza-yarn_2.11', version: "$SAMZA_VERSION")
diff --git a/gradle.properties b/gradle.properties
index 126ebd9..283cc4a 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -17,7 +17,7 @@
* under the License.
*/
-SAMZA_VERSION=1.1.0
+SAMZA_VERSION=1.2.0
KAFKA_VERSION=0.11.0.2
HADOOP_VERSION=2.6.1
diff --git a/pom.xml b/pom.xml
index c61eb45..bef75f0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.samza</groupId>
<artifactId>hello-samza</artifactId>
- <version>1.1.0</version>
+ <version>1.2.0</version>
<packaging>jar</packaging>
<name>Samza Example</name>
<description>
@@ -211,7 +211,7 @@
<properties>
<!-- maven specific properties -->
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <samza.version>1.1.0</samza.version>
+ <samza.version>1.2.0</samza.version>
<hadoop.version>2.6.1</hadoop.version>
</properties>
diff --git a/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java b/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
index 4165342..066f37c 100644
--- a/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
+++ b/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
@@ -30,6 +30,7 @@
import org.apache.samza.SamzaException;
import org.apache.samza.application.StreamApplication;
import org.apache.samza.application.descriptors.StreamApplicationDescriptor;
+import org.apache.samza.context.Context;
import org.apache.samza.operators.KV;
import org.apache.samza.operators.MessageStream;
import org.apache.samza.operators.OutputStream;
@@ -39,8 +40,10 @@
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.AsyncReadWriteTable;
import org.apache.samza.table.Table;
import org.apache.samza.table.descriptors.CachingTableDescriptor;
+import org.apache.samza.table.remote.BaseTableFunction;
import org.apache.samza.table.remote.TableReadFunction;
import org.apache.samza.table.descriptors.RemoteTableDescriptor;
import org.apache.samza.util.ExponentialSleepStrategy;
@@ -158,7 +161,7 @@
}
}
- static class StockPriceReadFunction implements TableReadFunction<String, Double> {
+ static class StockPriceReadFunction extends BaseTableFunction implements TableReadFunction<String, Double> {
@Override
public CompletableFuture<Double> getAsync(String symbol) {
return CompletableFuture.supplyAsync(() -> {
