natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove throws declarations on methods that don't throw those exceptions

This commit is contained in:
Dave Brosius 2013-05-05 15:43:54 -04:00
parent 90764b0ac7
commit bfa06db1ac
4 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/cassandra/client/RingCache.java
View File

@ -52,7 +52,7 @@ public class RingCache
private Multimap<Range<Token>, InetAddress> rangeMap;
public RingCache(Configuration conf) throws IOException
public RingCache(Configuration conf)
{
this.conf = conf;
this.partitioner = ConfigHelper.getOutputPartitioner(conf);

4
src/java/org/apache/cassandra/hadoop/ColumnFamilyOutputFormat.java
View File

@ -114,7 +114,7 @@ public class ColumnFamilyOutputFormat extends OutputFormat<ByteBuffer,List<Mutat
/** Fills the deprecated OutputFormat interface for streaming. */
@Deprecated @Override
public ColumnFamilyRecordWriter getRecordWriter(org.apache.hadoop.fs.FileSystem filesystem, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable progress) throws IOException
public ColumnFamilyRecordWriter getRecordWriter(org.apache.hadoop.fs.FileSystem filesystem, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable progress)
{
return new ColumnFamilyRecordWriter(job, new Progressable(progress));
}
@ -128,7 +128,7 @@ public class ColumnFamilyOutputFormat extends OutputFormat<ByteBuffer,List<Mutat
* @throws IOException
*/
@Override
public ColumnFamilyRecordWriter getRecordWriter(final TaskAttemptContext context) throws IOException, InterruptedException
public ColumnFamilyRecordWriter getRecordWriter(final TaskAttemptContext context) throws InterruptedException
{
return new ColumnFamilyRecordWriter(context);
}

7
src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
View File

@ -84,21 +84,20 @@ implements org.apache.hadoop.mapred.RecordWriter<ByteBuffer,List<Mutation>>
* mutations, and the ring cache for the given keyspace.
*
* @param context the task attempt context
* @throws IOException
*/
ColumnFamilyRecordWriter(TaskAttemptContext context) throws IOException
ColumnFamilyRecordWriter(TaskAttemptContext context)
{
this(context.getConfiguration());
this.progressable = new Progressable(context);
}
ColumnFamilyRecordWriter(Configuration conf, Progressable progressable) throws IOException
ColumnFamilyRecordWriter(Configuration conf, Progressable progressable)
{
this(conf);
this.progressable = progressable;
}
ColumnFamilyRecordWriter(Configuration conf) throws IOException
ColumnFamilyRecordWriter(Configuration conf)
{
this.conf = conf;
this.ringCache = new RingCache(conf);

3
test/unit/org/apache/cassandra/client/TestRingCache.java
View File

@ -17,7 +17,6 @@
*/
package org.apache.cassandra.client;
import java.io.IOException;
import java.net.InetAddress;
import java.nio.ByteBuffer;
import java.util.Collection;
@ -46,7 +45,7 @@ public class TestRingCache
private Cassandra.Client thriftClient;
private Configuration conf;
public TestRingCache(String keyspace) throws IOException
public TestRingCache(String keyspace)
{
ConfigHelper.setOutputColumnFamily(conf, keyspace, "Standard1");
ringCache = new RingCache(conf);