spatial_beam_01.java

TiledIntervalWindow.java

public class TiledIntervalWindow extends BoundedWindow {

    private final String hexAddr;
    private final Instant start;
    private final Instant end;

    public TiledIntervalWindow(String hexAddr, Instant start, Instant end) {
        this.hexAddr = hexAddr;
        this.start = start;
        this.end = end;
    }
    
    // ...
    
    private boolean isDisjoint(TiledIntervalWindow other) {
        return !this.end.isAfter(other.start) || !other.end.isAfter(this.start);
    }

    public boolean intersects(TiledIntervalWindow other) {
        return this.hexAddr.equals(other.hexAddr) && !this.isDisjoint(other);
    }
    
    // ...
}