Unlike the previous tasks, the MR p

Unlike the previous tasks, the MR program
for this task consists of both a Map and Reduce function. The Map
function first splits the input value by the field delimiter, and then
outputs the sourceIP field (given as the input key) and the adRevenue field as a new key/value pair. For the variant query, only the
first seven characters (representing the first two octets, each stored
as three digits) of the sourceIP are used. These two Map functions
share the same Reduce function that simply adds together all of the
adRevenue values for each sourceIP and then outputs the prefix and
revenue total. We also used MR’s Combine feature to perform the
pre-aggregate before data is transmitted to the Reduce instances,
improving the first query’s execution time by a factor of two [8].

ผลลัพธ์ (ไทย) 1:

ซึ่งแตกต่างจากงานก่อนหน้านี้ โปรแกรมนายสำหรับงานนี้ประกอบด้วยแผนที่และลด แผนที่ฟังก์ชันแรกแยกค่าอินพุต โดยตัวคั่นฟิลด์ และแสดงผลเขตข้อมูล sourceIP (กำหนดเป็นคีย์อินพุท) และฟิลด์ adRevenue เป็นคู่ค่าคีย์ใหม่ สำหรับตัวแปรแบบสอบถาม เท่าก่อนเจ็ดอักขระ (octets แรกที่สอง แต่ละเก็บไว้แทนเป็นสามหลัก) ของ sourceIP ที่ใช้ ฟังก์ชันเหล่านี้แผนสองแบ่งหน้าที่ลดเหมือนที่ก็เพิ่มด้วยกันทั้งหมดadRevenue ค่าสำหรับแต่ละ sourceIP และการแสดงผลแล้ว คำนำหน้า และรายได้รวม เราใช้ของนายรวมคุณลักษณะการดำเนินการรวมล่วงหน้าก่อนมีส่งข้อมูลกับอินสแตนซ์การลดปรับปรุงเวลาของแบบสอบถามแรกดำเนินการ โดยตัวคูณสอง [8]

ผลลัพธ์ (ไทย) 2:

ซึ่งแตกต่างจากงานก่อนหน้านี้นายฮโปรแกรมสำหรับงานนี้ประกอบด้วยทั้งแผนที่และฟังก์ชั่นลด แผนที่ฟังก์ชั่นแรกที่แยกค่าการป้อนข้อมูลโดยการกำหนดเขตฟิลด์แล้วผลสนามsourceIP (รับเป็นกุญแจสำคัญในการป้อนข้อมูล) และสนาม adRevenue เป็นคีย์ใหม่ / คู่ค่า สอบถามตัวแปรเพียงเจ็ดครั้งแรกตัวละคร (ที่เป็นตัวแทนของทั้งสอง octets แรกแต่ละที่เก็บไว้เป็นตัวเลขสามหลัก) ของ sourceIP ถูกนำมาใช้ ทั้งสองฟังก์ชั่นแผนที่แบ่งปันเดียวกันฟังก์ชั่นลดที่เพียงเพิ่มรวมกันทั้งหมดของค่าadRevenue สำหรับแต่ละ sourceIP แล้วผลคำนำหน้าและรายได้รวม นอกจากนี้เรายังใช้คุณลักษณะรวมนายที่จะดำเนินการก่อนการรวมข้อมูลก่อนที่จะถูกส่งไปยังอินสแตนซ์ลดการปรับปรุงเวลาดำเนินการครั้งแรกของแบบสอบถามโดยปัจจัยที่สอง[8]

ผลลัพธ์ (ไทย) 3:

ซึ่งแตกต่างจากงานก่อนหน้านี้ คุณโปรแกรม
สำหรับงานนี้มีทั้งแผนที่และลดฟังก์ชัน ฟังก์ชันแผนที่
ก่อนแยกค่าอินพุต โดยเขตตัวคั่นแล้ว
sourceip ออกฟิลด์ ( ให้ใส่คีย์ ) และ adrevenue เขตข้อมูลที่เป็นกุญแจใหม่ค่า / คู่ สำหรับแบบสอบถามตัวแปรเพียง
แรกเจ็ดตัวอักษร ( แสดงสอง octets แรกแต่ละเก็บไว้
เป็นเลขสามหลัก ) ของ sourceip ใช้ เหล่านี้สองแผนที่ฟังก์ชัน
ร่วมกันลดฟังก์ชันที่เพียงเพิ่มกันทุกคน
adrevenue ค่าสำหรับแต่ละ sourceip แล้วผลผลิตคำนำหน้าและ
รายได้ทั้งหมด เรายังใช้นายรวมคุณลักษณะการรวมข้อมูล
ก่อนก่อนส่งเพื่อลดกรณี
การปรับปรุงเวลาปฏิบัติการแรกของแบบสอบถามโดยปัจจัยสอง [ 8 ]