Repository: apex-malhar Updated Branches: refs/heads/master 0a924ada9 -> 2e870f4b8
APEXMALHAR-2256 Replacing getFields with getDeclaredFields Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/2e870f4b Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/2e870f4b Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/2e870f4b Branch: refs/heads/master Commit: 2e870f4b8096b686d2cd22dd888847844ad9640c Parents: 0a924ad Author: Chinmay Kolhatkar <chin...@datatorrent.com> Authored: Wed Sep 21 12:18:58 2016 +0530 Committer: Chinmay Kolhatkar <chin...@datatorrent.com> Committed: Wed Sep 21 12:18:58 2016 +0530 ---------------------------------------------------------------------- .../org/apache/apex/malhar/lib/join/POJOInnerJoinOperator.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/2e870f4b/library/src/main/java/org/apache/apex/malhar/lib/join/POJOInnerJoinOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/join/POJOInnerJoinOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/join/POJOInnerJoinOperator.java index d7f50c9..a7eff1d 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/join/POJOInnerJoinOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/join/POJOInnerJoinOperator.java @@ -137,12 +137,12 @@ public class POJOInnerJoinOperator extends AbstractManagedStateInnerJoinOperator try { inputFieldObjects[i].keyGet = PojoUtils.createGetter(inputClass, keyFieldExpressions.get(i), Object.class); if (timeFields != null && timeFields.size() == 2) { - Class timeField = ClassUtils.primitiveToWrapper(inputClass.getField(timeFields.get(i)).getType()); + Class timeField = ClassUtils.primitiveToWrapper(inputClass.getDeclaredField(timeFields.get(i)).getType()); inputFieldObjects[i].timeFieldGet = PojoUtils.createGetter(inputClass, timeFields.get(i), timeField); } for (int j = 0; j < includeFields[i].length; j++) { - Class inputField = ClassUtils.primitiveToWrapper(inputClass.getField(includeFields[i][j]).getType()); - Class outputField = ClassUtils.primitiveToWrapper(outputClass.getField(includeFields[i][j]).getType()); + Class inputField = ClassUtils.primitiveToWrapper(inputClass.getDeclaredField(includeFields[i][j]).getType()); + Class outputField = ClassUtils.primitiveToWrapper(outputClass.getDeclaredField(includeFields[i][j]).getType()); if (inputField != outputField) { continue; }
