Hadoop & PHP

HADOOP & PHP PHPNW 2017 @MICHAELCULLUMUK

@MICHAELCULLUMUK ME?

MICHAEL CULLUM @MICHAELCULLUMUK

@MICHAELCULLUMUK

@MICHAELCULLUMUK APACHE HADOOP SUITE OF APPLICATIONS

@MICHAELCULLUMUK HADOOP

@MICHAELCULLUMUK BIG DATA

@MICHAELCULLUMUK

@MICHAELCULLUMUK HADOOP 2003: GOOGLE FILE SYSTEM  2004: MAPREDUCE: SIMPLIFIED DATA
PROCESSING   ON LARGE CLUSTERS  2006: HADOOP DEVELOPMENT BEGINS (AND NAMED AFTER A TOY ELEPHANT)

@MICHAELCULLUMUK HADOOP 2006: 1.8 TB IN 47.9 HOURS  2007: 1PB
IN 12.13 HOURS, 1.37 TB/MIN  2008: 1PB IN 6.03 HOURS, 2.76 TB/MIN  2010: 1PB, 2.95 HOURS, 5.65 TB/MIN  2011: 1PB, 0.55 HOURS, 30.3 TB/MIN  2012: 50PB, 23 HOURS, 36.2 TB/MIN  2014: SPARK ALLOWED - SORT 5 TIMES AS FAST. 10 TIMES FEWER NODES

HADOOP COMPONENTS Hadoop Core Hadoop YARN Hadoop HDFS Hadoop Map-Reduce

@MICHAELCULLUMUK Hadoop YARN  Resources Management Hadoop Map-Reduce  Method of executing
large tasks

OTHER TOOLS ▸ Hive - Relational style database ▸ Bigtop
- Quickly setup a test cluster ▸ Pig - High level programming language for MapReduce jobs ▸ Sqoop - For importing/reading MySQL and other RDBMS ▸ Spark - Alternative to MapReduce designed for fast analytics ▸ Flume - Streaming data collection / aggregation manager ▸ Oozie - MapReduce Workﬂow Manager & Scheduler ▸ Whirr - Deployment of clusters to AWS ▸ HBase - Low-latency distributed, non- relational database ▸ Zookeeper - Distributed application HA management ▸ HCatalog - Interop between Pig and Hive

@MICHAELCULLUMUK ▸ Hadoop HDFS: How data is stored, accessed and
distributed under the hood ▸ Hive: Using Hadoop as an RDBMS; writing ▸ Presto: A Facebook library we can use to query the cluster; reading ▸ Phresto: A library to make Presto accessible from PHP userland ▸ Phresto & Doctrine CONTENTS

@MICHAELCULLUMUK HADOOP HDFS

@MICHAELCULLUMUK ARCHITECTURE Namenode Datanodes

@MICHAELCULLUMUK READING A FILE FROM HDFS ﬁle.txt 1: 192.168.0.2, 192.168.0.5 
2: 192.168.0.3, 192.168.0.12 Namenode Datanode: 191.168.0.5 Datanode: 192.168.0.3 Read block 1 {content} {content} Read block 2 Client Library

@MICHAELCULLUMUK ▸ ✓ Hadoop HDFS: How data is stored, accessed
and distributed under the hood ▸ Hive: Using Hadoop as an RDBMS; importing ﬁles ▸ Presto: A Facebook library we can use to query the cluster ▸ Phresto: A library to make Presto accessible from PHP userland ▸ Phresto & Doctrine CONTENTS

@MICHAELCULLUMUK HIVE

@MICHAELCULLUMUK METASTORE

@MICHAELCULLUMUK IMPORTING OF FILES

@MICHAELCULLUMUK TSV -> ORC

IMPORTING TO HIVE IS EASY while read filename; do echo
$filename hadoop fs -put /home/michael/for_hadoop_import/$filename /tmp/ echo "LOAD DATA INPATH '/tmp/$filename' INTO TABLE temp_csv; INSERT INTO TABLE temp_orc SELECT * FROM temp_csv; TRUNCATE TABLE temp_csv;" | hive done

@MICHAELCULLUMUK LIVE DEMO (IF WIFI WORKS)

