[03/26] hbase git commit: HBASE-19575 add copy constructor to Mutation
HBASE-19575 add copy constructor to Mutation Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/59baf12c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/59baf12c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/59baf12c Branch: refs/heads/HBASE-19397 Commit: 59baf12c03303dab2a69352d5f35d38bd464d943 Parents: 6cefabe Author: Chia-Ping TsaiAuthored: Fri Dec 22 03:13:03 2017 +0800 Committer: Chia-Ping Tsai Committed: Fri Dec 22 03:24:43 2017 +0800 -- .../org/apache/hadoop/hbase/client/Append.java | 32 ++- .../org/apache/hadoop/hbase/client/Delete.java | 32 ++- .../apache/hadoop/hbase/client/Increment.java | 32 ++- .../apache/hadoop/hbase/client/Mutation.java| 45 +++- .../hbase/client/OperationWithAttributes.java | 21 +- .../org/apache/hadoop/hbase/client/Put.java | 30 ++- .../hadoop/hbase/client/TestMutation.java | 239 +++ .../org/apache/hadoop/hbase/client/TestPut.java | 125 -- .../hbase/regionserver/TestMetricsRegion.java | 2 +- 9 files changed, 387 insertions(+), 171 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/59baf12c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java index 24e9512..0cb51a2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java @@ -112,17 +112,11 @@ public class Append extends Mutation { } /** * Copy constructor - * @param a + * @param appendToCopy append to copy */ - public Append(Append a) { -this.row = a.getRow(); -this.ts = a.getTimeStamp(); -this.tr = a.getTimeRange(); -this.familyMap.putAll(a.getFamilyCellMap()); -for (Map.Entry entry : a.getAttributesMap().entrySet()) { - this.setAttribute(entry.getKey(), entry.getValue()); -} -this.setPriority(a.getPriority()); + public Append(Append appendToCopy) { +super(appendToCopy); +this.tr = appendToCopy.getTimeRange(); } /** Create a Append operation for the specified row. @@ -138,6 +132,18 @@ public class Append extends Mutation { } /** + * Construct the Append with user defined data. NOTED: + * 1) all cells in the familyMap must have the DataType.Put + * 2) the row of each cell must be same with passed row. + * @param row row. CAN'T be null + * @param ts timestamp + * @param familyMap the map to collect all cells internally. CAN'T be null + */ + public Append(byte[] row, long ts, NavigableMap> familyMap) { +super(row, ts, familyMap); + } + + /** * Add the specified column and value to this Append operation. * @param family family name * @param qualifier column qualifier @@ -202,6 +208,12 @@ public class Append extends Mutation { return (Append) super.setDurability(d); } + /** + * Method for setting the Append's familyMap + * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0. + * Use {@link Append#Append(byte[], long, NavigableMap)} instead + */ + @Deprecated @Override public Append setFamilyCellMap(NavigableMap map) { return (Append) super.setFamilyCellMap(map); http://git-wip-us.apache.org/repos/asf/hbase/blob/59baf12c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java index 2d296fb..57f5648 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java @@ -135,17 +135,23 @@ public class Delete extends Mutation implements Comparable { } /** - * @param d Delete to clone. + * @param deleteToCopy delete to copy */ - public Delete(final Delete d) { -this.row = d.getRow(); -this.ts = d.getTimeStamp(); -this.familyMap.putAll(d.getFamilyCellMap()); -this.durability = d.durability; -for (Map.Entry entry : d.getAttributesMap().entrySet()) { - this.setAttribute(entry.getKey(), entry.getValue()); -} -super.setPriority(d.getPriority()); + public Delete(final Delete deleteToCopy) { +super(deleteToCopy); + } + + /** + * Construct the Delete with user defined data. NOTED: + * 1) all cells in the familyMap must have the delete type. + * see
hbase git commit: HBASE-19575 add copy constructor to Mutation
Repository: hbase Updated Branches: refs/heads/master 6cefabee2 -> 59baf12c0 HBASE-19575 add copy constructor to Mutation Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/59baf12c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/59baf12c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/59baf12c Branch: refs/heads/master Commit: 59baf12c03303dab2a69352d5f35d38bd464d943 Parents: 6cefabe Author: Chia-Ping TsaiAuthored: Fri Dec 22 03:13:03 2017 +0800 Committer: Chia-Ping Tsai Committed: Fri Dec 22 03:24:43 2017 +0800 -- .../org/apache/hadoop/hbase/client/Append.java | 32 ++- .../org/apache/hadoop/hbase/client/Delete.java | 32 ++- .../apache/hadoop/hbase/client/Increment.java | 32 ++- .../apache/hadoop/hbase/client/Mutation.java| 45 +++- .../hbase/client/OperationWithAttributes.java | 21 +- .../org/apache/hadoop/hbase/client/Put.java | 30 ++- .../hadoop/hbase/client/TestMutation.java | 239 +++ .../org/apache/hadoop/hbase/client/TestPut.java | 125 -- .../hbase/regionserver/TestMetricsRegion.java | 2 +- 9 files changed, 387 insertions(+), 171 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/59baf12c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java index 24e9512..0cb51a2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java @@ -112,17 +112,11 @@ public class Append extends Mutation { } /** * Copy constructor - * @param a + * @param appendToCopy append to copy */ - public Append(Append a) { -this.row = a.getRow(); -this.ts = a.getTimeStamp(); -this.tr = a.getTimeRange(); -this.familyMap.putAll(a.getFamilyCellMap()); -for (Map.Entry entry : a.getAttributesMap().entrySet()) { - this.setAttribute(entry.getKey(), entry.getValue()); -} -this.setPriority(a.getPriority()); + public Append(Append appendToCopy) { +super(appendToCopy); +this.tr = appendToCopy.getTimeRange(); } /** Create a Append operation for the specified row. @@ -138,6 +132,18 @@ public class Append extends Mutation { } /** + * Construct the Append with user defined data. NOTED: + * 1) all cells in the familyMap must have the DataType.Put + * 2) the row of each cell must be same with passed row. + * @param row row. CAN'T be null + * @param ts timestamp + * @param familyMap the map to collect all cells internally. CAN'T be null + */ + public Append(byte[] row, long ts, NavigableMap> familyMap) { +super(row, ts, familyMap); + } + + /** * Add the specified column and value to this Append operation. * @param family family name * @param qualifier column qualifier @@ -202,6 +208,12 @@ public class Append extends Mutation { return (Append) super.setDurability(d); } + /** + * Method for setting the Append's familyMap + * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0. + * Use {@link Append#Append(byte[], long, NavigableMap)} instead + */ + @Deprecated @Override public Append setFamilyCellMap(NavigableMap map) { return (Append) super.setFamilyCellMap(map); http://git-wip-us.apache.org/repos/asf/hbase/blob/59baf12c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java index 2d296fb..57f5648 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java @@ -135,17 +135,23 @@ public class Delete extends Mutation implements Comparable { } /** - * @param d Delete to clone. + * @param deleteToCopy delete to copy */ - public Delete(final Delete d) { -this.row = d.getRow(); -this.ts = d.getTimeStamp(); -this.familyMap.putAll(d.getFamilyCellMap()); -this.durability = d.durability; -for (Map.Entry entry : d.getAttributesMap().entrySet()) { - this.setAttribute(entry.getKey(), entry.getValue()); -} -super.setPriority(d.getPriority()); + public Delete(final Delete deleteToCopy) { +super(deleteToCopy); + } + + /** + * Construct the Delete with user defined data. NOTED: +
hbase git commit: HBASE-19575 add copy constructor to Mutation
Repository: hbase Updated Branches: refs/heads/branch-2 a28156be9 -> 4aec7a491 HBASE-19575 add copy constructor to Mutation Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4aec7a49 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4aec7a49 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4aec7a49 Branch: refs/heads/branch-2 Commit: 4aec7a491a15edac33bcb192f8c347b299b3990c Parents: a28156b Author: Chia-Ping TsaiAuthored: Fri Dec 22 03:13:03 2017 +0800 Committer: Chia-Ping Tsai Committed: Fri Dec 22 03:19:47 2017 +0800 -- .../org/apache/hadoop/hbase/client/Append.java | 32 ++- .../org/apache/hadoop/hbase/client/Delete.java | 32 ++- .../apache/hadoop/hbase/client/Increment.java | 32 ++- .../apache/hadoop/hbase/client/Mutation.java| 45 +++- .../hbase/client/OperationWithAttributes.java | 21 +- .../org/apache/hadoop/hbase/client/Put.java | 30 ++- .../hadoop/hbase/client/TestMutation.java | 239 +++ .../org/apache/hadoop/hbase/client/TestPut.java | 125 -- .../hbase/regionserver/TestMetricsRegion.java | 2 +- 9 files changed, 387 insertions(+), 171 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/4aec7a49/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java index 24e9512..0cb51a2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Append.java @@ -112,17 +112,11 @@ public class Append extends Mutation { } /** * Copy constructor - * @param a + * @param appendToCopy append to copy */ - public Append(Append a) { -this.row = a.getRow(); -this.ts = a.getTimeStamp(); -this.tr = a.getTimeRange(); -this.familyMap.putAll(a.getFamilyCellMap()); -for (Map.Entry entry : a.getAttributesMap().entrySet()) { - this.setAttribute(entry.getKey(), entry.getValue()); -} -this.setPriority(a.getPriority()); + public Append(Append appendToCopy) { +super(appendToCopy); +this.tr = appendToCopy.getTimeRange(); } /** Create a Append operation for the specified row. @@ -138,6 +132,18 @@ public class Append extends Mutation { } /** + * Construct the Append with user defined data. NOTED: + * 1) all cells in the familyMap must have the DataType.Put + * 2) the row of each cell must be same with passed row. + * @param row row. CAN'T be null + * @param ts timestamp + * @param familyMap the map to collect all cells internally. CAN'T be null + */ + public Append(byte[] row, long ts, NavigableMap> familyMap) { +super(row, ts, familyMap); + } + + /** * Add the specified column and value to this Append operation. * @param family family name * @param qualifier column qualifier @@ -202,6 +208,12 @@ public class Append extends Mutation { return (Append) super.setDurability(d); } + /** + * Method for setting the Append's familyMap + * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0. + * Use {@link Append#Append(byte[], long, NavigableMap)} instead + */ + @Deprecated @Override public Append setFamilyCellMap(NavigableMap map) { return (Append) super.setFamilyCellMap(map); http://git-wip-us.apache.org/repos/asf/hbase/blob/4aec7a49/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java index 2d296fb..57f5648 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java @@ -135,17 +135,23 @@ public class Delete extends Mutation implements Comparable { } /** - * @param d Delete to clone. + * @param deleteToCopy delete to copy */ - public Delete(final Delete d) { -this.row = d.getRow(); -this.ts = d.getTimeStamp(); -this.familyMap.putAll(d.getFamilyCellMap()); -this.durability = d.durability; -for (Map.Entry entry : d.getAttributesMap().entrySet()) { - this.setAttribute(entry.getKey(), entry.getValue()); -} -super.setPriority(d.getPriority()); + public Delete(final Delete deleteToCopy) { +super(deleteToCopy); + } + + /** + * Construct the Delete with user defined data.