Skip to content

Commit 846f41f

Browse files
committed
odpstable-fix-#820 : adjust the cases order for odps table
1 parent df527ce commit 846f41f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/za/co/absa/spline/harvester/plugin/embedded/DataSourceV2Plugin.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -163,9 +163,9 @@ class DataSourceV2Plugin
163163
val pathUris = paths.map(prependFileSchemaIfMissing)
164164
SourceIdentifier(Some(format), pathUris: _*)
165165

166-
case `_: TableV2`(tv2) => extractSourceIdFromDeltaTableV2(tv2)
167-
168166
case `_: OdpsTable`(ot) => SourceIdentifier(Some("odpstable"),s"odpstable:${extractValue[String](ot,"name")}")
167+
168+
case `_: TableV2`(tv2) => extractSourceIdFromDeltaTableV2(tv2)
169169
}
170170

171171
private def extractSourceIdFromDeltaTableV2(table: AnyRef): SourceIdentifier = {

0 commit comments

Comments
 (0)