Boilerplate U-SQL User Defined Extractor

gistfile1.txt

public override IEnumerable<IRow> Extract(IUnstructuredReader input, IUpdatableRow output)
{
	string line;
		 
	//Read the input line by line
	foreach (Stream current in input.Split(_row_delim))
	{
		using (StreamReader streamReader = new StreamReader(current, this._encoding))
		{
			line = streamReader.ReadToEnd().Trim();
			LogRowParser splitter = new LogRowParser();
			LogRowElements parts = new LogRowElements();
			parts = splitter.ParseElements(line);
		 
			// ... 
		 
			yield return output.AsReadOnly();
		}
	}
}