Remove dead sliced_buffer_size_in_kb option

patch by slebresne; reviewed by jbellis for CASSANDRA-4076
This commit is contained in:
Sylvain Lebresne 2012-03-30 16:44:24 +02:00
parent e05a327e2c
commit d69d304c4e
10 changed files with 7 additions and 25 deletions

View File

@ -2,6 +2,7 @@
* Adds caching and bloomFilterFpChange to CQL options (CASSANDRA-4042)
* Adds posibility to autoconfigure size of the KeyCache (CASSANDRA-4087)
* fix KEYS index from skipping results (CASSANDRA-3996)
* Remove sliced_buffer_size_in_kb dead option (CASSANDRA-4076)
1.1-beta2

View File

@ -48,7 +48,8 @@ Upgrading
+ Prior to 1.1, you could use KEY as the primary key name in some
select statements, even if the PK was actually given a different
name. In 1.1+ you must use the defined PK name.
- The sliced_buffer_size_in_kb option has been removed from the
cassandra.yaml config file (this option was a no-op since 1.0).
Features
--------

View File

@ -223,10 +223,6 @@ concurrent_writes: 32
# the maximum number of secondary indexes created on a single CF.
memtable_flush_queue_size: 4
# Buffer size to use when performing contiguous column slices.
# Increase this to the size of the column slices you typically perform
sliced_buffer_size_in_kb: 64
# Whether to, when doing sequential writing, fsync() at intervals in
# order to force the operating system to flush the dirty
# buffers. Enable this to avoid sudden dirty buffer flushing from

View File

@ -150,10 +150,6 @@ concurrent_writes: 32
# By default this will be set to the amount of data directories defined.
#memtable_flush_writers: 1
# Buffer size to use when performing contiguous column slices.
# Increase this to the size of the column slices you typically perform
sliced_buffer_size_in_kb: 64
# TCP port, for commands and data
storage_port: 7000

View File

@ -61,8 +61,6 @@ public class Config
public Integer memtable_flush_writers = null; // will get set to the length of data dirs in DatabaseDescriptor
public Integer memtable_total_space_in_mb;
public Integer sliced_buffer_size_in_kb = 64;
public Integer storage_port = 7000;
public Integer ssl_storage_port = 7001;
public String listen_address;

View File

@ -864,16 +864,6 @@ public class DatabaseDescriptor
return indexAccessMode;
}
public static int getIndexedReadBufferSizeInKB()
{
return conf.column_index_size_in_kb;
}
public static int getSlicedReadBufferSizeInKB()
{
return conf.sliced_buffer_size_in_kb;
}
public static boolean isSnapshotBeforeCompaction()
{
return conf.snapshot_before_compaction;

View File

@ -58,7 +58,7 @@ public class SSTableNamesIterator extends SimpleAbstractColumnIterator implement
this.columns = columns;
this.key = key;
FileDataInput file = sstable.getFileDataInput(key, DatabaseDescriptor.getIndexedReadBufferSizeInKB() * 1024);
FileDataInput file = sstable.getFileDataInput(key);
if (file == null)
return;

View File

@ -45,7 +45,7 @@ public class SSTableSliceIterator implements IColumnIterator
public SSTableSliceIterator(SSTableReader sstable, DecoratedKey key, ByteBuffer startColumn, ByteBuffer finishColumn, boolean reversed)
{
this.key = key;
fileToClose = sstable.getFileDataInput(this.key, DatabaseDescriptor.getSlicedReadBufferSizeInKB() * 1024);
fileToClose = sstable.getFileDataInput(this.key);
if (fileToClose == null)
return;

View File

@ -834,7 +834,7 @@ public class SSTableReader extends SSTable
return new SSTableBoundedScanner(this, true, range);
}
public FileDataInput getFileDataInput(DecoratedKey decoratedKey, int bufferSize)
public FileDataInput getFileDataInput(DecoratedKey decoratedKey)
{
long position = getPosition(decoratedKey, Operator.EQ);
if (position < 0)

View File

@ -125,7 +125,7 @@ public class SSTableReaderTest extends SchemaLoader
for (int j = 0; j < 100; j += 2)
{
DecoratedKey dk = Util.dk(String.valueOf(j));
FileDataInput file = sstable.getFileDataInput(dk, DatabaseDescriptor.getIndexedReadBufferSizeInKB() * 1024);
FileDataInput file = sstable.getFileDataInput(dk);
DecoratedKey keyInDisk = SSTableReader.decodeKey(sstable.partitioner,
sstable.descriptor,
ByteBufferUtil.readWithShortLength(file));