#include "components/segmentation_platform/internal/execution/processing/sql_feature_processor.h"
#include <utility>
#include "base/containers/flat_map.h"
#include "base/functional/bind.h"
#include "base/memory/weak_ptr.h"
#include "base/task/sequenced_task_runner.h"
#include "components/segmentation_platform/internal/execution/processing/custom_input_processor.h"
#include "components/segmentation_platform/internal/execution/processing/feature_processor_state.h"
#include "components/segmentation_platform/internal/metadata/metadata_utils.h"
#include "components/segmentation_platform/public/proto/model_metadata.pb.h"
#include "components/segmentation_platform/public/types/processed_value.h"
namespace segmentation_platform::processing {
SqlFeatureProcessor::SqlFeatureProcessor(
QueryList&& queries,
base::Time prediction_time,
InputDelegateHolder* input_delegate_holder,
UkmDatabase* ukm_database)
: … { … }
SqlFeatureProcessor::~SqlFeatureProcessor() = default;
void SqlFeatureProcessor::Process(
FeatureProcessorState& feature_processor_state,
QueryProcessorCallback callback) { … }
void SqlFeatureProcessor::OnCustomInputProcessed(
std::unique_ptr<CustomInputProcessor> custom_input_processor,
base::WeakPtr<FeatureProcessorState> feature_processor_state,
base::flat_map<SqlFeatureAndBindValueIndices, Tensor> result) { … }
void SqlFeatureProcessor::OnQueriesRun(
base::WeakPtr<FeatureProcessorState> feature_processor_state,
bool success,
IndexedTensors result) { … }
}