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) throws RpcThrottlingException { 047 // no-op 048 } 049 050 @Override 051 public void checkScanQuota(ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, 052 long maxBlockBytesScanned, long prevBlockBytesScannedDifference) throws RpcThrottlingException { 053 // no-op 054 } 055 056 @Override 057 public void close() { 058 // no-op 059 } 060 061 @Override 062 public void addGetResult(final Result result) { 063 // no-op 064 } 065 066 @Override 067 public void addScanResult(final List<Result> results) { 068 // no-op 069 } 070 071 @Override 072 public void addMutation(final Mutation mutation) { 073 // no-op 074 } 075 076 @Override 077 public long getReadAvailable() { 078 return Long.MAX_VALUE; 079 } 080 081 @Override 082 public long getReadConsumed() { 083 return 0L; 084 } 085 086 @Override 087 public void addScanResultCells(List<Cell> cells) { 088 // no-op 089 } 090}