@Test(expectedExceptions = SqoopException.class) public void testNotSettingSchemaAndSetObjectData() { dataFormat = new CSVIntermediateDataFormat(); dataFormat.setObjectData(null); }
@Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toCSV(data); }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toCSV(data); } }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toCSV(data); } CSVIntermediateDataFormat();  CSVIntermediateDataFormat(Schema schema); }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toCSV(data); } CSVIntermediateDataFormat();  CSVIntermediateDataFormat(Schema schema); @Override String getCSVTextData(); @Override void setCSVTextData(String csvText); @Override Object[] getObjectData(); @Override void setObjectData(Object[] data); @Override void write(DataOutput out); @Override void read(DataInput in); @Override Set<String> getJars(); }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toCSV(data); } CSVIntermediateDataFormat();  CSVIntermediateDataFormat(Schema schema); @Override String getCSVTextData(); @Override void setCSVTextData(String csvText); @Override Object[] getObjectData(); @Override void setObjectData(Object[] data); @Override void write(DataOutput out); @Override void read(DataInput in); @Override Set<String> getJars(); static final Logger LOG; }