CurtHagenlocher

(tableType as type, fn as function) =>
let
    TransformNode = (x) => Record.FromList(List.Transform(Record.FieldValues(x), TransformValue), Record.FieldNames(x)),
    TransformValue = (x) => if x is record then TransformRecord(x) else if x is list then TransformList(x) else x,
    TransformList = (x) => List.Transform(x, TransformValue),
    TransformRecord = (x) => 
        if x = RowExpression.Row then [Kind="Row"]
        else if x[Kind] = "Constant" then TransformConstant(x)
        else TransformNode(x),
    TransformConstant = (x) => if x[Value] is function and TryFunctionName(x[Value]) <> null then [Kind="Identifier", Name=TryFunctionName(x[Value])]

CurtHagenlocher

let
    Web.MultiPartPost = (url as text, parts as record) as binary =>
        let
            unique = Text.NewGuid(),
            boundary = "--" & unique,
            crlf = "#(cr)#(lf)",
            item = (name, value) =>
                let
                    filename = Value.Metadata(value)[name]?,
                    contentType = Value.Metadata(value)[type]?,

CurtHagenlocher

section Section1;

// Does a short search on Wikipedia. This is meant to stand in for a function that returns the navigation data.
GetWikipediaSearch = (term) => Json.Document(Web.Contents("https://en.wikipedia.org/w/api.php", [Query=[
    action="query",
    origin="*",
    format="json",
    generator="search",
    gsrnamespace="0",
    gsrlimit="5",

CurtHagenlocher

let
    Value.WaitFor = (producer as function, interval as function, optional count as number) as any =>
        let
            list = List.Generate(
                () => {0, null},
                (state) => state{0} <> null and (count = null or state{0} < count),
                (state) => if state{1} <> null
                    then {null, state{1}}
                    else {1 + state{0}, Function.InvokeAfter(() => producer(state{0}), interval(state{0}))},
                (state) => state{1})

CurtHagenlocher

using Apache.Arrow;
using Apache.Arrow.Types;
using Microsoft.Data.SqlClient;
using System.Data.Common;
using System.Data.SqlTypes;

namespace Loader
{
    internal class Program
    {