@Test public void testInputAsObjectArrayInAndDataOut() { Object[] out = createObjectArray(); dataFormat.setObjectData(out); GenericRecord avroObject = createAvroGenericRecord(); assertEquals(avroObject.toString(), dataFormat.getData().toString()); }
@Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toAVRO(data); }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toAVRO(data); } }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toAVRO(data); } AVROIntermediateDataFormat();  AVROIntermediateDataFormat(org.apache.sqoop.schema.Schema schema); }
AVROIntermediateDataFormat extends IntermediateDataFormat<GenericRecord> { @Override public void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toAVRO(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 void setObjectData(Object[] data) { super.validateSchema(schema); this.data = toAVRO(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();  }