@Override
    public TimestampedSegment getOrCreateSegmentIfLive(final long segmentId,
                                                    final ProcessorContext context,
                                                    final long streamTime) {
        final TimestampedSegment segment = super.getOrCreateSegmentIfLive(segmentId, context, streamTime);
        cleanupExpiredSegments(streamTime);
        return segment;
    }
@Test
    public void shouldGetCorrectSegmentString() {
        final TimestampedSegment segment = segments.getOrCreateSegmentIfLive(0, context, -1L);
        assertEquals("TimestampedSegment(id=0, name=test.0)", segment.toString());
    }