cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject cassandra git commit: don't declare throwing exceptions that aren't
Date Fri, 29 May 2015 01:25:30 GMT
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 <dbrosius@mebigfatguy.com>
Authored: Thu May 28 21:25:11 2015 -0400
Committer: Dave Brosius <dbrosius@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()


Mime
View raw message