जावा 8: निष्पादित स्ट्रीम

Question

पर आपरेशन को कम मैं एक java.util.stream.Stream जैसे प्रमुख मूल्य जोड़े युक्त मिल गया है: मैं सभी प्रविष्टियों, जो एक ही मिल गया है मर्ज करना चाहते हैं

<1,3> <1,5> <3,1> <4,2> <4,7> <4,8> 

अब कुंजी:

<1,[3,5]> <3,[1]> <4,[2,7,8]> 

डेटा पहले ही सॉर्ट किया गया है, इसलिए केवल लगातार डेटासेट को विलय करना होगा।

अब मैं एक तरह से ऊपर की तरह धारा की सामग्री को बदलने के लिए के लिए खोज रहा हूँ, स्मृति में सभी डेटासेट लोड किए बिना।

मैं एक ही मान के बजाय मानों की सूची से युक्त एक अलग ऑब्जेक्ट प्रकार के साथ परिणाम के रूप में एक java.util.stream.Stream पाने के लिए पसंद करेंगे।

मेरी केवल दृष्टिकोण एक कस्टम इटरेटर, जो मर्ज करता है, लेकिन यह बहुत पुनरावर्तक में बदलने के लिए बदसूरत हो रहा है और वापस स्ट्रीम करने के लिए।

इसके लिए सबसे अच्छा तरीका क्या है?

Answer 1

यहाँ SteamEx द्वारा समाधान है।

int[][] datasets = { { 1, 3 }, { 1, 5 }, { 3, 1 }, { 4, 2 }, { 4, 7 }, { 4, 8 } }; 

StreamEx.of(datasets) // 
     .collapse((a, b) -> a[0] == b[0], groupingBy(a -> a[0], mapping(a -> a[1], toList()))) // 
     .forEach(System.out::println); 

आप अपने dataset वस्तु के साथ int[] बदल सकते हैं। हम अगर यह आलसी लोड हो रहा है/गणना सत्यापित करने के लिए peek जोड़ सकते हैं:

StreamEx.of(datasets) // 
     .peek(System.out::println) // 
     .collapse((a, b) -> a[0] == b[0], groupingBy(a -> a[0], mapping(a -> a[1], toList()))) // 
     .limit(1) // 
     .forEach(System.out::println);