From 4a291fdf3094886e20d65b87554a6a5debd0a4f6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= Date: Wed, 11 Dec 2013 17:25:17 -0800 Subject: [PATCH] better naming --- .../io/druid/indexing/common/actions/SegmentMoveAction.java | 2 +- .../io/druid/indexing/overlord/IndexerDBCoordinator.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) 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/SegmentMoveAction.java index 67db4fc79be..c427709c5b3 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/SegmentMoveAction.java @@ -46,7 +46,7 @@ public class SegmentMoveAction implements TaskAction throw new ISE("Segments not covered by locks for task: %s", task.getId()); } - toolbox.getIndexerDBCoordinator().moveSegments(segments); + toolbox.getIndexerDBCoordinator().updateSegmentMetadata(segments); // Emit metrics final ServiceMetricEvent.Builder metricBuilder = new ServiceMetricEvent.Builder() diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/IndexerDBCoordinator.java b/indexing-service/src/main/java/io/druid/indexing/overlord/IndexerDBCoordinator.java index 943e63fa821..f9db89b3fc9 100644 --- a/indexing-service/src/main/java/io/druid/indexing/overlord/IndexerDBCoordinator.java +++ b/indexing-service/src/main/java/io/druid/indexing/overlord/IndexerDBCoordinator.java @@ -211,7 +211,7 @@ public class IndexerDBCoordinator return true; } - public void moveSegments(final Set segments) throws IOException + public void updateSegmentMetadata(final Set segments) throws IOException { dbi.inTransaction( new TransactionCallback() @@ -220,7 +220,7 @@ public class IndexerDBCoordinator public Void inTransaction(Handle handle, TransactionStatus transactionStatus) throws Exception { for(final DataSegment segment : segments) { - moveSegment(handle, segment); + updatePayload(handle, segment); } return null; @@ -256,7 +256,7 @@ public class IndexerDBCoordinator .execute(); } - private void moveSegment(final Handle handle, final DataSegment segment) throws IOException + private void updatePayload(final Handle handle, final DataSegment segment) throws IOException { try { handle.createStatement(