Examples of GetTableDescriptorsRequest

Examples of com.alibaba.wasp.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

386
387
388
389
390
391
392
393
394
395
396
    @Override
    public FTable[] listTables() throws IOException {
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitor();
      try {
        GetTableDescriptorsRequest req = RequestConverter
            .buildGetTableDescriptorsRequest(null);
        return ProtobufUtil.getHTableDescriptorArray(master
            .getTableDescriptors(null, req));
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
View Full Code Here

Examples of com.alibaba.wasp.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

407
408
409
410
411
412
413
414
415
416
417
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitor();
      GetTableDescriptorsResponse htds;
      try {
        List<String> tables = new ArrayList<String>();
        tables.add(Bytes.toString(tableName));
        GetTableDescriptorsRequest req = RequestConverter
            .buildGetTableDescriptorsRequest(tables);
        htds = master.getTableDescriptors(null, req);
        if (htds.getTableSchemaList().size() > 0) {
          return ProtobufUtil.convertITableSchema(htds.getTableSchemaList()
              .get(0));
View Full Code Here

Examples of com.alibaba.wasp.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

734
735
736
737
738
739
740
741
742
743
744
        throws IOException {
      if (tableNames == null || tableNames.isEmpty())
        return new FTable[0];
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitor();
      try {
        GetTableDescriptorsRequest req = RequestConverter
            .buildGetTableDescriptorsRequest(tableNames);
        return ProtobufUtil.getHTableDescriptorArray(master
            .getTableDescriptors(null, req));
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

2626
2627
2628
2629
2630
2631
2632
2633
2634
2635
2636
    @Override
    public HTableDescriptor[] listTables() throws IOException {
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitorService();
      try {
        GetTableDescriptorsRequest req =
          RequestConverter.buildGetTableDescriptorsRequest((List<TableName>)null);
        return ProtobufUtil.getHTableDescriptorArray(master.getTableDescriptors(null, req));
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
      } finally {
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

2666
2667
2668
2669
2670
2671
2672
2673
2674
2675
2676
    public HTableDescriptor[] getHTableDescriptorsByTableName(
        List<TableName> tableNames) throws IOException {
      if (tableNames == null || tableNames.isEmpty()) return new HTableDescriptor[0];
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitorService();
      try {
        GetTableDescriptorsRequest req =
          RequestConverter.buildGetTableDescriptorsRequest(tableNames);
        return ProtobufUtil.getHTableDescriptorArray(master.getTableDescriptors(null, req));
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
      } finally {
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

2704
2705
2706
2707
2708
2709
2710
2711
2712
2713
2714
        return HTableDescriptor.META_TABLEDESC;
      }
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitorService();
      GetTableDescriptorsResponse htds;
      try {
        GetTableDescriptorsRequest req =
          RequestConverter.buildGetTableDescriptorsRequest(tableName);
        htds = master.getTableDescriptors(null, req);
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
      } finally {
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
    MasterCoprocessorHost host = master.getCoprocessorHost();
    CPMasterObserver cp = (CPMasterObserver)host.findCoprocessor(
        CPMasterObserver.class.getName());
    cp.resetStates();

    GetTableDescriptorsRequest req =
        RequestConverter.buildGetTableDescriptorsRequest((List<TableName>)null);
    master.getTableDescriptors(null, req);

    assertTrue("Coprocessor should be called on table descriptors request",
      cp.wasGetTableDescriptorsCalled());
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

646
647
648
649
650
651
652
653
654
655
656
        if (values == null || values.length == 0) {
          tableExists = false;
          GetTableDescriptorsResponse htds;
          MasterMonitorKeepAliveConnection master = connection.getKeepAliveMasterMonitorService();
          try {
            GetTableDescriptorsRequest req =
              RequestConverter.buildGetTableDescriptorsRequest(tableName);
            htds = master.getTableDescriptors(null, req);
          } catch (ServiceException se) {
            throw ProtobufUtil.getRemoteException(se);
          } finally {
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

2454
2455
2456
2457
2458
2459
2460
2461
2462
2463
2464
    @Override
    public HTableDescriptor[] listTables() throws IOException {
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitor();
      try {
        GetTableDescriptorsRequest req =
          RequestConverter.buildGetTableDescriptorsRequest(null);
        return ProtobufUtil.getHTableDescriptorArray(master.getTableDescriptors(null, req));
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
      } finally {
View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.MasterMonitorProtos.GetTableDescriptorsRequest

2469
2470
2471
2472
2473
2474
2475
2476
2477
2478
2479
    @Override
    public HTableDescriptor[] getHTableDescriptors(List<String> tableNames) throws IOException {
      if (tableNames == null || tableNames.isEmpty()) return new HTableDescriptor[0];
      MasterMonitorKeepAliveConnection master = getKeepAliveMasterMonitor();
      try {
        GetTableDescriptorsRequest req =
          RequestConverter.buildGetTableDescriptorsRequest(tableNames);
        return ProtobufUtil.getHTableDescriptorArray(master.getTableDescriptors(null, req));
      } catch (ServiceException se) {
        throw ProtobufUtil.getRemoteException(se);
      } finally {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.