diff --git a/analytics/spark/src/main/java/org/locationtech/geowave/analytic/spark/spatial/TieredSpatialJoin.java b/analytics/spark/src/main/java/org/locationtech/geowave/analytic/spark/spatial/TieredSpatialJoin.java index d166a0f025c..50ef501b44b 100644 --- a/analytics/spark/src/main/java/org/locationtech/geowave/analytic/spark/spatial/TieredSpatialJoin.java +++ b/analytics/spark/src/main/java/org/locationtech/geowave/analytic/spark/spatial/TieredSpatialJoin.java @@ -379,10 +379,12 @@ public void join( private Map> createReprojectMap( final Byte[] buildSide, final Byte[] testSide, - final HashSet sharedTiers) { + final HashSet sharedTiers) + { final Map> resultMap = Maps.newHashMap(); final int testLastIndex = testSide.length; - for (final Byte tierLeft : buildSide) { + for (final Byte tierLeft : buildSide) + { final int firstGreater = Arrays.binarySearch(testSide, tierLeft); //add same tier id if (firstGreater >= 0) { @@ -393,7 +395,7 @@ private Map> createReprojectMap( HashSet higherTiers = Sets.newHashSet(); for(Byte testID :testSide) { - if(tierLefttierLeft) { higherTiers.add(testID); }