@Test
public void testAnnotatedIoType() {

    Assert.assertEquals(IOType.SourceBatch, AnnotationUtils.annotatedIoType(FakeOp1.class));
    Assert.assertEquals(IOType.SourceBatch, AnnotationUtils.annotatedIoType(FakeOp2.class));
    Assert.assertNull(AnnotationUtils.annotatedIoType(FakeOp3.class));
}