Bump the Arcane.Framework version (#14)

SneaksAndData · Oct 2, 2024 · 945c943 · 945c943
1 parent 07105f4
commit 945c943
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 1 deletion.
diff --git a/src/Arcane.Stream.SqlServer.csproj b/src/Arcane.Stream.SqlServer.csproj
@@ -5,7 +5,7 @@
         <TargetFramework>net8.0</TargetFramework>
     </PropertyGroup>
     <ItemGroup>
-        <PackageReference Include="Arcane.Framework" Version="0.0.29" />
+        <PackageReference Include="Arcane.Framework" Version="0.0.30" />
     </ItemGroup>
 
 </Project>
diff --git a/src/Models/SqlServerStreamContext.cs b/src/Models/SqlServerStreamContext.cs
@@ -1,4 +1,6 @@
 using System;
+using System.Text.Json.Serialization;
+using Arcane.Framework.Configuration;
 using Arcane.Framework.Services.Base;
 
 namespace Arcane.Stream.SqlServer.Models;
@@ -28,8 +30,16 @@ public class SqlServerStreamContext : IStreamContext, IStreamContextWriter
     /// <summary>
     /// Max time to wait for rowsPerGroup to accumulate.
     /// </summary>
+    [JsonConverter(typeof(SecondsToTimeSpanConverter))]
+    [JsonPropertyName("groupingIntervalSeconds")]
     public TimeSpan GroupingInterval { get; set; }
 
+    /// <summary>
+    /// How long to wait before polling for next result set.
+    /// </summary>
+    [JsonPropertyName("changeCaptureIntervalSeconds")]
+    public int ChangeCaptureIntervalSeconds { get; set; }
+
     /// <summary>
     /// Number of row groups per file.
     /// </summary>

diff --git a/src/Services/SqlServerGraphBuilder.cs b/src/Services/SqlServerGraphBuilder.cs
@@ -34,6 +34,7 @@ ILogger<SqlServerGraphBuilder> logger
             var source = SqlServerSource.Create(context.ConnectionString,
                 context.Schema,
                 context.Table,
+                TimeSpan.FromSeconds(context.ChangeCaptureIntervalSeconds),
                 context.CommandTimeout);
 
             var schema = source.GetParquetSchema();