Quote - events are sent to S4 with

Quote - events are sent to S4 with no key. The QuoteSplitterPE object (PE1) listens for Quote events that have no key.
QuoteSplitterPE is a keyless PE object that processes all Quote events.

For each unique word in a document, the QuoteSplitterPE object will assign a count and emit a new event of type WordEvent, keyed on word.

WordCountPE objects listen for WordEvent events emitted with key word. For example, the WordCountPE object for key word=“said” (PE2) receives all events of type WordEvent keyed on word=“said”.

When a WordEvent event for key word=“said” arrives, S4 looks up the WordCountPE object using the key word=“said”.
If the WordCountPE object exists, the PE object is called and the counter is incremented, otherwise a new WordCountPE object is instantiated.

Whenever a WordCountPE object increments its counter, it sends the updated count to a SortPE object. The key of the SortPE object is a random integer in [1, n], where n is the desired number ofSortPE objects.

Once a WordCountPE object chooses a sortID, it uses that sortID for the rest of its existence.
The purpose of using more than one SortPE object is to better distribute the load across several nodes and/or processors. For example, the WordCountPE object for key word=“said” sends an UpdatedCountEvent event to a SortPE object with key sortID=2 (PE5). Each SortPE object updates its top K list as UpdatedCountEvent events arrive. Periodically, each SortPE sends its partial top K lists to a single MergePE object (PE8), using an arbitrary agreed upon key, in this example topK=1234.

The MergePE object merges the partial lists and outputs the latest authoritative top K list.

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

ใบเสนอราคา - เหตุการณ์จะถูกส่งไป S4 กับคีย์ไม่ วัตถุ QuoteSplitterPE (PE1) ฟังสำหรับกิจกรรมใบเสนอราคาที่มีคีย์ไม่QuoteSplitterPE เป็นวัตถุ PE keyless ที่ประมวลเหตุการณ์ทั้งหมดที่เสนอราคา สำหรับแต่ละคำที่ไม่ซ้ำกันในเอกสาร วัตถุ QuoteSplitterPE จะกำหนดวิธีการนับ และปล่อยเหตุการณ์ใหม่ของชนิด WordEvent, keyed ในคำวัตถุ WordCountPE ฟังสำหรับเหตุการณ์ WordEvent ออกมา ด้วยคำ ตัวอย่าง วัตถุ WordCountPE สำหรับคำ = "กล่าวว่า" เหตุการณ์ทั้งหมดของชนิด WordEvent keyed ในคำรับ (PE2) = "กล่าวว่า" เมื่อเหตุการณ์ WordEvent สำหรับคำ = "กล่าวว่า" การมาถึง S4 ค้นหาวัตถุ WordCountPE ใช้คำคีย์ = "กล่าวว่า" ถ้ามีวัตถุ WordCountPE เรียกวัตถุ PE และเพิ่มตัวนับ หรือวัตถุ WordCountPE ใหม่จะสร้างอินสแตนซ์ เมื่อใดก็ ตามที่วัตถุ WordCountPE เพิ่มตัวนับของ มันส่งนับปรับปรุงวัตถุ SortPE คีย์ของวัตถุ SortPE เป็นจำนวนเต็มแบบสุ่มใน [1, n], โดยที่ n คือ วัตถุ ofSortPE หมายเลขที่ระบุ เมื่อวัตถุ WordCountPE เลือกแบบ sortID ซึ่งใช้ sortID นั้นสำหรับส่วนเหลือของการดำรงอยู่ของThe purpose of using more than one SortPE object is to better distribute the load across several nodes and/or processors. For example, the WordCountPE object for key word=“said” sends an UpdatedCountEvent event to a SortPE object with key sortID=2 (PE5). Each SortPE object updates its top K list as UpdatedCountEvent events arrive. Periodically, each SortPE sends its partial top K lists to a single MergePE object (PE8), using an arbitrary agreed upon key, in this example topK=1234. The MergePE object merges the partial lists and outputs the latest authoritative top K list.

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

