Skip to content

Commit 3c1bc04

Browse files
Fix incorrect sourcing of maxRowsPerFile (#128)
1 parent 1b01c0a commit 3c1bc04

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

src/main/scala/models/app/MicrosoftSynapseLinkStreamContext.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ case class MicrosoftSynapseLinkStreamContext(spec: StreamSpec) extends StreamCon
129129
override val baseLocation: String = spec.sourceSettings.baseLocation
130130
override val changeCaptureIntervalSeconds: Int = spec.sourceSettings.changeCaptureIntervalSeconds
131131

132-
override val maxRowsPerFile: Option[Int] = Some(spec.maxRowsPerFile)
132+
override val maxRowsPerFile: Option[Int] = Some(spec.stagingDataSettings.maxRowsPerFile)
133133

134134
private def parseBackfillStartDate(str: String): Option[OffsetDateTime] =
135135
val formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH.mm.ss'Z'").withZone(ZoneOffset.UTC)

src/main/scala/models/app/contracts/StreamSpec.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -74,9 +74,6 @@ case class FieldSelectionRuleSpec(ruleType: String, fields: Array[String]) deriv
7474
* @param lookBackInterval The look back interval in seconds
7575
*/
7676
case class StreamSpec(sourceSettings: SourceSettings,
77-
78-
// Staging settings
79-
maxRowsPerFile: Int,
8077

8178
// Grouping settings
8279
rowsPerGroup: Int,

0 commit comments

Comments
 (0)