diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/HadoopIngestionSchema.java b/indexing-hadoop/src/main/java/io/druid/indexer/HadoopIngestionSchema.java index 88f4f005ed4..acf9c7b557e 100644 --- a/indexing-hadoop/src/main/java/io/druid/indexer/HadoopIngestionSchema.java +++ b/indexing-hadoop/src/main/java/io/druid/indexer/HadoopIngestionSchema.java @@ -50,59 +50,6 @@ import java.util.Map; */ public class HadoopIngestionSchema extends IngestionSchema { - public static HadoopIngestionSchema convertLegacy( - String dataSource, - TimestampSpec timestampSpec, - DataSpec dataSpec, - GranularitySpec granularitySpec, - Map pathSpec, - String workingPath, - String segmentOutputPath, - String version, - PartitionsSpec partitionsSpec, - boolean leaveIntermediate, - Boolean cleanupOnFailure, - Map> 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 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 HadoopIOConfig ioConfig; private final HadoopDriverConfig driverConfig; @@ -156,25 +103,6 @@ public class HadoopIngestionSchema extends IngestionSchema() - // { - // @Override - // public String apply(AggregatorFactory aggregatorFactory) - // { - // return aggregatorFactory.getName(); - // } - // } - // ) - // ); - //} PartitionsSpec thePartitionSpec; if (partitionsSpec != null) {