Skip to content

Commit

Permalink
dev_0.1.4
Browse files Browse the repository at this point in the history
  • Loading branch information
Crossoverrr committed Dec 13, 2019
1 parent bdc7226 commit 04e5c5f
Show file tree
Hide file tree
Showing 5 changed files with 53 additions and 19 deletions.
Original file line number Diff line number Diff line change
@@ -1,3 +1,16 @@
/*
* Licensed 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 com.analysys.presto.connector.hbase.meta;

import com.fasterxml.jackson.annotation.JsonCreator;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,24 +80,6 @@ public ConnectorTableHandle getTableHandle(ConnectorSession connectorSession, Sc
return connectorTableHandle;
}

/*@Override
public List<ConnectorTableLayoutResult> getTableLayouts(ConnectorSession connectorSession,
ConnectorTableHandle connectorTableHandle,
Constraint constraint,
Optional<Set<ColumnHandle>> desiredColumns) {
HBaseTableHandle tableHandle = checkType(connectorTableHandle, HBaseTableHandle.class, "tableHandle");
ConnectorTableLayout layout = new ConnectorTableLayout(
new HBaseTableLayoutHandle(tableHandle, constraint.getSummary()));
return ImmutableList.of(new ConnectorTableLayoutResult(layout, constraint.getSummary()));
}
@Override
public ConnectorTableLayout getTableLayout(ConnectorSession connectorSession,
ConnectorTableLayoutHandle connectorTableLayoutHandle) {
HBaseTableLayoutHandle layout = checkType(connectorTableLayoutHandle, HBaseTableLayoutHandle.class, "layout");
return new ConnectorTableLayout(layout);
}*/

@Override
public ConnectorTableMetadata getTableMetadata(ConnectorSession connectorSession,
ConnectorTableHandle connectorTableHandle) {
Expand Down Expand Up @@ -304,7 +286,7 @@ public ColumnHandle getUpdateRowIdColumnHandle(ConnectorSession session, Connect
ColumnMetaInfo rowKeyInfo = rowKeyOpt.get();
// HBaseColumnHandle's attributes cannot be all the same with the REAL rowKey column,
// Or there will be a java.lang.IllegalArgumentException: Multiple entries with same value Exception.
return new HBaseColumnHandle(CONNECTOR_NAME, /*rowKeyInfo.getFamily(),*/ "",
return new HBaseColumnHandle(CONNECTOR_NAME, "",
rowKeyInfo.getColumnName(), VarcharType.VARCHAR,
tableMetaInfo.getColumns().indexOf(rowKeyOpt.get()),
rowKeyInfo.isRowKey());
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,16 @@
/*
* Licensed 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 com.analysys.presto.connector.hbase.query;

import com.analysys.presto.connector.hbase.meta.HBaseColumnHandle;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,16 @@
/*
* Licensed 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 com.analysys.presto.connector.hbase.query;

import com.analysys.presto.connector.hbase.connection.HBaseClientManager;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,16 @@
/*
* Licensed 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 com.analysys.presto.connector.hbase.utils;

/**
Expand Down

0 comments on commit 04e5c5f

Please # to comment.