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

remove dead code

This commit is contained in:
fjy 2014-02-27 15:52:19 -08:00
parent 77d3e25083
commit 13c7f1c7b1
1 changed files with 0 additions and 72 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
indexing-hadoop/src/main/java/io/druid/indexer/HadoopIngestionSchema.java
View File

@ -50,59 +50,6 @@ import java.util.Map;
*/ */
public class HadoopIngestionSchema extends IngestionSchema<HadoopIOConfig, HadoopDriverConfig> public class HadoopIngestionSchema extends IngestionSchema<HadoopIOConfig, HadoopDriverConfig>
{ {
public static HadoopIngestionSchema convertLegacy(
String dataSource,
TimestampSpec timestampSpec,
DataSpec dataSpec,
GranularitySpec granularitySpec,
Map<String, Object> pathSpec,
String workingPath,
String segmentOutputPath,
String version,
PartitionsSpec partitionsSpec,
boolean leaveIntermediate,
Boolean cleanupOnFailure,
Map<DateTime, List<HadoopyShardSpec>> shardSpecs,
boolean overwriteFiles,
DataRollupSpec rollupSpec,
DbUpdaterJobSpec updaterJobSpec,
boolean ignoreInvalidRows,
// These fields are deprecated and will be removed in the future
String timestampColumn,
String timestampFormat,
List<Interval> intervals,
Granularity segmentGranularity,
String partitionDimension,
Long targetPartitionSize
)
{
return new HadoopIngestionSchema(
null, null, null,
dataSource,
timestampSpec,
dataSpec,
granularitySpec,
pathSpec,
workingPath,
segmentOutputPath,
version,
partitionsSpec,
leaveIntermediate,
cleanupOnFailure,
shardSpecs,
overwriteFiles,
rollupSpec,
updaterJobSpec,
ignoreInvalidRows,
timestampColumn,
timestampFormat,
intervals,
segmentGranularity,
partitionDimension,
targetPartitionSize
);
}
private final DataSchema dataSchema; private final DataSchema dataSchema;
private final HadoopIOConfig ioConfig; private final HadoopIOConfig ioConfig;
private final HadoopDriverConfig driverConfig; private final HadoopDriverConfig driverConfig;
@ -156,25 +103,6 @@ public class HadoopIngestionSchema extends IngestionSchema<HadoopIOConfig, Hadoo
dimensionExclusions.add(aggregatorFactory.getName()); dimensionExclusions.add(aggregatorFactory.getName());
} }
} }
//
//if (dataSpec.hasCustomDimensions()) {
// dimensionExclusions = null;
//} else {
// dimensionExclusions = Lists.newArrayList();
// dimensionExclusions.add(theTimestampSpec.getTimestampColumn());
// dimensionExclusions.addAll(
// Lists.transform(
// rollupSpec.getAggs(), new Function<AggregatorFactory, String>()
// {
// @Override
// public String apply(AggregatorFactory aggregatorFactory)
// {
// return aggregatorFactory.getName();
// }
// }
// )
// );
//}
PartitionsSpec thePartitionSpec; PartitionsSpec thePartitionSpec;
if (partitionsSpec != null) { if (partitionsSpec != null) {