Repository: hbase Updated Branches: refs/heads/branch-1 c23c850ca -> 901d429e1
HBASE-11849 remove classes with audience.private for internals that we don't use. Signed-off-by: Jonathan M Hsieh <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/901d429e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/901d429e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/901d429e Branch: refs/heads/branch-1 Commit: 901d429e155a924fea879f9fdfbe0ddaec595f51 Parents: c23c850 Author: Sean Busbey <[email protected]> Authored: Thu Aug 28 09:53:23 2014 -0500 Committer: Jonathan M Hsieh <[email protected]> Committed: Thu Aug 28 11:54:28 2014 -0700 ---------------------------------------------------------------------- .../encode/ThreadLocalEncoderPool.java | 64 -------------------- .../wal/OrphanHLogAfterSplitException.java | 44 -------------- 2 files changed, 108 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/901d429e/hbase-prefix-tree/src/main/java/org/apache/hadoop/hbase/codec/prefixtree/encode/ThreadLocalEncoderPool.java ---------------------------------------------------------------------- diff --git a/hbase-prefix-tree/src/main/java/org/apache/hadoop/hbase/codec/prefixtree/encode/ThreadLocalEncoderPool.java b/hbase-prefix-tree/src/main/java/org/apache/hadoop/hbase/codec/prefixtree/encode/ThreadLocalEncoderPool.java deleted file mode 100644 index 6cbe0c2..0000000 --- a/hbase-prefix-tree/src/main/java/org/apache/hadoop/hbase/codec/prefixtree/encode/ThreadLocalEncoderPool.java +++ /dev/null @@ -1,64 +0,0 @@ -/* - * 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.codec.prefixtree.encode; - -import java.io.OutputStream; - -import org.apache.hadoop.classification.InterfaceAudience; - - -/** - * Pool to enable reusing the Encoder objects which can consist of thousands of smaller objects and - * would be more garbage than the data in the block. A new encoder is needed for each block in - * a flush, compaction, RPC response, etc. - * - * It is not a pool in the traditional sense, but implements the semantics of a traditional pool - * via ThreadLocals to avoid sharing between threads. Sharing between threads would not be - * very expensive given that it's accessed per-block, but this is just as easy. - * - * This pool implementation assumes there is a one-to-one mapping between a single thread and a - * single flush or compaction. - */ [email protected] -public class ThreadLocalEncoderPool implements EncoderPool{ - - private static final ThreadLocal<PrefixTreeEncoder> ENCODER - = new ThreadLocal<PrefixTreeEncoder>(); - - /** - * Get the encoder attached to the current ThreadLocal, or create a new one and attach it to the - * current thread. - */ - @Override - public PrefixTreeEncoder checkOut(OutputStream os, boolean includeMvccVersion) { - PrefixTreeEncoder builder = ENCODER.get(); - builder = EncoderFactory.prepareEncoder(builder, os, includeMvccVersion); - ENCODER.set(builder); - return builder; - } - - @Override - public void checkIn(PrefixTreeEncoder encoder) { - // attached to thread on checkOut, so shouldn't need to do anything here - - // do we need to worry about detaching encoders from compaction threads or are the same threads - // used over and over - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hbase/blob/901d429e/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/OrphanHLogAfterSplitException.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/OrphanHLogAfterSplitException.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/OrphanHLogAfterSplitException.java deleted file mode 100644 index 4fc19f3..0000000 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/OrphanHLogAfterSplitException.java +++ /dev/null @@ -1,44 +0,0 @@ -/** - * - * 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.regionserver.wal; - -import org.apache.hadoop.classification.InterfaceAudience; - -import java.io.IOException; - [email protected] -public class OrphanHLogAfterSplitException extends IOException { - - private static final long serialVersionUID = -4363805979687710634L; - - /** - * Create this exception without a message - */ - public OrphanHLogAfterSplitException() { - super(); - } - - /** - * Create this exception with a message - * @param message why it failed - */ - public OrphanHLogAfterSplitException(String message) { - super(message); - } -}
