Source code for ssp.spark.streaming.consumer

import socket
import gin
from ssp.spark.streaming.consumer.twiteer_stream_consumer import TwitterDataset

@gin.configurable
def get_local_spark_master():
    return "spark://" + socket.gethostname() + ":7077"