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

add more logging

This commit is contained in:
fjy 2014-10-01 09:13:59 -07:00
parent c3bea245a7
commit 4fc0382d8a
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/main/java/io/druid/segment/realtime/firehose/LocalFirehoseFactory.java
View File

@ -24,6 +24,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
import com.google.api.client.repackaged.com.google.common.base.Throwables; import com.google.api.client.repackaged.com.google.common.base.Throwables;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.metamx.common.ISE; import com.metamx.common.ISE;
import com.metamx.emitter.EmittingLogger;
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.impl.FileIteratingFirehose; import io.druid.data.input.impl.FileIteratingFirehose;
@ -43,6 +44,8 @@ import java.util.LinkedList;
*/ */
public class LocalFirehoseFactory implements FirehoseFactory<StringInputRowParser> public class LocalFirehoseFactory implements FirehoseFactory<StringInputRowParser>
{ {
private static final EmittingLogger log = new EmittingLogger(LocalFirehoseFactory.class);
private final File baseDir; private final File baseDir;
private final String filter; private final String filter;
private final StringInputRowParser parser; private final StringInputRowParser parser;
@ -80,6 +83,8 @@ public class LocalFirehoseFactory implements FirehoseFactory<StringInputRowParse
@Override @Override
public Firehose connect(StringInputRowParser firehoseParser) throws IOException public Firehose connect(StringInputRowParser firehoseParser) throws IOException
{ {
log.info("Searching for all [%s] in [%s]", filter, baseDir.getAbsoluteFile());
Collection<File> foundFiles = FileUtils.listFiles( Collection<File> foundFiles = FileUtils.listFiles(
baseDir.getAbsoluteFile(), baseDir.getAbsoluteFile(),
new WildcardFileFilter(filter), new WildcardFileFilter(filter),