This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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=' |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
SegID: 1 2 3 | |
Shard0: |_S_|_O_|_S_| |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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". |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* 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 | |
* |