Java 8 তে Streams API পরিচিতি পাওয়ার পর থেকে ডেটা প্রসেসিং এবং কোলেকশন পরিচালনায় বিশাল উন্নতি এসেছে। Streams API একটি খুব শক্তিশালী ফিচার যা ডেটা ফিল্টার, ম্যাপ, রিডিউস এবং অন্যান্য কার্যক্রম খুবই সহজে এবং কার্যকরভাবে পরিচালনা করতে সহায়ক। MongoDB, একটি জনপ্রিয় NoSQL ডেটাবেস, Java 8 Streams API এর সাথে ইন্টিগ্রেশন সমর্থন করে, যা ডেটাবেসের ডেটা প্রসেসিং আরও শক্তিশালী এবং কার্যকর করে তোলে।
MongoDB এবং Java 8 Streams API ইন্টিগ্রেশন ব্যবহার করে, আপনি MongoDB থেকে ডেটা সংগ্রহ করতে পারেন এবং সেই ডেটার ওপর Streams API ব্যবহার করে প্রয়োজনীয় প্রক্রিয়া সম্পাদন করতে পারেন।
Java 8 Streams API Overview
Java 8 Streams API একটি নতুন প্রোগ্রামিং প্যারাডাইম প্রদান করে যা ডেটা পিপলাইনের মতো কাজ করে, যেখানে আপনি ডেটা ফিল্টার, ম্যাপ, রিডিউস, গ্রুপিং ইত্যাদি ক্রিয়া সম্পাদন করতে পারেন। Streams API ডেটা ইটারেটর হিসেবে কাজ করে এবং বিভিন্ন ধরণের কার্যক্রম একত্রিত করে থাকে যা ডেটা পরিচালনাকে আরও সহজ করে তোলে।
এটি functional programming এর ধারণার ওপর ভিত্তি করে তৈরি এবং ল্যাম্বডা এক্সপ্রেশন এর সাথে খুব ভালোভাবে কাজ করে। Streams API সিঙ্ক্রোনাস এবং অ্যাসিঙ্ক্রোনাস অপারেশন সমর্থন করে এবং পারফরম্যান্স উন্নত করতে সাহায্য করে।
MongoDB Streams API Integration
MongoDB Java Driver এর মাধ্যমে MongoDB ডেটাবেস থেকে ডেটা বের করে Java 8 Streams API ব্যবহার করা যেতে পারে। MongoDB ডেটাবেস থেকে ডেটা নিয়ে এসে তা স্ট্রিম হিসেবে প্রসেস করতে এবং বিভিন্ন ফিল্টারিং, ম্যাপিং, এবং রিডিউস অপারেশন চালানো যায়।
১. MongoDB Java Driver এবং Streams API ইনস্টলেশন
MongoDB এবং Java Streams API ব্যবহার করার জন্য MongoDB Java Driver এর প্রয়োজন হয়, যা Maven বা Gradle এর মাধ্যমে প্রজেক্টে যোগ করা যাবে।
Maven Dependency:
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>4.4.0</version>
</dependency>
Gradle Dependency:
implementation 'org.mongodb:mongo-java-driver:4.4.0'
২. MongoDB তে ডেটা সংগ্রহ করা
MongoDB থেকে ডেটা সংগ্রহ করার জন্য MongoCollection ব্যবহার করা হয়। Java 8 Streams API এর সাথে MongoDB ডেটা সংগ্রহের পরে, স্ট্রিম ব্যবহার করে ডেটা প্রসেস করা যায়।
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase database = mongoClient.getDatabase("test");
MongoCollection<Document> collection = database.getCollection("users");
// MongoDB থেকে ডেটা সংগ্রহ
List<Document> documents = collection.find().into(new ArrayList<>());
এখানে, MongoDB এর users কোলেকশন থেকে সমস্ত ডেটা সংগ্রহ করা হচ্ছে।
৩. Java 8 Streams API ব্যবহার করে ডেটা প্রসেস করা
MongoDB থেকে ডেটা সংগ্রহের পরে, Java 8 Streams API ব্যবহার করে সেই ডেটার উপর বিভিন্ন ফিল্টার, ম্যাপ এবং রিডিউস অপারেশন করা যেতে পারে।
import java.util.List;
import java.util.stream.Collectors;
List<String> names = documents.stream()
.filter(doc -> doc.getInteger("age") > 18) // বয়স ১৮ এর বেশি এমন ডেটা ফিল্টার করা
.map(doc -> doc.getString("name")) // শুধু নামের তথ্য নেওয়া
.collect(Collectors.toList()); // লিস্টে সংগ্রহ করা
names.forEach(System.out::println); // ফলাফল প্রিন্ট করা
এখানে, MongoDB থেকে age এর ভিত্তিতে ফিল্টার করা হয়েছে এবং এরপর নাম (name) ফিল্টার করে একটি নতুন লিস্টে সংগ্রহ করা হয়েছে।
৪. Parallel Stream ব্যবহার
Java 8 এর Streams API পারালাল প্রসেসিং সমর্থন করে, যার মাধ্যমে ডেটা প্রসেসিং দ্রুত করা যায়, বিশেষ করে বড় ডেটাসেটের ক্ষেত্রে।
List<String> parallelNames = documents.parallelStream()
.filter(doc -> doc.getInteger("age") > 18)
.map(doc -> doc.getString("name"))
.collect(Collectors.toList());
parallelNames.forEach(System.out::println);
এখানে, parallelStream() ব্যবহার করা হয়েছে যা ডেটাকে পারালালভাবে প্রসেস করতে সক্ষম, যার ফলে পারফরম্যান্স উন্নত হয়।
৫. Aggregation ব্যবহার করে আরও উন্নত অপারেশন
MongoDB তে আরও জটিল অপারেশন যেমন গ্রুপিং, ফিল্টারিং এবং রিডাকশন করতে MongoDB Aggregation Framework ব্যবহার করা যেতে পারে, এবং তার সাথে Streams API ব্যবহার করলে আরও শক্তিশালী ফলাফল পাওয়া যাবে।
List<Document> aggregatedResults = collection.aggregate(Arrays.asList(
Aggregates.group("$age", Accumulators.sum("total", 1)),
Aggregates.sort(Sorts.ascending("_id"))
)).into(new ArrayList<>());
aggregatedResults.stream()
.map(doc -> "Age: " + doc.get("_id") + ", Total: " + doc.get("total"))
.forEach(System.out::println);
এখানে, MongoDB এর Aggregation Framework ব্যবহার করে বয়সের ভিত্তিতে গ্রুপিং করা হয়েছে এবং সেই ফলাফলকে স্ট্রিমে নিয়ে ফরম্যাট করে প্রিন্ট করা হয়েছে।
Java 8 Streams API এবং MongoDB এর ইন্টিগ্রেশন ডেটা প্রসেসিং এর জন্য একটি শক্তিশালী টুল। MongoDB Java Driver ব্যবহার করে ডেটা সংগ্রহ এবং Java 8 Streams API ব্যবহার করে ফিল্টার, ম্যাপ এবং রিডিউস অপারেশন করা সহজ এবং কার্যকরী। এটি ডেটার সাথে কাজ করার জন্য আরও কার্যকরী এবং পারফরম্যান্স উন্নত করতে সহায়ক, বিশেষ করে বড় ডেটাসেটের ক্ষেত্রে। MongoDB তে ডেটা সংগ্রহ করে, Java Streams API এর সাথে সমন্বয় করে আপনি জটিল ডেটা প্রসেসিং টাস্কগুলো আরও সহজভাবে সম্পাদন করতে পারবেন।
Read more
