Notebook的持久化系统主要的类图如下：

各类主要的职责如下：

  1. NotebookRepo是顶层接口，规定了持久化层基本的CRUD接口。
  2. NotebookVersioned定义了Note的版本管理接口，目前其实现类只有GitNotebookRepo（该功能目前实现的不完善，既没有实现按照rev log进行过滤检索，界面上目前也没有检索或者是回退到具体某个版本的入口），采用JGit实现。
  3. VFSNotebookRepo是zeppelin的默认实现类，使用apache common-vfs来实现多文件系统支持。（受配置参数zeppelin.notebook.storage控制，参见：ZeppelinConfiguration。
1
ZEPPELIN_NOTEBOOK_STORAGE("zeppelin.notebook.storage", VFSNotebookRepo.class.getName()),

目前common-vfs支持的文件系统虽然很多，但是由于Notebook持久化时需要RW、Create/Delete权限，实际上可用的只有如下：

File System Directory Contents Authentication Read Write Create/Delete Random Version Rename
File No No Yes Yes Yes Read/Write No Yes
FTP No Yes Yes Yes Yes Read No Yes
FTPS No Yes Yes Yes Yes - - -
RAM No No Yes Yes Yes Read/Write No Yes
RES No No Yes Yes Yes Read/Write No Yes
SFTP No Yes Yes Yes Yes Read No Yes
Temp No No Yes Yes Yes Read/Write No Yes
WebDAV Yes Yes Yes Yes Yes Read/Write Yes Yes

需要注意的是：不支持HDFS，由于vfs对hdfs://不支持Write、Create/Delete

  1. NotebookRepoSync的初衷是为了让2个NotebookRepo之间进行自动同步修改，实现：在本地repo保存修改的同时，让zeppelin自动将修改同步到远程的repo上。
    要启用2个repo之间的同步，需要：
    a. 在zeppelin-site.xml中修改配置参数zeppelin.notebook.storage，以逗号分隔2个实现类的完整类名
    b. 注意顺序，一般是将VFSNotebookRepo作为一个，而S3NotebookRepo或者是AzureNotebookRepo等作为第二个。zeppelin目前只支持最大2个Repo（maxRepoNum=2作为编译时常量），不能通过配置修改。

  2. S3NotebookRepo和AzureNotebookRepo，实现向2大云存储系统的持久化Notebook。

  3. ZeppelinHubRepo是为了向zeppelinhub持久化Notebook而设计的，zeppelinhub是一个类似于Github的分享网站，区别在于Github是分享git仓库的，zeppelinhub是分享notebook的。

Note的加载过程

  1. VFSNotebookRepo首先查看如下参数指定的地址：
    1
    ZEPPELIN_NOTEBOOK_DIR("zeppelin.notebook.dir", "notebook"),

默认是相对路径notebook，该路径会被解释成本地文件目录，相对于${ZEPPELIN_HOME}。

  1. 该路径下每个子目录会被认为存储了一个名为note.json的文件，目录名字被解释成note的id
  2. 使用Gson将该note.json文件反序列化成Note实例。
  3. 重建Note和相关对象的transient状态，参见Notebook.loadNoteFromRepo(Stringid)方法，如下：

如下是zeppelin自带的notebook中的demo note。经过VFSNotebookRepo加载之后，会产生2个Note实例，id分别为2A94M5J1Z和r。

1
2
3
4
5
notebook/
├── 2A94M5J1Z
│   └── note.json
└── r
    └── note.json

note.json中究竟序列化了什么内容？

打开id=2A94M5J1Z的note，可以看到其序列化成json后的内容

通过对比Note的字段可以发现，以上json实际是与Note的“非transient”字段一一对应的。这里会存在一个问题——为什么Note将replLoader、jobListenerFactory、repo、index和delayedPersist设置为transient？是因为这些字段（状态）可以通过Note剩下的字段以及与该Note实例相关的其他class实例的状态重建。

另外，由于在Note实例序列化成json的时候，实际是完成“图的序列化”——即Note实例“可达”的嵌套子对象（无论深度），需要一并序列化。实际上会将Paragraph、Job、GUI config、paragraphconfig（Map）。

以下是id=2A94M5J1Z的note的scala代码段Paragraph序列化成json之后的样子：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
{
  "title": "Load data into table",
  "text": "import org.apache.commons.io.IOUtils\nimport java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d sc.parallelize(\n    IOUtils.toString(\n        new URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\"),\n        Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age: Integer, job: String, marital: String, education: String, balance: Integer)\n\nval bank \u003d bankText.map(s \u003d\u003e s.split(\";\")).filter(s \u003d\u003e s(0) !\u003d \"\\\"age\\\"\").map(\n    s \u003d\u003e Bank(s(0).toInt, \n            s(1).replaceAll(\"\\\"\", \"\"),\n            s(2).replaceAll(\"\\\"\", \"\"),\n            s(3).replaceAll(\"\\\"\", \"\"),\n            s(5).replaceAll(\"\\\"\", \"\").toInt\n        )\n).toDF()\nbank.registerTempTable(\"bank\")",
  "dateUpdated": "Jan 14, 2016 7:58:56 PM",
  "config": {
    "colWidth": 12.0,
    "graph": {
      "mode": "table",
      "height": 300.0,
      "optionOpen": false,
      "keys": [],
      "values": [],
      "groups": [],
      "scatter": {}
    },
    "title": true,
    "enabled": true,
    "editorMode": "ace/mode/scala"
  },
  "settings": {
    "params": {},
    "forms": {}
  },
  "jobName": "paragraph_1423500779206_-1502780787",
  "id": "20150210-015259_1403135953",
  "result": {
    "code": "SUCCESS",
    "type": "TEXT",
    "msg": "import org.apache.commons.io.IOUtils\nimport java.net.URL\nimport java.nio.charset.Charset\nbankText: org.apache.spark.rdd.RDD[String] \u003d ParallelCollectionRDD[32] at parallelize at \u003cconsole\u003e:65\ndefined class Bank\nbank: org.apache.spark.sql.DataFrame \u003d [age: int, job: string, marital: string, education: string, balance: int]\n"
  },
  "dateCreated": "Feb 10, 2015 1:52:59 AM",
  "dateStarted": "Jul 3, 2015 1:43:40 PM",
  "dateFinished": "Jul 3, 2015 1:43:45 PM",
  "status": "FINISHED",
  "progressUpdateIntervalMs": 500
}

各字段都来自于Note和以上嵌套的对象。