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
|