code: @Override
      public Partition[] getPartitions(ExtractorConfig<T> config) {
  
          GetPartitionsAction<T> getPartitionsAction = new GetPartitionsAction<>(config);
  
          channel.writeAndFlush(getPartitionsAction);
  
          Response response;
          boolean interrupted = false;
          for (; ; ) {
              try {
                  response = answer.take();
                  break;
              } catch (InterruptedException ignore) {
                  interrupted = true;
              }
          }
  
          if (interrupted) {
              Thread.currentThread().interrupt();
          }
  
          return ((GetPartitionsResponse) response).getPartitions();
      }
docs: /*
  (non-Javadoc)
  
  @see com.stratio.deep.rdd.IDeepRDD#getPartitions(org.apache.spark.broadcast.Broadcast, int)