View Javadoc

1   /*
2    *
3    * Licensed to the Apache Software Foundation (ASF) under one
4    * or more contributor license agreements.  See the NOTICE file
5    * distributed with this work for additional information
6    * regarding copyright ownership.  The ASF licenses this file
7    * to you under the Apache License, Version 2.0 (the
8    * "License"); you may not use this file except in compliance
9    * with the License.  You may obtain a copy of the License at
10   *
11   * http://www.apache.org/licenses/LICENSE-2.0
12   *
13   * Unless required by applicable law or agreed to in writing, software
14   * distributed under the License is distributed on an "AS IS" BASIS,
15   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16   * See the License for the specific language governing permissions and
17   * limitations under the License.
18   */
19  
20  package org.apache.hadoop.hbase.coprocessor;
21  
22  import org.apache.hadoop.hbase.classification.InterfaceAudience;
23  import org.apache.hadoop.hbase.classification.InterfaceStability;
24  import com.google.common.net.HostAndPort;
25  
26  import java.io.IOException;
27  import java.util.List;
28  import java.util.Set;
29  
30  import org.apache.hadoop.hbase.CoprocessorEnvironment;
31  import org.apache.hadoop.hbase.HBaseInterfaceAudience;
32  import org.apache.hadoop.hbase.ProcedureInfo;
33  import org.apache.hadoop.hbase.TableName;
34  import org.apache.hadoop.hbase.HColumnDescriptor;
35  import org.apache.hadoop.hbase.HRegionInfo;
36  import org.apache.hadoop.hbase.CoprocessorEnvironment;
37  import org.apache.hadoop.hbase.HTableDescriptor;
38  import org.apache.hadoop.hbase.NamespaceDescriptor;
39  import org.apache.hadoop.hbase.ServerName;
40  import org.apache.hadoop.hbase.master.RegionPlan;
41  import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv;
42  import org.apache.hadoop.hbase.procedure2.ProcedureExecutor;
43  import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescription;
44  import org.apache.hadoop.hbase.protobuf.generated.QuotaProtos.Quotas;
45  
46  import java.io.IOException;
47  import java.util.List;
48  
49  @InterfaceAudience.LimitedPrivate({HBaseInterfaceAudience.COPROC, HBaseInterfaceAudience.CONFIG})
50  @InterfaceStability.Evolving
51  public class BaseMasterObserver implements MasterObserver {
52    @Override
53    public void preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
54        HTableDescriptor desc, HRegionInfo[] regions) throws IOException {
55    }
56  
57    @Override
58    public void postCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
59        HTableDescriptor desc, HRegionInfo[] regions) throws IOException {
60    }
61  
62    @Override
63    public void preCreateTableHandler(
64        final ObserverContext<MasterCoprocessorEnvironment> ctx,
65        HTableDescriptor desc, HRegionInfo[] regions) throws IOException {
66    }
67  
68    @Override
69    public void postCreateTableHandler(
70        final ObserverContext<MasterCoprocessorEnvironment> ctx,
71        HTableDescriptor desc, HRegionInfo[] regions) throws IOException {
72    }
73  
74    @Override
75    public void preDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
76        TableName tableName) throws IOException {
77    }
78  
79    @Override
80    public void postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
81        TableName tableName) throws IOException {
82    }
83  
84    @Override
85    public void preDeleteTableHandler(
86        final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
87        throws IOException{
88    }
89  
90    @Override
91    public void postDeleteTableHandler(
92        final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
93        throws IOException {
94    }
95  
96    @Override
97    public void preTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
98        TableName tableName) throws IOException {
99    }
100 
101   @Override
102   public void postTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
103       TableName tableName) throws IOException {
104   }
105 
106   @Override
107   public void preTruncateTableHandler(
108       final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
109       throws IOException {
110   }
111 
112   @Override
113   public void postTruncateTableHandler(
114       final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
115       throws IOException {
116   }
117 
118   @Override
119   public void preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
120       TableName tableName, HTableDescriptor htd) throws IOException {
121   }
122 
123   @Override
124   public void postModifyTableHandler(
125       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
126       HTableDescriptor htd) throws IOException {
127   }
128 
129   @Override
130   public void preModifyTableHandler(
131       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
132       HTableDescriptor htd) throws IOException {
133   }
134 
135   @Override
136   public void postModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
137       TableName tableName, HTableDescriptor htd) throws IOException {
138   }
139 
140   @Override
141   public void preCreateNamespace(
142       ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
143           throws IOException {
144   }
145 
146   @Override
147   public void postCreateNamespace(
148       ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
149           throws IOException {
150   }
151 
152   @Override
153   public void preDeleteNamespace(
154       ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) throws IOException {
155   }
156 
157   @Override
158   public void postDeleteNamespace(
159       ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) throws IOException {
160   }
161 
162   @Override
163   public void preModifyNamespace(
164       ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
165           throws IOException {
166   }
167 
168   @Override
169   public void postModifyNamespace(
170       ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
171           throws IOException {
172   }
173 
174   @Override
175   public void preGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx,
176       String namespace) throws IOException {
177   }
178 
179   @Override
180   public void postGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx,
181       NamespaceDescriptor ns) throws IOException {
182   }
183 
184   @Override
185   public void preListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
186       List<NamespaceDescriptor> descriptors) throws IOException {
187   }
188 
189   @Override
190   public void postListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
191       List<NamespaceDescriptor> descriptors) throws IOException {
192   }
193 
194   @Override
195   public void preAddColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
196       TableName tableName, HColumnDescriptor column) throws IOException {
197   }
198 
199   @Override
200   public void postAddColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
201       TableName tableName, HColumnDescriptor column) throws IOException {
202   }
203 
204   @Override
205   public void preAddColumnHandler(
206       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
207       HColumnDescriptor column) throws IOException {
208   }
209 
210   @Override
211   public void postAddColumnHandler(
212       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
213       HColumnDescriptor column) throws IOException {
214   }
215 
216   @Override
217   public void preModifyColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
218       TableName tableName, HColumnDescriptor descriptor) throws IOException {
219   }
220 
221   @Override
222   public void postModifyColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
223       TableName tableName, HColumnDescriptor descriptor) throws IOException {
224   }
225 
226   @Override
227   public void preModifyColumnHandler(
228       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
229       HColumnDescriptor descriptor) throws IOException {
230   }
231 
232   @Override
233   public void postModifyColumnHandler(
234       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
235       HColumnDescriptor descriptor) throws IOException {
236   }
237 
238   @Override
239   public void preDeleteColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
240       TableName tableName, byte[] c) throws IOException {
241   }
242 
243   @Override
244   public void postDeleteColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
245       TableName tableName, byte[] c) throws IOException {
246   }
247 
248   @Override
249   public void preDeleteColumnHandler(
250       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
251       byte[] c) throws IOException {
252   }
253 
254   @Override
255   public void postDeleteColumnHandler(
256       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName,
257       byte[] c) throws IOException {
258   }
259 
260 
261   @Override
262   public void preEnableTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
263       TableName tableName) throws IOException {
264   }
265 
266   @Override
267   public void postEnableTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
268       TableName tableName) throws IOException {
269   }
270 
271   @Override
272   public void preEnableTableHandler(
273       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
274       throws IOException {
275   }
276 
277   @Override
278   public void postEnableTableHandler(
279       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
280       throws IOException {
281   }
282 
283   @Override
284   public void preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
285       TableName tableName) throws IOException {
286   }
287 
288   @Override
289   public void postDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
290       TableName tableName) throws IOException {
291   }
292 
293   @Override
294   public void preDisableTableHandler(
295       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
296       throws IOException {
297   }
298 
299   @Override
300   public void postDisableTableHandler(
301       ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
302       throws IOException {
303   }
304 
305   @Override
306   public void preAbortProcedure(
307       ObserverContext<MasterCoprocessorEnvironment> ctx,
308       final ProcedureExecutor<MasterProcedureEnv> procEnv,
309       final long procId) throws IOException {
310   }
311 
312   @Override
313   public void postAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx)
314       throws IOException {
315   }
316 
317   @Override
318   public void preListProcedures(ObserverContext<MasterCoprocessorEnvironment> ctx)
319       throws IOException {
320   }
321 
322   @Override
323   public void postListProcedures(
324       ObserverContext<MasterCoprocessorEnvironment> ctx,
325       List<ProcedureInfo> procInfoList) throws IOException {
326   }
327 
328   @Override
329   public void preAssign(ObserverContext<MasterCoprocessorEnvironment> ctx,
330       HRegionInfo regionInfo) throws IOException {
331   }
332 
333   @Override
334   public void postAssign(ObserverContext<MasterCoprocessorEnvironment> ctx,
335       HRegionInfo regionInfo) throws IOException {
336   }
337 
338   @Override
339   public void preUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx,
340       HRegionInfo regionInfo, boolean force) throws IOException {
341   }
342 
343   @Override
344   public void postUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx,
345       HRegionInfo regionInfo, boolean force) throws IOException {
346   }
347 
348   @Override
349   public void preRegionOffline(ObserverContext<MasterCoprocessorEnvironment> ctx,
350     HRegionInfo regionInfo) throws IOException {
351   }
352 
353   @Override
354   public void postRegionOffline(ObserverContext<MasterCoprocessorEnvironment> ctx,
355     HRegionInfo regionInfo) throws IOException {
356   }
357 
358   @Override
359   public void preBalance(ObserverContext<MasterCoprocessorEnvironment> ctx)
360       throws IOException {
361   }
362 
363   @Override
364   public void postBalance(ObserverContext<MasterCoprocessorEnvironment> ctx, List<RegionPlan> plans)
365       throws IOException {
366   }
367 
368   @Override
369   public boolean preBalanceSwitch(ObserverContext<MasterCoprocessorEnvironment> ctx,
370       boolean b) throws IOException {
371     return b;
372   }
373 
374   @Override
375   public void postBalanceSwitch(ObserverContext<MasterCoprocessorEnvironment> ctx,
376       boolean oldValue, boolean newValue) throws IOException {
377   }
378 
379   @Override
380   public void preShutdown(ObserverContext<MasterCoprocessorEnvironment> ctx)
381       throws IOException {
382   }
383 
384   @Override
385   public void preStopMaster(ObserverContext<MasterCoprocessorEnvironment> ctx)
386       throws IOException {
387   }
388 
389   @Override
390   public void postStartMaster(ObserverContext<MasterCoprocessorEnvironment> ctx)
391       throws IOException {
392   }
393 
394   @Override
395   public void preMasterInitialization(
396       ObserverContext<MasterCoprocessorEnvironment> ctx) throws IOException {
397   }
398 
399   @Override
400   public void start(CoprocessorEnvironment ctx) throws IOException {
401   }
402 
403   @Override
404   public void stop(CoprocessorEnvironment ctx) throws IOException {
405   }
406 
407   @Override
408   public void preMove(ObserverContext<MasterCoprocessorEnvironment> ctx,
409       HRegionInfo region, ServerName srcServer, ServerName destServer)
410   throws IOException {
411   }
412 
413   @Override
414   public void postMove(ObserverContext<MasterCoprocessorEnvironment> ctx,
415       HRegionInfo region, ServerName srcServer, ServerName destServer)
416   throws IOException {
417   }
418 
419   @Override
420   public void preSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
421       final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor)
422       throws IOException {
423   }
424 
425   @Override
426   public void postSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
427       final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor)
428       throws IOException {
429   }
430 
431   @Override
432   public void preListSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
433       final SnapshotDescription snapshot) throws IOException {
434   }
435 
436   @Override
437   public void postListSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
438       final SnapshotDescription snapshot) throws IOException {
439   }
440   
441   @Override
442   public void preCloneSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
443       final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor)
444       throws IOException {
445   }
446 
447   @Override
448   public void postCloneSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
449       final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor)
450       throws IOException {
451   }
452 
453   @Override
454   public void preRestoreSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
455       final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor)
456       throws IOException {
457   }
458 
459   @Override
460   public void postRestoreSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
461       final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor)
462       throws IOException {
463   }
464 
465   @Override
466   public void preDeleteSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
467       final SnapshotDescription snapshot) throws IOException {
468   }
469 
470   @Override
471   public void postDeleteSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx,
472       final SnapshotDescription snapshot) throws IOException {
473   }
474 
475   @Override
476   public void preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
477       List<TableName> tableNamesList, List<HTableDescriptor> descriptors)
478       throws IOException {
479   }
480 
481   @Override
482   public void postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
483       List<HTableDescriptor> descriptors) throws IOException {
484   }
485 
486 
487   @Override
488   public void preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
489       List<TableName> tableNamesList, List<HTableDescriptor> descriptors, String regex)
490       throws IOException {
491   }
492 
493   @Override
494   public void postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
495       List<TableName> tableNamesList, List<HTableDescriptor> descriptors,
496       String regex) throws IOException {
497   }
498 
499   @Override
500   public void preGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx,
501       List<HTableDescriptor> descriptors, String regex) throws IOException {
502   }
503 
504   @Override
505   public void postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx,
506       List<HTableDescriptor> descriptors, String regex) throws IOException {
507   }
508 
509   @Override
510   public void preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx,
511       TableName tableName) throws IOException {
512   }
513 
514   @Override
515   public void postTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx,
516       TableName tableName) throws IOException {
517   }
518 
519   @Override
520   public void preSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
521       final String userName, final Quotas quotas) throws IOException {
522   }
523 
524   @Override
525   public void postSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
526       final String userName, final Quotas quotas) throws IOException {
527   }
528 
529   @Override
530   public void preSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
531       final String userName, final TableName tableName, final Quotas quotas) throws IOException {
532   }
533 
534   @Override
535   public void postSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
536       final String userName, final TableName tableName, final Quotas quotas) throws IOException {
537   }
538 
539   @Override
540   public void preSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
541       final String userName, final String namespace, final Quotas quotas) throws IOException {
542   }
543 
544   @Override
545   public void postSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
546       final String userName, final String namespace, final Quotas quotas) throws IOException {
547   }
548 
549   @Override
550   public void preSetTableQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
551       final TableName tableName, final Quotas quotas) throws IOException {
552   }
553 
554   @Override
555   public void postSetTableQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
556       final TableName tableName, final Quotas quotas) throws IOException {
557   }
558 
559   @Override
560   public void preSetNamespaceQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
561       final String namespace, final Quotas quotas) throws IOException {
562   }
563 
564   @Override
565   public void postSetNamespaceQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx,
566       final String namespace, final Quotas quotas) throws IOException {
567   }
568 
569   @Override
570   public void preMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<HostAndPort>
571       servers, String targetGroup) throws IOException {
572   }
573 
574   @Override
575   public void postMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<HostAndPort>
576       servers, String targetGroup) throws IOException {
577   }
578 
579   @Override
580   public void preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName>
581       tables, String targetGroup) throws IOException {
582   }
583 
584   @Override
585   public void postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
586       Set<TableName> tables, String targetGroup) throws IOException {
587   }
588 
589   @Override
590   public void preAddRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name)
591       throws IOException {
592   }
593 
594   @Override
595   public void postAddRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name)
596       throws IOException {
597   }
598 
599   @Override
600   public void preRemoveRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name)
601       throws IOException {
602 
603   }
604 
605   @Override
606   public void postRemoveRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name)
607       throws IOException {
608   }
609 
610   @Override
611   public void preBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName)
612       throws IOException {
613   }
614 
615   @Override
616   public void postBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx,
617                                  String groupName, boolean balancerRan) throws IOException {
618   }
619 }