code: @Override
      public TTransport connect(TTransport transport, String serverHost, String asUser) throws TTransportException {
          int maxBufferSize = type.getMaxBufferSize(storm_conf);
          // create a framed transport
          TTransport conn = new TFramedTransport(transport, maxBufferSize);
  
          // connect
          conn.open();
          LOG.debug("Simple client transport has been established");
  
          return conn;
      }
docs: Connect to the specified server via framed transport
  
  @param transport The underlying Thrift transport.
  @param serverHost unused.
  @param asUser unused.