[13/21] phoenix git commit: PHOENIX-4605 Support running multiple transaction providers
http://git-wip-us.apache.org/repos/asf/phoenix/blob/8eaca121/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
--
diff --git
a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
index a7b31e8..1a11427 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
@@ -69,6 +69,7 @@ import org.apache.phoenix.schema.types.PDataType;
import org.apache.phoenix.schema.types.PDouble;
import org.apache.phoenix.schema.types.PFloat;
import org.apache.phoenix.schema.types.PVarchar;
+import org.apache.phoenix.transaction.TransactionFactory;
import org.apache.phoenix.util.ByteUtil;
import org.apache.phoenix.util.EncodedColumnsUtil;
import org.apache.phoenix.util.PhoenixRuntime;
@@ -134,7 +135,7 @@ public class PTableImpl implements PTable {
private boolean disableWAL;
private boolean multiTenant;
private boolean storeNulls;
-private boolean isTransactional;
+private TransactionFactory.Provider transactionProvider;
private ViewType viewType;
private Short viewIndexId;
private int estimatedSize;
@@ -227,7 +228,7 @@ public class PTableImpl implements PTable {
init(tenantId, this.schemaName, this.tableName, PTableType.INDEX,
state, timeStamp, sequenceNumber, pkName, bucketNum, columns,
this.schemaName, parentTableName, indexes, isImmutableRows,
physicalNames, defaultFamilyName,
null, disableWAL, multiTenant, storeNulls, viewType, viewIndexId,
indexType, baseColumnCount, rowKeyOrderOptimizable,
-isTransactional, updateCacheFrequency, indexDisableTimestamp,
isNamespaceMpped, null, false, storageScheme, qualifierEncodingScheme,
encodedCQCounter, useStatsForParallelization);
+transactionProvider, updateCacheFrequency, indexDisableTimestamp,
isNamespaceMpped, null, false, storageScheme, qualifierEncodingScheme,
encodedCQCounter, useStatsForParallelization);
}
public PTableImpl(long timeStamp) { // For delete marker
@@ -270,7 +271,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), getColumnsToClone(table), table.getParentSchemaName(),
table.getParentTableName(),
indexes, table.isImmutableRows(), physicalNames,
table.getDefaultFamilyName(), viewStatement,
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(),
table.rowKeyOrderOptimizable(), table.isTransactional(), updateCacheFrequency,
+table.getBaseColumnCount(),
table.rowKeyOrderOptimizable(), table.getTransactionProvider(),
updateCacheFrequency,
table.getIndexDisableTimestamp(),
table.isNamespaceMapped(), table.getAutoPartitionSeqName(),
table.isAppendOnlySchema(), table.getImmutableStorageScheme(),
table.getEncodingScheme(), table.getEncodedCQCounter(),
table.useStatsForParallelization());
}
@@ -280,7 +281,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), getColumnsToClone(table), parentSchemaName,
table.getParentTableName(),
indexes, table.isImmutableRows(), table.getPhysicalNames(),
table.getDefaultFamilyName(), viewStatement,
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.isTransactional(), table.getUpdateCacheFrequency(),
+table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.getTransactionProvider(), table.getUpdateCacheFrequency(),
table.getIndexDisableTimestamp(), table.isNamespaceMapped(),
table.getAutoPartitionSeqName(), table.isAppendOnlySchema(),
table.getImmutableStorageScheme(), table.getEncodingScheme(),
table.getEncodedCQCounter(), table.useStatsForParallelization());
}
@@ -290,7 +291,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), columns, table.getParentSchemaName(),
table.getParentTableName(),
table.getIndexes(), table.isImmutableRows(),
table.getPhysicalNames(), table.getDefaultFamilyName(),
table.getViewStatement(),
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.isTransactional(), table.getUpdateCacheFrequency(),
[13/21] phoenix git commit: PHOENIX-4605 Support running multiple transaction providers
http://git-wip-us.apache.org/repos/asf/phoenix/blob/8eaca121/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
--
diff --git
a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
index a7b31e8..1a11427 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
@@ -69,6 +69,7 @@ import org.apache.phoenix.schema.types.PDataType;
import org.apache.phoenix.schema.types.PDouble;
import org.apache.phoenix.schema.types.PFloat;
import org.apache.phoenix.schema.types.PVarchar;
+import org.apache.phoenix.transaction.TransactionFactory;
import org.apache.phoenix.util.ByteUtil;
import org.apache.phoenix.util.EncodedColumnsUtil;
import org.apache.phoenix.util.PhoenixRuntime;
@@ -134,7 +135,7 @@ public class PTableImpl implements PTable {
private boolean disableWAL;
private boolean multiTenant;
private boolean storeNulls;
-private boolean isTransactional;
+private TransactionFactory.Provider transactionProvider;
private ViewType viewType;
private Short viewIndexId;
private int estimatedSize;
@@ -227,7 +228,7 @@ public class PTableImpl implements PTable {
init(tenantId, this.schemaName, this.tableName, PTableType.INDEX,
state, timeStamp, sequenceNumber, pkName, bucketNum, columns,
this.schemaName, parentTableName, indexes, isImmutableRows,
physicalNames, defaultFamilyName,
null, disableWAL, multiTenant, storeNulls, viewType, viewIndexId,
indexType, baseColumnCount, rowKeyOrderOptimizable,
-isTransactional, updateCacheFrequency, indexDisableTimestamp,
isNamespaceMpped, null, false, storageScheme, qualifierEncodingScheme,
encodedCQCounter, useStatsForParallelization);
+transactionProvider, updateCacheFrequency, indexDisableTimestamp,
isNamespaceMpped, null, false, storageScheme, qualifierEncodingScheme,
encodedCQCounter, useStatsForParallelization);
}
public PTableImpl(long timeStamp) { // For delete marker
@@ -270,7 +271,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), getColumnsToClone(table), table.getParentSchemaName(),
table.getParentTableName(),
indexes, table.isImmutableRows(), physicalNames,
table.getDefaultFamilyName(), viewStatement,
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(),
table.rowKeyOrderOptimizable(), table.isTransactional(), updateCacheFrequency,
+table.getBaseColumnCount(),
table.rowKeyOrderOptimizable(), table.getTransactionProvider(),
updateCacheFrequency,
table.getIndexDisableTimestamp(),
table.isNamespaceMapped(), table.getAutoPartitionSeqName(),
table.isAppendOnlySchema(), table.getImmutableStorageScheme(),
table.getEncodingScheme(), table.getEncodedCQCounter(),
table.useStatsForParallelization());
}
@@ -280,7 +281,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), getColumnsToClone(table), parentSchemaName,
table.getParentTableName(),
indexes, table.isImmutableRows(), table.getPhysicalNames(),
table.getDefaultFamilyName(), viewStatement,
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.isTransactional(), table.getUpdateCacheFrequency(),
+table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.getTransactionProvider(), table.getUpdateCacheFrequency(),
table.getIndexDisableTimestamp(), table.isNamespaceMapped(),
table.getAutoPartitionSeqName(), table.isAppendOnlySchema(),
table.getImmutableStorageScheme(), table.getEncodingScheme(),
table.getEncodedCQCounter(), table.useStatsForParallelization());
}
@@ -290,7 +291,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), columns, table.getParentSchemaName(),
table.getParentTableName(),
table.getIndexes(), table.isImmutableRows(),
table.getPhysicalNames(), table.getDefaultFamilyName(),
table.getViewStatement(),
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.isTransactional(), table.getUpdateCacheFrequency(),
[13/21] phoenix git commit: PHOENIX-4605 Support running multiple transaction providers
http://git-wip-us.apache.org/repos/asf/phoenix/blob/8eaca121/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
--
diff --git
a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
index a7b31e8..1a11427 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
@@ -69,6 +69,7 @@ import org.apache.phoenix.schema.types.PDataType;
import org.apache.phoenix.schema.types.PDouble;
import org.apache.phoenix.schema.types.PFloat;
import org.apache.phoenix.schema.types.PVarchar;
+import org.apache.phoenix.transaction.TransactionFactory;
import org.apache.phoenix.util.ByteUtil;
import org.apache.phoenix.util.EncodedColumnsUtil;
import org.apache.phoenix.util.PhoenixRuntime;
@@ -134,7 +135,7 @@ public class PTableImpl implements PTable {
private boolean disableWAL;
private boolean multiTenant;
private boolean storeNulls;
-private boolean isTransactional;
+private TransactionFactory.Provider transactionProvider;
private ViewType viewType;
private Short viewIndexId;
private int estimatedSize;
@@ -227,7 +228,7 @@ public class PTableImpl implements PTable {
init(tenantId, this.schemaName, this.tableName, PTableType.INDEX,
state, timeStamp, sequenceNumber, pkName, bucketNum, columns,
this.schemaName, parentTableName, indexes, isImmutableRows,
physicalNames, defaultFamilyName,
null, disableWAL, multiTenant, storeNulls, viewType, viewIndexId,
indexType, baseColumnCount, rowKeyOrderOptimizable,
-isTransactional, updateCacheFrequency, indexDisableTimestamp,
isNamespaceMpped, null, false, storageScheme, qualifierEncodingScheme,
encodedCQCounter, useStatsForParallelization);
+transactionProvider, updateCacheFrequency, indexDisableTimestamp,
isNamespaceMpped, null, false, storageScheme, qualifierEncodingScheme,
encodedCQCounter, useStatsForParallelization);
}
public PTableImpl(long timeStamp) { // For delete marker
@@ -270,7 +271,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), getColumnsToClone(table), table.getParentSchemaName(),
table.getParentTableName(),
indexes, table.isImmutableRows(), physicalNames,
table.getDefaultFamilyName(), viewStatement,
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(),
table.rowKeyOrderOptimizable(), table.isTransactional(), updateCacheFrequency,
+table.getBaseColumnCount(),
table.rowKeyOrderOptimizable(), table.getTransactionProvider(),
updateCacheFrequency,
table.getIndexDisableTimestamp(),
table.isNamespaceMapped(), table.getAutoPartitionSeqName(),
table.isAppendOnlySchema(), table.getImmutableStorageScheme(),
table.getEncodingScheme(), table.getEncodedCQCounter(),
table.useStatsForParallelization());
}
@@ -280,7 +281,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), getColumnsToClone(table), parentSchemaName,
table.getParentTableName(),
indexes, table.isImmutableRows(), table.getPhysicalNames(),
table.getDefaultFamilyName(), viewStatement,
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.isTransactional(), table.getUpdateCacheFrequency(),
+table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.getTransactionProvider(), table.getUpdateCacheFrequency(),
table.getIndexDisableTimestamp(), table.isNamespaceMapped(),
table.getAutoPartitionSeqName(), table.isAppendOnlySchema(),
table.getImmutableStorageScheme(), table.getEncodingScheme(),
table.getEncodedCQCounter(), table.useStatsForParallelization());
}
@@ -290,7 +291,7 @@ public class PTableImpl implements PTable {
table.getSequenceNumber(), table.getPKName(),
table.getBucketNum(), columns, table.getParentSchemaName(),
table.getParentTableName(),
table.getIndexes(), table.isImmutableRows(),
table.getPhysicalNames(), table.getDefaultFamilyName(),
table.getViewStatement(),
table.isWALDisabled(), table.isMultiTenant(),
table.getStoreNulls(), table.getViewType(), table.getViewIndexId(),
table.getIndexType(),
-table.getBaseColumnCount(), table.rowKeyOrderOptimizable(),
table.isTransactional(), table.getUpdateCacheFrequency(),
