in src/loaders/io-loader.ts [11:26]
export function getInputConnector(
type: InputType,
config: any
): InputConnector {
switch (type) {
case InputType.sql: {
return new SQLInputConnnector(config);
}
case InputType.json: {
return new JSONInputConnector(config);
}
default: {
throw new Error('Invalid input type');
}
}
}