private JavaPairRDD partitionForAccumulo()

in modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java [331:342]

• 11 lines of code
• 2 McCabe index (conditional complexity)

  private JavaPairRDD<RowColumn, Bytes> partitionForAccumulo(JavaPairRDD<RowColumn, Bytes> data,
      String accumuloTable, BulkImportOptions opts) {
    // partition and sort data so that one file is created per an accumulo tablet
    Partitioner accumuloPartitioner;
    try (AccumuloClient client = getAccumuloClient(fluoConfig)) {
      accumuloPartitioner = new AccumuloRangePartitioner(
          chooseConnector(client, opts).tableOperations().listSplits(accumuloTable));
    } catch (TableNotFoundException | AccumuloSecurityException | AccumuloException e) {
      throw new IllegalStateException(e);
    }
    return data.repartitionAndSortWithinPartitions(accumuloPartitioner);
  }