Skip to content

Commit

Permalink
Merge pull request #352 from atlanhq/temp
Browse files Browse the repository at this point in the history
Temporary fix
  • Loading branch information
cmgrote authored Nov 28, 2023
2 parents 3daa594 + a8282b2 commit eec52ca
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ package com.atlan.pkg.rab

import com.atlan.model.assets.Asset
import com.atlan.model.assets.Column
import com.atlan.model.enums.AtlanConnectorType
import com.atlan.model.fields.AtlanField
import com.atlan.pkg.serde.RowDeserializer
import mu.KotlinLogging
Expand Down Expand Up @@ -50,5 +51,6 @@ class ColumnImporter(
val parentQN = "$connectionQN/${qnDetails.parentPartialQN}"
val parentType = preprocessed.entityQualifiedNameToType[qnDetails.parentUniqueQN]
return Column.creator(name, parentType, parentQN, order)
.connectorType(AtlanConnectorType.AZURE_ANALYSIS_SERVICES)
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ package com.atlan.pkg.rab

import com.atlan.model.assets.Asset
import com.atlan.model.assets.Database
import com.atlan.model.enums.AtlanConnectorType
import com.atlan.model.fields.AtlanField
import com.atlan.pkg.serde.RowDeserializer
import mu.KotlinLogging
Expand Down Expand Up @@ -43,5 +44,6 @@ class DatabaseImporter(
val qnDetails = getQualifiedNameDetails(deserializer.row, deserializer.heading, typeNameFilter)
return Database.creator(name, connectionQN)
.schemaCount(preprocessed.qualifiedNameToChildCount[qnDetails.uniqueQN]?.toInt())
.connectorType(AtlanConnectorType.AZURE_ANALYSIS_SERVICES)
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ package com.atlan.pkg.rab

import com.atlan.model.assets.Asset
import com.atlan.model.assets.Schema
import com.atlan.model.enums.AtlanConnectorType
import com.atlan.model.fields.AtlanField
import com.atlan.pkg.serde.RowDeserializer
import mu.KotlinLogging
Expand Down Expand Up @@ -45,5 +46,6 @@ class SchemaImporter(
return Schema.creator(name, databaseQN)
.tableCount(preprocessed.qualifiedNameToTableCount[qnDetails.uniqueQN]?.toInt())
.viewCount(preprocessed.qualifiedNameToViewCount[qnDetails.uniqueQN]?.toInt())
.connectorType(AtlanConnectorType.AZURE_ANALYSIS_SERVICES)
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ package com.atlan.pkg.rab

import com.atlan.model.assets.Asset
import com.atlan.model.assets.Table
import com.atlan.model.enums.AtlanConnectorType
import com.atlan.model.fields.AtlanField
import com.atlan.pkg.serde.RowDeserializer
import mu.KotlinLogging
Expand Down Expand Up @@ -44,5 +45,6 @@ class TableImporter(
val schemaQN = "$connectionQN/${qnDetails.parentPartialQN}"
return Table.creator(name, schemaQN)
.columnCount(preprocessed.qualifiedNameToChildCount[qnDetails.uniqueQN]?.toLong())
.connectorType(AtlanConnectorType.AZURE_ANALYSIS_SERVICES)
}
}

0 comments on commit eec52ca

Please sign in to comment.