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