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

Merge pull request #2548 from metamx/moreLoggingJDBCNamespace 

More logging for JDBCExtractionNamespaceFunctionFactory
This commit is contained in:
Fangjin Yang 2016-02-25 17:13:20 -08:00
parent 53a5f07c14 a8820d837b
commit 3691fbd849
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
extensions/namespace-lookup/src/main/java/io/druid/server/namespace/JDBCExtractionNamespaceFunctionFactory.java
View File

@ -25,6 +25,7 @@ import com.google.common.base.Strings;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.metamx.common.Pair; import com.metamx.common.Pair;
import com.metamx.common.logger.Logger;
import io.druid.common.utils.JodaUtils; import io.druid.common.utils.JodaUtils;
import io.druid.query.extraction.namespace.ExtractionNamespaceFunctionFactory; import io.druid.query.extraction.namespace.ExtractionNamespaceFunctionFactory;
import io.druid.query.extraction.namespace.JDBCExtractionNamespace; import io.druid.query.extraction.namespace.JDBCExtractionNamespace;
@ -51,6 +52,7 @@ import java.util.concurrent.ConcurrentMap;
public class JDBCExtractionNamespaceFunctionFactory public class JDBCExtractionNamespaceFunctionFactory
implements ExtractionNamespaceFunctionFactory<JDBCExtractionNamespace> implements ExtractionNamespaceFunctionFactory<JDBCExtractionNamespace>
{ {
private static final Logger LOG = new Logger(JDBCExtractionNamespaceFunctionFactory.class);
private final ConcurrentMap<String, DBI> dbiCache = new ConcurrentHashMap<>(); private final ConcurrentMap<String, DBI> dbiCache = new ConcurrentHashMap<>();
@Override @Override
@ -121,6 +123,7 @@ public class JDBCExtractionNamespaceFunctionFactory
final String valueColumn = namespace.getValueColumn(); final String valueColumn = namespace.getValueColumn();
final String keyColumn = namespace.getKeyColumn(); final String keyColumn = namespace.getKeyColumn();
LOG.debug("Updating [%s]", namespace.getNamespace());
final List<Pair<String, String>> pairs = dbi.withHandle( final List<Pair<String, String>> pairs = dbi.withHandle(
new HandleCallback<List<Pair<String, String>>>() new HandleCallback<List<Pair<String, String>>>()
{ {
@ -158,6 +161,7 @@ public class JDBCExtractionNamespaceFunctionFactory
for (Pair<String, String> pair : pairs) { for (Pair<String, String> pair : pairs) {
cache.put(pair.lhs, pair.rhs); cache.put(pair.lhs, pair.rhs);
} }
LOG.info("Finished loading %d values for namespace[%s]", cache.size(), namespace.getNamespace());
return String.format("%d", System.currentTimeMillis()); return String.format("%d", System.currentTimeMillis());
} }
}; };