Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
suhsteve committed Apr 9, 2021
1 parent b25c3d4 commit 753f85c
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/csharp/Microsoft.Spark/RDD.cs
Original file line number Diff line number Diff line change
Expand Up @@ -298,12 +298,11 @@ internal virtual RDD<U> MapPartitionsWithIndexInternal<U>(
private (int, string) CollectAndServe()
{
JvmObjectReference rddRef = GetJvmRef();
object result = rddRef.Jvm.CallStaticJavaMethod(
var pair = (JvmObjectReference[])rddRef.Jvm.CallStaticJavaMethod(
"org.apache.spark.api.python.PythonRDD",
"collectAndServe",
rddRef.Invoke("rdd"));

var pair = (JvmObjectReference[])result;
return ((int)pair[0].Invoke("intValue"), (string)pair[1].Invoke("toString"));
}

Expand Down

0 comments on commit 753f85c

Please sign in to comment.