This method is used only in tests and has been deprecated. Remove it.
JIRA: CONTROLLER-2071
Change-Id: I4428b24b7fd4309d8a393ef3f91975abbb48f677
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
return this;
}
- /**
- * Sets the journal cache size.
- *
- * @param cacheSize the journal cache size
- * @return the journal builder
- * @throws IllegalArgumentException if the cache size is not positive
- * @deprecated since 3.0.4
- */
- @Deprecated
- public Builder<E> withCacheSize(int cacheSize) {
- checkArgument(cacheSize >= 0, "cacheSize must be positive");
- return this;
- }
-
/**
* Enables flushing buffers to disk when entries are committed to a segment, returning the builder for method
* chaining.
private static final Path PATH = Paths.get("target/test-logs/");
private final int maxSegmentSize;
- private final int cacheSize;
protected final int entriesPerSegment;
- protected AbstractJournalTest(int maxSegmentSize, int cacheSize) {
+ protected AbstractJournalTest(int maxSegmentSize) {
this.maxSegmentSize = maxSegmentSize;
- this.cacheSize = cacheSize;
int entryLength = (NAMESPACE.serialize(ENTRY).length + 8);
this.entriesPerSegment = (maxSegmentSize - 64) / entryLength;
}
List<Object[]> runs = new ArrayList<>();
for (int i = 1; i <= 10; i++) {
for (int j = 1; j <= 10; j++) {
- runs.add(new Object[]{64 + (i * (NAMESPACE.serialize(ENTRY).length + 8) + j), j});
+ runs.add(new Object[]{64 + (i * (NAMESPACE.serialize(ENTRY).length + 8) + j)});
}
}
return runs;
.withStorageLevel(storageLevel())
.withMaxSegmentSize(maxSegmentSize)
.withIndexDensity(.2)
- .withCacheSize(cacheSize)
.build();
}
* Disk journal test.
*/
public class DiskJournalTest extends PersistentJournalTest {
- public DiskJournalTest(int maxSegmentSize, int cacheSize) {
- super(maxSegmentSize, cacheSize);
+ public DiskJournalTest(int maxSegmentSize) {
+ super(maxSegmentSize);
}
@Override
* Memory mapped journal test.
*/
public class MappedJournalTest extends PersistentJournalTest {
- public MappedJournalTest(int maxSegmentSize, int cacheSize) {
- super(maxSegmentSize, cacheSize);
+ public MappedJournalTest(int maxSegmentSize) {
+ super(maxSegmentSize);
}
@Override
*/
@Deprecated
public class MemoryJournalTest extends AbstractJournalTest {
- public MemoryJournalTest(int maxSegmentSize, int cacheSize) {
- super(maxSegmentSize, cacheSize);
+ public MemoryJournalTest(int maxSegmentSize) {
+ super(maxSegmentSize);
}
@Override
* Persistent journal test base.
*/
public abstract class PersistentJournalTest extends AbstractJournalTest {
- protected PersistentJournalTest(int maxSegmentSize, int cacheSize) {
- super(maxSegmentSize, cacheSize);
+ protected PersistentJournalTest(int maxSegmentSize) {
+ super(maxSegmentSize);
}
/**