public JavaPairRDD readFromFluo()

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

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

  public JavaPairRDD<RowColumn, Bytes> readFromFluo(JavaSparkContext ctx) {
    Job job;
    try {
      job = Job.getInstance(hadoopConfig);
    } catch (IOException e) {
      throw new IllegalStateException(e);
    }
    FluoEntryInputFormat.configure(job, fluoConfig);

    return ctx.newAPIHadoopRDD(job.getConfiguration(), FluoEntryInputFormat.class, RowColumn.class,
        Bytes.class);
  }