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