Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix broken UT

This commit is contained in:
fjy 2014-07-17 14:39:52 -07:00
parent 8ef380b3f9
commit 465ac77b82
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/src/test/java/io/druid/realtime/firehose/CombiningFirehoseFactoryTest.java
View File

@ -24,9 +24,11 @@ import com.metamx.common.parsers.ParseException;
import io.druid.data.input.Firehose; import io.druid.data.input.Firehose;
import io.druid.data.input.FirehoseFactory; import io.druid.data.input.FirehoseFactory;
import io.druid.data.input.InputRow; import io.druid.data.input.InputRow;
import io.druid.data.input.Row;
import io.druid.data.input.impl.InputRowParser; import io.druid.data.input.impl.InputRowParser;
import io.druid.segment.realtime.firehose.CombiningFirehoseFactory; import io.druid.segment.realtime.firehose.CombiningFirehoseFactory;
import io.druid.utils.Runnables; import io.druid.utils.Runnables;
import org.joda.time.DateTime;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
@ -76,6 +78,18 @@ public class CombiningFirehoseFactoryTest
return timestamp; return timestamp;
} }
@Override
public DateTime getTimestamp()
{
return new DateTime(timestamp);
}
@Override
public int compareTo(Row o)
{
return 0;
}
@Override @Override
public List<String> getDimension(String dimension) public List<String> getDimension(String dimension)
{ {