在大数据的浪潮之下，技术的更新迭代十分频繁。受技术开源的影响，大数据开发者提供了十分丰富的工具。但也因为如此，增加了开发者选择合适工具的难度。在大数据处理一些问题的时候，往往使用的技术是多样化的。这完全取决于业务需求，比如进行批处理的MapReduce，实时流处理的Flink，以及SQL交互的Spark SQL等等。而把这些开源框架，工具，类库，平台整合到一起，所需要的工作量以及复杂度，可想而知。这也是大数据开发者比较头疼的问题。而今天要分享的就是整合这些资源的一个解决方案，它就是 Apache Beam。
　　Apache Beam 最初叫 Apache Dataflow，由谷歌和其合作伙伴向Apache捐赠了大量的核心代码，并创立孵化了该项目。该项目的大部分大码来自于 Cloud Dataflow SDK，其特点有以下几点：
统一数据批处理（Batch）和流处理（Stream）编程的范式
能运行在任何可执行的引擎之上
　　那 Apache Beam到底能解决哪些问题，它的应用场景是什么，下面我们可以通过一张图来说明，如下图所示：
　　通过改图，我们可以很清晰的看到整个技术的发展流向；一部分是谷歌派系，另一部分则是Apache派系。在开发大数据应用时，我们有时候使用谷歌的框架，API，类库，平台等，而有时候我们则使用Apache的，比如：HBase，Flink，Spark等。而我们要整合这些资源则是一个比较头疼的问题，Apache Beam 的问世，整合这些资源提供了很方便的解决方案。
2.1 Vision
　　下面，我们通过一张流程图来看Beam的运行流程，如下图所示：
　　通过上图，我们可以清楚的知道，执行一个流程分以下步骤：
End Users：选择一种你熟悉的编程语言提交应用
SDK Writers：该编程语言必须是 Beam 模型支持的
Library Writers：转换成Beam模型的格式
Runner Writers：在分布式环境下处理并支持Beam的数据处理管道
IO Providers：在Beam的数据处理管道上运行所有的应用
DSL Writers：创建一个高阶的数据处理管道
　　Beam SDK 提供了一个统一的编程模型，来处理任意规模的数据集，其中包括有限的数据集，无限的流数据。Apache Beam SDK 使用相同的类来表达有限和无限的数据，同样使用相同的转换方法对数据进行操作。Beam 提供了多种 SDK，你可以选择一种你熟悉的来建立数据处理管道，如上述的 2.1 中的图，我们可以知道，目前 Beam 支持 Java，Python 以及其他待开发的语言。
2.3 Pipeline Runners
　　在 Beam 管道上运行引擎会根据你选择的分布式处理引擎，其中兼容的 API 转换你的 Beam 程序应用，让你的 Beam 应用程序可以有效的运行在指定的分布式处理引擎上。因而，当运行 Beam 程序的时候，你可以按照自己的需求选择一种分布式处理引擎。当前 Beam 支持的管道运行引擎有以下几种：
Apache Apex
Apache Flink
Apache Spark
Google Cloud Dataflow
　　本示例通过使用 Java SDK 来完成，你可以尝试运行在不同的执行引擎上。
3.1 开发环境
下载安装 JDK 7 或更新的版本，检测 JAVA_HOME环境变量
下载 Maven 打包环境。
　　关于上述的安装步骤，并不是本篇博客的重点，这里笔者就不多赘述了，不明白的可以到官网翻阅文档进行安装。
3.2 下载示例代码
　　Apache Beam 的源代码在 Github 有托管，可以到 Github 下载对应的源码，下载地址：https://github.com/apache/beam
　　然后，将其中的示例代码进行打包，命令如下所示：
$ mvn archetype:generate \
-DarchetypeRepository=https://repository.apache.org/content/groups/snapshots \
-DarchetypeGroupId=org.apache.beam \
-DarchetypeArtifactId=beam-sdks-java-maven-archetypes-examples \
-DarchetypeVersion=LATEST \
-DgroupId=org.example \
-DartifactId=word-count-beam \
-Dversion="0.1" \
-Dpackage=org.apache.beam.examples \
-DinteractiveMode=false
　　此时，命令会创建一个文件夹 word-count-beam，里面包含一个 pom.xml 和相关的代码文件。命令如下所示：
$ cd word-count-beam/
$ ls src/main/java/org/apache/beam/examples/
DebuggingWordCount.java
WindowedWordCount.java
MinimalWordCount.java
WordCount.java
3.3 运行 WordCount 示例代码
　　一个 Beam 程序可以运行在多个 Beam 的可执行引擎上，包括 ApexRunner，FlinkRunner，SparkRunner 或者 DataflowRunner。 另外还有 DirectRunner。不需要特殊的配置就可以在本地执行，方便测试使用。
　　下面，你可以按需选择你想执行程序的引擎：
对引擎进行相关配置
使用不同的命令：通过 --runner=&runner&参数指明引擎类型，默认是 DirectRunner；添加引擎相关的参数；指定输出文件和输出目录，当然这里需要保证文件目录是执行引擎可以访问到的，比如本地文件目录是不能被外部集群访问的。
运行示例程序
3.3.1 Direct
$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--inputFile=pom.xml --output=counts" -Pdirect-runner
3.3.2 Apex
$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--inputFile=pom.xml --output=counts --runner=ApexRunner" -Papex-runner
3.3.3 Flink-Local
$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--runner=FlinkRunner --inputFile=pom.xml --output=counts" -Pflink-runner
3.3.4 Flink-Cluster
$ mvn package exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--runner=FlinkRunner --flinkMaster=&flink master& --filesToStage=target/word-count-beam-bundled-0.1.jar \
--inputFile=/path/to/quickstart/pom.xml --output=/tmp/counts" -Pflink-runner
　　然后，你可以通过访问&http://&flink master&:8081 来监测运行的应用程序。
3.3.5 Spark
$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--runner=SparkRunner --inputFile=pom.xml --output=counts" -Pspark-runner
3.3.6 Dataflow
$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--runner=DataflowRunner --gcpTempLocation=gs://&your-gcs-bucket&/tmp \
--inputFile=gs://apache-beam-samples/shakespeare/* --output=gs://&your-gcs-bucket&/counts" \
-Pdataflow-runner
3.4 运行结果
　　当程序运行完成后，你可以看到有多个文件以 count 开头，个数取决于执行引擎的类型。当你查看文件的内容的时候，每个唯一的单词后面会显示其出现次数，但是前后顺序是不固定的，也是分布式引擎为了提高效率的一种常用方式。
3.4.1 Direct
$ ls counts*
$ more counts*
bundled: 1
limitations: 1
Foundation: 1
3.4.2 Apex
$ cat counts*
PAssert: 1
3.4.3 Flink-Local
$ ls counts*
$ more counts*
limitations: 1
bundled: 1
Foundation: 1
3.4.4 Flink-Cluster
$ ls /tmp/counts*
$ more /tmp/counts*
limitations: 1
bundled: 1
Foundation: 1
3.4.5 Spark
$ ls counts*
$ more counts*
limitations: 1
require: 1
profile: 10
3.4.6 Dataflow
$ gsutil ls gs://&your-gcs-bucket&/counts*
$ gsutil cat gs://&your-gcs-bucket&/counts*
feature: 15
smother'st: 1
revelry: 1
bashfulness: 1
Bashful: 1
deserves: 32
barrenly: 1
　　Apache Beam 主要针对理想并行的数据处理任务，并通过把数据集拆分多个子数据集，让每个子数据集能够被单独处理，从而实现整体数据集的并行化处理。当然，也可以用 Beam 来处理抽取，转换和加载任务和数据集成任务（一个ETL过程）。进一步将数据从不同的存储介质中或者数据源中读取，转换数据格式，最后加载到新的系统中。
　　这篇博客就和大家分享到这里，如果大家在研究学习的过程当中有什么问题，可以加群进行讨论或发送邮件给我，我会尽我所能为您解答，与君共勉！&
阅读(...) 评论()手机哪些内置程序文件是可以删除的？
手机自带的程序文件哪些是可以删除的呢？最近内存不够用。外置的都是有用的，内置的哪些可以删除掉呢？求告知！
以下是个人掌握安卓等手机多年，研究文件信息总结！
AccuweatherDaemon.apk-
　　AccuweatherDaemon.odex
　　AccuweatherWidget.apk
　　AccuweatherWidget.odex
　　AccuweatherWidget_Main.apk
　　AccuweatherWidget_Main.odex
　　以及Accuweather开头的其它文件，系统自带的天气组件，可以删掉　　AllshareCastWidget.apk
　　AllshareCastWidget.odex
　　AllshareMediaServer.apk
　　AllshareMediaServer.odex
　　AllSharePlay.apk
　　AllshareService.apk
　　AllshareService.odex
　　以及Allshare开头的其它文件，使用Allshare可以跟三星的其它数码设备例如平板电视、相机、电脑等用wifi进行连接，共享电影、图片及音乐等文件。没什么实用性，可删掉。　　ogClockSimple.apk
　　ogClockSimple.odex
　　ogClockUnique.apk
　　ogClockUnique.odex
　　小组件里的模拟时钟插件，可删除。　　ChatON_MARKET.apk
　　三星的聊天软件，基本无用，可删除。　　DialerWidget.apk
　　DialerWidget.odex
　　小组件中的键盘，可删除。　　DigitalClock.apk
　　DigitalClock.odex
　　DigitalClock21.apk5
　　DigitalClock21.odex
　　小组件里的数字时钟插件，可删除。　　Dropbox.apk
　　DropboxOOBE.apk
　　国外网盘，国内无用。　　DualClockog.apk
　　DualClockog.odex
　　DualClockDigital.apk
　　DualClockDigital.odex
　　小组件里的双时钟插件，可删除。　　FotaClient.apk
　　FotaClient.odex
　　FWUpgrade.apk
　　FWUpgrade.odex
　　OTA固件升级相关的程序，ROOT后失效，可删除。　　GameHub_2.0_ICS.apk
　　游戏下载平台，可删除。　　Gmail.apk
　　Google电子邮箱，可删除。　　GoogleSearchWidget.apk
　　GoogleSearchWidget.odex
　　Google搜索栏，可删除。　　GroupCast.apk
　　群组广播，通过WIFI可以与他人分享图像、文档、音乐，可删除。　　HelpHub.apk
　　HelpHub.odex
　　帮助文件，可删除。　　Kaiti.apk
　　Kaiti.odex
　　设定—显示—字体风格中的楷体字体，可删除。　　MobilePrint.apk
　　MobilePrint.odex
　　移动打印，可删除。　　MoreServices.apk
　　MoreServices.odex
　　新浪为三星提供的应用商城，可删除。　　PaperArtist.apk
　　三星手机的一款图像处理软件，里面有多种特效，可以玩一玩，可删除。　　PhoneSky.apk
　　Play商店，可以删，但建议保留，尤其是喜欢玩游戏的基友。　　PlusOne.apk
　　谷歌社交软件，基本没用。　　PolarisViewer.apk
　　系统自带的文档浏览器，可以浏览word excel pdf等格式文档，可删除，看个人需要　　SamsungApps.apk
　　SamsungAppsUNA3.apk
　　三星应用市场，可删除。　　SamsungChineseIME_HKTW_Phone.apk
　　三星各类输入法，不需要三星输入法或者装了其它输入法的话可删除。　　Samsungservice.apk
　　三星服务，可删除。　　SamsungWidget_FavoriteAPP.apk
　　SamsungWidget_FavoriteAPP. odex
　　小组件里面的常用应用程序插件，可删除。　　sCloudBackupApp.apk
　　sCloudBackupProvider.apk
　　sCloudDataRelay.apk
　　sCloudDataSync.apk
　　sCloudSyncBrowser.apk
　　sCloudSyncCalendar.apk
　　sCloudSyncContacts.apk
　　sCloudSyncSMemo.apk
　　以及sCloud相关的其他文件，三星云服务可删除。　　SecCalculator2.apk
　　SecCalculator2.odex
　　计算器，可删。　　SecCalendar.apk
　　SecCalendar.odex
　　SecCalendarProvider.apk
　　SecCalendarProvider.odex
　　S日历，可删。　　SecEmail.apk
　　SecEmail.odex
　　电子邮件，可删。　　SecExchange.apk
　　SecExchange.odex
　　微软的邮件平台，可删除。　　ShaoNv.apk
　　ShaoNv.odex
　　设定—显示—字体风格中的少女字体,可删除。　　SimpleAlarmClock.apk
　　SimpleAlarmClock.odex
　　小组件里的简单闹钟，可删除。　　SimpleFavoritesWidget.apk
　　SimpleFavoritesWidget.odex
　　小组件里的常用联系人，可删除。　　SMemo.apk
　　SMemo.odex
　　SMemoProvider.apk
　　SMemoProvider.odex
　　S备忘录，可删除。　　SNS.apk
　　Facebook社交软件，国内基本无用。　　SPlannerAppWidget.apk
　　SPlannerAppWidget.odex
　　S日历中的日程，事件，需要配合S日历使用，如果删除了S日历的这个也可以删了。　　Street.apk
　　Google街景，可删。　　Talk.apk
　　Google talk聊天软件，删了吧。　　talkback.apk
　　读屏软件，为视力障碍者提供语音辅助的应用，可删除。　　Velvet.apk
　　Google搜索，可删除。　　VoiceSearchStub.apk
　　语音搜索，可删除。　　Voicetalk.apk
　　S Voice，类似苹果siri的语音助手，可删除。　　WebManual.apk
　　WebManual.odex
　　使用说明书，可删除。　　WfdBroker.apk
　　WfdBroker.odex
　　Allshare功能中的组件，基本无用，可删除。　　YahoonewsDaemon.apk
　　YahoonewsDaemon.odex
　　YahoonewsWidget.apk
　　YahoonewsWidget.odex
　　YahoostockDaemon.apk
　　YahoostockDaemon.odex
　　YahoostockWidget.apk
　　YahoostockWidget.odex
　　雅虎相关的东西，可删除。　　.apk
　　视频网站，国内需要科学上网，可删除。
动态壁纸功能相关
　　以下是跟动态壁纸功能(设定—显示—墙纸)相关的几个文件：
DeepSea.apk
　　DeepSea.odex
　　动态壁纸“深海”，可删除。　　LuminousDots.apk.
　　LuminousDots.odex
　　动态壁纸“发光点”，可删除。　　NoiseField.apk
　　NoiseField.odex
　　动态壁纸“气泡”，可删除。　　PhaseBeam.apk
　　PhaseBeam.odex
　　动态壁纸“光束”，可删除。　　PhotoWall.apk
　　PhotoWall.odex
　　动态壁纸“照片墙”，能够在手机主屏上展示你所有照片的动态壁纸，可删除。　　SecLiveWallpapersPicker.apk
　　SecLiveWallpapersPicker.odex
　　动态壁纸程序，删掉后不能使用动态壁纸，可删除。　　TopicWall.apk
　　TopicWall.odex
　　动态壁纸“股票墙”，可删除。　　WeatherWall.apk
　　WeatherWall.odex
　　动态壁纸“多风的天气”，可删除。
要回复问题请先或
Copyright & .com, All Rights Reserved正在初始化报价器有谁清楚beam是什么文件夹3个回答Tester莖豼其实是一个工具来的，可以找出文件里面的错误。工具名称是IBM Checking Tool for Bugs Errors and Mistakes，简称beam。
暴风O7e你好，beam里面保存的是你拍的照片和图片文件的缩略图缓存这是可以删的，但是删了以后打开图片文件的速度会变慢，看不见是因为有隐藏，安卓手机里面以文件名以.开头的是隐藏文件，这和windows是不一样的，希望我的回答对您有帮助
加我qq521您好，很高兴为您解答,
beam一个静态分析工具，可以用于分析并查找出 C, C++ 和 Java 代码中的一些不容易发现的潜在错误，从而达到提高代码质量的目的。同动态分析工具和其它静态分析工具相比，它拥有一些可贵的特性。供参考。希望能够帮到您,
其他回答热门问答1234567891011121314151617181920查看更多21222324252627282930相关问答2个回答lvxiujiecfc摇头灯有4种功率型号的：250摇头灯575摇头灯1200摇头灯1500摇头灯。款式就根据各厂家机箱改变有所不同如有需要可以咨询广州创美特灯光音响设备有限公司
5个回答liangjie412亲，beam摇头灯一般瓦数分：200瓦、230瓦和250瓦。每个品牌因为有不同的外观它的尺寸和型号也不一样的：比如 ACME Saber Speed (AE-710 Beam)摇头...3个回答Tester莖豼其实是一个工具来的，可以找出文件里面的错误。工具名称是IBM Checking Tool for Bugs Errors and Mistakes，简称beam。
2个回答红尘一滴水abc亲，beam摇头灯一般瓦数分：200瓦、230瓦和250瓦。每个品牌因为有不同的外观它的尺寸和型号也不一样的：比如ACMESaberSpeed(AE-710Beam)摇头灯尺寸45...3个回答猴萄了31很好，我用了大半年了，一点问题都没有。不过他不是专业做吸尘器的，啥家电都做那种，所以在吸尘器里也就算个中等档次的品牌。
4个回答唯yui一319伊莱克斯beam中央吸尘器的报价是859元
可将居住区的尘土、灰尘和脏物收集至集尘筒。从中央主机中排出的空气具有98%的清洁度。由此可见BEAM中央吸尘系统可以创造一个较好的...1个回答残爱丶振维修主要是判断哪个部件出了问题，直接更换，这个需要一定的经验，也需要一些工具。3个回答xdzbrbjnl三星beam2手机性价比挺不错的。
三星beam2手机与普通的三星智能机没有什么差异，依旧是熟悉的圆角矩形设计，也依旧是标志性的实体Home按键，让人一看就知道是三星...3个回答amp方圆amp按DEL或F22个回答baoyinhao沙坪坝区马家岩建材市场，高新区石桥铺八益建材市场，渝北区龙溪建材市场是几个比较大的，设立时间长的建材市场； 卫浴的话在几大卖场都有，红星美凯龙、美美家、居然之家等，然后凯恩家具市场...beam文件夹是什么意思? - 知乎有问题，上知乎。知乎作为中文互联网最大的知识分享平台，以「知识连接一切」为愿景，致力于构建一个人人都可以便捷接入的知识分享网络，让人们便捷地与世界分享知识、经验和见解，发现更大的世界。2被浏览<strong class="NumberBoard-itemValue" title="分享邀请回答添加评论分享收藏感谢收起写回答您所在位置： &
&nbsp&&nbsp&nbsp&&nbsp
三星手机系统精简必备 三星手机App文件夹 apk列表完整版.pdf 20页
本文档一共被下载：
次 ,您可全文免费在线阅读后下载本文档。
&#xe600;下载提示
1.本站不保证该用户上传的文档完整性，不预览、不比对内容而直接下载产生的反悔问题本站不予受理。
2.该文档所得收入(下载+内容+预览三)归上传者、原创者。
3.登录后可充值，立即自动返金币，充值渠道很便利
三星手机系统精简必备 三星手机App文件夹 apk列表完整版
你可能关注的文档：
··········
··········
三星手机系统精简必备 三星手机App 文件夹 apk 列表完整版
优化需要root 使用R.E 管理器挂载为读写模式
AllShareCastWidget.apk
三星自家的无线视频共享之类,意义不大
和wifi 直连有关
AllshareMediaServer.apk
三星自家的无线视频共享之类,意义不大
AllSharePlay.apk
三星自家的无线视频共享之类,意义不大
AllshareService.apk
三星自家的无线视频共享之类,意义不大
AnalogClockSimple.apk
模拟时钟,可以保留反正不大
ApplicationsProvider.apk
应用程序管理信息储备
这个有争议,说删除的也有不能删除的也有
Autonav_V5.0.apk
7127.42 KB
国行才带的高德导航
BackupRestoreConfirmation.apk
备份恢复确认,貌似谷歌自带这些东西,是不是三星也在公用这个,还不清
BadgeProvider.apk
短信通知相关,最好不要删除TW 桌面用的 未接电话和未收邮
BCService.apk
BestGroupPose.apk
BluetoothAvrcp.apk
BluetoothMap.apk
BluetoothTest.apk
CapabilityManagerService.apk
兼容性管理服务
CertInstaller.apk
证书服务,还和wifi 有关
ChatON_MARKET.apk
14717.73 KB
类似一个qq 之流的交友软件
ClipboardSaveService.apk
剪贴板保存服务
ClockPackageChina.apk
26492.44 KB
时钟不能删除
ContextProvider.apk
背景程序供应
和版本有关,删除之后部分测试指令估计就没用了
DeepSea.apk
正在加载中，请稍后...