hadoop - Hive: Collecting the source and target table count when the hive insert statement is finished -


i running insert script hive tables using shell script in loop using command hive -f filename.sql . want collect source table count , target table count , insert log table after data has been inserted in hive target table.

please me identify source , target count when map reduce job running.


Comments

Post a Comment

Popular posts from this blog

Sort a complex associative array in PHP -

this question has answer here: php sort array subarray value 5 answers i have associative array in php like: $newarray1 = array ( [producta] => array ( [link] => http://sanjosespartan.com/blog/products/agile-java-development/ [visitcount] => 4 ) [productd] => array ( [link] => http://sanjosespartan.com/blog/products/intro-to-go/ [visitcount] => 1 ) [productg] => array ( [link] => http://sanjosespartan.com/blog/products/node-js-for-developers/ [visitcount] => 1 ) [productb] => array ( [link] => http://sanjosespartan.com/blog/products/beginning-mysql/ [visitcount] => 1 ) [productc] => array ( [link] => http://sanjosespartan.com/blog/products/computer-networks/ [visitcount] => 1 ) ...
Read more

c++ - Fill edges and center of array/vector with different values -

i create function initializes vector or array of size width * height , creates border around these values. the values around outside need initialized different value ones in center. the objects storing not have default constructor, cannot rely on initialization. this code have far, feels there should simpler or more idiomatic way of doing this. i can use features , including c++1z. #include <iostream> #include <vector> void fill_values(const unsigned width, const unsigned height, std::vector<int> &values) { for(unsigned y=0; y<height+2; ++y) { for(unsigned x=0; x<width+2; ++x) { if(x==0 || x==width+1 || y==0 || y==height+1) { values.push_back(1); } else { values.push_back(0); } } } } int main(int argc, char *argv[]) { const unsigned width = 4; const unsigned height = 3; std::vector<int> values; fill_values(width, height, values);...
Read more

sql - calculate weighted average for each day and id based on time intervals in PostgreSQL -

i have table in postgresql database looks this: stid | e5 | e10 | diesel | date -----+------+------+--------+------------------------ e850 | 1300 | 1400 | 1500 | 2016-05-02 05:30:01+02 e850 | 1400 | 1500 | 1700 | 2016-05-02 08:30:01+02 e850 | 1300 | 1400 | 1500 | 2016-05-02 21:00:01+02 e850 | 1200 | 1300 | 1350 | 2016-05-03 10:30:01+02 e850 | 1300 | 1400 | 1500 | 2016-05-03 21:00:01+02 954d | 1200 | 1100 | 1300 | 2016-05-02 03:30:01+02 954d | 1300 | 1100 | 1300 | 2016-05-02 15:00:01+02 954d | 1400 | 1800 | 1400 | 2016-05-02 22:30:01+02 954d | 1700 | 1900 | 1400 | 2016-05-03 09:30:01+02 954d | 1500 | 1900 | 1200 | 2016-05-03 23:30:01+02 so have unique id's (stid), prices (e5,e10,diesel) , timestamp (date) indicates when price introduced. want calculate average price per day , stid, weighted duration price charged. , want take period between 8 , 8 pm account. to calculate weighted average price of e5 stid e850 , date 2016-05-02 between 8 , 8 pm follo...
Read more