public TableBuilder getTableBuilder()

in kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaBridgeConnection.java [164:204]

32 lines of code
2 McCabe index (conditional complexity)


  public TableBuilder getTableBuilder(final TableName tn, ExecutorService pool) {
    if (isClosed()) {
      throw new RuntimeException("KafkaBridgeConnection is closed.");
    }
    final Configuration passedInConfiguration = getConfiguration();
    return new TableBuilder() {
      @Override
      public TableBuilder setOperationTimeout(int timeout) {
        return null;
      }

      @Override
      public TableBuilder setRpcTimeout(int timeout) {
        return null;
      }

      @Override
      public TableBuilder setReadRpcTimeout(int timeout) {
        return null;
      }

      @Override
      public TableBuilder setWriteRpcTimeout(int timeout) {
        return null;
      }

      /**
       * This method was added in HBASE-27657. We donot add @Override to allow code to compile with
       * versions of hbase both having and not having HBASE-27657
       **/
      public TableBuilder setRequestAttribute(String key, byte[] value) {
        return null;
      }

      @Override
      public Table build() {
        return new KafkaTableForBridge(tn, passedInConfiguration, routingRules, producer,
          avroWriter);
      }
    };
  }