You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by mo...@apache.org on 2016/12/15 02:50:48 UTC
zeppelin git commit: [ZEPPELIN-1800] Update scio doc - fix type $
should be %
Repository: zeppelin
Updated Branches:
refs/heads/master 6177c819b -> 7ef0554af
[ZEPPELIN-1800] Update scio doc - fix type $ should be %
### What is this PR for?
Update scio doc - fix type $ should be %
### What type of PR is it?
Documentation
### Todos
### What is the Jira issue?
https://issues.apache.org/jira/browse/ZEPPELIN-1800
### Questions:
* Does the licenses files need update? No
* Is there breaking changes for older versions? No
* Does this needs documentation? No
Author: Rafal Wojdyla <ra...@spotify.com>
Closes #1754 from ravwojdyla/fix_1800 and squashes the following commits:
d4287a9 [Rafal Wojdyla] Update scio doc - fix type $ should be %
Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/7ef0554a
Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/7ef0554a
Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/7ef0554a
Branch: refs/heads/master
Commit: 7ef0554af7c5682077df1bee8892fee4caeb87d5
Parents: 6177c81
Author: Rafal Wojdyla <ra...@spotify.com>
Authored: Tue Dec 13 10:42:20 2016 -0500
Committer: Lee moon soo <mo...@apache.org>
Committed: Wed Dec 14 18:50:44 2016 -0800
----------------------------------------------------------------------
docs/interpreter/scio.md | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/7ef0554a/docs/interpreter/scio.md
----------------------------------------------------------------------
diff --git a/docs/interpreter/scio.md b/docs/interpreter/scio.md
index 6da348a..cb8d127 100644
--- a/docs/interpreter/scio.md
+++ b/docs/interpreter/scio.md
@@ -52,10 +52,10 @@ In a notebook, to enable the **Scio** interpreter, click the **Gear** icon and s
## Using the Scio Interpreter
-In a paragraph, use `$beam.scio` to select the **Scio** interpreter. You can use it much the same way as vanilla Scala REPL and [Scio REPL](https://github.com/spotify/scio/wiki/Scio-REPL). State (like variables, imports, execution etc) is shared among all *Scio* paragraphs. There is a special variable **argz** which holds arguments from Scio interpreter settings. The easiest way to proceed is to create a Scio context via standard `ContextAndArgs`.
+In a paragraph, use `%beam.scio` to select the **Scio** interpreter. You can use it much the same way as vanilla Scala REPL and [Scio REPL](https://github.com/spotify/scio/wiki/Scio-REPL). State (like variables, imports, execution etc) is shared among all *Scio* paragraphs. There is a special variable **argz** which holds arguments from Scio interpreter settings. The easiest way to proceed is to create a Scio context via standard `ContextAndArgs`.
```scala
-$beam.scio
+%beam.scio
val (sc, args) = ContextAndArgs(argz)
```
@@ -64,7 +64,7 @@ Use `sc` context the way you would in a regular pipeline/REPL.
Example:
```scala
-$beam.scio
+%beam.scio
val (sc, args) = ContextAndArgs(argz)
sc.parallelize(Seq("foo", "foo", "bar")).countByValue.closeAndDisplay()
```
@@ -108,7 +108,7 @@ There are different helper methods for different objects. You can easily display
#### BigQuery example:
```scala
-$beam.scio
+%beam.scio
@BigQueryType.fromQuery("""|SELECT departure_airport,count(case when departure_delay>0 then 1 else 0 end) as no_of_delays
|FROM [bigquery-samples:airline_ontime_data.flights]
|group by departure_airport
@@ -122,7 +122,7 @@ sc.bigQuerySelect(Flights.query).closeAndDisplay(Flights.schema)
#### BigQuery typed example:
```scala
-$beam.scio
+%beam.scio
@BigQueryType.fromQuery("""|SELECT departure_airport,count(case when departure_delay>0 then 1 else 0 end) as no_of_delays
|FROM [bigquery-samples:airline_ontime_data.flights]
|group by departure_airport
@@ -136,7 +136,7 @@ sc.typedBigQuery[Flights]().flatMap(_.no_of_delays).mean.closeAndDisplay()
#### Avro example:
```scala
-$beam.scio
+%beam.scio
import com.spotify.data.ExampleAvro
val (sc, args) = ContextAndArgs(argz)
@@ -146,7 +146,7 @@ sc.avroFile[ExampleAvro]("gs://<bucket>/tmp/my.avro").take(10).closeAndDisplay()
#### Avro example with a view schema:
```scala
-$beam.scio
+%beam.scio
import com.spotify.data.ExampleAvro
import org.apache.avro.Schema