case class NetworkManager(numTasks: Int, driverServerSocket: ServerSocket, host: String, port: Int, timeout: Double, useBarrierExecutionMode: Boolean) extends Logging with Product with Serializable

Object to encapsulate all Spark/LightGBM network topology information, along with operations on the network.

Linear Supertypes
Serializable, Serializable, Product, Equals, Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NetworkManager
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. Logging
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new NetworkManager(numTasks: Int, driverServerSocket: ServerSocket, host: String, port: Int, timeout: Double, useBarrierExecutionMode: Boolean)

Value Members

  1. def closeConnections(): Unit
  2. val driverServerSocket: ServerSocket
  3. val host: String
  4. lazy val networkTopologyAsString: String
  5. val numTasks: Int
  6. lazy val partitionsByExecutorAsString: String
  7. val port: Int
  8. def sendDataToExecutors(lightGBMNetworkTopology: String, partitionsByExecutor: String): Unit
  9. val timeout: Double
  10. val useBarrierExecutionMode: Boolean
  11. def waitForAllTasksToReport(): Unit
  12. def waitForNetworkCommunicationsDone(): Unit