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 7f2f2bf Fixed build failure due to changes in Samza project (#63)
7f2f2bf is described below
commit 7f2f2bfbfe50cf13911ccd14be715cd8e0671e7a
Author: Wei Song <[email protected]>
AuthorDate: Wed May 22 15:33:56 2019 -0700
Fixed build failure due to changes in Samza project (#63)
Fixed build failure due to changes in Samza project
---
.gitignore | 1 +
build.gradle | 4 ++--
gradle.properties | 2 +-
src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java | 4 +++-
4 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/.gitignore b/.gitignore
index 8d1f669..a80b94e 100644
--- a/.gitignore
+++ b/.gitignore
@@ -33,3 +33,4 @@ build/
state
manifest.txt
pathing.jar
+out/
diff --git a/build.gradle b/build.gradle
index 80dafea..9c807c7 100644
--- a/build.gradle
+++ b/build.gradle
@@ -59,11 +59,11 @@ 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")
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")
runtime(group: 'org.apache.kafka', name: 'kafka_2.11', version:
"$KAFKA_VERSION")
diff --git a/gradle.properties b/gradle.properties
index 126ebd9..1063c21 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -17,7 +17,7 @@
* under the License.
*/
-SAMZA_VERSION=1.1.0
+SAMZA_VERSION=1.1.1-SNAPSHOT
KAFKA_VERSION=0.11.0.2
HADOOP_VERSION=2.6.1
diff --git a/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
b/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
index 4165342..b21a48a 100644
--- a/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
+++ b/src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java
@@ -41,6 +41,7 @@ import
org.apache.samza.system.kafka.descriptors.KafkaOutputDescriptor;
import org.apache.samza.system.kafka.descriptors.KafkaSystemDescriptor;
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 +159,8 @@ 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(() -> {
