44
55< html xmlns ="http://www.w3.org/1999/xhtml " lang ="en ">
66 < head >
7+ < meta http-equiv ="X-UA-Compatible " content ="IE=Edge " />
78 < meta http-equiv ="Content-Type " content ="text/html; charset=utf-8 " />
8- < title > tensorflowonspark.TFManager — TensorFlowOnSpark 1.2.0 documentation</ title >
9+ < title > tensorflowonspark.TFManager — TensorFlowOnSpark 1.2.1 documentation</ title >
910 < link rel ="stylesheet " href ="../../_static/classic.css " type ="text/css " />
1011 < link rel ="stylesheet " href ="../../_static/pygments.css " type ="text/css " />
11- < script type ="text/javascript ">
12- var DOCUMENTATION_OPTIONS = {
13- URL_ROOT : '../../' ,
14- VERSION : '1.2.0' ,
15- COLLAPSE_INDEX : false ,
16- FILE_SUFFIX : '.html' ,
17- HAS_SOURCE : true ,
18- SOURCELINK_SUFFIX : '.txt'
19- } ;
20- </ script >
12+ < script type ="text/javascript " src ="../../_static/documentation_options.js "> </ script >
2113 < script type ="text/javascript " src ="../../_static/jquery.js "> </ script >
2214 < script type ="text/javascript " src ="../../_static/underscore.js "> </ script >
2315 < script type ="text/javascript " src ="../../_static/doctools.js "> </ script >
2416 < link rel ="index " title ="Index " href ="../../genindex.html " />
2517 < link rel ="search " title ="Search " href ="../../search.html " />
26- </ head >
27- < body >
18+ </ head > < body >
2819 < div class ="related " role ="navigation " aria-label ="related navigation ">
2920 < h3 > Navigation</ h3 >
3021 < ul >
@@ -34,7 +25,7 @@ <h3>Navigation</h3>
3425 < li class ="right " >
3526 < a href ="../../py-modindex.html " title ="Python Module Index "
3627 > modules</ a > |</ li >
37- < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.2.0 documentation</ a > »</ li >
28+ < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.2.1 documentation</ a > »</ li >
3829 < li class ="nav-item nav-item-1 "> < a href ="../index.html " accesskey ="U "> Module code</ a > »</ li >
3930 </ ul >
4031 </ div >
@@ -58,8 +49,8 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
5849< span class ="kn "> from</ span > < span class ="nn "> multiprocessing</ span > < span class ="k "> import</ span > < span class ="n "> JoinableQueue</ span >
5950
6051< div class ="viewcode-block " id ="TFManager "> < a class ="viewcode-back " href ="../../tensorflowonspark.TFManager.html#tensorflowonspark.TFManager.TFManager "> [docs]</ a > < span class ="k "> class</ span > < span class ="nc "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> BaseManager</ span > < span class ="p "> ):</ span >
61- < span class ="sd "> """Python multiprocessing.Manager for distributed, multi-process communication."""</ span >
62- < span class ="k "> pass</ span > </ div >
52+ < span class ="sd "> """Python multiprocessing.Manager for distributed, multi-process communication."""</ span > </ div >
53+ < span class ="k "> pass</ span >
6354
6455
6556< span class ="c1 "> # global to each Spark executor's python worker</ span >
@@ -73,6 +64,12 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
7364< span class ="k "> def</ span > < span class ="nf "> _set</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> value</ span > < span class ="p "> ):</ span >
7465 < span class ="n "> kdict</ span > < span class ="p "> [</ span > < span class ="n "> key</ span > < span class ="p "> ]</ span > < span class ="o "> =</ span > < span class ="n "> value</ span >
7566
67+ < span class ="k "> def</ span > < span class ="nf "> _get_queue</ span > < span class ="p "> (</ span > < span class ="n "> qname</ span > < span class ="p "> ):</ span >
68+ < span class ="k "> try</ span > < span class ="p "> :</ span >
69+ < span class ="k "> return</ span > < span class ="n "> qdict</ span > < span class ="p "> [</ span > < span class ="n "> qname</ span > < span class ="p "> ]</ span >
70+ < span class ="k "> except</ span > < span class ="ne "> KeyError</ span > < span class ="p "> :</ span >
71+ < span class ="k "> return</ span > < span class ="kc "> None</ span >
72+
7673< div class ="viewcode-block " id ="start "> < a class ="viewcode-back " href ="../../tensorflowonspark.TFManager.html#tensorflowonspark.TFManager.start "> [docs]</ a > < span class ="k "> def</ span > < span class ="nf "> start</ span > < span class ="p "> (</ span > < span class ="n "> authkey</ span > < span class ="p "> ,</ span > < span class ="n "> queues</ span > < span class ="p "> ,</ span > < span class ="n "> mode</ span > < span class ="o "> =</ span > < span class ="s1 "> 'local'</ span > < span class ="p "> ):</ span >
7774 < span class ="sd "> """Create a new multiprocess.Manager (or return existing one).</ span >
7875
@@ -89,15 +86,16 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
8986 < span class ="n "> kdict</ span > < span class ="o "> .</ span > < span class ="n "> clear</ span > < span class ="p "> ()</ span >
9087 < span class ="k "> for</ span > < span class ="n "> q</ span > < span class ="ow "> in</ span > < span class ="n "> queues</ span > < span class ="p "> :</ span >
9188 < span class ="n "> qdict</ span > < span class ="p "> [</ span > < span class ="n "> q</ span > < span class ="p "> ]</ span > < span class ="o "> =</ span > < span class ="n "> JoinableQueue</ span > < span class ="p "> ()</ span >
92- < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'get_queue'</ span > < span class ="p "> ,</ span > < span class ="n "> callable</ span > < span class ="o "> =</ span > < span class ="k "> lambda</ span > < span class ="n "> qname</ span > < span class ="p "> :</ span > < span class ="n "> qdict</ span > < span class ="p "> [</ span > < span class ="n "> qname</ span > < span class ="p "> ])</ span >
89+
90+ < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'get_queue'</ span > < span class ="p "> ,</ span > < span class ="n "> callable</ span > < span class ="o "> =</ span > < span class ="k "> lambda</ span > < span class ="n "> qname</ span > < span class ="p "> :</ span > < span class ="n "> _get_queue</ span > < span class ="p "> (</ span > < span class ="n "> qname</ span > < span class ="p "> ))</ span >
9391 < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'get'</ span > < span class ="p "> ,</ span > < span class ="n "> callable</ span > < span class ="o "> =</ span > < span class ="k "> lambda</ span > < span class ="n "> key</ span > < span class ="p "> :</ span > < span class ="n "> _get</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ))</ span >
9492 < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'set'</ span > < span class ="p "> ,</ span > < span class ="n "> callable</ span > < span class ="o "> =</ span > < span class ="k "> lambda</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> value</ span > < span class ="p "> :</ span > < span class ="n "> _set</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> value</ span > < span class ="p "> ))</ span >
9593 < span class ="k "> if</ span > < span class ="n "> mode</ span > < span class ="o "> ==</ span > < span class ="s1 "> 'remote'</ span > < span class ="p "> :</ span >
9694 < span class ="n "> mgr</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="o "> =</ span > < span class ="p "> (</ span > < span class ="s1 "> ''</ span > < span class ="p "> ,</ span > < span class ="mi "> 0</ span > < span class ="p "> ),</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
9795 < span class ="k "> else</ span > < span class ="p "> :</ span >
9896 < span class ="n "> mgr</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
99- < span class ="n "> mgr</ span > < span class ="o "> .</ span > < span class ="n "> start</ span > < span class ="p "> ()</ span >
100- < span class ="k "> return</ span > < span class ="n "> mgr</ span > </ div >
97+ < span class ="n "> mgr</ span > < span class ="o "> .</ span > < span class ="n "> start</ span > < span class ="p "> ()</ span > </ div >
98+ < span class ="k "> return</ span > < span class ="n "> mgr</ span >
10199
102100< div class ="viewcode-block " id ="connect "> < a class ="viewcode-back " href ="../../tensorflowonspark.TFManager.html#tensorflowonspark.TFManager.connect "> [docs]</ a > < span class ="k "> def</ span > < span class ="nf "> connect</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="p "> ,</ span > < span class ="n "> authkey</ span > < span class ="p "> ):</ span >
103101 < span class ="sd "> """Connect to a multiprocess.Manager.</ span >
@@ -113,8 +111,8 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
113111 < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'get'</ span > < span class ="p "> )</ span >
114112 < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'set'</ span > < span class ="p "> )</ span >
115113 < span class ="n "> m</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="p "> ,</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
116- < span class ="n "> m</ span > < span class ="o "> .</ span > < span class ="n "> connect</ span > < span class ="p "> ()</ span >
117- < span class ="k "> return</ span > < span class ="n "> m</ span > </ div >
114+ < span class ="n "> m</ span > < span class ="o "> .</ span > < span class ="n "> connect</ span > < span class ="p "> ()</ span > </ div >
115+ < span class ="k "> return</ span > < span class ="n "> m</ span >
118116
119117</ pre > </ div >
120118
@@ -125,12 +123,14 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
125123 < div class ="sphinxsidebarwrapper ">
126124< div id ="searchbox " style ="display: none " role ="search ">
127125 < h3 > Quick search</ h3 >
126+ < div class ="searchformwrapper ">
128127 < form class ="search " action ="../../search.html " method ="get ">
129- < div > < input type ="text " name ="q " /> </ div >
130- < div > < input type ="submit " value ="Go " /> </ div >
128+ < input type ="text " name ="q " />
129+ < input type ="submit " value ="Go " />
131130 < input type ="hidden " name ="check_keywords " value ="yes " />
132131 < input type ="hidden " name ="area " value ="default " />
133132 </ form >
133+ </ div >
134134</ div >
135135< script type ="text/javascript "> $ ( '#searchbox' ) . show ( 0 ) ; </ script >
136136 </ div >
@@ -146,13 +146,13 @@ <h3>Navigation</h3>
146146 < li class ="right " >
147147 < a href ="../../py-modindex.html " title ="Python Module Index "
148148 > modules</ a > |</ li >
149- < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.2.0 documentation</ a > »</ li >
149+ < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.2.1 documentation</ a > »</ li >
150150 < li class ="nav-item nav-item-1 "> < a href ="../index.html " > Module code</ a > »</ li >
151151 </ ul >
152152 </ div >
153153 < div class ="footer " role ="contentinfo ">
154154 © Copyright 2017, Yahoo Inc.
155- Created using < a href ="http://sphinx-doc.org/ "> Sphinx</ a > 1.6.7 .
155+ Created using < a href ="http://sphinx-doc.org/ "> Sphinx</ a > 1.7.1 .
156156 </ div >
157157 </ body >
158158</ html >
0 commit comments