Commit e6a57b8d authored by 赵威's avatar 赵威

remove comment

parent bfb08c9e
...@@ -8,9 +8,9 @@ sys.path.append(os.path.realpath(".")) ...@@ -8,9 +8,9 @@ sys.path.append(os.path.realpath("."))
from gensim.models import Word2Vec, word2vec from gensim.models import Word2Vec, word2vec
from utils.date import get_ndays_before_no_minus, get_ndays_before_with_format from utils.date import get_ndays_before_no_minus, get_ndays_before_with_format
from utils.es import get_offline_ids
from utils.files import DATA_PATH, MODEL_PATH from utils.files import DATA_PATH, MODEL_PATH
from utils.spark import get_spark from utils.spark import get_spark
from utils.es import get_offline_ids
answer_click_ids_model_path = os.path.join(MODEL_PATH, "answer_click_ids_item2vec_model") answer_click_ids_model_path = os.path.join(MODEL_PATH, "answer_click_ids_item2vec_model")
...@@ -139,9 +139,6 @@ def get_offline_answer_ids(): ...@@ -139,9 +139,6 @@ def get_offline_answer_ids():
return res_set return res_set
curl "http://172.16.31.17:9200/gm-dbmw-answer-read/_search?pretty&size=100" -d '{"query": {"bool": {"must": [{"term": {"is_online": true}}, {"match_phrase": {"tag_name_analyze": {"query": "草莓鼻", "analyzer": "gm_default_index"}}}]}}}'
def get_device_click_answer_ids_dict(click_df): def get_device_click_answer_ids_dict(click_df):
res = defaultdict(list) res = defaultdict(list)
cols = click_df.orderBy("partition_date", ascending=False).collect() cols = click_df.orderBy("partition_date", ascending=False).collect()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment