PREHOOK: query: CREATE TEMPORARY FUNCTION dboutput AS 'org.apache.hadoop.hive.contrib.genericudf.example.GenericUDFDBOutput' PREHOOK: type: CREATEFUNCTION PREHOOK: Output: dboutput POSTHOOK: query: CREATE TEMPORARY FUNCTION dboutput AS 'org.apache.hadoop.hive.contrib.genericudf.example.GenericUDFDBOutput' POSTHOOK: type: CREATEFUNCTION POSTHOOK: Output: dboutput PREHOOK: query: DESCRIBE FUNCTION dboutput PREHOOK: type: DESCFUNCTION POSTHOOK: query: DESCRIBE FUNCTION dboutput POSTHOOK: type: DESCFUNCTION dboutput(jdbcstring,username,password,preparedstatement,[arguments]) - sends data to a jdbc driver PREHOOK: query: DESCRIBE FUNCTION EXTENDED dboutput PREHOOK: type: DESCFUNCTION POSTHOOK: query: DESCRIBE FUNCTION EXTENDED dboutput POSTHOOK: type: DESCFUNCTION dboutput(jdbcstring,username,password,preparedstatement,[arguments]) - sends data to a jdbc driver argument 0 is the JDBC connection string argument 1 is the user name argument 2 is the password argument 3 is an SQL query to be used in the PreparedStatement argument (4-n) The remaining arguments must be primitive and are passed to the PreparedStatement object PREHOOK: query: EXPLAIN FROM src SELECT dboutput ( 'jdbc:derby:../build/test_dboutput_db;create=true','','', 'CREATE TABLE app_info ( kkey VARCHAR(255) NOT NULL, vvalue VARCHAR(255) NOT NULL, UNIQUE(kkey))' ), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','a'), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','b') limit 1 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN FROM src SELECT dboutput ( 'jdbc:derby:../build/test_dboutput_db;create=true','','', 'CREATE TABLE app_info ( kkey VARCHAR(255) NOT NULL, vvalue VARCHAR(255) NOT NULL, UNIQUE(kkey))' ), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','a'), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','b') limit 1 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 STAGE PLANS: Stage: Stage-1 Map Reduce Map Operator Tree: TableScan alias: src Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: COMPLETE Select Operator expressions: dboutput('jdbc:derby:../build/test_dboutput_db;create=true','','','CREATE TABLE app_info ( kkey VARCHAR(255) NOT NULL, vvalue VARCHAR(255) NOT NULL, UNIQUE(kkey))') (type: int), dboutput('jdbc:derby:../build/test_dboutput_db','','','INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','a') (type: int), dboutput('jdbc:derby:../build/test_dboutput_db','','','INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','b') (type: int) outputColumnNames: _col0, _col1, _col2 Statistics: Num rows: 500 Data size: 6000 Basic stats: COMPLETE Column stats: COMPLETE Limit Number of rows: 1 Statistics: Num rows: 1 Data size: 12 Basic stats: COMPLETE Column stats: COMPLETE File Output Operator compressed: false Statistics: Num rows: 1 Data size: 12 Basic stats: COMPLETE Column stats: COMPLETE table: input format: org.apache.hadoop.mapred.TextInputFormat output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe Stage: Stage-0 Fetch Operator limit: 1 Processor Tree: ListSink PREHOOK: query: FROM src SELECT dboutput ( 'jdbc:derby:../build/test_dboutput_db;create=true','','', 'CREATE TABLE app_info ( kkey INTEGER NOT NULL, vvalue VARCHAR(255) NOT NULL, UNIQUE(kkey))' ), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','a'), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','b') limit 1 PREHOOK: type: QUERY PREHOOK: Input: default@src #### A masked pattern was here #### POSTHOOK: query: FROM src SELECT dboutput ( 'jdbc:derby:../build/test_dboutput_db;create=true','','', 'CREATE TABLE app_info ( kkey INTEGER NOT NULL, vvalue VARCHAR(255) NOT NULL, UNIQUE(kkey))' ), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','a'), dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)','20','b') limit 1 POSTHOOK: type: QUERY POSTHOOK: Input: default@src #### A masked pattern was here #### 0 0 1 PREHOOK: query: EXPLAIN SELECT dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)',key,value) FROM src WHERE key < 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)',key,value) FROM src WHERE key < 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 STAGE PLANS: Stage: Stage-1 Map Reduce Map Operator Tree: TableScan alias: src Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: (UDFToDouble(key) < 10.0) (type: boolean) Statistics: Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: dboutput('jdbc:derby:../build/test_dboutput_db','','','INSERT INTO app_info (kkey,vvalue) VALUES (?,?)',key,value) (type: int) outputColumnNames: _col0 Statistics: Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false Statistics: Num rows: 166 Data size: 1763 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.TextInputFormat output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe Stage: Stage-0 Fetch Operator limit: -1 Processor Tree: ListSink PREHOOK: query: SELECT dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)',key,value) FROM src WHERE key < 10 PREHOOK: type: QUERY PREHOOK: Input: default@src #### A masked pattern was here #### POSTHOOK: query: SELECT dboutput('jdbc:derby:../build/test_dboutput_db','','', 'INSERT INTO app_info (kkey,vvalue) VALUES (?,?)',key,value) FROM src WHERE key < 10 POSTHOOK: type: QUERY POSTHOOK: Input: default@src #### A masked pattern was here #### 0 0 0 1 1 0 1 0 1 0 #### A masked pattern was here #### PREHOOK: query: DROP TEMPORARY FUNCTION dboutput PREHOOK: type: DROPFUNCTION PREHOOK: Output: dboutput POSTHOOK: query: DROP TEMPORARY FUNCTION dboutput POSTHOOK: type: DROPFUNCTION POSTHOOK: Output: dboutput