@thomas_briggs you can probably manage to do this with a combination of

__source__

and

__filter__

if there's a column you can use to split the stream of records https://sdk.meltano.com/en/latest/stream_maps.html#duplicating-or-splitting-a-stream-using-source