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

cleanup rowflushboundary

This commit is contained in:
fjy 2014-08-20 13:09:37 -07:00
parent 8933685884
commit 92f26d9a1f
2 changed files with 0 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
indexing-hadoop/src/main/java/io/druid/indexer/rollup/DataRollupSpec.java
View File

@ -38,9 +38,6 @@ public class DataRollupSpec
@JsonProperty @JsonProperty
public QueryGranularity rollupGranularity = QueryGranularity.NONE; public QueryGranularity rollupGranularity = QueryGranularity.NONE;
@JsonProperty
public int rowFlushBoundary = 500000;
public DataRollupSpec() {} public DataRollupSpec() {}
public DataRollupSpec(List<AggregatorFactory> aggs, QueryGranularity rollupGranularity) public DataRollupSpec(List<AggregatorFactory> aggs, QueryGranularity rollupGranularity)

10
indexing-service/src/main/java/io/druid/indexing/common/config/TaskConfig.java
View File

@ -41,9 +41,6 @@ public class TaskConfig
@JsonProperty @JsonProperty
private final String hadoopWorkingPath; private final String hadoopWorkingPath;
@JsonProperty
private final int defaultRowFlushBoundary;
@JsonProperty @JsonProperty
private final List<String> defaultHadoopCoordinates; private final List<String> defaultHadoopCoordinates;
@ -59,7 +56,6 @@ public class TaskConfig
this.baseDir = baseDir == null ? "/tmp" : baseDir; this.baseDir = baseDir == null ? "/tmp" : baseDir;
this.baseTaskDir = new File(defaultDir(baseTaskDir, "persistent/task")); this.baseTaskDir = new File(defaultDir(baseTaskDir, "persistent/task"));
this.hadoopWorkingPath = defaultDir(hadoopWorkingPath, "druid-indexing"); this.hadoopWorkingPath = defaultDir(hadoopWorkingPath, "druid-indexing");
this.defaultRowFlushBoundary = defaultRowFlushBoundary == null ? 500000 : defaultRowFlushBoundary;
this.defaultHadoopCoordinates = defaultHadoopCoordinates == null this.defaultHadoopCoordinates = defaultHadoopCoordinates == null
? DEFAULT_DEFAULT_HADOOP_COORDINATES ? DEFAULT_DEFAULT_HADOOP_COORDINATES
: defaultHadoopCoordinates; : defaultHadoopCoordinates;
@ -83,12 +79,6 @@ public class TaskConfig
return hadoopWorkingPath; return hadoopWorkingPath;
} }
@JsonProperty
public int getDefaultRowFlushBoundary()
{
return defaultRowFlushBoundary;
}
@JsonProperty @JsonProperty
public List<String> getDefaultHadoopCoordinates() public List<String> getDefaultHadoopCoordinates()
{ {