def init_context(self): self.base_hostname = socket.gethostname().split(".")[0] master_node = 'spark://' + self.base_hostname + ':7077' self.context = SparkContext(master_node, 'INFO')