DEMO_如何用Oracle实现Hadoop_MR函数.pdfVIP

DEMO：如何用Oracle 来实现Hadoop M/R 函数    1、创建分析数据源  这里创建一个表来模拟存放待分析的数据CLOB 格式。    CREATE TABLE web_result (a CLOB)     LOB(a) STORE AS SECUREFILE(TABLESPACE sysaux);    INSERT INTO web_result VALUES (kasim luna);  INSERT INTO web_result VALUES (luna goto hziee);  INSERT INTO web_result VALUES (hziee is a school);  INSERT INTO web_result VALUES (selene and luna);  INSERT INTO web_result VALUES (hello kasim);  INSERT INTO web_result VALUES (kasim say hello to world);  INSERT INTO web_result VALUES (hello world and hello kasim);  commit;    2、创建Map/Reduce 函数    create or replace  package my_map_reduce is      type word_t      is record (word varchar2(4000));    type words_t     is table of word_t;      type word_cur_t is ref cursor return word_t;    type wordcnt_t   is record (word varchar2(4000), count number);    type wordcnts_t is table of wordcnt_t;      function mapper(rec in sys_refcursor, sep in varchar2) return words_t       pipelined parallel_enable (partition rec by any);      function reducer(in_cur in word_cur_t) return wordcnts_t       pipelined parallel_enable (partition in_cur by hash(word))      cluster in_cur by (word);    end;  /    create or replace  package body my_map_reduce is      function mapper(rec in sys_refcursor, sep in varchar2) return words_t       pipelined parallel_enable (partition rec by any)     is       recode  clob;       istart    number;       pos       number;       len       number;      word_rec word_t;     begin         loop          fetch rec into recode;        exit when rec%notfound;           istart := 1;         len := length(recode);          while (istart = len) loop           pos := instr(recode, sep, istart);             if (pos = 0) then            word_rec.word := substr(recode, istart);             pipe row (word_rec);             istart := len + 1;          else            word_rec.word := substr(recode, istart, pos ‐ i