001/* 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018package org.apache.hadoop.hbase.quotas; 019 020import java.util.List; 021import org.apache.hadoop.hbase.Cell; 022import org.apache.hadoop.hbase.client.Mutation; 023import org.apache.hadoop.hbase.client.Result; 024import org.apache.yetus.audience.InterfaceAudience; 025import org.apache.yetus.audience.InterfaceStability; 026 027import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos; 028 029/** 030 * Noop operation quota returned when no quota is associated to the user/table 031 */ 032@InterfaceAudience.Private 033@InterfaceStability.Evolving 034class NoopOperationQuota implements OperationQuota { 035 private static OperationQuota instance = new NoopOperationQuota(); 036 037 private NoopOperationQuota() { 038 // no-op 039 } 040 041 public static OperationQuota get() { 042 return instance; 043 } 044 045 @Override 046 public void checkBatchQuota(int numWrites, int numReads, boolean isAtomic) 047 throws RpcThrottlingException { 048 // no-op 049 } 050 051 @Override 052 public void checkScanQuota(ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, 053 long maxBlockBytesScanned, long prevBlockBytesScannedDifference) throws RpcThrottlingException { 054 // no-op 055 } 056 057 @Override 058 public void close() { 059 // no-op 060 } 061 062 @Override 063 public void addGetResult(final Result result) { 064 // no-op 065 } 066 067 @Override 068 public void addScanResult(final List<Result> results) { 069 // no-op 070 } 071 072 @Override 073 public void addMutation(final Mutation mutation) { 074 // no-op 075 } 076 077 @Override 078 public long getReadAvailable() { 079 return Long.MAX_VALUE; 080 } 081 082 @Override 083 public long getReadConsumed() { 084 return 0L; 085 } 086 087 @Override 088 public void addScanResultCells(List<Cell> cells) { 089 // no-op 090 } 091}