@Test public void testInputAsCSVTextInAndDataOut() { Schema schema = new Schema("test"); schema.addColumn(new org.apache.sqoop.schema.type.Enum("1")).addColumn(new FixedPoint("2", 2L, false)) .addColumn(new FixedPoint("3", 2L, false)).addColumn(new Text("4")).addColumn(new Text("5")) .addColumn(new Binary("6")).addColumn(new Text("7")).addColumn(new FloatingPoint("ft", 4L)); String testData = "'ENUM',10,34,'54','random data'," + getByteFieldString(new byte[] { (byte) -112, (byte) 54 }) + ",'" + String.valueOf(0x0A) + "',13.44"; dataFormat = new CSVIntermediateDataFormat(schema); dataFormat.setCSVTextData(testData); assertEquals(testData, dataFormat.getData()); }
@Override public void setCSVTextData(String csvText) { super.setData(csvText); }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setCSVTextData(String csvText) { super.setData(csvText); } }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setCSVTextData(String csvText) { super.setData(csvText); } CSVIntermediateDataFormat();  CSVIntermediateDataFormat(Schema schema); }
CSVIntermediateDataFormat extends IntermediateDataFormat<String> { @Override public void setCSVTextData(String csvText) { super.setData(csvText); } 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 setCSVTextData(String csvText) { super.setData(csvText); } 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; }