上海品茶

Ray on Apache Spark™ Apache Spark™上的Ray.pdf

编号:139139 PDF 22页 1.34MB 下载积分:VIP专享
下载报告请您先登录!

Ray on Apache Spark™ Apache Spark™上的Ray.pdf

1、Ray on SparkBen Wilson,DatabricksJiajun Yao,AnyscaleDatabricks2023Who we are Ben WilsonJiajun YaoWorks with ML open source software at DatabricksMLflow maintainerSoftware engineer at AnyscaleRay committerAgenda What is Ray What is Ray-on-Spark Why Ray-on-Spark How to use Ray-on-Spark Demos How does

2、Ray-on-Spark work Future workWhat is RayWhat is Ray An open-source unified distributed framework that makes it easy to scale AI and Python applications.An ecosystem of Python libraries(for scaling ML and more).Makes distributed computing easy and accessible to everyone.Runs on laptop,public cloud,K8

3、s,on-premise.Run anywhereGeneral-purpose framework for distributed computingLibrary+app ecosystemRay coreWhat is RayWhat is Ray def read_array(file):#read ndarray“a”#from“file”return adef add(a,b):return np.add(a,b)a=read_array(file1)b=read_array(file2)sum=add(a,b)class Counter(object):def _init_(se

4、lf):self.value=0 def inc(self):self.value+=1 return self.valuec=Counter()c.inc()c.inc()FunctionClassWhat is Ray ray.remote def read_array(file):#read ndarray“a”#from“file”return a ray.remotedef add(a,b):return np.add(a,b)a_ref=read_array.remote(file1)b_ref=read_array.remote(file2)sum_ref=add.remote(

5、a,b)sum=ray.get(sum_ref)ray.remoteclass Counter(object):def _init_(self):self.value=0 def inc(self):self.value+=1 return self.valuec=Counter.remote()c.inc.remote()c.inc.remote()Function-TaskClass-ActorWhat is RayHigh-level libraries that make scaling easy for both data scientists and ML engineers.Wh

6、at is Ray1,000+OrganizationsUsing Ray25,000+GitHubstars5,000+RepositoriesDepend on Ray820+CommunityContributorsWhat is Ray-on-Spark A library to deploy Ray clusters on Spark and run Ray applications.Ray coreWhy Ray-on-Spark User asksSpark users want to use both Spark MLlib and Ray ML libraries(e.g.R

7、LLib).CostShare the same physical cluster between Ray and Spark applications.Easy to manageNo need to manage two separate physical clusters.How to use Ray-on-Spark Install Ray%pip install rayall=2.3.0 Start a Ray clusterimport rayray.util.spark.setup_ray_cluster(num_worker_nodes=5)Run Ray applicatio

8、nsray.init()#Connect to the previously created Ray cluster.#Your Ray application codeprint(ray.nodes()Stop the Ray clusterray.util.spark.shutdown_ray_cluster()Getting startedThe Ray DashboardValidationParallel processingDistributed Hyperparameter tuningHow does Ray-on-Spark work Driver WorkerGlobal

9、Control Service(GCS)Scheduler Object Store Raylet Worker Worker Scheduler Object Store Raylet Worker Worker Scheduler Object Store Raylet Head NodeWorker Node#1Worker Node#N.An anatomy of a Ray clusterHow does Ray-on-Spark workSpark ClusterSpark Driver NodeSpark Worker NodeSpark Worker NodeSpark Tas

10、kRay Worker NodeSpark TaskRay Worker NodeSpark TaskRay Worker NodeSpark Driver ProgramRay Head NodeRay head node runs on the Spark driver node.Ray worker nodes are started by a long-running Spark job.Each long-running Spark task starts a Ray worker node and allocates to the node the full set of resources available to it.Future work Autoscaling support Delta data source support in Ray DataConclusion Ray-on-Spark is in Public Preview for Ray=2.3&(Spark=3.3|Databricks Runtime=12.0)Try out Ray-on-Spark on Databricks clustersTry out Ray-on-Spark on Spark standalone clustersLearn more about Ray

友情提示

1、下载报告失败解决办法
2、PDF文件下载后,可能会被浏览器默认打开,此种情况可以点击浏览器菜单,保存网页到桌面,就可以正常下载了。
3、本站不支持迅雷下载,请使用电脑自带的IE浏览器,或者360浏览器、谷歌浏览器下载即可。
4、本站报告下载后的文档和图纸-无水印,预览文档经过压缩,下载后原文更清晰。

