|
|
@@ -76,7 +76,7 @@ public class PAIModel {
|
|
|
|
|
|
List<String> scoreKeys = Arrays.asList("y_return_n_uv", "probs_is_share");
|
|
|
int size = rankItems.size();
|
|
|
-
|
|
|
+ String currentName = "";
|
|
|
try {
|
|
|
|
|
|
List<Map<String, Float>> featureMapList = new ArrayList<>(rankItems.size());
|
|
|
@@ -95,7 +95,7 @@ public class PAIModel {
|
|
|
String featureName = featureKeyTuple.getV2();
|
|
|
String featureKey = featureKeyTuple.getV1();
|
|
|
String defaultValue = featureKeyTuple.getV3();
|
|
|
-
|
|
|
+ currentName = String.format("1@%s@%s", featureKey, featureName);
|
|
|
if (TFDataType.DT_STRING.equals(dataType)) {
|
|
|
for (int i = 0; i < size; i++) {
|
|
|
Map<String, String> featureMapString = featureMapStringList.get(i);
|
|
|
@@ -118,6 +118,7 @@ public class PAIModel {
|
|
|
for (Tuple4<String, String, String, TFDataType> featureKey : featureKeys) {
|
|
|
String featureName = featureKey.getV2();
|
|
|
TFDataType dataType = featureKey.getV4();
|
|
|
+ currentName = String.format("2@%s@%s", featureKey.getV1(), featureName);
|
|
|
if (TFDataType.DT_STRING.equals(dataType)) {
|
|
|
request.addFeed(featureName, TFDataType.DT_STRING, shape, stringFeatureArr.get(featureName));
|
|
|
} else {
|
|
|
@@ -133,7 +134,7 @@ public class PAIModel {
|
|
|
}
|
|
|
return resultMap;
|
|
|
} catch (Exception e) {
|
|
|
- LOGGER.error("pai eas error ", e);
|
|
|
+ LOGGER.error("pai eas error currentName: {}", currentName, e);
|
|
|
Map<String, List<Float>> resultMap = new HashMap<>();
|
|
|
for (String scoreKey : scoreKeys) {
|
|
|
resultMap.put(scoreKey, Collections.nCopies(size, 0.0f));
|