private void flushComplete(long lastIndexedOffset) {
        this.aggregator.reset();
        this.aggregator.setLastIndexedOffset(lastIndexedOffset);
        this.connector.notifyIndexOffsetChanged(this.aggregator.getLastIndexedOffset());
        log.debug("{}: FlushComplete (State={}).", this.traceObjectId, this.aggregator);
    }
private void flushComplete ( long lastIndexedOffset ) { this . aggregator . reset ( ) ; this . aggregator . setLastIndexedOffset ( lastIndexedOffset ) ; this . connector . notifyIndexOffsetChanged ( this . aggregator . getLastIndexedOffset ( ) ) ; log . debug ( "{}: FlushComplete (State={})." , this . traceObjectId , this . aggregator ) ; }
Updates the internal state post flush and notifies the {@link TableWriterConnector} of the fact.

@param lastIndexedOffset The last offset in the Table Segment that was indexed.