Map<String, String> datasetArgs = RuntimeArguments.extractScope(Scope.DATASET, datasetName, getRuntimeArguments());
SparkDatasetInputFormat.setDataset(configuration, datasetName, datasetArgs);
return getSparkFacade().createRDD(SparkDatasetInputFormat.class, kClass, vClass, configuration);
}
@Override
<BUG>public <T> void writeToDataset(T rdd, String datasetName, Class<?> kClass, Class<?> vClass) {
Map<String, String> datasetArgs = RuntimeArguments.extractScope(Scope.DATASET, datasetName, getRuntimeArguments());
getSparkFacade().saveAsDataset(rdd, datasetName, datasetArgs, kClass, vClass, new Configuration(hConf));
</BUG>
}

Map<String, String> datasetArgs = RuntimeArguments.extractScope(Scope.DATASET, datasetName, getRuntimeArguments());
SparkDatasetInputFormat.setDataset(configuration, datasetName, datasetArgs);
return getSparkFacade().createRDD(SparkDatasetInputFormat.class, kClass, vClass, configuration);
}
