Skip to content
Open
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ We welcome contributions! Please review our [contribution guide](CONTRIBUTING.md

This project would not have been possible without the outstanding work from the following communities:

- [Apache Spark](https://spark.apache.org/): Unified Analytics Engine for Big Data, the underlying backend execution engine for .NET for Apache Spark
- [Apache Spark](https://spark.apache.org/): Unified Analytics Engine for Big Data, the underlying back-end execution engine for .NET for Apache Spark
- [Mobius](https://github.com/Microsoft/Mobius): C# and F# language binding and extensions to Apache Spark, a pre-cursor project to .NET for Apache Spark from the same Microsoft group.
- [PySpark](https://spark.apache.org/docs/latest/api/python/index.html): Python bindings for Apache Spark, one of the implementations .NET for Apache Spark derives inspiration from.
- [sparkR](https://spark.apache.org/docs/latest/sparkr.html): one of the implementations .NET for Apache Spark derives inspiration from.
Expand Down
2 changes: 1 addition & 1 deletion deployment/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ Deploying your App on the Cloud
```

# Preparing Worker Dependencies
Microsoft.Spark.Worker is a backend component that lives on the individual worker nodes of your Spark cluster. When you want to execute a C# UDF (user-defined function), Spark needs to understand how to launch the .NET CLR to execute this UDF. Microsoft.Spark.Worker provides a collection of classes to Spark that enable this functionality.
Microsoft.Spark.Worker is a back-end component that lives on the individual worker nodes of your Spark cluster. When you want to execute a C# UDF (user-defined function), Spark needs to understand how to launch the .NET CLR to execute this UDF. Microsoft.Spark.Worker provides a collection of classes to Spark that enable this functionality.

## Microsoft.Spark.Worker
1. Select a [Microsoft.Spark.Worker](https://github.com/dotnet/spark/releases) Linux netcoreapp release to be deployed on your cluster.
Expand Down
2 changes: 1 addition & 1 deletion docs/developer-guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ spark-submit \
and you will see the followng output:
```
***********************************************************************
* .NET Backend running debug mode. Press enter to exit *
* .NET back end running debug mode. Press enter to exit *
***********************************************************************
```
In this debug mode, `DotnetRunner` does not launch the .NET application, but waits for it to connect. Leave this command prompt window open.
Expand Down
2 changes: 1 addition & 1 deletion src/csharp/Microsoft.Spark.E2ETest/SparkFixture.cs
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ public SparkFixture()
// Scala-side driver for .NET emits the following message after it is
// launched and ready to accept connections.
if (!isSparkReady &&
arguments.Data.Contains("Backend running debug mode"))
arguments.Data.Contains("back end running debug mode"))
{
isSparkReady = true;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ namespace Microsoft.Spark.Services
{
/// <summary>
/// Implementation of configuration service that helps getting config settings
/// to be used in .NET backend.
/// to be used in .NET back end.
/// </summary>
internal sealed class ConfigurationService : IConfigurationService
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ namespace Microsoft.Spark.Services
internal interface IConfigurationService
{
/// <summary>
/// The port number used for communicating with the .NET backend process.
/// The port number used for communicating with the .NET back-end process.
/// </summary>
int GetBackendPortNumber();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ object DotnetRunner extends Logging {
val dotnetBackendThread = new Thread("DotnetBackend") {
override def run() {
// need to get back dotnetBackendPortNumber because if the value passed to init is 0
// the port number is dynamically assigned in the backend
// the port number is dynamically assigned in the back end
dotnetBackendPortNumber = dotnetBackend.init(dotnetBackendPortNumber)
logInfo(s"Port number used by DotnetBackend is $dotnetBackendPortNumber")
initialized.release()
Expand Down Expand Up @@ -147,7 +147,7 @@ object DotnetRunner extends Logging {
} else {
// scalastyle:off println
println("***********************************************************************")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

println("* .NET Backend running debug mode. Press enter to exit *")
println("* .NET back end running debug mode. Press enter to exit *")
println("***********************************************************************")
// scalastyle:on println

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ object DotnetRunner extends Logging {
val dotnetBackendThread = new Thread("DotnetBackend") {
override def run() {
// need to get back dotnetBackendPortNumber because if the value passed to init is 0
// the port number is dynamically assigned in the backend
// the port number is dynamically assigned in the back end
dotnetBackendPortNumber = dotnetBackend.init(dotnetBackendPortNumber)
logInfo(s"Port number used by DotnetBackend is $dotnetBackendPortNumber")
initialized.release()
Expand Down Expand Up @@ -147,7 +147,7 @@ object DotnetRunner extends Logging {
} else {
// scalastyle:off println
println("***********************************************************************")
println("* .NET Backend running debug mode. Press enter to exit *")
println("* .NET back end running debug mode. Press enter to exit *")
println("***********************************************************************")
// scalastyle:on println

Expand Down