and distributed under the hood ▸ ✓ Hive: Using Hadoop as an RDBMS; importing ﬁles ▸ Presto: A Facebook library we can use to query the cluster ▸ Phresto: A library to make Presto accessible from PHP userland ▸ Phresto & Doctrine CONTENTS

@MICHAELCULLUMUK PRESTO

@MICHAELCULLUMUK “DISTRIBUTED SQL ENGINE”

@MICHAELCULLUMUK ▸ Hive ▸ MySQL ▸ Cassandra ▸ MongoDB ▸
PostgreSQL ▸ Redis ▸ SQL Server ▸ JMX ▸ REST API ▸ Local ﬁles ▸ Memory CONNECTORS

@MICHAELCULLUMUK HDF Your (PHP) application Presto Coordinator Presto Workers HDFS
Hive Metastore

@MICHAELCULLUMUK IT HAS A UI TOO ;)

@MICHAELCULLUMUK LIVE DEMO #2

and distributed under the hood ▸ ✓ Hive: Using Hadoop as an RDBMS; importing ﬁles ▸ ✓ Presto: A Facebook library we can use to query the cluster ▸ Phresto: A library to make Presto accessible from PHP userland ▸ Phresto & Doctrine CONTENTS

@MICHAELCULLUMUK PHRESTO

@MICHAELCULLUMUK PHP

@MICHAELCULLUMUK REST API

@MICHAELCULLUMUK

@MICHAELCULLUMUK SIMPLE PHP CLIENT $socket = new \SamKnows\Phresto\Client\RemoteHost('http', ‘coordinator.hostname.com', '8080');
$connection = new \SamKnows\Phresto\Client\HttpConnection($socket, new NullLogger(), 'Michael\'s Macbook', 'Michael', '', 0, 0, 0, false); $result = $connection->executeQuery("SELECT * FROM table WHERE id=5')", 'hive', ‘database_name’); $resultClass = $result->getResult();

@MICHAELCULLUMUK TAP INTO PRESTO FUNCTIONALITY TOO $connection->getNodeList(); $connection->getClusterStatus(); $connection->getServerInfo(); $connection->getQueriesStatus();
$connection->getQueryStatus('20170508_163921_00807_v2znp');

@MICHAELCULLUMUK SAMKNOWS/PHRESTO

and distributed under the hood ▸ ✓ Hive: Using Hadoop as an RDBMS; importing ﬁles ▸ ✓ Presto: A Facebook library we can use to query the cluster ▸ ✓ Phresto: A library to make Presto accessible from PHP userland ▸ Phresto & Doctrine CONTENTS

@MICHAELCULLUMUK DOCTRINE & SYMFONY

@MICHAELCULLUMUK DOCTRINE DBAL / PDO-STYLE INTERFACE $configuration = new Configuration();
$params = [ 'host' => 'coordinator.hostname.com', 'port' => '8080', 'user' => 'Michael', 'password' => '', 'source' => __FILE__, 'protocol' => 'http', 'catalog' => 'hive', 'schema' => 'database_name', 'driverClass' => Driver::class, ]; $connection = DriverManager::getConnection($params, $configuration); $result = $connection->executeQuery('SELECT * FROM messages LIMIT 1'); $result->fetchAll(); foreach ($result->fetch() as $row) { var_dump($row); }

@MICHAELCULLUMUK SYMFONY # Doctrine Configuration doctrine: dbal: default_connection: presto connections:
presto: driver_class: '\SamKnows\Phresto\Doctrine\DBAL\Driver\Phresto\Driver' host: 'coordinator.hostname.com' port: '8080' user: 'Michael' password: 'password' charset: UTF8 options: source: 'Michaels MBP' catalog: 'hive' schema: 'table_name' protocol: 'http' Use parameters for these  conﬁguration values

and distributed under the hood ▸ ✓ Hive: Using Hadoop as an RDBMS; importing ﬁles ▸ ✓ Presto: A Facebook library we can use to query the cluster ▸ ✓ Phresto: A library to make Presto accessible from PHP userland ▸ ✓ Phresto & Doctrine CONTENTS

@MICHAELCULLUMUK ANY QUESTIONS?

THANKS @MICHAELCULLUMUK

HADOOP & PHP PHPNW 2017 @MICHAELCULLUMUK

Hadoop & PHP

Hadoop & PHP

More Decks by Michael C.

Other Decks in Programming

Featured

Transcript