You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2015/05/29 03:25:30 UTC
cassandra git commit: don't declare throwing exceptions that aren't
Repository: cassandra
Updated Branches:
refs/heads/trunk 64f1eadd5 -> f55a4f451
don't declare throwing exceptions that aren't
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f55a4f45
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f55a4f45
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f55a4f45
Branch: refs/heads/trunk
Commit: f55a4f451227564d01bda77620a28d848a219f16
Parents: 64f1ead
Author: Dave Brosius <db...@mebigfatguy.com>
Authored: Thu May 28 21:25:11 2015 -0400
Committer: Dave Brosius <db...@mebigfatguy.com>
Committed: Thu May 28 21:25:11 2015 -0400
----------------------------------------------------------------------
src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java | 2 +-
.../org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java | 2 +-
src/java/org/apache/cassandra/io/util/DataOutputBuffer.java | 2 +-
.../apache/cassandra/streaming/messages/CompleteMessage.java | 5 ++---
.../cassandra/streaming/messages/SessionFailedMessage.java | 5 ++---
5 files changed, 7 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f55a4f45/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
index 6b9ecb5..99abf9f 100644
--- a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
@@ -163,7 +163,7 @@ public final class BulkRecordWriter extends RecordWriter<ByteBuffer, List<Mutati
}
@Override
- public void close(TaskAttemptContext context) throws IOException, InterruptedException
+ public void close(TaskAttemptContext context) throws IOException
{
close();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f55a4f45/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
index f06f03d..9547d0e 100644
--- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java
@@ -112,7 +112,7 @@ final class ColumnFamilyRecordWriter extends RecordWriter<ByteBuffer, List<Mutat
* @param context the context of the task
* @throws IOException
*/
- public void close(TaskAttemptContext context) throws IOException, InterruptedException
+ public void close(TaskAttemptContext context) throws IOException
{
close();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f55a4f45/src/java/org/apache/cassandra/io/util/DataOutputBuffer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/util/DataOutputBuffer.java b/src/java/org/apache/cassandra/io/util/DataOutputBuffer.java
index 6ffc895..d9a290e 100644
--- a/src/java/org/apache/cassandra/io/util/DataOutputBuffer.java
+++ b/src/java/org/apache/cassandra/io/util/DataOutputBuffer.java
@@ -87,7 +87,7 @@ public class DataOutputBuffer extends BufferedDataOutputStreamPlus
return true;
}
- public void close() throws IOException
+ public void close()
{
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f55a4f45/src/java/org/apache/cassandra/streaming/messages/CompleteMessage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/messages/CompleteMessage.java b/src/java/org/apache/cassandra/streaming/messages/CompleteMessage.java
index b555f64..44ff553 100644
--- a/src/java/org/apache/cassandra/streaming/messages/CompleteMessage.java
+++ b/src/java/org/apache/cassandra/streaming/messages/CompleteMessage.java
@@ -17,7 +17,6 @@
*/
package org.apache.cassandra.streaming.messages;
-import java.io.IOException;
import java.nio.channels.ReadableByteChannel;
import org.apache.cassandra.io.util.DataOutputStreamPlus;
@@ -27,12 +26,12 @@ public class CompleteMessage extends StreamMessage
{
public static Serializer<CompleteMessage> serializer = new Serializer<CompleteMessage>()
{
- public CompleteMessage deserialize(ReadableByteChannel in, int version, StreamSession session) throws IOException
+ public CompleteMessage deserialize(ReadableByteChannel in, int version, StreamSession session)
{
return new CompleteMessage();
}
- public void serialize(CompleteMessage message, DataOutputStreamPlus out, int version, StreamSession session) throws IOException {}
+ public void serialize(CompleteMessage message, DataOutputStreamPlus out, int version, StreamSession session) {}
};
public CompleteMessage()
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f55a4f45/src/java/org/apache/cassandra/streaming/messages/SessionFailedMessage.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/messages/SessionFailedMessage.java b/src/java/org/apache/cassandra/streaming/messages/SessionFailedMessage.java
index 46f49d6..4a5b6df 100644
--- a/src/java/org/apache/cassandra/streaming/messages/SessionFailedMessage.java
+++ b/src/java/org/apache/cassandra/streaming/messages/SessionFailedMessage.java
@@ -17,7 +17,6 @@
*/
package org.apache.cassandra.streaming.messages;
-import java.io.IOException;
import java.nio.channels.ReadableByteChannel;
import org.apache.cassandra.io.util.DataOutputStreamPlus;
@@ -27,12 +26,12 @@ public class SessionFailedMessage extends StreamMessage
{
public static Serializer<SessionFailedMessage> serializer = new Serializer<SessionFailedMessage>()
{
- public SessionFailedMessage deserialize(ReadableByteChannel in, int version, StreamSession session) throws IOException
+ public SessionFailedMessage deserialize(ReadableByteChannel in, int version, StreamSession session)
{
return new SessionFailedMessage();
}
- public void serialize(SessionFailedMessage message, DataOutputStreamPlus out, int version, StreamSession session) throws IOException {}
+ public void serialize(SessionFailedMessage message, DataOutputStreamPlus out, int version, StreamSession session) {}
};
public SessionFailedMessage()