###Summary

phdfs - PHP extensions, using PHP to manipulate Hadoop HDFS,Extension is an interface to HDFS

###Maintainers yuduanchen qingliangcn

PS

官方版本很久没有更新，接口设计也存在不合理的情况，这个分支进行了适当的修改.

Install

Requirements

• PHP Version: PHP 5.3+
• ZTS Enabled ( Thread Safety )
• Installing Hadoop

##Hadoop installation

hadoop docs: http://hadoop.apache.org/docs/r1.0.4/cn/quickstart.html

配置hadoop本地环境

vim /etc/profile

64-bit system

export JAVA_HOME=/usr/jdk1.7.0_40/
export JRE_HOME=$JAVA_HOME/jre/
export HADOOP_HOME=/usr/local/hadoop/
export C_INICLUDE_PATH=$HADOOP_HOME/hdfs/src/c++/libhdfs:$JAVA_HOME/include:$JAVA_HOME/include/Linux
export LD_LIBRARY_PATH=$HADOOP_HOME/c++/Linux-amd64-64/lib:$JAVA_HOME/jre/lib/i386/server
for i in $HADOOP_HOME/*.jar
do
    CLASSPATH=$CLASSPATH:$i
done
for i in $HADOOP_HOME/lib/*.jar
do
     CLASSPATH=$CLASSPATH:$i
done
export CLASSPATH

source /etc/profile

vim /etc/ld.so.conf

64-bit system

${HADOOP_HOME}/c++/Linux-amd64-64/lib
${JAVA_HOME}jre/lib/amd64/

ldconfig -v

##phdfs installation

$ /path/to/phpize
$ ./configure --with-php-config=/path/to/php-config/
$make && make install

Documentation

The phdfs class

class phdfs {
    /* variable */
    public $host= "127.0.0.1" ;//hadoop ip
    public $port = "9000";//hadoop port /
    public $username = "hadoop"; // 用户名
    
    public function __construct(string $host,string $port, string $username);

    /***
     * Connect to a hdfs file system. Connect to the hdfs.
     * Returns true on success, false on error.
     */
    public function connect();
    /***
     * Disconnect from the hdfs file system. Disconnect from hdfs.
     * Returns true on success, false on error.
     */
    public function disconnect();
    /***
     * Checks if a given path exsits on the filesystem
     * Returns true on success, false on error.
     */
    public function exists(string $path);
    
    /***
     * 打开文件句柄
     * Returns file handler resource on success, false on error.
     */
    public function fopen(string $file);
    
    /***
     * Write data into an open file handler.
     * Returns true on success, false on error.
     */
    public function fwrite(string $file, string buffer);
    
    /***
     * close an open file handler.
     * Returns true on success, false on error.
     */
    public function fclose(resource $fileHandler);
    
     /***
     * Write data into an open file.
     * int mode: O_WRONLY 、O_CREAT、O_APPEND
     * Returns true on success, false on error.
     */
    public function write(string $file,string buffer [, int $mode ]);
     /***
     * Read data from an open file.
     * $buffer_len default 1024k
     * Returns true on success, false on error.
     */
    public function read(string $file[,int $buffer_len]);
     /***
     * Get information about a path
     * Returns array on success, false on error.
     */
    public function file_info(string $path);

    /***
     * make the given file and all non-existent parents into directories.
     * Returns true on success, false on error.
     */
    public function create_directory(string $path);
     /***
     * Rename file.
     * Returns true on success, false on error.
     */
    public function rename(sting $old_path,sting $new_ptah);
     /***
     * Get list of files/directories for a given directory-path
     * Returns true on success, false on error.
     */
    public function list_directory(string $path);
    /***
     * Get the current offset in the file, in bytes.
     * Returns Current offset,  false on error.
     */
    public function tell(string $file  [, int $buffer_len ]);
    /***
     * Copy file
     * Returns true on success, false on error.
     */
    public function copy(string $source_file,string $destination_file);
    /***
     * Delete file
     * Returns true on success, false on error.
     */
    public function delete($string $file);

}

Demo

<?php
try {
    $obj = new phdfs("127.0.0.1", "8020", 'impala');
    $log = $obj->connect();
    var_dump($log);
    $handler = $obj->fopen('/user/impala/test.log');
    var_dump($handler);
    $result = $obj->fwrite($handler, 'aaaaaaaaaaa');
    echo "写文件结果:", $result, "\n";
    $result = $obj->fclose($handler);
    var_dump($result);
} catch (Exception $ex) {
    var_dump($ex->getMessage());
}
?>

more

任何问题请提issue。