| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | SplitTransactionImpl.java | 245 if (this.parent.getCoprocessorHost() != null) { in createDaughters()
248 parent.getCoprocessorHost().preSplit(); in createDaughters()
249 parent.getCoprocessorHost().preSplit(splitrow); in createDaughters()
255 parent.getCoprocessorHost().preSplit(); in createDaughters()
256 parent.getCoprocessorHost().preSplit(splitrow); in createDaughters()
281 if (this.parent.getCoprocessorHost() != null) { in createDaughters()
561 if (this.parent.getCoprocessorHost() != null) { in execute()
563 parent.getCoprocessorHost().preSplitAfterPONR(); in execute()
607 if (parent.getCoprocessorHost() != null) { in stepsAfterPONR()
915 if (this.parent.getCoprocessorHost() != null) { in rollback()
[all …]
|
| H A D | StoreFlusher.java | 80 if (store.getCoprocessorHost() != null) { in createScanner()
81 scanner = store.getCoprocessorHost().preFlushScannerOpen(store, snapshotScanner); in createScanner()
91 if (store.getCoprocessorHost() != null) { in createScanner()
93 return store.getCoprocessorHost().preFlush(store, scanner); in createScanner()
|
| H A D | RSRpcServices.java | 503 if (region.getCoprocessorHost() != null) { in append()
515 if (region.getCoprocessorHost() != null) { in append()
540 if (region.getCoprocessorHost() != null) { in increment()
552 if (region.getCoprocessorHost() != null) { in increment()
1185 region.getCoprocessorHost().preClose(false); in closeRegion()
1725 ? region.getCoprocessorHost() in replay()
1945 if (region.getCoprocessorHost() != null) { in bulkLoadHFile()
1952 if (region.getCoprocessorHost() != null) { in bulkLoadHFile()
2242 if (region.getCoprocessorHost() != null) { in mutate()
2402 if (region.getCoprocessorHost() != null) { in scan()
[all …]
|
| H A D | MultiRowMutationProcessor.java | 105 RegionCoprocessorHost coprocessorHost = region.getCoprocessorHost(); in preProcess()
129 RegionCoprocessorHost coprocessorHost = region.getCoprocessorHost(); in preBatchMutate()
156 RegionCoprocessorHost coprocessorHost = region.getCoprocessorHost(); in postBatchMutate()
166 RegionCoprocessorHost coprocessorHost = region.getCoprocessorHost(); in postProcess()
|
| H A D | ReversedRegionScannerImpl.java | 75 if (this.region.getCoprocessorHost() != null) { in nextRow()
76 return this.region.getCoprocessorHost().postScannerFilterRow(this, in nextRow()
|
| H A D | HStore.java | 1266 if (this.getCoprocessorHost() != null) { in moveCompatedFilesIntoPlace()
1269 getCoprocessorHost().postCompact(thisStore, sf, cr); in moveCompatedFilesIntoPlace()
1487 if (this.getCoprocessorHost() != null) { in compactRecentForTestingAssumingDefaultPolicy()
1551 if (this.getCoprocessorHost() != null) { in requestCompaction()
1598 if (this.getCoprocessorHost() != null) { in requestCompaction()
1600 this.getCoprocessorHost().postCompactSelection( in requestCompaction()
1607 getCoprocessorHost().postCompactSelection( in requestCompaction()
2071 if (this.getCoprocessorHost() != null) { in getScanner()
2178 public RegionCoprocessorHost getCoprocessorHost() { in getCoprocessorHost() method in HStore
2179 return this.region.getCoprocessorHost(); in getCoprocessorHost()
[all …]
|
| H A D | SplitRequest.java | 118 if (this.parent.getCoprocessorHost() != null) { in doSplitting()
120 this.parent.getCoprocessorHost().postCompleteSplit(); in doSplitting()
|
| H A D | StoreScanner.java | 187 oldestUnexpiredTS, now, store.getCoprocessorHost()); in StoreScanner()
252 earliestPutTs, oldestUnexpiredTS, now, store.getCoprocessorHost()); in StoreScanner()
255 oldestUnexpiredTS, now, dropDeletesFromRow, dropDeletesToRow, store.getCoprocessorHost()); in StoreScanner()
|
| H A D | Store.java | 386 RegionCoprocessorHost getCoprocessorHost(); in getCoprocessorHost() method
|
| H A D | HRegionServer.java | 1187 Set<String> coprocessors = getWAL(null).getCoprocessorHost().getCoprocessors(); in buildServerLoad()
1195 if (region.getCoprocessorHost() != null) { in buildServerLoad()
1196 Set<String> regionCoprocessors = region.getCoprocessorHost().getCoprocessors(); in buildServerLoad()
1203 for (String coprocessor : getWAL(region.getRegionInfo()).getCoprocessorHost() in buildServerLoad()
2714 coprocessors.addAll(getWAL(null).getCoprocessorHost().getCoprocessors()); in getRegionServerCoprocessors()
2722 coprocessors.addAll(region.getCoprocessorHost().getCoprocessors()); in getRegionServerCoprocessors()
2724 coprocessors.addAll(getWAL(region.getRegionInfo()).getCoprocessorHost().getCoprocessors()); in getRegionServerCoprocessors()
2777 if ((actualRegion != null) && (actualRegion.getCoprocessorHost() != null)) { in closeRegion()
2779 actualRegion.getCoprocessorHost().preClose(false); in closeRegion()
|
| H A D | Region.java | 542 RegionCoprocessorHost getCoprocessorHost(); in getCoprocessorHost() method
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ |
| H A D | TestCoprocessorInterface.java | 307 Coprocessor c = regions[0].getCoprocessorHost(). in testSharedData()
309 Coprocessor c2 = regions[0].getCoprocessorHost(). in testSharedData()
318 c = regions[i].getCoprocessorHost(). in testSharedData()
320 c2 = regions[i].getCoprocessorHost(). in testSharedData()
339 assertNull(regions[i].getCoprocessorHost(). in testSharedData()
342 c = regions[0].getCoprocessorHost(). in testSharedData()
350 c = region.getCoprocessorHost(). in testSharedData()
354 c2 = region.getCoprocessorHost(). in testSharedData()
385 Coprocessor c = region.getCoprocessorHost(). in testCoprocessorInterface()
390 …RegionScanner scanner = regions[0].getCoprocessorHost().postScannerOpen(s, regions[0].getScanner(s… in testCoprocessorInterface()
[all …]
|
| H A D | TestClassLoading.java | 176 env = region.getCoprocessorHost().findCoprocessorEnvironment(cpName1); in testClassLoadingFromHDFS()
178 env = region.getCoprocessorHost().findCoprocessorEnvironment(cpName2); in testClassLoadingFromHDFS()
242 found = (region.getCoprocessorHost().findCoprocessor(cpName3) != null); in testClassLoadingFromLocalFS()
267 Coprocessor cp = region.getCoprocessorHost().findCoprocessor(cpName4); in testPrivateClassLoader()
339 (region.getCoprocessorHost().findCoprocessor(cpName1) != null); in testHBase3810()
341 (region.getCoprocessorHost().findCoprocessor(cpName2) != null); in testHBase3810()
343 (region.getCoprocessorHost().findCoprocessor("SimpleRegionObserver") in testHBase3810()
346 (region.getCoprocessorHost().findCoprocessor(cpName5) != null); in testHBase3810()
349 region.getCoprocessorHost().findCoprocessorEnvironment(cpName6); in testHBase3810()
427 env = region.getCoprocessorHost().findCoprocessorEnvironment(cpName1); in loadingClassFromLibDirInJar()
[all …]
|
| H A D | TestRegionObserverScannerOpenHook.java | 175 RegionCoprocessorHost h = region.getCoprocessorHost(); in testRegionObserverScanTimeStacking()
199 RegionCoprocessorHost h = region.getCoprocessorHost(); in testRegionObserverFlushTimeStacking()
|
| H A D | TestRegionObserverStacking.java | 123 RegionCoprocessorHost h = region.getCoprocessorHost(); in testRegionObserverStacking()
|
| H A D | TestWALObserver.java | 427 (SampleRegionWALObserver)region.getCoprocessorHost().findCoprocessor( in testWALCoprocessorReplay()
455 WALCoprocessorHost host = wal.getCoprocessorHost(); in getCoprocessor()
|
| H A D | TestRegionObserverInterface.java | 536 Coprocessor cp = firstRegion.getCoprocessorHost().findCoprocessor(
766 getCoprocessorHost();
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/ |
| H A D | Compactor.java | 221 if (store.getCoprocessorHost() == null) return null; in preCreateCoprocScanner()
223 return store.getCoprocessorHost().preCompactScannerOpen(store, scanners, scanType, in preCreateCoprocScanner()
230 return store.getCoprocessorHost().preCompactScannerOpen(store, scanners, in preCreateCoprocScanner()
251 if (store.getCoprocessorHost() == null) return scanner;
253 return store.getCoprocessorHost().preCompact(store, scanner, scanType, request);
259 return store.getCoprocessorHost().preCompact(store, scanner, scanType, request);
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/ |
| H A D | SecureBulkLoadEndpoint.java | 242 if (region.getCoprocessorHost() != null) { in secureBulkLoadHFiles()
244 bypass = region.getCoprocessorHost().preBulkLoadHFile(familyPaths); in secureBulkLoadHFiles()
309 if (region.getCoprocessorHost() != null) { in secureBulkLoadHFiles()
311 loaded = region.getCoprocessorHost().postBulkLoadHFile(familyPaths, loaded); in secureBulkLoadHFiles()
323 this.env.getRegion().getCoprocessorHost().findCoprocessors(BulkLoadObserver.class); in getBulkLoadObservers()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/ |
| H A D | WAL.java | 176 WALCoprocessorHost getCoprocessorHost(); in getCoprocessorHost() method
|
| H A D | DisabledWALProvider.java | 202 public WALCoprocessorHost getCoprocessorHost() { in getCoprocessorHost() method in DisabledWALProvider.DisabledWAL
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | TestSplitTransactionOnCluster.java | 309 region.getCoprocessorHost().load(FailingSplitRegionObserver.class, in testRITStateForRollback()
317 .getCoprocessorHost().findCoprocessor(FailingSplitRegionObserver.class.getName()); in testRITStateForRollback()
1318 actualRegion.getCoprocessorHost().load(FailingSplitRegionObserver.class, in testFailedSplit()
1324 .getCoprocessorHost().findCoprocessor(FailingSplitRegionObserver.class.getName()); in testFailedSplit()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/namespace/ |
| H A D | TestNamespaceAuditor.java | 467 (CustomObserver) actualRegion.getCoprocessorHost().findCoprocessor( in testRegionOperations()
474 (CustomObserver) actualRegion.getCoprocessorHost().findCoprocessor( in testRegionOperations()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/ |
| H A D | TestFSHLog.java | 144 WALCoprocessorHost host = log.getCoprocessorHost(); in testWALCoprocessorLoaded()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/security/access/ |
| H A D | SecureTestUtil.java | 300 Coprocessor cp = region.getCoprocessorHost() in getAccessControllers()
|