本文(Ray on Apache Spark™ Apache Spark™上的Ray.pdf)为本站 (2200) 主动上传,三个皮匠报告文库仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对上载内容本身不做任何修改或编辑。 若此文所含内容侵犯了您的版权或隐私,请立即通知三个皮匠报告文库(点击联系客服),我们立即给予删除!

温馨提示:如果因为网速或其他原因下载失败请重新下载,重复下载不扣分。
客服
商务合作
小程序
服务号
会员动态
会员动态 会员动态:

 wei**n_... 升级为标准VIP  微**...  升级为至尊VIP 

wei**n_...  升级为至尊VIP 138**73... 升级为高级VIP 

 138**36...  升级为标准VIP  138**56...  升级为标准VIP

 wei**n_... 升级为至尊VIP   wei**n_... 升级为标准VIP 

 137**86... 升级为高级VIP  159**79...  升级为高级VIP

 wei**n_... 升级为高级VIP 139**22... 升级为至尊VIP

 151**96... 升级为高级VIP  wei**n_... 升级为至尊VIP 

186**49... 升级为高级VIP   187**87... 升级为高级VIP

wei**n_... 升级为高级VIP  wei**n_... 升级为至尊VIP

sha**01...  升级为至尊VIP wei**n_...  升级为高级VIP

 139**62... 升级为标准VIP wei**n_...  升级为高级VIP 

 跟**... 升级为标准VIP 182**26... 升级为高级VIP 

wei**n_... 升级为高级VIP  136**44... 升级为高级VIP 

136**89...  升级为标准VIP wei**n_...  升级为至尊VIP 

 wei**n_... 升级为至尊VIP  wei**n_... 升级为至尊VIP

wei**n_... 升级为高级VIP   wei**n_... 升级为高级VIP 

177**45...  升级为至尊VIP wei**n_...  升级为至尊VIP

wei**n_... 升级为至尊VIP    微**... 升级为标准VIP

 wei**n_... 升级为标准VIP   wei**n_... 升级为标准VIP

139**16...  升级为至尊VIP  wei**n_... 升级为标准VIP

wei**n_...  升级为高级VIP 182**00... 升级为至尊VIP 

wei**n_...   升级为高级VIP wei**n_... 升级为高级VIP

wei**n_...  升级为标准VIP 133**67... 升级为至尊VIP 

wei**n_... 升级为至尊VIP 柯平  升级为高级VIP

shi**ey...  升级为高级VIP  153**71... 升级为至尊VIP 

 132**42... 升级为高级VIP   wei**n_... 升级为至尊VIP

178**35...  升级为至尊VIP  wei**n_...  升级为高级VIP

wei**n_...  升级为至尊VIP  wei**n_... 升级为高级VIP 

wei**n_... 升级为高级VIP  133**95... 升级为高级VIP

188**50...  升级为高级VIP 138**47... 升级为高级VIP 

  187**70... 升级为高级VIP  Tom**12... 升级为至尊VIP 

 微**... 升级为至尊VIP wei**n_... 升级为至尊VIP

156**93...  升级为至尊VIP wei**n_...  升级为高级VIP 

wei**n_... 升级为至尊VIP  wei**n_... 升级为标准VIP 

小敏  升级为高级VIP  hak**a9...  升级为至尊VIP

185**56... 升级为高级VIP 156**93...  升级为标准VIP 

wei**n_...  升级为至尊VIP  wei**n_... 升级为至尊VIP

Br**e有...  升级为至尊VIP  wei**n_... 升级为标准VIP

 wei**n_... 升级为高级VIP  wei**n_...  升级为至尊VIP

 156**20... 升级为至尊VIP  wei**n_...   升级为至尊VIP

微**...   升级为标准VIP   135**45... 升级为标准VIP

  wei**n_... 升级为至尊VIP wei**n_...  升级为高级VIP

157**60... 升级为高级VIP  150**45... 升级为至尊VIP

 wei**n_... 升级为标准VIP  wei**n_... 升级为至尊VIP

151**80...  升级为高级VIP 135**10...  升级为标准VIP 

wei**n_... 升级为高级VIP  wei**n_... 升级为高级VIP

 wei**n_... 升级为至尊VIP  wei**n_... 升级为标准VIP 

 wei**n_...  升级为高级VIP wei**n_...  升级为高级VIP 

135**22...  升级为高级VIP  wei**n_...  升级为至尊VIP

 181**62...  升级为至尊VIP 黑**... 升级为至尊VIP