Database Reference
In-Depth Information
<includes>
<include>org.apache.samza:samza-core_2.8.1</include>
<include>org.apache.samza:samza-kafka_2.8.1</include>
<include>org.apache.samza:samza-serializers_2.8.1</include>
<include>org.apache.samza:samza-yarn_2.8.1</include>
<include>org.slf4j:slf4j-log4j12</include>
<!--
<include>wiley:streaming-chapter-5</include> -->
<include>org.apache.kafka:kafka_2.8.1</include>
</includes>
<useTransitiveFiltering>true</useTransitiveFiltering>
</dependencySet>
</dependencySets>
</assembly>
Executing Samza Jobs
After building the distribution archive, copy it to an appropriate location.
For a multinode installation, this would be a machine with the appropriate
YARN client installed.
Unpack the archive into an appropriate directory, such as
deploy
:
$ mkdir deploy
$ cd deploy
$ tar xvfz ../target/streaming-chapter-5-1-dist.tar.gz
$ cd ..
Then, use the included
run-job.sh
script to submit the
Job
s to YARN.
For example, to submit the
WordSplitTask
and the
WordCountTask
examples for this chapter, execute the following commands:
$ ./deploy/bin/run-job.sh \
> --config-factory=\
>
