diff --git a/indexing-service/src/main/java/io/druid/indexing/common/actions/SegmentMoveAction.java b/indexing-service/src/main/java/io/druid/indexing/common/actions/SegmentMetadataUpdateAction.java similarity index 92% rename from indexing-service/src/main/java/io/druid/indexing/common/actions/SegmentMoveAction.java rename to indexing-service/src/main/java/io/druid/indexing/common/actions/SegmentMetadataUpdateAction.java index c427709c5b3..f996a2c6ab0 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/actions/SegmentMoveAction.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/actions/SegmentMetadataUpdateAction.java @@ -13,13 +13,13 @@ import io.druid.timeline.DataSegment; import java.io.IOException; import java.util.Set; -public class SegmentMoveAction implements TaskAction +public class SegmentMetadataUpdateAction implements TaskAction { @JsonIgnore private final Set segments; @JsonCreator - public SegmentMoveAction( + public SegmentMetadataUpdateAction( @JsonProperty("segments") Set segments ) { @@ -70,7 +70,7 @@ public class SegmentMoveAction implements TaskAction @Override public String toString() { - return "SegmentMoveAction{" + + return "SegmentMetadataUpdateAction{" + "segments=" + segments + '}'; } diff --git a/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskAction.java b/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskAction.java index 1d59e40c6c3..038d06be3c6 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskAction.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskAction.java @@ -36,7 +36,7 @@ import java.io.IOException; @JsonSubTypes.Type(name = "segmentListUsed", value = SegmentListUsedAction.class), @JsonSubTypes.Type(name = "segmentListUnused", value = SegmentListUnusedAction.class), @JsonSubTypes.Type(name = "segmentNuke", value = SegmentNukeAction.class), - @JsonSubTypes.Type(name = "segmentMove", value = SegmentMoveAction.class) + @JsonSubTypes.Type(name = "segmentMetadataUpdate", value = SegmentMetadataUpdateAction.class) }) public interface TaskAction { diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/ArchiveTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/ArchiveTask.java index 43f8fd60e18..97747e211ab 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/task/ArchiveTask.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/task/ArchiveTask.java @@ -29,7 +29,7 @@ import io.druid.indexing.common.TaskLock; import io.druid.indexing.common.TaskStatus; import io.druid.indexing.common.TaskToolbox; import io.druid.indexing.common.actions.SegmentListUnusedAction; -import io.druid.indexing.common.actions.SegmentMoveAction; +import io.druid.indexing.common.actions.SegmentMetadataUpdateAction; import io.druid.timeline.DataSegment; import org.joda.time.Interval; @@ -96,7 +96,7 @@ public class ArchiveTask extends AbstractFixedIntervalTask // Update metadata for moved segments toolbox.getTaskActionClient().submit( - new SegmentMoveAction( + new SegmentMetadataUpdateAction( ImmutableSet.copyOf(archivedSegments) ) ); diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java index c8742f31c34..371f0dc38a4 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java @@ -30,7 +30,7 @@ import io.druid.indexing.common.TaskLock; import io.druid.indexing.common.TaskStatus; import io.druid.indexing.common.TaskToolbox; import io.druid.indexing.common.actions.SegmentListUnusedAction; -import io.druid.indexing.common.actions.SegmentMoveAction; +import io.druid.indexing.common.actions.SegmentMetadataUpdateAction; import io.druid.timeline.DataSegment; import org.joda.time.Interval; @@ -106,7 +106,7 @@ public class MoveTask extends AbstractFixedIntervalTask } // Update metadata for moved segments - toolbox.getTaskActionClient().submit(new SegmentMoveAction( + toolbox.getTaskActionClient().submit(new SegmentMetadataUpdateAction( ImmutableSet.copyOf(movedSegments) ));