def get_rows():
    line = input("Enter a row (python dict) into the table: ")
    while line:
        yield ast.literal_eval(line)
        line = input("Enter another row into the table \n" +
                     "[hit enter to stop]: ")
# [END run]


# [START main]
dataset/ETHPy150Open GoogleCloudPlatform/python-docs-samples/bigquery/api/streaming.py/get_rows/original