refactored and added support for setting up streaming logs
refactored and added support for setting up streaming logs

GoogleCloudPlatform/processing-logs-using-dataflow,GoogleCloudPlatform/processing-logs-using-dataflow,GoogleCloudPlatform/processing-logs-using-dataflow