Package com.leumanuel.woozydata.repository

Class MongoDbConnector

java.lang.Object

com.leumanuel.woozydata.repository.MongoDbConnector

public class MongoDbConnector
extends Object

Connector class for MongoDB operations. Provides methods for reading data from MongoDB collections into DataFrames.

Version:

1.0

Author:

Leu A. Manuel

Constructor Summary

Constructors

Constructor	Description
MongoDbConnector(MongoConfig mongoConfig)	Creates a new MongoDB connector with specified configuration.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the MongoDB connection.
DataFrame	readCollection(String collectionName)	Reads a MongoDB collection into a DataFrame.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MongoDbConnector

public MongoDbConnector(MongoConfig mongoConfig)

Creates a new MongoDB connector with specified configuration.

Parameters:

mongoConfig - MongoDB configuration

Method Details

readCollection

public DataFrame readCollection(String collectionName)

Reads a MongoDB collection into a DataFrame.

Parameters:

collectionName - Name of the collection to read

Returns:

DataFrame containing collection data

close

public void close()

Closes the MongoDB connection. Should be called when the connector is no longer needed.