class Multiwoven::Integrations::Source::Sftp::Client

def group_by_table(records)
  result = {}
  records.each_with_index do |column, index|
    table_name = @remote_file_path
    column_data = {
      column_name: column,
      type: "string",
      optional: true
    }
    result[index] ||= {}
    result[index][:tablename] = table_name
    result[index][:columns] = [column_data]
  end
  result
end