class_docstr: Synchronous Spark worker. This code will be executed on workers.
      
code: def __init__(
      self,
      json,
      parameters,
      train_config,
      master_optimizer,
      master_loss,
      master_metrics,
      custom_objects,
  ):
      self.json = json
      self.parameters = parameters
      self.train_config = train_config
      self.master_optimizer = master_optimizer
      self.master_loss = master_loss
      self.master_metrics = master_metrics
      self.custom_objects = custom_objects
      self.model = None
  
file_path: elephas/elephas/worker.py
imports: import numpy
  from itertools import tee
  from tensorflow.keras.models import model_from_json
  from tensorflow.keras.optimizers import get
  from tensorflow.python.keras.utils.generic_utils import slice_arrays
  from .utils import subtract_params
  from .parameter import BaseParameterClient
label_desc: Use image node_id 1 to create a new SparkWorker object from inherited base classes: object with example: obj = SparkWorker(json, parameters, train_config, master_optimizer, master_loss, master_metrics, custom_objects)