-
Notifications
You must be signed in to change notification settings - Fork 999
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
PHOENIX-4198 Remove the need for users to have access to the Phoenix …
…SYSTEM tables to create tables
- Loading branch information
1 parent
6e7b7d4
commit f85bf4c
Showing
16 changed files
with
2,209 additions
and
117 deletions.
There are no files selected for viewing
695 changes: 695 additions & 0 deletions
695
phoenix-core/src/it/java/org/apache/phoenix/end2end/TableDDLPermissionsIT.java
Large diffs are not rendered by default.
Oops, something went wrong.
31 changes: 31 additions & 0 deletions
31
phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/RpcUtil.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Original file line | Diff line number | Diff line change |
---|---|---|---|
@@ -0,0 +1,31 @@ | |||
/* | |||
* 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.hadoop.hbase.ipc; | |||
|
|||
|
|||
public class RpcUtil { | |||
|
|||
public static RpcCall getRpcContext() { | |||
return RpcServer.CurCall.get(); | |||
} | |||
|
|||
public static void setRpcContext(RpcCall c){ | |||
RpcServer.CurCall.set(c); | |||
} | |||
|
|||
} |
111 changes: 111 additions & 0 deletions
111
phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseMetaDataEndpointObserver.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Original file line | Diff line number | Diff line change |
---|---|---|---|
@@ -0,0 +1,111 @@ | |||
/* | |||
* 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.coprocessor; | |||
|
|||
import java.io.IOException; | |||
import java.util.List; | |||
import java.util.Set; | |||
|
|||
import org.apache.hadoop.hbase.CoprocessorEnvironment; | |||
import org.apache.hadoop.hbase.TableName; | |||
import org.apache.hadoop.hbase.coprocessor.ObserverContext; | |||
import org.apache.phoenix.coprocessor.PhoenixMetaDataCoprocessorHost.PhoenixMetaDataControllerEnvironment; | |||
import org.apache.phoenix.schema.PIndexState; | |||
import org.apache.phoenix.schema.PTable; | |||
import org.apache.phoenix.schema.PTableType; | |||
|
|||
public class BaseMetaDataEndpointObserver implements MetaDataEndpointObserver, PhoenixCoprocessor{ | |||
|
|||
@Override | |||
public void start(CoprocessorEnvironment env) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void stop(CoprocessorEnvironment env) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preGetTable( | |||
org.apache.hadoop.hbase.coprocessor.ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, | |||
String tenantId, String tableName, TableName physicalTableName) throws IOException { | |||
|
|||
} | |||
|
|||
|
|||
@Override | |||
public void preCreateTable(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, | |||
String tableName, TableName physicalTableName, TableName parentPhysicalTableName, PTableType tableType, | |||
Set<byte[]> familySet, Set<TableName> indexes) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preDropTable(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, | |||
String tableName, TableName physicalTableName, TableName parentPhysicalTableName, PTableType tableType, | |||
List<PTable> indexes) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preAlterTable(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, | |||
String tableName, TableName physicalTableName, TableName parentPhysicalTableName, PTableType type) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preGetSchema(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String schemaName) | |||
throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preCreateSchema(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String schemaName) | |||
throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preDropSchema(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String schemaName) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preCreateFunction(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, | |||
String functionName) throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preDropFunction(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, String functionName) | |||
throws IOException {} | |||
|
|||
@Override | |||
public void preGetFunctions(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, String functionName) | |||
throws IOException { | |||
|
|||
} | |||
|
|||
@Override | |||
public void preIndexUpdate(ObserverContext<PhoenixMetaDataControllerEnvironment> ctx, String tenantId, | |||
String indexName, TableName physicalTableName, TableName parentPhysicalTableName, PIndexState newState) | |||
throws IOException { | |||
|
|||
} | |||
} |
Oops, something went wrong.