Skip to content

Navigation Menu

Appearance settings

View all features
- BY COMPANY SIZE
  Enterprises
  Small and medium teams
  Startups
  Nonprofits
- BY USE CASE
  App Modernization
  DevSecOps
  DevOps
  CI/CD
  View all use cases
- BY INDUSTRY
  Healthcare
  Financial services
  Manufacturing
  Government
  View all industries
View all solutions
- EXPLORE BY TOPIC
  AI
  Software Development
  DevOps
  Security
  View all topics
- EXPLORE BY TYPE
  Customer stories
  Events & webinars
  Ebooks & reports
  Business insights
  GitHub Skills
- SUPPORT & SERVICES
  Documentation
  Customer support
  Community forum
  Trust center
  Partners
View all resources
- COMMUNITY
  GitHub SponsorsFund open source developers
- PROGRAMS
  Security Lab
  Maintainer Community
  Accelerator
  GitHub Stars
  Archive Program
- REPOSITORIES
  Topics
  Trending
  Collections
- ENTERPRISE SOLUTIONS
  Enterprise platformAI-powered developer platform
- AVAILABLE ADD-ONS
  GitHub Advanced SecurityEnterprise-grade security features
  Copilot for BusinessEnterprise-grade AI features
  Premium SupportEnterprise-grade 24/7 support
Pricing

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

Appearance settings

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

weaviate / java-client Public

Notifications You must be signed in to change notification settings
Fork 26
Star 34

Code
Issues 16
Pull requests
Discussions
Actions
Projects
Security
Insights

Additional navigation options

Code
Issues
Pull requests
Discussions
Actions
Projects
Security
Insights

Server-side batching (SSB)#537

Merged

bevzzz merged 98 commits intomainweaviate/java-client:mainfrom

feat/ssbweaviate/java-client:feat/ssbCopy head branch name to clipboard

Mar 12, 2026

Conversation Commits98 (98)Checks Files changed

Merged

Server-side batching (SSB)#537
bevzzz merged 98 commits intomainfrom
feat/ssb

Commits

Commits on Mar 10, 2026

