3 रिपॉजिटरी
Processing multiple data elements across pipeline stages simultaneously to maximize throughput.
Distinct from Per-Element Effect Execution: None of the candidates cover general concurrent element processing in data streams without being tied to images or hardware optimization.
Explore 3 awesome GitHub repositories matching data & databases · Concurrent Stream Processing. Refine with filters or upvote what's useful.
Streem एक स्ट्रीम-आधारित प्रोग्रामिंग भाषा और डेटा पाइपलाइन ऑर्केस्ट्रेटर है। यह कॉनकरेंट डेटा फ़्लो को परिभाषित करने के लिए एक डोमेन-विशिष्ट भाषा प्रदान करता है, जो यूज़र्स को डेटा स्रोतों को गंतव्यों से ऑपरेशंस के एक अनुक्रम के माध्यम से जोड़ने की अनुमति देता है जो व्यक्तिगत स्ट्रीम तत्वों को बदलते और फ़िल्टर करते हैं। सिस्टम डेटा-फ़्लो कनेक्शन और पाइपलाइन परिभाषाओं को परिभाषित करने के लिए एक कस्टम स्क्रिप्ट सिंटैक्स का उपयोग करता है। यह कॉनकरेंट डेटा प्रोसेसिंग के ऑर्केस्ट्रेशन की अनुमति देता है जहाँ कई पाइपलाइन चरण सिस्टम के माध्यम से डेटा तत्वों को स्थानांतरित करने के लिए एक साथ निष्पादित होते हैं। प्लेटफ़ॉर्म कार्यात्मक डेटा ट्रांसफॉर्मेशन और चरण-आधारित कंपोजिशन को कवर करता है, जो लिंक्ड ऑपरेशंस की एक अनुक्रमिक श्रृंखला के माध्यम से गुजरते समय आइटम्स को संशोधित या फ़िल्टर करने के लिए विशिष्ट फंक्शन्स लागू करता है।
Executes multiple pipeline stages simultaneously to move data elements through the system with higher throughput.
more-itertools एक Python इटरेबल यूटिलिटी लाइब्रेरी है जो डेटा सीक्वेंस को मैनिपुलेट, फिल्टर और ट्रांसफॉर्म करने के लिए एडवांस्ड फंक्शन्स प्रदान करती है। यह डेटा स्ट्रीम प्रोसेसिंग टूलकिट और इटरेशन स्टेट मैनेजमेंट के लिए यूटिलिटीज का एक सेट है, जो स्टैंडर्ड Python itertools मॉड्यूल की क्षमताओं का विस्तार करता है। इस लाइब्रेरी में परम्यूटेशन, कॉम्बिनेशन और पावरसेट्स जनरेट करने के लिए एक कॉम्बिनेटरियल मैथ टूलकिट शामिल है, साथ ही नंबर थ्योरी कैलकुलेशन और मैट्रिक्स ऑपरेशंस के लिए रूटीन भी हैं। यह स्ट्रीम स्टेट मैनेजमेंट के लिए टूल्स भी प्रदान करती है, जिससे यूजर्स आने वाले एलिमेंट्स को देख सकते हैं या डेटा को कैसे कंज्यूम किया जाए, इसे नियंत्रित करने के लिए सीक्वेंस के भीतर सर्च कर सकते हैं। अतिरिक्त क्षमताओं में जटिल सीक्वेंस को चंकिंग, इंटरलीविंग और फ्लैटनिंग करने के लिए डेटा प्रोसेसिंग रूटीन शामिल हैं। इस टूलकिट में इटरेबल प्रॉपर्टीज का विश्लेषण करने और समवर्ती डेटा स्ट्रीम्स को सिंक्रोनाइज़ करने के लिए फंक्शन्स भी शामिल हैं।
Provides capabilities to synchronize and distribute data across multiple simultaneous consumers to prevent race conditions.
Lychee is a command line link checker written in Rust that scans websites and local files to identify broken hyperlinks and invalid email addresses. It functions as an asynchronous link validator and static site auditor designed to ensure content accessibility and quality. The tool features disk-based response caching to accelerate subsequent scans and avoid redundant network requests. It supports token-based API authentication for services like GitHub to bypass rate limits when verifying links on remote repositories. The project covers a range of capabilities including multi-format content
Implements concurrent processing of network requests and file reads via asynchronous streams to maximize validation throughput.