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

Remove parser in the constructor of statics3 firehose as it is no longer needed with the new ingestion schemas

This commit is contained in:
Nick Tate 2015-01-20 10:44:12 -05:00 committed by fjy
parent 91a79dbf95
commit dd9b646037
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
extensions/s3-extensions/src/main/java/io/druid/firehose/s3/StaticS3FirehoseFactory.java
View File

@ -56,18 +56,15 @@ public class StaticS3FirehoseFactory implements FirehoseFactory<StringInputRowPa
private static final Logger log = new Logger(StaticS3FirehoseFactory.class);
private final RestS3Service s3Client;
private final StringInputRowParser parser;
private final List<URI> uris;
@JsonCreator
public StaticS3FirehoseFactory(
@JacksonInject("s3Client") RestS3Service s3Client,
@JsonProperty("parser") StringInputRowParser parser,
@JsonProperty("uris") List<URI> uris
)
{
this.s3Client = s3Client;
this.parser = Preconditions.checkNotNull(parser, "parser");
this.uris = ImmutableList.copyOf(uris);
for (final URI inputURI : uris) {
@ -75,12 +72,6 @@ public class StaticS3FirehoseFactory implements FirehoseFactory<StringInputRowPa
}
}
@JsonProperty
public StringInputRowParser getParser()
{
return parser;
}
@JsonProperty
public List<URI> getUris()
{
@ -151,7 +142,7 @@ public class StaticS3FirehoseFactory implements FirehoseFactory<StringInputRowPa
throw new UnsupportedOperationException();
}
},
(StringInputRowParser) firehoseParser
firehoseParser
);
}
}