IGNITE-4277: Hadoop: better property naming for "partially raw" comparator.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f8ac0f14 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f8ac0f14 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f8ac0f14 Branch: refs/heads/master Commit: f8ac0f14986169ee25159734d0a97b08976c5751 Parents: c1ddf21 Author: devozerov <[email protected]> Authored: Thu Dec 15 12:13:10 2016 +0300 Committer: devozerov <[email protected]> Committed: Thu Dec 15 13:46:46 2016 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/hadoop/HadoopJobProperty.java | 4 ++-- .../internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java | 2 +- .../internal/processors/hadoop/impl/HadoopTeraSortTest.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f8ac0f14/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobProperty.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobProperty.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobProperty.java index 4122eef..9dd430b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobProperty.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/HadoopJobProperty.java @@ -64,9 +64,9 @@ public enum HadoopJobProperty { JOB_SHARED_CLASSLOADER("ignite.job.shared.classloader"), /** - * Fully qualified name of partially-raw comparator which should be used on sorting phase. + * Fully qualified name of partially raw comparator which should be used on sorting phase. */ - JOB_PARTIAL_RAW_COMPARATOR("ignite.job.partial.raw.comparator"), + JOB_PARTIALLY_RAW_COMPARATOR("ignite.job.partially.raw.comparator"), /** * Size in bytes of single memory page which will be allocated for data structures in shuffle. http://git-wip-us.apache.org/repos/asf/ignite/blob/f8ac0f14/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java index 42bbec5..e9cae1c 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java @@ -433,7 +433,7 @@ public class HadoopV2TaskContext extends HadoopTaskContext { /** {@inheritDoc} */ @SuppressWarnings("unchecked") @Override public PartiallyOffheapRawComparatorEx<Object> partialRawSortComparator() { - Class cls = jobCtx.getJobConf().getClass(HadoopJobProperty.JOB_PARTIAL_RAW_COMPARATOR.propertyName(), null); + Class cls = jobCtx.getJobConf().getClass(HadoopJobProperty.JOB_PARTIALLY_RAW_COMPARATOR.propertyName(), null); if (cls == null) return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/f8ac0f14/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopTeraSortTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopTeraSortTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopTeraSortTest.java index a016506..b1fa91f 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopTeraSortTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopTeraSortTest.java @@ -165,7 +165,7 @@ public class HadoopTeraSortTest extends HadoopAbstractSelfTest { jobConf.setBoolean(HadoopJobProperty.SHUFFLE_MAPPER_STRIPED_OUTPUT.propertyName(), true); - jobConf.set(HadoopJobProperty.JOB_PARTIAL_RAW_COMPARATOR.propertyName(), + jobConf.set(HadoopJobProperty.JOB_PARTIALLY_RAW_COMPARATOR.propertyName(), TextPartiallyRawComparator.class.getName()); Job job = setupConfig(jobConf);
