Create ExtractionStep as an Avro schema
Update test to use ProgresService #write(item), #read(Select)