Jimmy Ma 5cd605d221 Prepare injection of Versioning compatible StreamReaderFactory (#17487) ...

* Use Version instead of AirbyteVersion

* Update Deserializer interface to fit better in existing flow

* Add versioned migrator

* Refactor DefaultAirbyteStreamFactory to enable Versioning

* Use explicit constructor

* Add logging on failed message upgrade

2022-10-03 12:38:26 -07:00

..

src

Prepare injection of Versioning compatible StreamReaderFactory (#17487)

2022-10-03 12:38:26 -07:00

build.gradle

Add AirbyteProtocol Migration and SerDe framework (#17114)

2022-09-28 15:08:28 -07:00