rezataroosheh commented on code in PR #7989:
URL: https://github.com/apache/ignite-3/pull/7989#discussion_r3158612368
##########
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTests.cs:
##########
@@ -140,6 +140,33 @@ public async Task TestBroadcastAllNodes()
Assert.AreEqual(nodes[3].Name + "123", await
res4.GetResultAsync());
}
+ [Test]
+ public async Task TestBroadcastTable()
+ {
+ var table = await Client.Tables.GetTableAsync(TableName);
+ var partitions = await
table!.PartitionDistribution.GetPartitionsAsync();
+ var partitionIds = partitions.Select(p => p.Id).Order();
+
+ IBroadcastExecution<long> broadcastExecution = await
Client.Compute.SubmitBroadcastAsync(
+ BroadcastJobTarget.Table(TableName),
+ GetPartitionJob,
+ null);
+
+ long[] taskResults = await Task
+ .WhenAll(broadcastExecution.JobExecutions.Select(x =>
x.GetResultAsync()));
+
+ Assert.AreEqual(partitionIds, taskResults.Order());
+ }
+
+ [Test]
+ public void TestBroadcastTableOverloads()
+ {
+ var target1 = BroadcastJobTarget.Table(TableName);
+ var target2 =
BroadcastJobTarget.Table(QualifiedName.Parse(TableName));
+ Assert.AreEqual(target1.Data.ObjectName, target2.Data.ObjectName);
+ Assert.AreEqual(target1.Data.ObjectName, target2.Data.ObjectName);
Review Comment:
@ptupitsyn I removed this method as part of the requested change, so this
comment is no longer relevant. Marked as resolved. Let me know if anything is
missing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
