example.java

JavaRDD<String> inputFile = sparkContext.textFile(filePath, minPartitions).toJavaRDD();

JavaRDD<byte[]> bytes = inputFile.map(new Function<String, byte[]>(){
    @Override
    public byte[] call(String str) {
        return ByteUtils.utf8StringToBytes(str);
    }
});

return Option$.MODULE$.apply(JavaRDD.toRDD(bytes));