Hi list, I am trying to implement a custom ReadableSource by extending FileSourceImpl, but it doesn't look like my source is actually being used since I am reusing AvroTypes (basically just trying to pass through some avro getMeta() values).
It looks like cache() -> materialize() -> ptype.getDefaultFileSource() is being used to perform the actual read (even though pipeline.read() is being passed my custom Source). Is there any way to do this without also implementing a custom PType? Thanks -- Evan McClain https://keybase.io/aeroevan
signature.asc
Description: This is a digitally signed message part
