Skip to content

Instantly share code, notes, and snippets.

View guobingkun's full-sized avatar

Bingkun Guo guobingkun

View GitHub Profile
@guobingkun
guobingkun / gist:6025d9b0afa3edfe8e6e
Created August 14, 2015 14:35
index_realtime_wikipedia_index_test_0_2015-08-13T22:32:22.830Z_bialmpie log
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/home/y/libexec/druid_dev/log4j-slf4j-impl-2.2.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/y/share/hadoop-2.5.0.8.1411070359/share/hadoop/common/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2015-08-13T22:32:24,077 INFO [main] io.druid.guice.PropertiesModule - Loading properties from runtime.properties
2015-08-13T22:32:24,131 INFO [main] org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 5.1.3.Final
2015-08-13T22:32:24,811 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.guice.ExtensionsConfig] from props[druid.extensions.] as [ExtensionsConfig{searchCurrentClassloader=true, coordinates=[], defaultVersion='0.8.1-1439503961-819aa08-3', localRepository='
SegID: 1 2 3
Shard0: |_S_|_O_|_S_|
public class DruidCoordinatorConfig
{
//
// skipping other exisiting configs
//
/*
I was thinking JsonConfigProvider.bind("druid.coordinator", DruidCoordinatorConfig.class)
could magically recursively deserialize DruidCoordinatorHadoopMergeConfig using properties
starting with "druid.coordinator.hadoopMerge".
package io.druid.client.indexing;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.google.common.collect.ImmutableMap;
import io.druid.granularity.QueryGranularity;
import io.druid.query.aggregation.AggregatorFactory;
import io.druid.segment.indexing.granularity.ArbitraryGranularitySpec;
import io.druid.segment.indexing.granularity.GranularitySpec;
import org.joda.time.Interval;
/**
* This interface is only used internally for discovering Druid servers in the cluster, its implementation should not
* involve any external announcement or discovery, and should never change the state of a Druid cluster.
*/
public interface DruidServerDiscovery
{
/**
* Find all the Druid servers that have the specified type
*