@Test public void testTrigInput() throws Exception { RdfFileInputFormat.setRDFFormat(job, RDFFormat.TRIG); init(TRIG_INPUT); Assert.assertTrue(reader.nextKeyValue()); Assert.assertEquals(1, reader.getCurrentKey().get()); Statement expected = VF.createStatement( VF.createIRI("http: VF.createIRI("http: VF.createLiteral("Monica Murphy"), VF.createIRI("http: Statement actual = RyaToRdfConversions.convertStatement( reader.getCurrentValue().getRyaStatement()); Assert.assertEquals(expected, actual); }
public static void setRDFFormat(Job job, RDFFormat format) { job.getConfiguration().set(FORMAT_PROP, format.getName()); }
RdfFileInputFormat extends FileInputFormat<LongWritable, RyaStatementWritable> { public static void setRDFFormat(Job job, RDFFormat format) { job.getConfiguration().set(FORMAT_PROP, format.getName()); } }
RdfFileInputFormat extends FileInputFormat<LongWritable, RyaStatementWritable> { public static void setRDFFormat(Job job, RDFFormat format) { job.getConfiguration().set(FORMAT_PROP, format.getName()); }  }
RdfFileInputFormat extends FileInputFormat<LongWritable, RyaStatementWritable> { public static void setRDFFormat(Job job, RDFFormat format) { job.getConfiguration().set(FORMAT_PROP, format.getName()); }  static void setRDFFormat(Job job, RDFFormat format); static void setCharBufferSize(Job job, int size); static void setStatementBufferSize(Job job, int size); static void setTimeout(Job job, int seconds); @Override RecordReader<LongWritable, RyaStatementWritable> createRecordReader(InputSplit inputSplit,
            TaskAttemptContext taskAttemptContext); }
RdfFileInputFormat extends FileInputFormat<LongWritable, RyaStatementWritable> { public static void setRDFFormat(Job job, RDFFormat format) { job.getConfiguration().set(FORMAT_PROP, format.getName()); }  static void setRDFFormat(Job job, RDFFormat format); static void setCharBufferSize(Job job, int size); static void setStatementBufferSize(Job job, int size); static void setTimeout(Job job, int seconds); @Override RecordReader<LongWritable, RyaStatementWritable> createRecordReader(InputSplit inputSplit,
            TaskAttemptContext taskAttemptContext);  }