class PartitionedWriteAheadEventStore extends PartitionedEventStore {

    @Override
    public void initialize() throws IOException {
        if (repoConfig.isCompressOnRollover()) {
            for (int i = 0; i < repoConfig.getIndexThreadPoolSize(); i++) {
                final EventFileCompressor compressor = new EventFileCompressor(filesToCompress, fileManager);
                compressionExecutor.submit(compressor);
                fileCompressors.add(compressor);
            }
        }

        super.initialize();
    }

    public  PartitionedWriteAheadEventStore(final RepositoryConfiguration repoConfig, final RecordWriterFactory recordWriterFactory,
        final RecordReaderFactory recordReaderFactory, final EventReporter eventReporter, final EventFileManager fileManager);

}