diff --git a/common/src/main/java/io/druid/collections/OrderedMergeIterator.java b/common/src/main/java/io/druid/collections/OrderedMergeIterator.java
index 7cfc72adefc..a1214379e84 100644
--- a/common/src/main/java/io/druid/collections/OrderedMergeIterator.java
+++ b/common/src/main/java/io/druid/collections/OrderedMergeIterator.java
@@ -75,7 +75,7 @@ public class OrderedMergeIterator<T> implements Iterator<T>
                               new Predicate<Iterator<T>>()
                               {
                                 @Override
-                                public boolean apply(@Nullable Iterator<T> input)
+                                public boolean apply(Iterator<T> input)
                                 {
                                   return input.hasNext();
                                 }
@@ -85,7 +85,7 @@ public class OrderedMergeIterator<T> implements Iterator<T>
                               new Function<Iterator<T>, PeekingIterator<T>>()
                               {
                                 @Override
-                                public PeekingIterator<T> apply(@Nullable Iterator<T> input)
+                                public PeekingIterator<T> apply(Iterator<T> input)
                                 {
                                   return Iterators.peekingIterator(input);
                                 }
diff --git a/common/src/main/java/io/druid/collections/OrderedMergeSequence.java b/common/src/main/java/io/druid/collections/OrderedMergeSequence.java
index 00b1f12d3de..c24404c9a57 100644
--- a/common/src/main/java/io/druid/collections/OrderedMergeSequence.java
+++ b/common/src/main/java/io/druid/collections/OrderedMergeSequence.java
@@ -83,7 +83,7 @@ public class OrderedMergeSequence<T> implements Sequence<T>
             new Function<Yielder<T>, T>()
             {
               @Override
-              public T apply(@Nullable Yielder<T> input)
+              public T apply(Yielder<T> input)
               {
                 return input.get();
               }
diff --git a/common/src/main/java/io/druid/common/utils/JodaUtils.java b/common/src/main/java/io/druid/common/utils/JodaUtils.java
index b488f1e5a7d..db6da04e875 100644
--- a/common/src/main/java/io/druid/common/utils/JodaUtils.java
+++ b/common/src/main/java/io/druid/common/utils/JodaUtils.java
@@ -91,7 +91,7 @@ public class JodaUtils
         intervals, new Predicate<Interval>()
     {
       @Override
-      public boolean apply(@Nullable Interval input)
+      public boolean apply(Interval input)
       {
         return input.overlaps(i);
       }
diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/AppendTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/AppendTask.java
index 40807073874..d2a3c93594c 100644
--- a/indexing-service/src/main/java/io/druid/indexing/common/task/AppendTask.java
+++ b/indexing-service/src/main/java/io/druid/indexing/common/task/AppendTask.java
@@ -97,7 +97,7 @@ public class AppendTask extends MergeTaskBase
               new Predicate<Rowboat>()
               {
                 @Override
-                public boolean apply(@Nullable Rowboat input)
+                public boolean apply(Rowboat input)
                 {
                   return holder.getInterval().contains(input.getTimestamp());
                 }
diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/MergeTaskBase.java b/indexing-service/src/main/java/io/druid/indexing/common/task/MergeTaskBase.java
index 29749501227..7e66991e188 100644
--- a/indexing-service/src/main/java/io/druid/indexing/common/task/MergeTaskBase.java
+++ b/indexing-service/src/main/java/io/druid/indexing/common/task/MergeTaskBase.java
@@ -133,7 +133,7 @@ public abstract class MergeTaskBase extends AbstractFixedIntervalTask
               new Function<DataSegment, String>()
               {
                 @Override
-                public String apply(@Nullable DataSegment input)
+                public String apply(DataSegment input)
                 {
                   return input.getIdentifier();
                 }
diff --git a/indexing-service/src/main/java/io/druid/indexing/firehose/IngestSegmentFirehoseFactory.java b/indexing-service/src/main/java/io/druid/indexing/firehose/IngestSegmentFirehoseFactory.java
index 6987a24e97f..ca496d346ba 100644
--- a/indexing-service/src/main/java/io/druid/indexing/firehose/IngestSegmentFirehoseFactory.java
+++ b/indexing-service/src/main/java/io/druid/indexing/firehose/IngestSegmentFirehoseFactory.java
@@ -236,7 +236,7 @@ public class IngestSegmentFirehoseFactory implements FirehoseFactory<InputRowPar
           {
             @Nullable
             @Override
-            public Sequence<InputRow> apply(@Nullable StorageAdapter adapter)
+            public Sequence<InputRow> apply(StorageAdapter adapter)
             {
               return Sequences.concat(
                   Sequences.map(
@@ -248,7 +248,7 @@ public class IngestSegmentFirehoseFactory implements FirehoseFactory<InputRowPar
                   {
                     @Nullable
                     @Override
-                    public Sequence<InputRow> apply(@Nullable final Cursor cursor)
+                    public Sequence<InputRow> apply(final Cursor cursor)
                     {
                       final TimestampColumnSelector timestampColumnSelector = cursor.makeTimestampColumnSelector();
 
diff --git a/processing/src/main/java/io/druid/query/IntervalChunkingQueryRunner.java b/processing/src/main/java/io/druid/query/IntervalChunkingQueryRunner.java
index 0bf4c3928b0..df4c8596217 100644
--- a/processing/src/main/java/io/druid/query/IntervalChunkingQueryRunner.java
+++ b/processing/src/main/java/io/druid/query/IntervalChunkingQueryRunner.java
@@ -61,7 +61,7 @@ public class IntervalChunkingQueryRunner<T> implements QueryRunner<T>
                 new Function<Interval, Iterable<Interval>>()
                 {
                   @Override
-                  public Iterable<Interval> apply(@Nullable Interval input)
+                  public Iterable<Interval> apply(Interval input)
                   {
                     return splitInterval(input);
                   }
diff --git a/processing/src/main/java/io/druid/query/Queries.java b/processing/src/main/java/io/druid/query/Queries.java
index 3fd1f802189..7691a8f7eb4 100644
--- a/processing/src/main/java/io/druid/query/Queries.java
+++ b/processing/src/main/java/io/druid/query/Queries.java
@@ -49,7 +49,7 @@ public class Queries
               new Function<AggregatorFactory, String>()
               {
                 @Override
-                public String apply(@Nullable AggregatorFactory input)
+                public String apply(AggregatorFactory input)
                 {
                   return input.getName();
                 }
diff --git a/processing/src/main/java/io/druid/query/QueryRunnerHelper.java b/processing/src/main/java/io/druid/query/QueryRunnerHelper.java
index 2765cf0e35c..d9c2e147dda 100644
--- a/processing/src/main/java/io/druid/query/QueryRunnerHelper.java
+++ b/processing/src/main/java/io/druid/query/QueryRunnerHelper.java
@@ -71,7 +71,7 @@ public class QueryRunnerHelper
             new Function<Cursor, Result<T>>()
             {
               @Override
-              public Result<T> apply(@Nullable Cursor input)
+              public Result<T> apply(Cursor input)
               {
                 log.debug("Running over cursor[%s]", adapter.getInterval(), input.getTime());
                 return mapFn.apply(input);
diff --git a/server/src/main/java/io/druid/server/http/DBResource.java b/server/src/main/java/io/druid/server/http/DBResource.java
index 02277f9e79d..24c96d2b8b9 100644
--- a/server/src/main/java/io/druid/server/http/DBResource.java
+++ b/server/src/main/java/io/druid/server/http/DBResource.java
@@ -74,7 +74,7 @@ public class DBResource
             new Function<DruidDataSource, String>()
             {
               @Override
-              public String apply(@Nullable DruidDataSource dataSource)
+              public String apply(DruidDataSource dataSource)
               {
                 return dataSource.getName();
               }
@@ -126,7 +126,7 @@ public class DBResource
             new Function<DataSegment, Object>()
             {
               @Override
-              public Object apply(@Nullable DataSegment segment)
+              public Object apply(DataSegment segment)
               {
                 return segment.getIdentifier();
               }
diff --git a/server/src/main/java/io/druid/server/http/ServersResource.java b/server/src/main/java/io/druid/server/http/ServersResource.java
index ed43c340e8d..3a7b325d202 100644
--- a/server/src/main/java/io/druid/server/http/ServersResource.java
+++ b/server/src/main/java/io/druid/server/http/ServersResource.java
@@ -158,7 +158,7 @@ public class ServersResource
             new Function<DataSegment, String>()
             {
               @Override
-              public String apply(@Nullable DataSegment segment)
+              public String apply(DataSegment segment)
               {
                 return segment.getIdentifier();
               }