Boilerplate U-SQL User Defined Extractor
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(); | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment