def make_dstream_helper(sc, ssc, test_input):
    """ make dstream from input
    Args:
        test_input: list of lists of input rdd data

    Returns: a dstream

    """
    input_rdds = [sc.parallelize(d, 1) for d in test_input]
    input_stream = ssc.queueStream(input_rdds)
    return input_stream