EARLY WIP on Source/Sink/Flow JavaAPIs, code compiles, tests not yet