@Test public void testNullValueAsDataInAndCSVTextOut() { GenericRecord avroObject = new GenericData.Record(avroSchema); avroObject = setAvroRecordWithNulls(); dataFormat.setData(avroObject); String csvText = dataFormat.getCSVTextData(); String[] textValues = csvText.split(","); assertEquals(15, textValues.length); for (String text : textValues) { assertEquals(text, NULL_VALUE); } }
@Override public String getCSVTextData() { super.validateSchema(schema); return toCSV(data); }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public String getCSVTextData() { super.validateSchema(schema); return toCSV(data); } }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public String getCSVTextData() { super.validateSchema(schema); return toCSV(data); } AVROIntermediateDataFormat();  AVROIntermediateDataFormat(org.apache.sqoop.schema.Schema schema); }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public String getCSVTextData() { super.validateSchema(schema); return toCSV(data); } AVROIntermediateDataFormat();  AVROIntermediateDataFormat(org.apache.sqoop.schema.Schema schema); @Override void setCSVTextData(String text); @Override String getCSVTextData(); @Override void setObjectData(Object[] data); @Override Object[] getObjectData(); @Override void write(DataOutput out); @Override void read(DataInput in); @Override Set<String> getJars(); }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public String getCSVTextData() { super.validateSchema(schema); return toCSV(data); } AVROIntermediateDataFormat();  AVROIntermediateDataFormat(org.apache.sqoop.schema.Schema schema); @Override void setCSVTextData(String text); @Override String getCSVTextData(); @Override void setObjectData(Object[] data); @Override Object[] getObjectData(); @Override void write(DataOutput out); @Override void read(DataInput in); @Override Set<String> getJars();  }