อ้าง - เหตุการณ์ที่ถูกส่งไปยัง S4 ด้วยกุญแจไม่มี วัตถุ QuoteSplitterPE (PE1) ฟังสำหรับเหตุการณ์ที่อ้างว่ามีคีย์ไม่มี.
QuoteSplitterPE เป็นวัตถุ PE กุญแจที่ประมวลผลเหตุการณ์อ้างทั้งหมด. สำหรับแต่ละคำที่ไม่ซ้ำกันในเอกสารวัตถุ QuoteSplitterPE จะกำหนดจำนวนและปล่อยเหตุการณ์ใหม่ประเภท WordEvent , คีย์คำ. วัตถุ WordCountPE ฟังสำหรับกิจกรรม WordEvent ปล่อยออกมาด้วยคำสำคัญ ตัวอย่างเช่นวัตถุ WordCountPE สำหรับคำสำคัญ = "กล่าวว่า" (PE2) ได้รับการจัดกิจกรรมทุกประเภท WordEvent คีย์คำ = "กล่าวว่า". เมื่อเหตุการณ์ WordEvent สำหรับคำสำคัญ = "กล่าวว่า" มาถึง S4 เงยหน้าขึ้นมองวัตถุ WordCountPE ใช้ คำสำคัญ = "กล่าวว่า". ถ้าวัตถุ WordCountPE อยู่วัตถุ PE ที่เรียกว่าและเคาน์เตอร์จะเพิ่มขึ้นมิฉะนั้นวัตถุ WordCountPE ใหม่ instantiated. เมื่อใดก็ตามที่วัตถุ WordCountPE เพิ่มขึ้นเคาน์เตอร์ของมันก็จะส่งนับปรับปรุงวัตถุ SortPE . ที่สำคัญของวัตถุ SortPE เป็นจำนวนเต็มสุ่มใน [1] n ที่ n คือวัตถุที่ต้องการ ofSortPE จำนวน. เมื่อวัตถุ WordCountPE เลือก sortID จะใช้ที่ sortID สำหรับส่วนที่เหลือของชีวิต. วัตถุประสงค์ของการใช้มากขึ้น มากกว่าหนึ่งวัตถุ SortPE คือการกระจายโหลดที่ดีขึ้นในหลายโหนดและ / หรือการประมวลผล ตัวอย่างเช่นวัตถุ WordCountPE สำหรับคำสำคัญ = "กล่าวว่า" ส่งเหตุการณ์ UpdatedCountEvent กับวัตถุที่มีคีย์ SortPE sortID = 2 (PE5) แต่ละวัตถุ SortPE ปรับปรุงรายการ K ด้านบนของมันเป็นเหตุการณ์ UpdatedCountEvent มาถึง ระยะ SortPE แต่ละส่งบางส่วนรายการ K ด้านบนของวัตถุ MergePE เดียว (PE8) ใช้โดยพลการตกลงกันที่สำคัญในตัวอย่างนี้ topK = 1,234. วัตถุ MergePE ผสานรายชื่อบางส่วนและออกรายการ K บนเผด็จการล่าสุด

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

อ้างเหตุการณ์จะถูกส่งไปยัง S4 ไม่มีกุญแจ การ quotesplitterpe วัตถุ ( pe1 ) ฟังเหตุการณ์ที่อ้างว่าไม่มีกุญแจ . . .
quotesplitterpe เป็นแบบ PE วัตถุที่กระบวนการเหตุการณ์ทั้งหมดครับ

สำหรับแต่ละไม่ซ้ำคำในเอกสาร , quotesplitterpe วัตถุจะให้นับและปล่อยเหตุการณ์ใหม่ประเภท wordevent คีย์บน

, คำwordcountpe วัตถุฟัง wordevent เหตุการณ์ออกมาด้วยคำสำคัญ ตัวอย่างเช่น wordcountpe วัตถุสำหรับคำสำคัญ = " กล่าวว่า " ( pe2 ) ได้รับเหตุการณ์ประเภท wordevent คีย์ในคำ = " กล่าวว่า "

เมื่อ wordevent เหตุการณ์สำหรับคำสำคัญ = " กล่าวว่า " มาถึง S4 ดูดีขึ้น wordcountpe วัตถุโดยใช้คำสำคัญ = " กล่าวว่า "
ถ้า wordcountpe วัตถุมีอยู่จริงPE วัตถุเรียกว่าและนับถูกสั่ง หรือวัตถุ wordcountpe ใหม่ instantiated .

เมื่อ wordcountpe วัตถุทีละเคาน์เตอร์ มันส่งการปรับปรุง นับหนึ่งถึง sortpe วัตถุ กุญแจของ sortpe วัตถุเป็นจำนวนเต็มแบบสุ่มใน [ 1 ] , n โดยที่ n คือหมายเลขที่ต้องการ ofsortpe วัตถุ

เมื่อ wordcountpe sortid วัตถุที่เลือก ,มันใช้ sortid สำหรับส่วนที่เหลือของการดำรงอยู่ .
วัตถุประสงค์ของการใช้มากกว่าหนึ่งวัตถุ sortpe ดีกว่ากระจายโหลดผ่านโหนดต่างๆ และ / หรือ โปรเซสเซอร์ ตัวอย่างเช่น wordcountpe วัตถุสำหรับคำสำคัญ = " กล่าวว่า " ส่งงาน updatedcountevent เพื่อวัตถุ sortpe กับคีย์ sortid = 2 ( pe5 ) แต่ละ sortpe วัตถุปรับปรุงรายการ K ของด้านบนเป็นเหตุการณ์ updatedcountevent มาถึงเป็นระยะ ๆ แต่ละ sortpe ส่งของบางส่วนของด้านบน k รายการวัตถุ mergepe เดี่ยว ( pe8 ) ใช้ตกลงตามอำเภอใจบนคีย์ ในตัวอย่าง topk = 1234 .

mergepe วัตถุผสานรายการบางส่วนและผลล่าสุด มี K

ด้านบนรายการ