You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/02/28 22:57:50 UTC
git commit: SAMZA-143;
cleaning up configs in docs to reflect samza 0.7.0
Repository: incubator-samza
Updated Branches:
refs/heads/master 2fa280022 -> d364a5f70
SAMZA-143; cleaning up configs in docs to reflect samza 0.7.0
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/d364a5f7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/d364a5f7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/d364a5f7
Branch: refs/heads/master
Commit: d364a5f703d3db9c839702de107f0515139fcc6f
Parents: 2fa2800
Author: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Authored: Fri Feb 28 13:57:43 2014 -0800
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Fri Feb 28 13:57:43 2014 -0800
----------------------------------------------------------------------
docs/learn/documentation/0.7.0/jobs/configuration.md | 15 ++++++---------
1 file changed, 6 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/d364a5f7/docs/learn/documentation/0.7.0/jobs/configuration.md
----------------------------------------------------------------------
diff --git a/docs/learn/documentation/0.7.0/jobs/configuration.md b/docs/learn/documentation/0.7.0/jobs/configuration.md
index 01035ba..d4a516e 100644
--- a/docs/learn/documentation/0.7.0/jobs/configuration.md
+++ b/docs/learn/documentation/0.7.0/jobs/configuration.md
@@ -12,22 +12,19 @@ job.name=hello-world
# Task
task.class=samza.task.example.MyJavaStreamerTask
-task.inputs=example-stream
+task.inputs=example-system.example-stream
# Serializers
serializers.registry.json.class=samza.serializers.JsonSerdeFactory
-serializers.default=json
-
-# Streams
-streams.example-stream.system=example-system
-streams.example-stream.stream=some-stream
+serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory
# Systems
-systems.example-system.samza.consumer.factory=samza.stream.example.ExampleConsumerFactory
-systems.example-system.samza.partition.manager=samza.stream.example.ExamplePartitionManager
+systems.example-system.samza.factory=samza.stream.example.ExampleConsumerFactory
+systems.example-system.samza.key.serde=string
+systems.example-system.samza.msg.serde=json
```
-There are five major sections to a configuration file. The job section defines things like the name of the job, and whether to use the YarnJobFactory or LocalJobFactory. The task section is where you specify the class name for your StreamTask. It's also where you define what the input streams are for your task. The system section defines systems that you can read from. Usually, you'll define a Kafka system, if you're reading from Kafka. After that you'll need to define the stream(s) that you want to read from, which systems they're coming from, and how to deserialize objects from the stream.
+There are four major sections to a configuration file. The job section defines things like the name of the job, and whether to use the YarnJobFactory or LocalJobFactory. The task section is where you specify the class name for your StreamTask. It's also where you define what the input streams are for your task. The serializers section defines the classes of the serdes used for serialization and deserialization of specific objects that are received and sent along different streams. The system section defines systems that your StreamTask can read from along with the types of serdes used for sending keys and messages from that system. Usually, you'll define a Kafka system, if you're reading from Kafka, although you can also specify your own self-implemented Samza-compatible systems. See the hello-samza example project's Wikipedia system for a good example of a self-implemented system.
### Required Configuration