remove unused columnConfig

This commit is contained in:
Xavier Léauté 2014-09-15 13:02:47 -07:00
parent 0712c666cb
commit d501b052ea
1 changed files with 0 additions and 7 deletions

View File

@ -170,7 +170,6 @@ public class HadoopDruidIndexerConfig
private volatile HadoopIngestionSpec schema; private volatile HadoopIngestionSpec schema;
private volatile PathSpec pathSpec; private volatile PathSpec pathSpec;
private volatile ColumnConfig columnConfig;
private volatile Map<DateTime,ShardSpecLookup> shardSpecLookups = Maps.newHashMap(); private volatile Map<DateTime,ShardSpecLookup> shardSpecLookups = Maps.newHashMap();
private volatile Map<ShardSpec, HadoopyShardSpec> hadoopShardSpecLookup = Maps.newHashMap(); private volatile Map<ShardSpec, HadoopyShardSpec> hadoopShardSpecLookup = Maps.newHashMap();
@ -179,7 +178,6 @@ public class HadoopDruidIndexerConfig
final @JsonProperty("schema") HadoopIngestionSpec schema final @JsonProperty("schema") HadoopIngestionSpec schema
) )
{ {
this.columnConfig = columnConfig;
this.schema = schema; this.schema = schema;
this.pathSpec = jsonMapper.convertValue(schema.getIOConfig().getPathSpec(), PathSpec.class); this.pathSpec = jsonMapper.convertValue(schema.getIOConfig().getPathSpec(), PathSpec.class);
for (Map.Entry<DateTime, List<HadoopyShardSpec>> entry : schema.getTuningConfig().getShardSpecs().entrySet()) { for (Map.Entry<DateTime, List<HadoopyShardSpec>> entry : schema.getTuningConfig().getShardSpecs().entrySet()) {
@ -213,11 +211,6 @@ public class HadoopDruidIndexerConfig
return schema; return schema;
} }
public ColumnConfig getColumnConfig()
{
return columnConfig;
}
public String getDataSource() public String getDataSource()
{ {
return schema.getDataSchema().getDataSource(); return schema.getDataSchema().getDataSource();