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 <dbros...@mebigfatguy.com> Authored: Thu May 28 21:25:11 2015 -0400 Committer: Dave Brosius <dbros...@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()