private boolean expired(Map.Entry<TransactionIdKey, HashQueue<RecordSequence>> entry, LocalDateTime startTime) {
    return startTime != null && // Can be null if starting from SCN and first batch is not complete yet.
        entry.getKey().txnStartTime.isBefore(startTime.minusSeconds(configBean.txnWindow)) &&
        entry.getValue().peek().seq == 1;
  }
private boolean expired(Map.Entry<TransactionIdKey, HashQueue<RecordSequence>> entry, LocalDateTime startTime) {
    return startTime != null && 
        entry.getKey().txnStartTime.isBefore(startTime.minusSeconds(configBean.txnWindow)) &&
        entry.getValue().peek().seq == 1;
  }
private boolean expired ( Map . Entry < TransactionIdKey , HashQueue < RecordSequence > > entry , LocalDateTime startTime ) { return startTime != null && // Can be null if starting from SCN and first batch is not complete yet. entry . getKey ( ) . txnStartTime . isBefore ( startTime . minusSeconds ( configBean . txnWindow ) ) && entry . getValue ( ) . peek ( ) . seq == 1 ; }
An element is "expired" if the transaction started before the current window being processed
and if no records have actually been sent to the pipeline. If a record has been sent, then a commit was seen,
so it is not expired.
@param entry
@return
An element is expired if the transaction started before the current window being processed and if no records have actually been sent to the pipeline . If a record has been sent then a commit was seen so it is not expired .