@Test public void testSkipHeaderCountIsNotANaturalNumber() { thrown.expect(IllegalArgumentException.class); thrown.expectMessage("Property SKIP_HEADER_COUNT has incorrect value -5 : must be a non-negative integer"); context.setDataSource("/foo"); context.addOption("SKIP_HEADER_COUNT", "-5"); accessor.initialize(context); }
@Override public void initialize(RequestContext context) { super.initialize(context); ((TextInputFormat) inputFormat).configure(jobConf); skipHeaderCount = context.getFragmentIndex() == 0 ? context.getOption("SKIP_HEADER_COUNT", 0, true) : 0; }
LineBreakAccessor extends HdfsSplittableDataAccessor { @Override public void initialize(RequestContext context) { super.initialize(context); ((TextInputFormat) inputFormat).configure(jobConf); skipHeaderCount = context.getFragmentIndex() == 0 ? context.getOption("SKIP_HEADER_COUNT", 0, true) : 0; } }
LineBreakAccessor extends HdfsSplittableDataAccessor { @Override public void initialize(RequestContext context) { super.initialize(context); ((TextInputFormat) inputFormat).configure(jobConf); skipHeaderCount = context.getFragmentIndex() == 0 ? context.getOption("SKIP_HEADER_COUNT", 0, true) : 0; } LineBreakAccessor(); }
LineBreakAccessor extends HdfsSplittableDataAccessor { @Override public void initialize(RequestContext context) { super.initialize(context); ((TextInputFormat) inputFormat).configure(jobConf); skipHeaderCount = context.getFragmentIndex() == 0 ? context.getOption("SKIP_HEADER_COUNT", 0, true) : 0; } LineBreakAccessor(); @Override void initialize(RequestContext context); @Override OneRow readNextObject(); @Override boolean openForWrite(); @Override boolean writeNextObject(OneRow onerow); @Override void closeForWrite(); }
LineBreakAccessor extends HdfsSplittableDataAccessor { @Override public void initialize(RequestContext context) { super.initialize(context); ((TextInputFormat) inputFormat).configure(jobConf); skipHeaderCount = context.getFragmentIndex() == 0 ? context.getOption("SKIP_HEADER_COUNT", 0, true) : 0; } LineBreakAccessor(); @Override void initialize(RequestContext context); @Override OneRow readNextObject(); @Override boolean openForWrite(); @Override boolean writeNextObject(OneRow onerow); @Override void closeForWrite(); static final String PXF_CHUNK_RECORD_READER_ENABLED; static final boolean PXF_CHUNK_RECORD_READER_DEFAULT; }