Statistics: Expanded ForceTraversalOperations scheme, add CreatedAt (#8194)

Author: andrewstalin

ydb/core/statistics/aggregator/aggregator_impl.h

@@ -379,6 +379,7 @@ class TStatisticsAggregator : public TActor<TStatisticsAggregator>, public NTabl
         std::vector<TForceTraversalTable> Tables;
         TString Types;
         TActorId ReplyToActorId;
+        TInstant CreatedAt;
     };
     std::list<TForceTraversalOperation> ForceTraversals;
 

ydb/core/statistics/aggregator/schema.h

@@ -51,11 +51,13 @@ struct TAggregatorSchema : NIceDb::Schema {
     struct ForceTraversalOperations : Table<6> {
         struct OperationId    : Column<1, NScheme::NTypeIds::String> {};
         struct Types          : Column<2, NScheme::NTypeIds::String> {};
+        struct CreatedAt      : Column<3, NScheme::NTypeIds::Uint64> {};
 
         using TKey = TableKey<OperationId>;
         using TColumns = TableColumns<
             OperationId,
-            Types
+            Types,
+            CreatedAt
         >;
     };
 

ydb/core/statistics/aggregator/tx_analyze.cpp

@@ -18,7 +18,7 @@ struct TStatisticsAggregator::TTxAnalyze : public TTxBase {
 
     TTxType GetTxType() const override { return TXTYPE_ANALYZE_TABLE; }
 
-    bool Execute(TTransactionContext& txc, const TActorContext&) override {
+    bool Execute(TTransactionContext& txc, const TActorContext& ctx) override {
         SA_LOG_D("[" << Self->TabletID() << "] TTxAnalyze::Execute. ReplyToActorId " << ReplyToActorId << " , Record " << Record);
 
         if (!Self->EnableColumnStatistics) {
@@ -48,11 +48,13 @@ struct TStatisticsAggregator::TTxAnalyze : public TTxBase {
         const TString types = JoinVectorIntoString(TVector<ui32>(Record.GetTypes().begin(), Record.GetTypes().end()), ",");
 
         // create new force trasersal
+        auto createdAt = ctx.Now();
         TForceTraversalOperation operation {
             .OperationId = operationId,
             .Tables = {},
             .Types = types,
-            .ReplyToActorId = ReplyToActorId
+            .ReplyToActorId = ReplyToActorId,
+            .CreatedAt = createdAt
         };
 
         for (const auto& table : Record.GetTables()) {
@@ -79,11 +81,12 @@ struct TStatisticsAggregator::TTxAnalyze : public TTxBase {
             );
         }
 
-        Self->ForceTraversals.emplace_back(operation);        
+        Self->ForceTraversals.emplace_back(operation);
 
         db.Table<Schema::ForceTraversalOperations>().Key(operationId).Update(
             NIceDb::TUpdate<Schema::ForceTraversalOperations::OperationId>(operationId),
-            NIceDb::TUpdate<Schema::ForceTraversalOperations::Types>(types)
+            NIceDb::TUpdate<Schema::ForceTraversalOperations::Types>(types),
+            NIceDb::TUpdate<Schema::ForceTraversalOperations::CreatedAt>(createdAt.GetValue())
         );
 
         return true;

ydb/core/statistics/aggregator/tx_init.cpp

@@ -194,12 +194,14 @@ struct TStatisticsAggregator::TTxInit : public TTxBase {
             while (!rowset.EndOfSet()) {
                 TString operationId = rowset.GetValue<Schema::ForceTraversalOperations::OperationId>();
                 TString types = rowset.GetValue<Schema::ForceTraversalOperations::Types>();
+                ui64 createdAt = rowset.GetValue<Schema::ForceTraversalOperations::CreatedAt>();
 
                 TForceTraversalOperation operation {
                     .OperationId = operationId,
                     .Tables = {},
                     .Types = types,
-                    .ReplyToActorId = {}
+                    .ReplyToActorId = {},
+                    .CreatedAt = TInstant::FromValue(createdAt)
                 };
                 Self->ForceTraversals.emplace_back(operation);