bookkeeperProgrammer.html 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083
  1. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
  2. <html>
  3. <head>
  4. <META http-equiv="Content-Type" content="text/html; charset=UTF-8">
  5. <meta content="Apache Forrest" name="Generator">
  6. <meta name="Forrest-version" content="0.9">
  7. <meta name="Forrest-skin-name" content="pelt">
  8. <title>BookKeeper Getting Started Guide</title>
  9. <link type="text/css" href="skin/basic.css" rel="stylesheet">
  10. <link media="screen" type="text/css" href="skin/screen.css" rel="stylesheet">
  11. <link media="print" type="text/css" href="skin/print.css" rel="stylesheet">
  12. <link type="text/css" href="skin/profile.css" rel="stylesheet">
  13. <script src="skin/getBlank.js" language="javascript" type="text/javascript"></script><script src="skin/getMenu.js" language="javascript" type="text/javascript"></script><script src="skin/fontsize.js" language="javascript" type="text/javascript"></script>
  14. <link rel="shortcut icon" href="images/favicon.ico">
  15. </head>
  16. <body onload="init()">
  17. <script type="text/javascript">ndeSetTextSize();</script>
  18. <div id="top">
  19. <!--+
  20. |breadtrail
  21. +-->
  22. <div class="breadtrail">
  23. <a href="http://www.apache.org/">Apache</a> &gt; <a href="http://zookeeper.apache.org/">ZooKeeper</a> &gt; <a href="http://zookeeper.apache.org/">ZooKeeper</a><script src="skin/breadcrumbs.js" language="JavaScript" type="text/javascript"></script>
  24. </div>
  25. <!--+
  26. |header
  27. +-->
  28. <div class="header">
  29. <!--+
  30. |start group logo
  31. +-->
  32. <div class="grouplogo">
  33. <a href="http://hadoop.apache.org/"><img class="logoImage" alt="Hadoop" src="images/hadoop-logo.jpg" title="Apache Hadoop"></a>
  34. </div>
  35. <!--+
  36. |end group logo
  37. +-->
  38. <!--+
  39. |start Project Logo
  40. +-->
  41. <div class="projectlogo">
  42. <a href="http://zookeeper.apache.org/"><img class="logoImage" alt="ZooKeeper" src="images/zookeeper_small.gif" title="ZooKeeper: distributed coordination"></a>
  43. </div>
  44. <!--+
  45. |end Project Logo
  46. +-->
  47. <!--+
  48. |start Search
  49. +-->
  50. <div class="searchbox">
  51. <form action="http://www.google.com/search" method="get" class="roundtopsmall">
  52. <input value="zookeeper.apache.org" name="sitesearch" type="hidden"><input onFocus="getBlank (this, 'Search the site with google');" size="25" name="q" id="query" type="text" value="Search the site with google">&nbsp;
  53. <input name="Search" value="Search" type="submit">
  54. </form>
  55. </div>
  56. <!--+
  57. |end search
  58. +-->
  59. <!--+
  60. |start Tabs
  61. +-->
  62. <ul id="tabs">
  63. <li>
  64. <a class="unselected" href="http://zookeeper.apache.org/">Project</a>
  65. </li>
  66. <li>
  67. <a class="unselected" href="https://cwiki.apache.org/confluence/display/ZOOKEEPER/">Wiki</a>
  68. </li>
  69. <li class="current">
  70. <a class="selected" href="index.html">ZooKeeper 3.4 Documentation</a>
  71. </li>
  72. </ul>
  73. <!--+
  74. |end Tabs
  75. +-->
  76. </div>
  77. </div>
  78. <div id="main">
  79. <div id="publishedStrip">
  80. <!--+
  81. |start Subtabs
  82. +-->
  83. <div id="level2tabs"></div>
  84. <!--+
  85. |end Endtabs
  86. +-->
  87. <script type="text/javascript"><!--
  88. document.write("Last Published: " + document.lastModified);
  89. // --></script>
  90. </div>
  91. <!--+
  92. |breadtrail
  93. +-->
  94. <div class="breadtrail">
  95. &nbsp;
  96. </div>
  97. <!--+
  98. |start Menu, mainarea
  99. +-->
  100. <!--+
  101. |start Menu
  102. +-->
  103. <div id="menu">
  104. <div onclick="SwitchMenu('menu_1.1', 'skin/')" id="menu_1.1Title" class="menutitle">Overview</div>
  105. <div id="menu_1.1" class="menuitemgroup">
  106. <div class="menuitem">
  107. <a href="index.html">Welcome</a>
  108. </div>
  109. <div class="menuitem">
  110. <a href="zookeeperOver.html">Overview</a>
  111. </div>
  112. <div class="menuitem">
  113. <a href="zookeeperStarted.html">Getting Started</a>
  114. </div>
  115. <div class="menuitem">
  116. <a href="releasenotes.html">Release Notes</a>
  117. </div>
  118. </div>
  119. <div onclick="SwitchMenu('menu_1.2', 'skin/')" id="menu_1.2Title" class="menutitle">Developer</div>
  120. <div id="menu_1.2" class="menuitemgroup">
  121. <div class="menuitem">
  122. <a href="api/index.html">API Docs</a>
  123. </div>
  124. <div class="menuitem">
  125. <a href="zookeeperProgrammers.html">Programmer's Guide</a>
  126. </div>
  127. <div class="menuitem">
  128. <a href="javaExample.html">Java Example</a>
  129. </div>
  130. <div class="menuitem">
  131. <a href="zookeeperTutorial.html">Barrier and Queue Tutorial</a>
  132. </div>
  133. <div class="menuitem">
  134. <a href="recipes.html">Recipes</a>
  135. </div>
  136. </div>
  137. <div onclick="SwitchMenu('menu_selected_1.3', 'skin/')" id="menu_selected_1.3Title" class="menutitle" style="background-image: url('skin/images/chapter_open.gif');">BookKeeper</div>
  138. <div id="menu_selected_1.3" class="selectedmenuitemgroup" style="display: block;">
  139. <div class="menuitem">
  140. <a href="bookkeeperStarted.html">Getting started</a>
  141. </div>
  142. <div class="menuitem">
  143. <a href="bookkeeperOverview.html">Overview</a>
  144. </div>
  145. <div class="menuitem">
  146. <a href="bookkeeperConfig.html">Setup guide</a>
  147. </div>
  148. <div class="menupage">
  149. <div class="menupagetitle">Programmer's guide</div>
  150. </div>
  151. </div>
  152. <div onclick="SwitchMenu('menu_1.4', 'skin/')" id="menu_1.4Title" class="menutitle">Admin &amp; Ops</div>
  153. <div id="menu_1.4" class="menuitemgroup">
  154. <div class="menuitem">
  155. <a href="zookeeperAdmin.html">Administrator's Guide</a>
  156. </div>
  157. <div class="menuitem">
  158. <a href="zookeeperQuotas.html">Quota Guide</a>
  159. </div>
  160. <div class="menuitem">
  161. <a href="zookeeperJMX.html">JMX</a>
  162. </div>
  163. <div class="menuitem">
  164. <a href="zookeeperObservers.html">Observers Guide</a>
  165. </div>
  166. </div>
  167. <div onclick="SwitchMenu('menu_1.5', 'skin/')" id="menu_1.5Title" class="menutitle">Contributor</div>
  168. <div id="menu_1.5" class="menuitemgroup">
  169. <div class="menuitem">
  170. <a href="zookeeperInternals.html">ZooKeeper Internals</a>
  171. </div>
  172. </div>
  173. <div onclick="SwitchMenu('menu_1.6', 'skin/')" id="menu_1.6Title" class="menutitle">Miscellaneous</div>
  174. <div id="menu_1.6" class="menuitemgroup">
  175. <div class="menuitem">
  176. <a href="https://cwiki.apache.org/confluence/display/ZOOKEEPER">Wiki</a>
  177. </div>
  178. <div class="menuitem">
  179. <a href="https://cwiki.apache.org/confluence/display/ZOOKEEPER/FAQ">FAQ</a>
  180. </div>
  181. <div class="menuitem">
  182. <a href="http://zookeeper.apache.org/mailing_lists.html">Mailing Lists</a>
  183. </div>
  184. </div>
  185. <div id="credit"></div>
  186. <div id="roundbottom">
  187. <img style="display: none" class="corner" height="15" width="15" alt="" src="skin/images/rc-b-l-15-1body-2menu-3menu.png"></div>
  188. <!--+
  189. |alternative credits
  190. +-->
  191. <div id="credit2"></div>
  192. </div>
  193. <!--+
  194. |end Menu
  195. +-->
  196. <!--+
  197. |start content
  198. +-->
  199. <div id="content">
  200. <div title="Portable Document Format" class="pdflink">
  201. <a class="dida" href="bookkeeperProgrammer.pdf"><img alt="PDF -icon" src="skin/images/pdfdoc.gif" class="skin"><br>
  202. PDF</a>
  203. </div>
  204. <h1>BookKeeper Getting Started Guide</h1>
  205. <div id="front-matter">
  206. <div id="minitoc-area">
  207. <ul class="minitoc">
  208. <li>
  209. <a href="#bk_GettingStarted">Programming with BookKeeper</a>
  210. <ul class="minitoc">
  211. <li>
  212. <a href="#bk_instance"> Instantiating BookKeeper.</a>
  213. </li>
  214. <li>
  215. <a href="#bk_createLedger"> Creating a ledger. </a>
  216. </li>
  217. <li>
  218. <a href="#bk_writeLedger"> Adding entries to a ledger. </a>
  219. </li>
  220. <li>
  221. <a href="#bk_closeLedger"> Closing a ledger. </a>
  222. </li>
  223. <li>
  224. <a href="#bk_openLedger"> Opening a ledger. </a>
  225. </li>
  226. <li>
  227. <a href="#bk_readLedger"> Reading from ledger </a>
  228. </li>
  229. <li>
  230. <a href="#bk_deleteLedger"> Deleting a ledger </a>
  231. </li>
  232. </ul>
  233. </li>
  234. </ul>
  235. </div>
  236. </div>
  237. <a name="bk_GettingStarted"></a>
  238. <h2 class="h3">Programming with BookKeeper</h2>
  239. <div class="section">
  240. <ul>
  241. <li>
  242. <p>
  243. <a href="#bk_instance"> Instantiating BookKeeper.</a>
  244. </p>
  245. </li>
  246. <li>
  247. <p>
  248. <a href="#bk_createLedger"> Creating a ledger. </a>
  249. </p>
  250. </li>
  251. <li>
  252. <p>
  253. <a href="#bk_writeLedger"> Adding entries to a ledger. </a>
  254. </p>
  255. </li>
  256. <li>
  257. <p>
  258. <a href="#bk_closeLedger"> Closing a ledger. </a>
  259. </p>
  260. </li>
  261. <li>
  262. <p>
  263. <a href="#bk_openLedger"> Opening a ledger. </a>
  264. </p>
  265. </li>
  266. <li>
  267. <p>
  268. <a href="#bk_readLedger"> Reading from ledger </a>
  269. </p>
  270. </li>
  271. <li>
  272. <p>
  273. <a href="#bk_deleteLedger"> Deleting a ledger </a>
  274. </p>
  275. </li>
  276. </ul>
  277. <a name="bk_instance"></a>
  278. <h3 class="h4"> Instantiating BookKeeper.</h3>
  279. <p>
  280. The first step to use BookKeeper is to instantiate a BookKeeper object:
  281. </p>
  282. <p>
  283. <span class="codefrag computeroutput">
  284. org.apache.bookkeeper.BookKeeper
  285. </span>
  286. </p>
  287. <p>
  288. There are three BookKeeper constructors:
  289. </p>
  290. <p>
  291. <span class="codefrag computeroutput">
  292. public BookKeeper(String servers)
  293. throws KeeperException, IOException
  294. </span>
  295. </p>
  296. <p>
  297. where:
  298. </p>
  299. <ul>
  300. <li>
  301. <p>
  302. <span class="codefrag computeroutput">servers</span> is a comma-separated list of ZooKeeper servers.
  303. </p>
  304. </li>
  305. </ul>
  306. <p>
  307. <span class="codefrag computeroutput">
  308. public BookKeeper(ZooKeeper zk)
  309. throws InterruptedException, KeeperException
  310. </span>
  311. </p>
  312. <p>
  313. where:
  314. </p>
  315. <ul>
  316. <li>
  317. <p>
  318. <span class="codefrag computeroutput">zk</span> is a ZooKeeper object. This constructor is useful when
  319. the application also using ZooKeeper and wants to have a single instance of ZooKeeper.
  320. </p>
  321. </li>
  322. </ul>
  323. <p>
  324. <span class="codefrag computeroutput">
  325. public BookKeeper(ZooKeeper zk, ClientSocketChannelFactory channelFactory)
  326. throws InterruptedException, KeeperException
  327. </span>
  328. </p>
  329. <p>
  330. where:
  331. </p>
  332. <ul>
  333. <li>
  334. <p>
  335. <span class="codefrag computeroutput">zk</span> is a ZooKeeper object. This constructor is useful when
  336. the application also using ZooKeeper and wants to have a single instance of ZooKeeper.
  337. </p>
  338. </li>
  339. <li>
  340. <p>
  341. <span class="codefrag computeroutput">channelFactory</span> is a netty channel object
  342. (<span class="codefrag computeroutput">org.jboss.netty.channel.socket</span>).
  343. </p>
  344. </li>
  345. </ul>
  346. <a name="bk_createLedger"></a>
  347. <h3 class="h4"> Creating a ledger. </h3>
  348. <p> Before writing entries to BookKeeper, it is necessary to create a ledger.
  349. With the current BookKeeper API, it is possible to create a ledger both synchronously
  350. or asynchronously. The following methods belong
  351. to <span class="codefrag computeroutput">org.apache.bookkeeper.client.BookKeeper</span>.
  352. </p>
  353. <p>
  354. <strong>Synchronous call:</strong>
  355. </p>
  356. <p>
  357. <span class="codefrag computeroutput">
  358. public LedgerHandle createLedger(int ensSize, int qSize, DigestType type, byte passwd[])
  359. throws KeeperException, InterruptedException,
  360. IOException, BKException
  361. </span>
  362. </p>
  363. <p>
  364. where:
  365. </p>
  366. <ul>
  367. <li>
  368. <p>
  369. <span class="codefrag computeroutput">ensSize</span> is the number of bookies (ensemble size);
  370. </p>
  371. </li>
  372. <li>
  373. <p>
  374. <span class="codefrag computeroutput">qSize</span> is the write quorum size;
  375. </p>
  376. </li>
  377. <li>
  378. <p>
  379. <span class="codefrag computeroutput">type</span> is the type of digest used with entries: either MAC or CRC32.
  380. </p>
  381. </li>
  382. <li>
  383. <p>
  384. <span class="codefrag computeroutput">passwd</span> is a password that authorizes the client to write to the
  385. ledger being created.
  386. </p>
  387. </li>
  388. </ul>
  389. <p>
  390. All further operations on a ledger are invoked through the <span class="codefrag computeroutput">LedgerHandle</span>
  391. object returned.
  392. </p>
  393. <p>
  394. As a convenience, we provide a <span class="codefrag computeroutput">createLedger</span> with default parameters (3,2,VERIFIABLE),
  395. and the only two input parameters it requires are a digest type and a password.
  396. </p>
  397. <p>
  398. <strong>Asynchronous call:</strong>
  399. </p>
  400. <p>
  401. <span class="codefrag computeroutput">
  402. public void asyncCreateLedger(int ensSize,
  403. int qSize,
  404. DigestType type,
  405. byte passwd[],
  406. CreateCallback cb,
  407. Object ctx
  408. )
  409. </span>
  410. </p>
  411. <p>
  412. The parameters are the same of the synchronous version, with the
  413. exception of <span class="codefrag computeroutput">cb</span> and <span class="codefrag computeroutput">ctx</span>. <span class="codefrag computeroutput">CreateCallback</span>
  414. is an interface in <span class="codefrag computeroutput">org.apache.bookkeeper.client.AsyncCallback</span>, and
  415. a class implementing it has to implement a method called <span class="codefrag computeroutput">createComplete</span>
  416. that has the following signature:
  417. </p>
  418. <p>
  419. <span class="codefrag computeroutput">
  420. void createComplete(int rc, LedgerHandle lh, Object ctx);
  421. </span>
  422. </p>
  423. <p>
  424. where:
  425. </p>
  426. <ul>
  427. <li>
  428. <p>
  429. <span class="codefrag computeroutput">rc</span> is a return code (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKException</span> for a list);
  430. </p>
  431. </li>
  432. <li>
  433. <p>
  434. <span class="codefrag computeroutput">lh</span> is a <span class="codefrag computeroutput">LedgerHandle</span> object to manipulate a ledger;
  435. </p>
  436. </li>
  437. <li>
  438. <p>
  439. <span class="codefrag computeroutput">ctx</span> is a control object for accountability purposes. It can be essentially any object the application is happy with.
  440. </p>
  441. </li>
  442. </ul>
  443. <p>
  444. The <span class="codefrag computeroutput">ctx</span> object passed as a parameter to the call to create a ledger
  445. is the one same returned in the callback.
  446. </p>
  447. <a name="bk_writeLedger"></a>
  448. <h3 class="h4"> Adding entries to a ledger. </h3>
  449. <p>
  450. Once we have a ledger handle <span class="codefrag computeroutput">lh</span> obtained through a call to create a ledger, we
  451. can start writing entries. As with creating ledgers, we can write both synchronously and
  452. asynchronously. The following methods belong
  453. to <span class="codefrag computeroutput">org.apache.bookkeeper.client.LedgerHandle</span>.
  454. </p>
  455. <p>
  456. <strong>Synchronous call:</strong>
  457. </p>
  458. <p>
  459. <span class="codefrag computeroutput">
  460. public long addEntry(byte[] data)
  461. throws InterruptedException
  462. </span>
  463. </p>
  464. <p>
  465. where:
  466. </p>
  467. <ul>
  468. <li>
  469. <p>
  470. <span class="codefrag computeroutput">data</span> is a byte array;
  471. </p>
  472. </li>
  473. </ul>
  474. <p>
  475. A call to <span class="codefrag computeroutput">addEntry</span> returns the status of the operation (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKDefs</span> for a list);
  476. </p>
  477. <p>
  478. <strong>Asynchronous call:</strong>
  479. </p>
  480. <p>
  481. <span class="codefrag computeroutput">
  482. public void asyncAddEntry(byte[] data, AddCallback cb, Object ctx)
  483. </span>
  484. </p>
  485. <p>
  486. It also takes a byte array as the sequence of bytes to be stored as an entry. Additionaly, it takes
  487. a callback object <span class="codefrag computeroutput">cb</span> and a control object <span class="codefrag computeroutput">ctx</span>. The callback object must implement
  488. the <span class="codefrag computeroutput">AddCallback</span> interface in <span class="codefrag computeroutput">org.apache.bookkeeper.client.AsyncCallback</span>, and
  489. a class implementing it has to implement a method called <span class="codefrag computeroutput">addComplete</span>
  490. that has the following signature:
  491. </p>
  492. <p>
  493. <span class="codefrag computeroutput">
  494. void addComplete(int rc, LedgerHandle lh, long entryId, Object ctx);
  495. </span>
  496. </p>
  497. <p>
  498. where:
  499. </p>
  500. <ul>
  501. <li>
  502. <p>
  503. <span class="codefrag computeroutput">rc</span> is a return code (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKDefs</span> for a list);
  504. </p>
  505. </li>
  506. <li>
  507. <p>
  508. <span class="codefrag computeroutput">lh</span> is a <span class="codefrag computeroutput">LedgerHandle</span> object to manipulate a ledger;
  509. </p>
  510. </li>
  511. <li>
  512. <p>
  513. <span class="codefrag computeroutput">entryId</span> is the identifier of entry associated with this request;
  514. </p>
  515. </li>
  516. <li>
  517. <p>
  518. <span class="codefrag computeroutput">ctx</span> is control object used for accountability purposes. It can be any object the application is happy with.
  519. </p>
  520. </li>
  521. </ul>
  522. <a name="bk_closeLedger"></a>
  523. <h3 class="h4"> Closing a ledger. </h3>
  524. <p>
  525. Once a client is done writing, it closes the ledger. The following methods belong
  526. to <span class="codefrag computeroutput">org.apache.bookkeeper.client.LedgerHandle</span>.
  527. </p>
  528. <p>
  529. <strong>Synchronous close:</strong>
  530. </p>
  531. <p>
  532. <span class="codefrag computeroutput">
  533. public void close()
  534. throws InterruptedException
  535. </span>
  536. </p>
  537. <p>
  538. It takes no input parameters.
  539. </p>
  540. <p>
  541. <strong>Asynchronous close:</strong>
  542. </p>
  543. <p>
  544. <span class="codefrag computeroutput">
  545. public void asyncClose(CloseCallback cb, Object ctx)
  546. throws InterruptedException
  547. </span>
  548. </p>
  549. <p>
  550. It takes a callback object <span class="codefrag computeroutput">cb</span> and a control object <span class="codefrag computeroutput">ctx</span>. The callback object must implement
  551. the <span class="codefrag computeroutput">CloseCallback</span> interface in <span class="codefrag computeroutput">org.apache.bookkeeper.client.AsyncCallback</span>, and
  552. a class implementing it has to implement a method called <span class="codefrag computeroutput">closeComplete</span>
  553. that has the following signature:
  554. </p>
  555. <p>
  556. <span class="codefrag computeroutput">
  557. void closeComplete(int rc, LedgerHandle lh, Object ctx)
  558. </span>
  559. </p>
  560. <p>
  561. where:
  562. </p>
  563. <ul>
  564. <li>
  565. <p>
  566. <span class="codefrag computeroutput">rc</span> is a return code (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKDefs</span> for a list);
  567. </p>
  568. </li>
  569. <li>
  570. <p>
  571. <span class="codefrag computeroutput">lh</span> is a <span class="codefrag computeroutput">LedgerHandle</span> object to manipulate a ledger;
  572. </p>
  573. </li>
  574. <li>
  575. <p>
  576. <span class="codefrag computeroutput">ctx</span> is control object used for accountability purposes.
  577. </p>
  578. </li>
  579. </ul>
  580. <a name="bk_openLedger"></a>
  581. <h3 class="h4"> Opening a ledger. </h3>
  582. <p>
  583. To read from a ledger, a client must open it first. The following methods belong
  584. to <span class="codefrag computeroutput">org.apache.bookkeeper.client.BookKeeper</span>.
  585. </p>
  586. <p>
  587. <strong>Synchronous open:</strong>
  588. </p>
  589. <p>
  590. <span class="codefrag computeroutput">
  591. public LedgerHandle openLedger(long lId, DigestType type, byte passwd[])
  592. throws InterruptedException, BKException
  593. </span>
  594. </p>
  595. <ul>
  596. <li>
  597. <p>
  598. <span class="codefrag computeroutput">ledgerId</span> is the ledger identifier;
  599. </p>
  600. </li>
  601. <li>
  602. <p>
  603. <span class="codefrag computeroutput">type</span> is the type of digest used with entries: either MAC or CRC32.
  604. </p>
  605. </li>
  606. <li>
  607. <p>
  608. <span class="codefrag computeroutput">passwd</span> is a password to access the ledger (used only in the case of <span class="codefrag computeroutput">VERIFIABLE</span> ledgers);
  609. </p>
  610. </li>
  611. </ul>
  612. <p>
  613. <strong>Asynchronous open:</strong>
  614. </p>
  615. <p>
  616. <span class="codefrag computeroutput">
  617. public void asyncOpenLedger(long lId, DigestType type, byte passwd[], OpenCallback cb, Object ctx)
  618. </span>
  619. </p>
  620. <p>
  621. It also takes a a ledger identifier and a password. Additionaly, it takes a callback object
  622. <span class="codefrag computeroutput">cb</span> and a control object <span class="codefrag computeroutput">ctx</span>. The callback object must implement
  623. the <span class="codefrag computeroutput">OpenCallback</span> interface in <span class="codefrag computeroutput">org.apache.bookkeeper.client.AsyncCallback</span>, and
  624. a class implementing it has to implement a method called <span class="codefrag computeroutput">openComplete</span>
  625. that has the following signature:
  626. </p>
  627. <p>
  628. <span class="codefrag computeroutput">
  629. public void openComplete(int rc, LedgerHandle lh, Object ctx)
  630. </span>
  631. </p>
  632. <p>
  633. where:
  634. </p>
  635. <ul>
  636. <li>
  637. <p>
  638. <span class="codefrag computeroutput">rc</span> is a return code (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKDefs</span> for a list);
  639. </p>
  640. </li>
  641. <li>
  642. <p>
  643. <span class="codefrag computeroutput">lh</span> is a <span class="codefrag computeroutput">LedgerHandle</span> object to manipulate a ledger;
  644. </p>
  645. </li>
  646. <li>
  647. <p>
  648. <span class="codefrag computeroutput">ctx</span> is control object used for accountability purposes.
  649. </p>
  650. </li>
  651. </ul>
  652. <a name="bk_readLedger"></a>
  653. <h3 class="h4"> Reading from ledger </h3>
  654. <p>
  655. Read calls may request one or more consecutive entries. The following methods belong
  656. to <span class="codefrag computeroutput">org.apache.bookkeeper.client.LedgerHandle</span>.
  657. </p>
  658. <p>
  659. <strong>Synchronous read:</strong>
  660. </p>
  661. <p>
  662. <span class="codefrag computeroutput">
  663. public Enumeration&lt;LedgerEntry&gt; readEntries(long firstEntry, long lastEntry)
  664. throws InterruptedException, BKException
  665. </span>
  666. </p>
  667. <ul>
  668. <li>
  669. <p>
  670. <span class="codefrag computeroutput">firstEntry</span> is the identifier of the first entry in the sequence of entries to read;
  671. </p>
  672. </li>
  673. <li>
  674. <p>
  675. <span class="codefrag computeroutput">lastEntry</span> is the identifier of the last entry in the sequence of entries to read.
  676. </p>
  677. </li>
  678. </ul>
  679. <p>
  680. <strong>Asynchronous read:</strong>
  681. </p>
  682. <p>
  683. <span class="codefrag computeroutput">
  684. public void asyncReadEntries(long firstEntry,
  685. long lastEntry, ReadCallback cb, Object ctx)
  686. throws BKException, InterruptedException
  687. </span>
  688. </p>
  689. <p>
  690. It also takes a first and a last entry identifiers. Additionaly, it takes a callback object
  691. <span class="codefrag computeroutput">cb</span> and a control object <span class="codefrag computeroutput">ctx</span>. The callback object must implement
  692. the <span class="codefrag computeroutput">ReadCallback</span> interface in <span class="codefrag computeroutput">org.apache.bookkeeper.client.AsyncCallback</span>, and
  693. a class implementing it has to implement a method called <span class="codefrag computeroutput">readComplete</span>
  694. that has the following signature:
  695. </p>
  696. <p>
  697. <span class="codefrag computeroutput">
  698. void readComplete(int rc, LedgerHandle lh, Enumeration&lt;LedgerEntry&gt; seq, Object ctx)
  699. </span>
  700. </p>
  701. <p>
  702. where:
  703. </p>
  704. <ul>
  705. <li>
  706. <p>
  707. <span class="codefrag computeroutput">rc</span> is a return code (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKDefs</span> for a list);
  708. </p>
  709. </li>
  710. <li>
  711. <p>
  712. <span class="codefrag computeroutput">lh</span> is a <span class="codefrag computeroutput">LedgerHandle</span> object to manipulate a ledger;
  713. </p>
  714. </li>
  715. <li>
  716. <p>
  717. <span class="codefrag computeroutput">seq</span> is a <span class="codefrag computeroutput">Enumeration&lt;LedgerEntry&gt; </span> object to containing the list of entries requested;
  718. </p>
  719. </li>
  720. <li>
  721. <p>
  722. <span class="codefrag computeroutput">ctx</span> is control object used for accountability purposes.
  723. </p>
  724. </li>
  725. </ul>
  726. <a name="bk_deleteLedger"></a>
  727. <h3 class="h4"> Deleting a ledger </h3>
  728. <p>
  729. Once a client is done with a ledger and is sure that nobody will ever need to read from it again, they can delete the ledger.
  730. The following methods belong to <span class="codefrag computeroutput">org.apache.bookkeeper.client.BookKeeper</span>.
  731. </p>
  732. <p>
  733. <strong>Synchronous delete:</strong>
  734. </p>
  735. <p>
  736. <span class="codefrag computeroutput">
  737. public void deleteLedger(long lId) throws InterruptedException, BKException
  738. </span>
  739. </p>
  740. <ul>
  741. <li>
  742. <p>
  743. <span class="codefrag computeroutput">lId</span> is the ledger identifier;
  744. </p>
  745. </li>
  746. </ul>
  747. <p>
  748. <strong>Asynchronous delete:</strong>
  749. </p>
  750. <p>
  751. <span class="codefrag computeroutput">
  752. public void asyncDeleteLedger(long lId, DeleteCallback cb, Object ctx)
  753. </span>
  754. </p>
  755. <p>
  756. It takes a ledger identifier. Additionally, it takes a callback object
  757. <span class="codefrag computeroutput">cb</span> and a control object <span class="codefrag computeroutput">ctx</span>. The callback object must implement
  758. the <span class="codefrag computeroutput">DeleteCallback</span> interface in <span class="codefrag computeroutput">org.apache.bookkeeper.client.AsyncCallback</span>, and
  759. a class implementing it has to implement a method called <span class="codefrag computeroutput">deleteComplete</span>
  760. that has the following signature:
  761. </p>
  762. <p>
  763. <span class="codefrag computeroutput">
  764. void deleteComplete(int rc, Object ctx)
  765. </span>
  766. </p>
  767. <p>
  768. where:
  769. </p>
  770. <ul>
  771. <li>
  772. <p>
  773. <span class="codefrag computeroutput">rc</span> is a return code (please refer to <span class="codefrag computeroutput">org.apache.bookeeper.client.BKDefs</span> for a list);
  774. </p>
  775. </li>
  776. <li>
  777. <p>
  778. <span class="codefrag computeroutput">ctx</span> is control object used for accountability purposes.
  779. </p>
  780. </li>
  781. </ul>
  782. </div>
  783. <p align="right">
  784. <font size="-2"></font>
  785. </p>
  786. </div>
  787. <!--+
  788. |end content
  789. +-->
  790. <div class="clearboth">&nbsp;</div>
  791. </div>
  792. <div id="footer">
  793. <!--+
  794. |start bottomstrip
  795. +-->
  796. <div class="lastmodified">
  797. <script type="text/javascript"><!--
  798. document.write("Last Published: " + document.lastModified);
  799. // --></script>
  800. </div>
  801. <div class="copyright">
  802. Copyright &copy;
  803. 2008 <a href="http://www.apache.org/licenses/">The Apache Software Foundation.</a>
  804. </div>
  805. <!--+
  806. |end bottomstrip
  807. +-->
  808. </div>
  809. </body>
  810. </html>