[1/2] phoenix git commit: PHOENIX-4057 Do not issue index updates for out of order mutation
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-1.2 d55bc82a0 -> 03152d03e
PHOENIX-4057 Do not issue index updates for out of order mutation
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/31edca2c
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/31edca2c
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/31edca2c
Branch: refs/heads/4.x-HBase-1.2
Commit: 31edca2c15fddc42df32ae1a7d7c4736a29e7924
Parents: d55bc82
Author: James Taylor
Authored: Tue Aug 1 16:41:01 2017 -0700
Committer: James Taylor
Committed: Wed Aug 2 16:04:23 2017 -0700
--
.../phoenix/end2end/ConcurrentMutationsIT.java | 3 -
.../phoenix/end2end/OutOfOrderMutationsIT.java | 561 +++
.../example/EndToEndCoveredIndexingIT.java | 6 +-
.../hbase/index/covered/NonTxIndexBuilder.java | 75 ++-
4 files changed, 613 insertions(+), 32 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/phoenix/blob/31edca2c/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
index 19cb70e..9ed5174 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
@@ -52,7 +52,6 @@ import org.apache.phoenix.util.PropertiesUtil;
import org.apache.phoenix.util.ReadOnlyProps;
import org.apache.phoenix.util.TestUtil;
import org.junit.BeforeClass;
-import org.junit.Ignore;
import org.junit.Test;
import com.google.common.collect.Maps;
@@ -80,7 +79,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testSynchronousDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
@@ -164,7 +162,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testConcurrentDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
http://git-wip-us.apache.org/repos/asf/phoenix/blob/31edca2c/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
new file mode 100644
index 000..3cf7336
--- /dev/null
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
@@ -0,0 +1,561 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.end2end;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.Properties;
+
+import org.apache.hadoop.hbase.CellScanner;
+import org.apache.hadoop.hbase.client.HTableInterface;
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.client.ResultScanner;
+import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.phoenix.jdbc.PhoenixConnection;
+import org.apache.phoenix.util.PhoenixRuntime;
+import org.apache.phoenix.util.PropertiesUtil;
+import org.apache.phoenix.util.TestUtil;
+import org.junit.Ignore;
+import org.junit.Test;
+
+public class OutOfOrderMutation
[1/2] phoenix git commit: PHOENIX-4057 Do not issue index updates for out of order mutation
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-1.1 ef1e30e5a -> a0772f522
PHOENIX-4057 Do not issue index updates for out of order mutation
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/defec53e
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/defec53e
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/defec53e
Branch: refs/heads/4.x-HBase-1.1
Commit: defec53ebccdee7dae2a401bb0e09a00ff84eee5
Parents: ef1e30e
Author: James Taylor
Authored: Tue Aug 1 16:41:01 2017 -0700
Committer: James Taylor
Committed: Wed Aug 2 16:02:31 2017 -0700
--
.../phoenix/end2end/ConcurrentMutationsIT.java | 3 -
.../phoenix/end2end/OutOfOrderMutationsIT.java | 561 +++
.../example/EndToEndCoveredIndexingIT.java | 6 +-
.../hbase/index/covered/NonTxIndexBuilder.java | 75 ++-
4 files changed, 613 insertions(+), 32 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/phoenix/blob/defec53e/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
index 19cb70e..9ed5174 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
@@ -52,7 +52,6 @@ import org.apache.phoenix.util.PropertiesUtil;
import org.apache.phoenix.util.ReadOnlyProps;
import org.apache.phoenix.util.TestUtil;
import org.junit.BeforeClass;
-import org.junit.Ignore;
import org.junit.Test;
import com.google.common.collect.Maps;
@@ -80,7 +79,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testSynchronousDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
@@ -164,7 +162,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testConcurrentDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
http://git-wip-us.apache.org/repos/asf/phoenix/blob/defec53e/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
new file mode 100644
index 000..3cf7336
--- /dev/null
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
@@ -0,0 +1,561 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.end2end;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.Properties;
+
+import org.apache.hadoop.hbase.CellScanner;
+import org.apache.hadoop.hbase.client.HTableInterface;
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.client.ResultScanner;
+import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.phoenix.jdbc.PhoenixConnection;
+import org.apache.phoenix.util.PhoenixRuntime;
+import org.apache.phoenix.util.PropertiesUtil;
+import org.apache.phoenix.util.TestUtil;
+import org.junit.Ignore;
+import org.junit.Test;
+
+public class OutOfOrderMutation
[1/2] phoenix git commit: PHOENIX-4057 Do not issue index updates for out of order mutation
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-0.98 0135c1075 -> 24a75045f
PHOENIX-4057 Do not issue index updates for out of order mutation
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/2448a95e
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/2448a95e
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/2448a95e
Branch: refs/heads/4.x-HBase-0.98
Commit: 2448a95e018b9baf30b85474b459fec788b7cd23
Parents: 0135c10
Author: James Taylor
Authored: Tue Aug 1 16:41:01 2017 -0700
Committer: James Taylor
Committed: Wed Aug 2 16:00:59 2017 -0700
--
.../phoenix/end2end/ConcurrentMutationsIT.java | 3 -
.../phoenix/end2end/OutOfOrderMutationsIT.java | 561 +++
.../example/EndToEndCoveredIndexingIT.java | 6 +-
.../hbase/index/covered/NonTxIndexBuilder.java | 75 ++-
4 files changed, 613 insertions(+), 32 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/phoenix/blob/2448a95e/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
index 19cb70e..9ed5174 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
@@ -52,7 +52,6 @@ import org.apache.phoenix.util.PropertiesUtil;
import org.apache.phoenix.util.ReadOnlyProps;
import org.apache.phoenix.util.TestUtil;
import org.junit.BeforeClass;
-import org.junit.Ignore;
import org.junit.Test;
import com.google.common.collect.Maps;
@@ -80,7 +79,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testSynchronousDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
@@ -164,7 +162,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testConcurrentDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
http://git-wip-us.apache.org/repos/asf/phoenix/blob/2448a95e/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
new file mode 100644
index 000..3cf7336
--- /dev/null
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
@@ -0,0 +1,561 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.end2end;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.Properties;
+
+import org.apache.hadoop.hbase.CellScanner;
+import org.apache.hadoop.hbase.client.HTableInterface;
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.client.ResultScanner;
+import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.phoenix.jdbc.PhoenixConnection;
+import org.apache.phoenix.util.PhoenixRuntime;
+import org.apache.phoenix.util.PropertiesUtil;
+import org.apache.phoenix.util.TestUtil;
+import org.junit.Ignore;
+import org.junit.Test;
+
+public class OutOfOrderMutati
[1/2] phoenix git commit: PHOENIX-4057 Do not issue index updates for out of order mutation
Repository: phoenix
Updated Branches:
refs/heads/master 5e33dc12b -> 0bd43f536
PHOENIX-4057 Do not issue index updates for out of order mutation
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e494fe9f
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e494fe9f
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e494fe9f
Branch: refs/heads/master
Commit: e494fe9fa744ec2948cf75b007e92fef0b1ba829
Parents: 5e33dc1
Author: James Taylor
Authored: Tue Aug 1 16:41:01 2017 -0700
Committer: James Taylor
Committed: Wed Aug 2 14:40:26 2017 -0700
--
.../phoenix/end2end/ConcurrentMutationsIT.java | 3 -
.../phoenix/end2end/OutOfOrderMutationsIT.java | 561 +++
.../example/EndToEndCoveredIndexingIT.java | 6 +-
.../hbase/index/covered/NonTxIndexBuilder.java | 75 ++-
4 files changed, 613 insertions(+), 32 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/phoenix/blob/e494fe9f/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
index 19cb70e..9ed5174 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsIT.java
@@ -52,7 +52,6 @@ import org.apache.phoenix.util.PropertiesUtil;
import org.apache.phoenix.util.ReadOnlyProps;
import org.apache.phoenix.util.TestUtil;
import org.junit.BeforeClass;
-import org.junit.Ignore;
import org.junit.Test;
import com.google.common.collect.Maps;
@@ -80,7 +79,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testSynchronousDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
@@ -164,7 +162,6 @@ public class ConcurrentMutationsIT extends
BaseUniqueNamesOwnClusterIT {
}
@Test
-@Ignore
public void testConcurrentDeletesAndUpsertValues() throws Exception {
final String tableName = generateUniqueName();
final String indexName = generateUniqueName();
http://git-wip-us.apache.org/repos/asf/phoenix/blob/e494fe9f/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
--
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
new file mode 100644
index 000..3cf7336
--- /dev/null
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OutOfOrderMutationsIT.java
@@ -0,0 +1,561 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.end2end;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.Properties;
+
+import org.apache.hadoop.hbase.CellScanner;
+import org.apache.hadoop.hbase.client.HTableInterface;
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.client.ResultScanner;
+import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.phoenix.jdbc.PhoenixConnection;
+import org.apache.phoenix.util.PhoenixRuntime;
+import org.apache.phoenix.util.PropertiesUtil;
+import org.apache.phoenix.util.TestUtil;
+import org.junit.Ignore;
+import org.junit.Test;
+
+public class OutOfOrderMutationsIT extends Pa
