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

return immutable list of modules from getJacksonModules

This commit is contained in:
fjy 2013-11-11 16:13:32 -08:00
parent 9be644847e
commit 2631c016c7
4 changed files with 26 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/config/realtime/runtime.properties
View File

@ -4,7 +4,7 @@ druid.port=8083
druid.zk.service.host=localhost
druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.10"]
druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.10","io.druid.extensions:druid-kafka-seven:0.6.10"]
druid.db.connector.connectURI=jdbc\:mysql\://localhost\:3306/druid
druid.db.connector.user=druid

4
kafka-eight/src/main/java/io/druid/firehose/kafka/KafkaEightDruidModule.java
View File

@ -22,10 +22,10 @@ package io.druid.firehose.kafka;
import com.fasterxml.jackson.databind.Module;
import com.fasterxml.jackson.databind.jsontype.NamedType;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.google.common.collect.ImmutableList;
import com.google.inject.Binder;
import io.druid.initialization.DruidModule;
import java.util.Arrays;
import java.util.List;
/**
@ -35,7 +35,7 @@ public class KafkaEightDruidModule implements DruidModule
@Override
public List<? extends Module> getJacksonModules()
{
return Arrays.<Module>asList(
return ImmutableList.of(
new SimpleModule("KafkaEightFirehoseModule")
.registerSubtypes(
new NamedType(KafkaEightFirehoseFactory.class, "kafka-0.8")

4
kafka-seven/src/main/java/io/druid/firehose/kafka/KafkaSevenDruidModule.java
View File

@ -22,10 +22,10 @@ package io.druid.firehose.kafka;
import com.fasterxml.jackson.databind.Module;
import com.fasterxml.jackson.databind.jsontype.NamedType;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.google.common.collect.ImmutableList;
import com.google.inject.Binder;
import io.druid.initialization.DruidModule;
import java.util.Arrays;
import java.util.List;
/**
@ -35,7 +35,7 @@ public class KafkaSevenDruidModule implements DruidModule
@Override
public List<? extends Module> getJacksonModules()
{
return Arrays.<Module>asList(
return ImmutableList.of(
new SimpleModule("KafkaSevenFirehoseModule")
.registerSubtypes(
new NamedType(KafkaSevenFirehoseFactory.class, "kafka-0.7.2")

6
pom.xml
View File

@ -18,7 +18,8 @@
~ Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>io.druid</groupId>
<artifactId>druid</artifactId>
@ -30,7 +31,7 @@
<connection>scm:git:ssh://git@github.com/metamx/druid.git</connection>
<developerConnection>scm:git:ssh://git@github.com/metamx/druid.git</developerConnection>
<url>http://www.github.com/metamx/druid</url>
<tag>druid-0.6.10-SNAPSHOT</tag>
<tag>${artifactId}-${project.version}</tag>
</scm>
<prerequisites>
@ -56,6 +57,7 @@
<module>hdfs-storage</module>
<module>s3-extensions</module>
<module>kafka-seven</module>
<module>kafka-eight</module>
</modules>
<dependencyManagement>