refactor: use Optional<ConsistencyLevel>
bevzzz
committed
wip(batch): add batch primitives (TaskHandle, Message, BatchContext
bevzzz
committed
feat(batch): start a new batch from CollectionHandle
bevzzz
committed
feat(batch): implement state transitions and event handling
bevzzz
committed
chore(batch): remove old comment
bevzzz
committed
feat(batch): implement graceful shutdown and abort
bevzzz
committed
wip(batch): implement shutdown policies
bevzzz
committed
feat(batch): implement reconnect and shutdown policies
bevzzz
committed
chore(batch): fix type Messeger -> Messenger
bevzzz
committed
fix(batch): perform OOM reconnect sequence via BaseState, not BatchContext#onEvent
bevzzz
committed
feat(batch): reconnect to GCP every 160 seconds
bevzzz
committed
test(batch): add the '10_000 objects' integration test
bevzzz
committed
fix(batch): remove redundat parameter from Event.Started
bevzzz
committed
fix(batch): use API compatible w/ JDK 17
bevzzz
committed
fix(batch): add OPENED state for when the stream hasn't been started
bevzzz
committed
fix(batch): replace of -> ofNullable
bevzzz
committed
fix(batch): create empty EnumSet via noneOf
bevzzz
committed
fix(batch): start the context before returning it
bevzzz
committed
fix(batch): handle happy path
bevzzz
committed
refactor(batch): keep safety margin for max gRPC message size
bevzzz
committed
fix(batch): update batch backlog correctly
bevzzz
committed
fix(batch): do not check invariants on entering setMaxSize()
bevzzz
committed
test(batch): test TranslatingStreamFactory
bevzzz
committed
feat(batch): updata batch.proto and adjust code
bevzzz
committed
chore(proto): delete old gRPC service stub
bevzzz
committed
fix: correct usage of Optional tenant
bevzzz
committed
ci(tests): run against Weaviate 1.36.0
bevzzz
committed
chore(javadoc): do not use @apiNote in JDK 17
bevzzz
committed
feat: provide shorthand for an empty WeaviateObject
bevzzz
committed
test(batch): add unit tests for TaskHandle
bevzzz
committed
feat(batch): make default batch size and queue size configurable
bevzzz
committed
test(batch): add tests for BatchContext
bevzzz
committed
fix(batch): avoid NPE in TaskHandle.POISON#toString
bevzzz
committed
fix(batch): fine-tuning reconnect flow after OOM and stream hangup
bevzzz
committed
chore(javadoc): remove <h3> tag
bevzzz
committed
test(batch): provide executor for running after-close events
bevzzz
committed
test(batch): drain after hangup
bevzzz
committed
test(batch): await Results event to avoid flaky tests
bevzzz
committed
test(batch): test ClientError flow triggered by exhausted reconect retries
bevzzz
committed
ci(test): use latest Weaviate version
bevzzz
committed
chore: remove dummy method
bevzzz
committed
test(batch): cleanup BatchContextTest
bevzzz
committed
feat(batch): do not interrupt the parent thread if the context is being closed already
bevzzz
committed
test(it): stop cluster after ClusterITest
bevzzz
committed
test(batch): add 100ms wait to reduce flakiness in BatchContextTest
bevzzz
committed
test(batch): rename test case
bevzzz
committed
docs(batch): document BatchContext
bevzzz
committed
test(oidc): add grace period for access token refresh
bevzzz
committed
chore(batch): fix javadoc
bevzzz
committed
test(batch): alias long variables
bevzzz
committed
refactor(batch): structure Send and Recv as CompletableFutures
bevzzz
committed
feat(batch): make sure to read all Results before closing the context
bevzzz
committed
chore(batch): update comment
bevzzz
committed
test(batch): simplify integration test setup
bevzzz
committed
test(batch): use explicit type
bevzzz
committed
fix(batch): use Future for 'send' task, as it is actually cancelable
bevzzz
committed
debug(batch): add more detailed message to test assertion
bevzzz
committed
test(it): do not stop static containers
bevzzz
committed
fix(batch): guard against null reference
bevzzz
committed
chore: remove stale imports
bevzzz
committed
refactor: handle all events in BaseState
bevzzz
committed
debug: disable tests which may potentially block
bevzzz
committed
debug: ignore more tests
bevzzz
committed
fix: replace %s -> %q formatting directive
bevzzz
committed
debug: disable remaining integration tests
bevzzz
committed
debug: disable BatchContextTest
bevzzz
committed
fix(batch): allow Oom to ignore incoming ServerShuttingDown message
bevzzz
committed
debug: re-introduce some of the integration tests
bevzzz
committed
debug: enable all integration tests
bevzzz
committed
debug: disable Oidc and Orm tests
bevzzz
committed
debug: enable BatchContextTest
bevzzz
committed
debug: re-activate Oidc/Orm tests
bevzzz
committed
fix(batch): improve reconnect and shutdown mechanisms
bevzzz
committed
debug: ignore Oidc test again
bevzzz
committed
test(oidc): ignore flaky test and enable test suite
bevzzz
committed
test(batch): enable BatchContextTest
bevzzz
committed
debug: disable oidc support test
bevzzz
committed
fix(batch): shutdown reconnect executor
bevzzz
committed
ci: only run BatchContextTest
bevzzz
committed
debug: only run OidcSupport test
bevzzz
committed
debug: skip Oidc test
bevzzz
committed
ci: run tests sequentially and run BatchContextTest first
bevzzz
committed
fix(batch): avoid Assertions.catch*
bevzzz
committed
ci: run unit tests separately
bevzzz
committed
test(batch): increase timeout
bevzzz
committed
test(batch): create individual executors for every test
bevzzz
committed
test(batch): add assertions
bevzzz
committed
test(oidc): add eventually to reduce flakiness
bevzzz
committed
test(batch): increase timeout
bevzzz
committed
chore: cleanup
bevzzz
committed
test(batch): re-arrange assertions
bevzzz
committed
debug: delete assertion
bevzzz
committed
test(batch): reset interrupted flag before shutting down executors
bevzzz
committed
fix(batch): implement review suggestions
bevzzz
committed
fix(batch): send batch and transition to IN_FLIGHT atomically
bevzzz
committed
chore(batch): replace System.out.println with SLF4J logging
bevzzz
committed
chore(batch): add debug logs to tests
bevzzz
committed
chore(batch): change default logging format for tests
bevzzz
committed

Footer

© 2026 GitHub, Inc.

Footer navigation

Terms
Privacy
Security
Status
Community
Docs
Contact

You can’t perform that action at this time.