* cleaned up TypeScript in coders.ts

* run prettier again

* exporting HackedWriter interface

* fixed type and linting issues left after resolving merge conflict

[BEAM-14166] Push logic in RowWithGetters down into getters and use TreeMap to reduce memory footprint of field value cache. (#17172)

Fix NonType error when importing google.api_core fails

* added docs and location hints

* simplified model hints to come from the loader

* yapf

* added optional clock

* moved clock

* fixed typo'

* keep clock in right space

* fixed bad hints

Update beam-master version for legacy

* Fix: Spliting scans into smaller chunks to buffer reads

* Nit: removing unused imports

* Small clean up, iteration 1

* Splitting duplicate logic into helper function

* Splitting logic for rows

* Test for below batch size and fixing up internal logic

* Adding SingleRange test above the mini batch limit

* Fixing nits

* Adding multiple range test with non-overlapping ranges

* Added multiple range test with overlapping keys

* Temp commit for easier meeting. Will clean up after and commit again

* First Async change with tests working. Multiple ranges needs to be checked for proper advancing and the ArgumentCaptor test must be created

* Fixed tests, still need to implement Captor test

* Created ArgumentCaptor test and fixed test errors

* Fixed the failing emulator tests

* Spotless fix

* Cleaning up code

* Fixing nits and added test comments

* Fixing spotless

* Fixing comments

* Spotless

* Fixing build issues

* There is one error with using a non-vendered dependency. Working on it but PR is good otherwise

* Fixing build error

* Fixing part of the first round of comments, still need to work on a few

* Removed nesting from advance

* Added configurable batch limit

* Fixed tests

* Fixed tests for new implementation

* Added Byte Limit test and responded to half of the new comments

* Testing build errors, due to IDE issues

* Implemented Runtime usage which caused ByteBuffer test to fail. Cleaned up some code based on comments.

* Working on the byte buffer test, having issues with mocking Runtime values which would result in flakiness. Going to try to push for review

* Fixed the byte buffer test and should use the machine's memory when testing

* Attempting to fix ByteBufferTest

* Applying Spotless and keeping debug statements to make sure test is OK

* Reduced percentage of memory and removed print statements

* Apply spotless

* Apply spotless again

* Fixing nits

* Fixing up nits and comments

* Refactoring multiple states into cleaning flow, provided factory method and removed default segementSize behavior

* Fixing import

* Fixed tests for refactor and cleaned up implementation

* Refactored tests, added an exception test and Byte test needs to be tested manually

* Responding to comments, removed some error handling

* Responding to comments, fixed error handling and cleaned tests

* Fixing warnings

* Removed factory method inside of test and removed source dependencies. Waiting to fix CallMetric for error handling

* Fixed error handling test

* Responding to nits

* Fixed error handling

* Responding to nits

* Apply Spotless

* added comment about runiference being under development

* removed date

Bump google.golang.org/api from 0.76.0 to 0.81.0 in /sdks

Updated BatchSpannerRead.java with standard logging for exception.

* Sort expected data by index

* Update flight_delays pipeline to use apache-beam-testing dataset

Fix 2.38.0 download page.

Bumps [google.golang.org/api](https://github.com/googleapis/google-api-go-client) from 0.76.0 to 0.81.0.
- [Release notes](https://github.com/googleapis/google-api-go-client/releases)
- [Changelog](https://github.com/googleapis/google-api-go-client/blob/main/CHANGES.md)
- [Commits](https://github.com/googleapis/google-api-go-client/compare/v0.76.0...v0.81.0

)

---
updated-dependencies:
- dependency-name: google.golang.org/api
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Bump cloud.google.com/go/storage from 1.22.0 to 1.22.1 in /sdks

Merge pull request #17568 [BEAM-14426] Allow skipping of any output when writing an empty PCollection.

* Flink 1.15 runner

* Ignore Flink 1.11

* [BEAM-9324] Fix incompatibility of direct runner with cython

* documented workaround for future clean up

* Updates ModelLoader to allow defining arguments to BatchElements

* Update base.py

* Adds unit test for batch arg forwarding

* Fixes run_inference_base -> base

* lint changes

* lint changes

* fmt fix

* lint changes

* [BEAM-14129] Clean up PubsubLiteIO by removing options that no longer apply

Also remove explicit blocking on data delivery- yield to the runtime instead if no data is available since reading from Pub/Sub Lite is now performed in the background

* [BEAM-14129] Clean up PubsubLiteIO by removing options that no longer apply

Also remove explicit blocking on data delivery- yield to the runtime instead if no data is available since reading from Pub/Sub Lite is now performed in the background

* [BEAM-14129] Clean up PubsubLiteIO by removing options that no longer apply

Also remove explicit blocking on data delivery- yield to the runtime instead if no data is available since reading from Pub/Sub Lite is now performed in the background

* [BEAM-14129] Perform all file writes in WriteFiles in the background

This should allow bundles which write to multiple files to write to each of them in parallel, instead of blocking when any of their buffers fill up.

* Fix python formatting issues

Co-authored-by: Lukasz Cwik <lcwik@google.com>

[BEAM-14471] Adding testcases and examples for xlang Python DataframeTransform