This is an automated email from the ASF dual-hosted git repository. boryas pushed a commit to branch 1.2.0 in repository https://gitbox.apache.org/repos/asf/samza-hello-samza.git
commit 5263b5ec43dd5a734392d685f5d6cf8c6513f2a0 Author: Boris S <[email protected]> AuthorDate: Fri Jun 7 11:13:14 2019 -0700 update to samza 1.2.0 --- README.md | 2 +- bin/deploy.sh | 2 +- build.gradle | 5 +++-- gradle.properties | 2 +- pom.xml | 4 ++-- src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java | 5 ++++- 6 files changed, 12 insertions(+), 8 deletions(-) diff --git a/README.md b/README.md index 3f2a7b5..ea5113a 100644 --- a/README.md +++ b/README.md @@ -67,7 +67,7 @@ Package [samza.examples.wikipedia.application](https://github.com/apache/samza-h 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 @@ base_dir=`pwd` 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 @@ dependencies { 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 @@ under the License. <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 @@ under the License. <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 java.util.concurrent.CompletableFuture; 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.serializers.StringSerde; 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 @@ public class RemoteTableJoinExample implements StreamApplication { } } - 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(() -> {
