Java MongoDB Hadoop Connector是否有C#等效项

本文关键字：是否 MongoDB Hadoop Connector Java | 更新日期: 2023-09-27 17:56:04

我正在玩Mobius（Spark的C#语言绑定）和MongoDB的C#驱动程序。我的目标是使用 MongoDB 作为我的 C# 应用程序中 Spark 查询的输入/输出。我知道有一个Java MongoDB Hadoop Connector，但我想继续使用Mobius来编写我的Spark查询。

您可以在Mobius中使用MongoDB Spark Connector和DataFrame API来查询MongoDB。加载数据的代码如下所示

var mongoDbDataFrame = sqlContext.Read.Format("com.mongodb.spark.sql").Load()

加载数据后，您可以在数据帧上执行 Select（）、Filter（）操作。还可以将数据帧注册为 TempTable，以便使用以下代码模板使用 SQL 查询

mongoDbDataFrame.RegisterTempTable("MongDbDataFrameTempTable")
sqlContext.Sql("SELECT <columns> FROM MongDbDataFrameTempTable WHERE <condition>")

请注意，您需要在类路径中包含连接器及其依赖项，并且可以使用"--jars"参数。