another giant code bolus, got sink operator working, localfilesink as poc, other fixes to carry schema forward