From a78b76b664830a1ac691396d5cb64166c6919ff1 Mon Sep 17 00:00:00 2001
From: shikeying <shikeying@163.com>
Date: 星期五, 30 九月 2022 18:12:44 +0800
Subject: [PATCH] 视频相似度分析5
---
recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultVideoLoader.java | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultVideoLoader.java b/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultVideoLoader.java
index ad69420..7a3cd92 100644
--- a/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultVideoLoader.java
+++ b/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultVideoLoader.java
@@ -6,6 +6,7 @@
import com.iplatform.recvideo.VideoLoadInfo;
import com.iplatform.recvideo.VideoLoader;
import com.iplatform.recvideo.service.VideoLoaderServiceImpl;
+import com.walker.connector.support.DatabaseConnector;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.NumberGenerator;
@@ -15,6 +16,12 @@
public class DefaultVideoLoader extends VideoLoader {
private VideoLoaderServiceImpl videoLoaderService;
+
+ private DatabaseConnector databaseConnector = null;
+
+ public void setDatabaseConnector(DatabaseConnector databaseConnector) {
+ this.databaseConnector = databaseConnector;
+ }
public void setVideoLoaderService(VideoLoaderServiceImpl videoLoaderService) {
this.videoLoaderService = videoLoaderService;
@@ -27,11 +34,12 @@
@Override
protected long acquireInitBatchId() {
- return 0;
+ return 20210101;
}
@Override
protected List<VideoLoadInfo> acquireLoadVideoFromDatabase(long nextBatchId) {
+ this.databaseConnector.queryForList("", new Object[]{nextBatchId});
return null;
}
--
Gitblit v1.9.1