fix incorrect nullable annotations

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);
                                 }

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();
               }

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);
       }

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());
                 }

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();
                 }

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();
 

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);
                   }

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();
                 }

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);

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();
               }

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();
               }