Path Lines of Code abtest/abtest.go 42 algorithm/algorithm.go 154 algorithm/eas/client.go 95 algorithm/eas/easyrec/easyrec_predict.pb.go 2947 algorithm/eas/easyrec/easyrec_predict.proto 228 algorithm/eas/easyrec/easyrec_request_builder.go 512 algorithm/eas/easyrec_request.go 62 algorithm/eas/easyrec_response.go 546 algorithm/eas/fm_request.go 62 algorithm/eas/fm_response.go 47 algorithm/eas/fm_response_easyjson.go 148 algorithm/eas/http_easyrec_request.go 76 algorithm/eas/lincub_request.go 57 algorithm/eas/lincub_response.go 43 algorithm/eas/model.go 191 algorithm/eas/pmml_request.go 42 algorithm/eas/pmml_response.go 42 algorithm/eas/tf_request.go 57 algorithm/eas/tf_response.go 86 algorithm/eas/tfserving_request.go 37 algorithm/eas/tfserving_response.go 34 algorithm/faiss/model.go 24 algorithm/faiss/pai_web/vectorretrieval.pb.go 183 algorithm/faiss/vector_client.go 34 algorithm/faiss/vectorretrieval.proto 15 algorithm/lookup.go 42 algorithm/milvus/model.go 35 algorithm/milvus/request.go 38 algorithm/response/resonse.go 10 algorithm/seldon/client.go 26 algorithm/seldon/model.go 24 algorithm/seldon/request.go 67 algorithm/seldon/response.go 53 algorithm/tfserving/client.go 94 algorithm/tfserving/model.go 46 algorithm/tfserving/predict.go 74 algorithm/tfserving/response.go 32 app.go 81 callback_hook.go 53 commands/app/options/config.go 16 commands/app/server.go 43 commands/commands/project.go 82 commands/commands/project_data.go 298 commands/log/log.go 13 commands/main.go 16 config/app.go 11 config/config.go 26 config/json.go 136 config/pairec_config/pairec_config.go 104 configloader.go 141 constants/common.go 12 context/context.go 14 context/recommend_context.go 90 controller.go 129 datasource/beengine/be.go 59 datasource/datahub/akless.go 33 datasource/datahub/datahub.go 326 datasource/datahub/types.go 126 datasource/graph/graph.go 50 datasource/ha3engine/engine.go 70 datasource/ha3engine/ha3client/client.go 818 datasource/hbase/hbase.go 70 datasource/hbase_thrift/gen-go/hbase/GoUnusedProtection__.go 2 datasource/hbase_thrift/gen-go/hbase/hbase-consts.go 17 datasource/hbase_thrift/gen-go/hbase/t_h_base_service-remote/t_h_base_service-remote.go 1315 datasource/hbase_thrift/hbase_thrift.go 106 datasource/kafka/kafka.go 89 datasource/kafka/kafka_log.go 21 datasource/opensearch/client/client.go 223 datasource/opensearch/opensearch.go 69 datasource/sls/sls.go 77 datasource/sls/slsfeature/log.go 53 filter/adjust_count_filter.go 57 filter/bloomfilter/bloom.go 78 filter/bloomfilter/bloom_rotation.go 71 filter/bloomfilter/bloommeta.go 46 filter/bloomfilter/redis_bitset.go 134 filter/bloomfilter/redis_bloom.go 61 filter/bloomfilter/redis_bloommeta_store.go 75 filter/completely_fair_count_filter.go 69 filter/condition_filter.go 69 filter/dimension_field_unique_filter.go 47 filter/diversity_adjust_count_filter.go 129 filter/filter.go 193 filter/group_weight_count_filter.go 268 filter/item_custom_filter.go 38 filter/item_state_filter.go 32 filter/priority_adjust_count_filter.go 223 filter/priority_adjust_count_filter_clone.go 34 filter/priority_adjust_count_filter_v2.go 81 filter/priority_adjust_count_filter_v2_clone.go 34 filter/unique_filter.go 42 filter/user_item_custom_filter.go 35 filter/user_item_exposure_bloom_filter.go 95 filter/user_item_exposure_filter.go 35 filter/user_item_exposure_with_condition_filter.go 53 log.go 110 log/feature_log/feature_log.go 103 log/log.go 43 log/sls.go 30 middleware/prometheus/option.go 30 middleware/prometheus/prometheus.go 215 module/boost_score_by_weight_dao.go 14 module/boost_score_by_weight_hologres_dao.go 84 module/cold_start_recall_dao.go 16 module/cold_start_recall_featurestore_dao.go 140 module/cold_start_recall_hologres_dao.go 130 module/diversity_dao.go 16 module/diversity_hologres_dao.go 122 module/feature_be_dao.go 556 module/feature_clickhouse_dao.go 279 module/feature_dao.go 123 module/feature_featurestore_dao.go 271 module/feature_hbase_thrift_dao.go 180 module/feature_hologres_dao.go 623 module/feature_lindorm_dao.go 287 module/feature_mysql_dao.go 291 module/feature_redis_dao.go 343 module/feature_tablestore_dao.go 407 module/filter_op.go 1559 module/item.go 276 module/item_collaborative_dao.go 16 module/item_collaborative_featurestore_dao.go 105 module/item_collaborative_hologres_dao.go 124 module/item_custom_filter_dao.go 17 module/item_custom_filter_hologres_dao.go 81 module/item_custom_filter_tablestore_dao.go 86 module/item_state_filter_dao.go 20 module/item_state_filter_featurestore_dao.go 154 module/item_state_filter_hbase_thrift_dao.go 143 module/item_state_filter_hologres_dao.go 261 module/item_state_filter_tablestore_dao.go 129 module/realtime_trigger_diversity_rule.go 42 module/realtime_user2item_be_dao.go 170 module/realtime_user2item_dao.go 160 module/realtime_user2item_featurestore_dao.go 240 module/realtime_user2item_hologres_dao.go 302 module/realtime_user2item_u2i2x2i_hologres_dao.go 347 module/trigger.go 61 module/trigger_info.go 36 module/user.go 283 module/user2item_dao.go 14 module/user2item_hologres_dao.go 183 module/user_collaborative_dao.go 58 module/user_collaborative_featurestore_dao.go 166 module/user_collaborative_hologres_dao.go 251 module/user_collaborative_mysql_dao.go 186 module/user_collaborative_redis_dao.go 173 module/user_collaborative_tablestore_dao.go 219 module/user_collaborative_u2i2x2i_hologres_dao.go 361 module/user_custom_recall_clickhouse_dao.go 117 module/user_custom_recall_dao.go 24 module/user_custom_recall_featurestore_dao.go 98 module/user_custom_recall_hologres_dao.go 117 module/user_custom_recall_mysql_dao.go 78 module/user_custom_recall_redids_dao.go 92 module/user_custom_recall_tablestore_dao.go 98 module/user_global_hot_recall_dao.go 18 module/user_global_hot_recall_featurestore_dao.go 107 module/user_global_hot_recall_hologres_dao.go 133 module/user_global_hot_recall_tablestore_dao.go 100 module/user_group_hot_recall_dao.go 17 module/user_group_hot_recall_featurestore_dao.go 106 module/user_group_hot_recall_hologres_dao.go 122 module/user_item_custom_filter_dao.go 19 module/user_item_custom_filter_featurestore_dao.go 52 module/user_item_custom_filter_hologres_dao.go 111 module/user_item_custom_filter_tablestore_dao.go 65 module/user_item_exposure_be_dao.go 89 module/user_item_exposure_dao.go 76 module/user_item_exposure_featurestore_dao.go 134 module/user_item_exposure_graph_dao.go 183 module/user_item_exposure_hologres_dao.go 228 module/user_item_exposure_mysql_dao.go 150 module/user_item_exposure_redis_dao.go 156 module/user_item_exposure_tablestore_dao.go 219 module/user_topic_dao.go 17 module/user_topic_mysql_dao.go 120 module/user_topic_tablestore_dao.go 186 module/user_video_collaborative_mysql_dao.go 186 module/vector_be_dao.go 48 module/vector_clickhouse_dao.go 73 module/vector_dao.go 27 module/vector_hbase_dao.go 48 module/vector_hologres_dao.go 126 module/vector_mysql_dao.go 80 module/vector_redis_dao.go 43 pairec.go 148 persist/clickhouse/clickhouse.go 49 persist/fs/featurestore.go 62 persist/holo/postgres.go 77 persist/lindorm/lindorm.go 59 persist/mysqldb/mysql.go 44 persist/redisdb/redis.go 118 persist/tablestoredb/tablestore.go 56 pkg/eas/cacheserver_endpoint.go 56 pkg/eas/endpoint.go 72 pkg/eas/gateway_endpoint.go 21 pkg/eas/predict_client.go 243 pkg/eas/queue_client.go 574 pkg/eas/tf_data_type.go 15 pkg/eas/tf_request.go 132 pkg/eas/torch_data_type.go 13 pkg/eas/torch_request.go 97 pkg/eas/types/codec.go 243 pkg/eas/types/index.go 15 pkg/eas/types/queue_service_protos/queueservice.pb.go 272 pkg/eas/types/queue_service_protos/queueservice.proto 15 pkg/eas/types/tf_predict_protos/tf_predict.pb.go 513 pkg/eas/types/tf_predict_protos/tf_predict.proto 85 pkg/eas/types/torch_predict_protos/pytorch_predict.pb.go 318 pkg/eas/types/torch_predict_protos/pytorch_predict.proto 63 pkg/eas/types/types.go 367 pkg/eas/util.go 18 pkg/eas/vipserver_endpoint.go 83 pkg/eas/wrr.go 75 pkg/generate_golang_files/tensorflow/core/example/example.proto 296 pkg/generate_golang_files/tensorflow/core/example/example_parser_configuration.proto 32 pkg/generate_golang_files/tensorflow/core/example/feature.proto 99 pkg/generate_golang_files/tensorflow/core/framework/allocation_description.proto 21 pkg/generate_golang_files/tensorflow/core/framework/api_def.proto 118 pkg/generate_golang_files/tensorflow/core/framework/attr_value.proto 56 pkg/generate_golang_files/tensorflow/core/framework/cost_graph.proto 62 pkg/generate_golang_files/tensorflow/core/framework/device_attributes.proto 40 pkg/generate_golang_files/tensorflow/core/framework/function.proto 92 pkg/generate_golang_files/tensorflow/core/framework/graph.proto 51 pkg/generate_golang_files/tensorflow/core/framework/graph_transfer_info.proto 64 pkg/generate_golang_files/tensorflow/core/framework/iterator.proto 15 pkg/generate_golang_files/tensorflow/core/framework/kernel_def.proto 37 pkg/generate_golang_files/tensorflow/core/framework/log_memory.proto 70 pkg/generate_golang_files/tensorflow/core/framework/node_def.proto 69 pkg/generate_golang_files/tensorflow/core/framework/op_def.proto 136 pkg/generate_golang_files/tensorflow/core/framework/reader_base.proto 15 pkg/generate_golang_files/tensorflow/core/framework/remote_fused_graph_execute_info.proto 37 pkg/generate_golang_files/tensorflow/core/framework/resource_handle.proto 24 pkg/generate_golang_files/tensorflow/core/framework/step_stats.proto 74 pkg/generate_golang_files/tensorflow/core/framework/summary.proto 108 pkg/generate_golang_files/tensorflow/core/framework/tensor.proto 73 pkg/generate_golang_files/tensorflow/core/framework/tensor_description.proto 18 pkg/generate_golang_files/tensorflow/core/framework/tensor_shape.proto 40 pkg/generate_golang_files/tensorflow/core/framework/tensor_slice.proto 32 pkg/generate_golang_files/tensorflow/core/framework/types.proto 71 pkg/generate_golang_files/tensorflow/core/framework/variable.proto 34 pkg/generate_golang_files/tensorflow/core/framework/versions.proto 28 pkg/generate_golang_files/tensorflow/core/lib/core/error_codes.proto 130 pkg/generate_golang_files/tensorflow/core/protobuf/checkpointable_object_graph.proto 47 pkg/generate_golang_files/tensorflow/core/protobuf/cluster.proto 74 pkg/generate_golang_files/tensorflow/core/protobuf/config.proto 524 pkg/generate_golang_files/tensorflow/core/protobuf/control_flow.proto 66 pkg/generate_golang_files/tensorflow/core/protobuf/critical_section.proto 20 pkg/generate_golang_files/tensorflow/core/protobuf/debug.proto 76 pkg/generate_golang_files/tensorflow/core/protobuf/device_properties.proto 50 pkg/generate_golang_files/tensorflow/core/protobuf/eager_service.proto 162 pkg/generate_golang_files/tensorflow/core/protobuf/master.proto 278 pkg/generate_golang_files/tensorflow/core/protobuf/master_service.proto 103 pkg/generate_golang_files/tensorflow/core/protobuf/meta_graph.proto 296 pkg/generate_golang_files/tensorflow/core/protobuf/named_tensor.proto 20 pkg/generate_golang_files/tensorflow/core/protobuf/queue_runner.proto 22 pkg/generate_golang_files/tensorflow/core/protobuf/replay_log.proto 41 pkg/generate_golang_files/tensorflow/core/protobuf/rewriter_config.proto 149 pkg/generate_golang_files/tensorflow/core/protobuf/saved_model.proto 18 pkg/generate_golang_files/tensorflow/core/protobuf/saver.proto 39 pkg/generate_golang_files/tensorflow/core/protobuf/tensor_bundle.proto 56 pkg/generate_golang_files/tensorflow/core/protobuf/tensorflow_server.proto 41 pkg/generate_golang_files/tensorflow/core/protobuf/transport_options.proto 6 pkg/generate_golang_files/tensorflow/core/protobuf/worker.proto 462 pkg/generate_golang_files/tensorflow/core/protobuf/worker_service.proto 68 pkg/generate_golang_files/tensorflow_serving/apis/input.proto 70 pkg/generate_golang_files/tensorflow_serving/apis/internal/serialized_input.proto 35 pkg/generate_golang_files/tensorflow_serving/apis/model.proto 28 pkg/generate_golang_files/tensorflow_serving/apis/predict.proto 34 pkg/generate_golang_files/tensorflow_serving/apis/prediction_service.proto 12 pkg/generate_golang_files/tensorflow_serving/config/log_collector_config.proto 9 pkg/generate_golang_files/tensorflow_serving/config/logging_config.proto 14 pkg/generate_golang_files/tensorflow_serving/config/model_server_config.proto 71 pkg/generate_golang_files/tensorflow_serving/config/monitoring_config.proto 15 pkg/generate_golang_files/tensorflow_serving/config/platform_config.proto 15 pkg/generate_golang_files/tensorflow_serving/config/ssl_config.proto 14 pkg/generate_golang_files/tensorflow_serving/core/logging.proto 11 pkg/generate_golang_files/tensorflow_serving/resources/resources.proto 39 pkg/generate_golang_files/tensorflow_serving/servables/hashmap/hashmap_source_adapter.proto 14 pkg/generate_golang_files/tensorflow_serving/servables/tensorflow/saved_model_bundle_source_adapter.proto 10 pkg/generate_golang_files/tensorflow_serving/servables/tensorflow/session_bundle_config.proto 90 pkg/generate_golang_files/tensorflow_serving/servables/tensorflow/session_bundle_source_adapter.proto 7 pkg/generate_golang_files/tensorflow_serving/sources/storage_path/file_system_storage_path_source.proto 64 pkg/generate_golang_files/tensorflow_serving/sources/storage_path/static_storage_path_source.proto 9 pkg/generate_golang_files/tensorflow_serving/util/status.proto 12 pkg/tensorflow/core/example/example.pb.go 200 pkg/tensorflow/core/example/example_parser_configuration.pb.go 423 pkg/tensorflow/core/example/feature.pb.go 520 pkg/tensorflow/core/framework/allocation_description.pb.go 175 pkg/tensorflow/core/framework/api_def.pb.go 581 pkg/tensorflow/core/framework/attr_value.pb.go 473 pkg/tensorflow/core/framework/cost_graph.pb.go 488 pkg/tensorflow/core/framework/device_attributes.pb.go 375 pkg/tensorflow/core/framework/function.pb.go 318 pkg/tensorflow/core/framework/graph.pb.go 172 pkg/tensorflow/core/framework/graph_transfer_info.pb.go 793 pkg/tensorflow/core/framework/iterator.pb.go 133 pkg/tensorflow/core/framework/kernel_def.pb.go 298 pkg/tensorflow/core/framework/log_memory.pb.go 551 pkg/tensorflow/core/framework/node_def.pb.go 242 pkg/tensorflow/core/framework/op_def.pb.go 573 pkg/tensorflow/core/framework/reader_base.pb.go 155 pkg/tensorflow/core/framework/remote_fused_graph_execute_info.pb.go 287 pkg/tensorflow/core/framework/resource_handle.pb.go 161 pkg/tensorflow/core/framework/step_stats.pb.go 765 pkg/tensorflow/core/framework/summary.pb.go 777 pkg/tensorflow/core/framework/tensor.pb.go 372 pkg/tensorflow/core/framework/tensor_description.pb.go 168 pkg/tensorflow/core/framework/tensor_shape.pb.go 198 pkg/tensorflow/core/framework/tensor_slice.pb.go 207 pkg/tensorflow/core/framework/types.pb.go 291 pkg/tensorflow/core/framework/variable.pb.go 266 pkg/tensorflow/core/framework/versions.pb.go 143 pkg/tensorflow_serving/apis/input.pb.go 286 pkg/tensorflow_serving/apis/model.pb.go 174 pkg/tensorflow_serving/apis/predict.pb.go 238 pkg/tensorflow_serving/apis/prediction_service.pb.go 65 pkg/tensorflow_serving/apis/prediction_service_grpc.pb.go 70 recconf/check.go 37 recconf/modules.go 174 recconf/recconf.go 890 recconf/requirements.go 164 recconf/userconf.go 41 recconf/validator.go 4 register.go 31 route.go 58 service/call_back_service.go 219 service/category.go 41 service/debug/debug_service.go 475 service/embedding_service.go 175 service/feature/batch_raw_feature_op.go 46 service/feature/delete_feature_op.go 35 service/feature/feature.go 65 service/feature/feature_service.go 182 service/feature/new_feature_op.go 46 service/feature/normalizer.go 95 service/feature/op.go 126 service/feature/user_feature_service.go 205 service/feature_reply.go 276 service/general_rank/action.go 68 service/general_rank/base_general_rank.go 184 service/general_rank/coldstart_general_rank.go 33 service/general_rank/custom_general_rank.go 9 service/general_rank/feature_consistency_job_service.go 150 service/general_rank/general_rank.go 179 service/hook/recommend.go 55 service/metrics/metrics.go 124 service/pipeline/cold_start_rank.go 73 service/pipeline/feature_service.go 66 service/pipeline/filter.go 44 service/pipeline/general_rank.go 97 service/pipeline/pipeline.go 52 service/pipeline/rank_service.go 144 service/pipeline/recall.go 119 service/pipeline/sort.go 44 service/pipeline/user_recommend.go 70 service/rank/algo_data.go 291 service/rank/cold_start_rank.go 80 service/rank/custom_rank.go 30 service/rank/feature_consistency_job_service.go 344 service/rank/rank_service.go 316 service/recall.go 122 service/recall/be_multibiz_recall.go 272 service/recall/be_recall.go 65 service/recall/be_vector_recall.go 180 service/recall/be_x2i_recall.go 232 service/recall/berecall/be_trigger_key.go 111 service/recall/berecall/filter.go 78 service/recall/berecall/u2i_base_trigger.go 46 service/recall/berecall/u2i_realtime_trigger.go 26 service/recall/berecall/u2i_trigger.go 24 service/recall/berecall/user_embedding_dssm_o2o_trigger.go 115 service/recall/berecall/user_item_exposure_filter.go 25 service/recall/berecall/user_realtime_embedding_mind_trigger.go 121 service/recall/berecall/user_realtime_embedding_trigger.go 108 service/recall/berecall/user_vector_trigger.go 79 service/recall/cold_start_recall.go 88 service/recall/context_item_recall.go 49 service/recall/graph_recall.go 153 service/recall/hologres_vector_recall.go 186 service/recall/hologres_vector_recall_v2.go 190 service/recall/item_2_item_vector_racall.go 135 service/recall/item_collaborative_filter_recall.go 66 service/recall/mock_recall.go 33 service/recall/online_hologres_vector_recall.go 209 service/recall/online_vector_recall.go 125 service/recall/opensearch_recall.go 131 service/recall/realtime_u2i_recall.go 65 service/recall/recall.go 116 service/recall/user_collaborative_filter_recall.go 72 service/recall/user_custom_recall.go 66 service/recall/user_global_hot_recall.go 92 service/recall/user_group_hot_recall.go 94 service/recall/user_topic_recall.go 59 service/recall/vector_recall.go 111 service/recommend.go 38 service/scene.go 58 service/user_recall_service.go 36 service/user_recommend.go 131 sort/algo_score_sort.go 59 sort/boost_score_by_weight.go 30 sort/boost_score_sort.go 90 sort/boost_score_sort_clone.go 34 sort/distinct_id_sort.go 55 sort/diversity_rule.go 68 sort/diversity_rule_sort.go 137 sort/diversity_rule_sort_clone.go 33 sort/dpp_sort.go 527 sort/item_container.go 154 sort/item_rank_score.go 27 sort/item_score.go 32 sort/matrix_scatter_rule.go 29 sort/mix_sort_strategy.go 178 sort/multi_recall_mix_sort.go 179 sort/multi_recall_mix_sort_clone.go 33 sort/pid_controller.go 627 sort/sort.go 191 sort/ssd_sort.go 468 sort/traffic_control_sort.go 970 sort/traffic_control_sort_clone.go 33 sort/window_rule.go 54 utils/ast/ast.go 312 utils/ast/data.go 5 utils/ast/parse.go 140 utils/cycle_queue.go 70 utils/date.go 46 utils/geohash.go 63 utils/govaluate_functions.go 65 utils/jsonutil/map.go 54 utils/math.go 47 utils/md5.go 18 utils/nested_map.go 123 utils/net.go 19 utils/netutil/dns.go 112 utils/sqlutil/sql.go 107 utils/string.go 16 utils/synclog/log_info.go 139 utils/synclog/meta_data.go 44 utils/synclog/meta_info.go 74 utils/synclog/sync_log.go 151 utils/time.go 38 utils/type.go 349 utils/util.go 352 utils/uuid.go 6 web/callback_controller.go 237 web/callback_controller_func.go 13 web/callback_controller_handler.go 36 web/complex_type_features.go 226 web/controller.go 67 web/embedding_controller.go 153 web/feature_reply_controller.go 146 web/proxy/baseline.go 49 web/proxy/proxy_controller.go 73 web/recommend_controller.go 158 web/response.go 6 web/user_recall_controller.go 134