Skip to content

Commit

Permalink
fix conflict
Browse files Browse the repository at this point in the history
Signed-off-by: Murphy <[email protected]>
  • Loading branch information
murphyatwork committed Sep 18, 2024
1 parent 1bc3de2 commit f165d5a
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,22 +81,22 @@ public void triggerOnLoad() throws Exception {
InsertTxnCommitAttachment attachment = new InsertTxnCommitAttachment(1, 5);
transactionState.setTxnCommitAttachment(attachment);
StatisticsCollectionTrigger trigger =
StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true);
StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true, true);
Assert.assertEquals(null, trigger.getAnalyzeType());
}
{
InsertTxnCommitAttachment attachment = new InsertTxnCommitAttachment(1000, 5);
transactionState.setTxnCommitAttachment(attachment);
StatisticsCollectionTrigger trigger =
StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true);
StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true, true);
Assert.assertEquals(StatsConstants.AnalyzeType.FULL, trigger.getAnalyzeType());
}

{
InsertTxnCommitAttachment attachment = new InsertTxnCommitAttachment(1000000, 5);
transactionState.setTxnCommitAttachment(attachment);
StatisticsCollectionTrigger trigger =
StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true);
StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true, true);
Assert.assertEquals(StatsConstants.AnalyzeType.SAMPLE, trigger.getAnalyzeType());
}
}
Expand Down Expand Up @@ -128,7 +128,7 @@ public void triggerOnInsertOverwrite() throws Exception {
{
InsertOverwriteJobStats stats = new InsertOverwriteJobStats(
List.of(sourceId), List.of(targetId), 1000, 1001);
StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true);
StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true, true);
Partition targetPartition = new Partition(targetId, "p1", null, null);
Map<Long, Optional<Long>> tableStats =
storage.getTableStatistics(table.getId(), List.of(targetPartition));
Expand All @@ -140,7 +140,7 @@ public void triggerOnInsertOverwrite() throws Exception {
InsertOverwriteJobStats stats = new InsertOverwriteJobStats(
List.of(sourceId), List.of(targetId), 1000, 50000);
StatisticsCollectionTrigger trigger =
StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true);
StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true, true);
Assert.assertEquals(StatsConstants.AnalyzeType.FULL, trigger.getAnalyzeType());
}

Expand All @@ -149,7 +149,7 @@ public void triggerOnInsertOverwrite() throws Exception {
InsertOverwriteJobStats stats = new InsertOverwriteJobStats(
List.of(sourceId), List.of(targetId), 1000, 50000000);
StatisticsCollectionTrigger trigger =
StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true);
StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true, true);
Assert.assertEquals(StatsConstants.AnalyzeType.SAMPLE, trigger.getAnalyzeType());
}
}
Expand Down

0 comments on commit f165d5a

Please sign in to comment.