class Multiwoven::Integrations::Destination::DatabricksLakehouse::Client

def create_streams(records)
  message = []
  group_by_table(records).each_value do |r|
    message << Multiwoven::Integrations::Protocol::Stream.new(name: r[:tablename], action: StreamAction["fetch"], json_schema: convert_to_json_schema(r[:columns]))
  end
  message
end