OrcFile extends Scheme<Configuration, RecordReader, OutputCollector, Corc, Corc> { public static SinkBuilder sink() { return new SinkBuilder(); } OrcFile(StructTypeInfo typeInfo, SearchArgument searchArgument, Fields fields, StructTypeInfo schemaTypeInfo,
      ConverterFactory converterFactory);  OrcFile(Fields fields, StructTypeInfo schemaTypeInfo, ConverterFactory converterFactory); private  OrcFile(StructTypeInfo typeInfo, SearchArgument searchArgument, Fields fields, StructTypeInfo schemaTypeInfo,
      ConverterFactory converterFactory, SchemeType type); static SourceBuilder source(); static SinkBuilder sink(); @Override void sourceConfInit(FlowProcess<? extends Configuration> flowProcess,
      Tap<Configuration, RecordReader, OutputCollector> tap, Configuration conf); @Override void sourcePrepare(FlowProcess<? extends Configuration> flowProcess, SourceCall<Corc, RecordReader> sourceCall); @Override boolean source(FlowProcess<? extends Configuration> flowProcess, SourceCall<Corc, RecordReader> sourceCall); @Override void sinkConfInit(FlowProcess<? extends Configuration> flowProcess,
      Tap<Configuration, RecordReader, OutputCollector> tap, Configuration conf); @Override void sinkPrepare(FlowProcess<? extends Configuration> flowProcess, SinkCall<Corc, OutputCollector> sinkCall); @SuppressWarnings("unchecked") @Override void sink(FlowProcess<? extends Configuration> flowProcess, SinkCall<Corc, OutputCollector> sinkCall); @Override boolean isSymmetrical(); @Override boolean isSource(); @Override boolean isSink(); static final Fields ROW__ID; static final boolean IGNORE_ROW_ID; }
@Test(expected = TupleException.class) public void writeIncorrectType() throws IOException { Fields intField = new Fields("A", int.class); OrcFile orcFile = OrcFile.sink().schema(intField).build(); Tap<?, ?, ?> tap = new Hfs(orcFile, path); Data data = new DataBuilder(FIELD_A).addTuple("hello").build(); Plunger.writeData(data).toTap(tap); }