Spark pipe PHP 实例
2016-03-07 16:24
330 查看
package test import org.apache.spark.SparkConf import org.apache.spark.SparkContext object PipeTest { def main(args: Array[String]) { val sparkConf = new SparkConf().setAppName("pipe Test") val sc = new SparkContext(sparkConf) val a = sc.parallelize(1 to 9 , 3) val result = a.pipe("php /home/gt/spark/bin/test.php").collect()//所以这里决定每台机子都装好php result.foreach { x => println("!!!!!"+x) } sc.stop() } }
<?php $in = fopen('php://stdin','r'); for ($x=0; $x<3; $x++){ $line += fgets($in); } echo $line; echo " Hello world!"; ?>
输出:
!!!!!6 Hello world!
!!!!!15 Hello world!
!!!!!24 Hello world!
相关文章推荐
- 快速排序法 php
- 搭建SMTP邮件拦截工具
- 在smarty中通过php脚本给smarty赋值
- Getting this error message: dbModel read resource does not implement Zend_Db_Adapter_Abstract
- 基于数据库、php、ajax的 3级地区联动
- windows下 VIM安装配置,打造PHP IDE开发工具
- php echo字符串的连接格式
- 在smarty中通过php脚本获取smarty变量
- PHP转换IP地址到真实地址的方法详解
- PHP常用函数收藏
- php can't connect to mysql with error 13
- PHP如何取出数组最后一个元素?
- 检测PHP环境
- Windows下的PHP安装文件线程安全和非线程安全的区别
- Laravel 5.1学习之 验证
- php 简洁上传
- php 的定界符 <<<eof 的问题
- 【PHP】PHP 7.0.4 发布
- ContentProvider的生命周期
- PHP - 继承 - 子类使用父类方法