From 050fc75aa2f89820ed54a04c121bf875efe9fd2e Mon Sep 17 00:00:00 2001
From: Jorge Esteban Quilcate Otoya
Date: Wed, 21 Jan 2026 20:10:38 +0200
Subject: [PATCH 1/2] chore(inkless): Update make and ci to check built jooq
classes
---
.github/workflows/build.yml | 10 +++------
.github/workflows/inkless.yml | 39 ++++++++++++++++++++++++++++-------
Makefile | 10 ++++++---
build.gradle | 6 +++---
4 files changed, 44 insertions(+), 21 deletions(-)
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
index 0593464041f..75e76f1f2b4 100644
--- a/.github/workflows/build.yml
+++ b/.github/workflows/build.yml
@@ -219,16 +219,12 @@ jobs:
with:
name: combined-test-catalog
- # JOOQ classes are generated on the previous validate job,
- # but if generated with JDK 17, there are no warning suppressions for `this-escape` needed after JDK 21.
- # see https://github.com/jOOQ/jOOQ/issues/15619
- - name: Regenerate JOOQ classes (needed after JDK 21)
- if: matrix.java != '17'
- run: ./gradlew :storage:inkless:generateJooqClasses
+ # JOOQ classes are pre-committed with JDK 23 (includes @SuppressWarnings("this-escape") annotations)
+ # No regeneration needed for any JDK version
- name: Verify JOOQ classes are up-to-date in release branches
if: startsWith(github.ref_name, 'inkless-')
run: |
- git diff --exit-code --stat -- storage/inkless/src/main/generated-jooq || (echo "JOOQ classes are not up-to-date, please run './gradlew :storage:inkless:generateJooqClasses' and commit the changes" && exit 1)
+ git diff --exit-code --stat -- storage/inkless/src/main/jooq || (echo "JOOQ classes are not up-to-date, please run 'make jooq' with JDK 23 and commit the changes" && exit 1)
- name: JUnit Tests
id: junit-test
uses: ./.github/actions/run-gradle
diff --git a/.github/workflows/inkless.yml b/.github/workflows/inkless.yml
index f6d66d82de4..6ef4a105635 100644
--- a/.github/workflows/inkless.yml
+++ b/.github/workflows/inkless.yml
@@ -35,12 +35,39 @@ jobs:
- uses: actions/setup-python@v5
with:
python-version: '3.12'
+
+ # Generate JOOQ classes with JDK 23 to include @SuppressWarnings("this-escape") annotations
+ - name: Setup JDK 23 for JOOQ generation
+ uses: actions/setup-java@v4
+ with:
+ distribution: temurin
+ java-version: 23
+
+ - name: Generate JOOQ classes
+ run: make jooq
+
+ - name: Verify JOOQ classes are up-to-date
+ run: |
+ if [[ -n $(git status -s -- storage/inkless/src/main/jooq) ]]; then
+ echo "JOOQ classes are not up-to-date with Flyway migrations:"
+ git status -s -- storage/inkless/src/main/jooq
+ git diff --stat -- storage/inkless/src/main/jooq
+ echo ""
+ echo "Please run 'make jooq' with JDK 23 and commit the changes"
+ exit 1
+ else
+ echo "JOOQ classes are up-to-date."
+ fi
+ shell: bash
+
+ # Switch to JDK 17 for compilation and validation
- name: Setup Gradle
uses: ./.github/actions/setup-gradle
with:
java-version: 17
gradle-cache-read-only: ${{ inputs.gradle-cache-read-only }}
gradle-cache-write-only: ${{ inputs.gradle-cache-write-only }}
+
- name: Compile and validate
env:
SCAN_ARG: ${{ inputs.is-public-fork && '--no-scan' || '--scan' }}
@@ -50,7 +77,7 @@ jobs:
# --scan: Publish the build scan. This will only work on PRs from apache/kafka and trunk
# --no-scan: For public fork PRs, we won't attempt to publish the scan
run: |
- ./gradlew --build-cache --info $SCAN_ARG check -x test
+ ./gradlew --build-cache --info $SCAN_ARG check -x test -x generateJooqClasses
- name: Gen docs
run: make docs
@@ -112,23 +139,19 @@ jobs:
gradle-cache-read-only: ${{ inputs.gradle-cache-read-only }}
gradle-cache-write-only: ${{ inputs.gradle-cache-write-only }}
develocity-access-key: ${{ secrets.GE_ACCESS_TOKEN }}
- # JOOQ classes are generated on the previous validate job,
- # but if generated with JDK 17, there are no warning suppressions for `this-escape` needed after JDK 21.
- # see https://github.com/jOOQ/jOOQ/issues/15619
- - name: Regenerate JOOQ classes (needed after JDK 21)
- if: matrix.java != '17'
- run: ./gradlew :storage:inkless:generateJooqClasses
- name: Test
# Gradle flags
# --build-cache: Let Gradle restore the build cache
# --no-scan: Don't attempt to publish the scan yet. We want to archive it first.
# --continue: Keep running even if a test fails
# -PcommitId Prevent the Git SHA being written into the jar files (which breaks caching)
+ # JOOQ classes are pre-committed with JDK 23, so no regeneration needed
id: junit-test
env:
TIMEOUT_MINUTES: 30
GRADLE_ARGS: >-
- --build-cache --no-scan
+ --build-cache --no-scan
+ -x generateJooqClasses
-PtestLoggingEvents=started,passed,skipped,failed
-PmaxParallelForks=2
-PmaxTestRetries=1 -PmaxTestRetryFailures=3
diff --git a/Makefile b/Makefile
index 8e373e82f17..3958bb2bd11 100644
--- a/Makefile
+++ b/Makefile
@@ -5,7 +5,7 @@ VERSION := 4.1.0-inkless-SNAPSHOT
.PHONY: build
build:
- ./gradlew :core:build :storage:inkless:build :metadata:build -x test
+ ./gradlew :core:build :storage:inkless:build :metadata:build -x test -x generateJooqClasses
core/build/distributions/kafka_2.13-$(VERSION).tgz:
echo "Building Kafka distribution with version $(VERSION)"
@@ -51,13 +51,13 @@ fmt:
.PHONY: test
test:
- ./gradlew :storage:inkless:test :storage:inkless:integrationTest
+ ./gradlew :storage:inkless:test :storage:inkless:integrationTest -x generateJooqClasses
./gradlew :metadata:test --tests "org.apache.kafka.controller.*"
./gradlew :core:test --tests "*Inkless*"
.PHONY: pitest
pitest:
- ./gradlew :storage:inkless:pitest
+ ./gradlew :storage:inkless:pitest -x generateJooqClasses
.PHONY: integration_test
integration_test_core:
@@ -67,6 +67,10 @@ integration_test_core:
clean:
./gradlew clean
+.PHONY: jooq
+jooq:
+ ./gradlew :storage:inkless:generateJooqClasses
+
DEMO := s3-local
.PHONY: demo
demo:
diff --git a/build.gradle b/build.gradle
index 56acda39dc8..fcd022fb582 100644
--- a/build.gradle
+++ b/build.gradle
@@ -2571,7 +2571,7 @@ project(':storage:inkless') {
)
}
basePackageName.set("org.jooq.generated")
- outputDirectory.set(project.layout.buildDirectory.dir("generated-jooq"))
+ outputDirectory.set(project.layout.projectDirectory.dir("src/main/jooq"))
includeFlywayTable.set(false)
outputSchemaToDefault.add("public")
inputs.dir("src/main/resources/db/migration")
@@ -2583,8 +2583,8 @@ project(':storage:inkless') {
java {
srcDirs = [
"src/main/java",
- "${projectDir}/build/generated/main/java",
- "${projectDir}/build/generated-jooq"
+ "src/main/jooq",
+ "${projectDir}/build/generated/main/java"
]
}
}
From 746e284519c8cd4178bca3251c577dae7916d0c4 Mon Sep 17 00:00:00 2001
From: Jorge Esteban Quilcate Otoya
Date: Wed, 21 Jan 2026 20:09:45 +0200
Subject: [PATCH 2/2] chore(storage:inkless): add jooq classes
To improve developer experience, jooq classes will be added to the
source code instead of generating them on build. This will remove the
strong dependency on Docker to build inkless.
---
.../org/jooq/generated/DefaultCatalog.java | 63 ++
.../org/jooq/generated/DefaultSchema.java | 597 ++++++++++++++++
.../main/jooq/org/jooq/generated/Domains.java | 222 ++++++
.../main/jooq/org/jooq/generated/Indexes.java | 39 ++
.../main/jooq/org/jooq/generated/Keys.java | 63 ++
.../jooq/org/jooq/generated/Routines.java | 639 ++++++++++++++++++
.../main/jooq/org/jooq/generated/Tables.java | 483 +++++++++++++
.../main/jooq/org/jooq/generated/UDTs.java | 132 ++++
.../enums/CommitBatchResponseErrorV1.java | 73 ++
.../enums/CommitFileMergeWorkItemErrorV1.java | 71 ++
.../enums/DeleteRecordsResponseErrorV1.java | 67 ++
.../EnforceRetentionResponseErrorV1.java | 65 ++
.../org/jooq/generated/enums/FileReasonT.java | 67 ++
.../org/jooq/generated/enums/FileStateT.java | 67 ++
.../enums/FindBatchesResponseErrorV1.java | 67 ++
.../enums/ListOffsetsResponseErrorV1.java | 69 ++
.../ReleaseFileMergeWorkItemErrorV1.java | 67 ++
.../generated/routines/BatchTimestamp.java | 111 +++
.../routines/CommitFileMergeWorkItemV1.java | 208 ++++++
.../generated/routines/DeleteBatchV1.java | 69 ++
.../generated/routines/DeleteFilesV1.java | 52 ++
.../generated/routines/DeleteTopicV1.java | 70 ++
.../routines/MarkFileToDeleteV1.java | 69 ++
.../routines/ReleaseFileMergeWorkItemV1.java | 71 ++
.../org/jooq/generated/tables/Batches.java | 379 +++++++++++
.../jooq/generated/tables/CommitFileV1.java | 200 ++++++
.../generated/tables/DeleteRecordsV1.java | 179 +++++
.../generated/tables/EnforceRetentionV1.java | 179 +++++
.../generated/tables/EnforceRetentionV2.java | 184 +++++
.../tables/FileMergeWorkItemFiles.java | 318 +++++++++
.../generated/tables/FileMergeWorkItems.java | 309 +++++++++
.../jooq/org/jooq/generated/tables/Files.java | 377 +++++++++++
.../jooq/generated/tables/FindBatchesV1.java | 175 +++++
.../jooq/generated/tables/FindBatchesV2.java | 180 +++++
.../tables/GetFileMergeWorkItemV1.java | 186 +++++
.../jooq/generated/tables/ListOffsetsV1.java | 169 +++++
.../jooq/org/jooq/generated/tables/Logs.java | 315 +++++++++
.../jooq/generated/tables/ProducerState.java | 277 ++++++++
.../tables/records/BatchesRecord.java | 240 +++++++
.../tables/records/CommitFileV1Record.java | 75 ++
.../tables/records/DeleteRecordsV1Record.java | 75 ++
.../records/EnforceRetentionV1Record.java | 75 ++
.../records/EnforceRetentionV2Record.java | 75 ++
.../records/FileMergeWorkItemFilesRecord.java | 88 +++
.../records/FileMergeWorkItemsRecord.java | 90 +++
.../generated/tables/records/FilesRecord.java | 198 ++++++
.../tables/records/FindBatchesV1Record.java | 75 ++
.../tables/records/FindBatchesV2Record.java | 75 ++
.../records/GetFileMergeWorkItemV1Record.java | 75 ++
.../tables/records/ListOffsetsV1Record.java | 75 ++
.../generated/tables/records/LogsRecord.java | 149 ++++
.../tables/records/ProducerStateRecord.java | 194 ++++++
.../org/jooq/generated/udt/BatchInfoV1.java | 76 +++
.../jooq/generated/udt/BatchMetadataV1.java | 120 ++++
.../generated/udt/CommitBatchRequestV1.java | 130 ++++
.../generated/udt/CommitBatchResponseV1.java | 94 +++
.../udt/CommitFileMergeWorkItemBatchV1.java | 72 ++
.../CommitFileMergeWorkItemResponseV1.java | 73 ++
.../generated/udt/DeleteRecordsRequestV1.java | 78 +++
.../udt/DeleteRecordsResponseV1.java | 84 +++
.../udt/EnforceRetentionRequestV1.java | 83 +++
.../udt/EnforceRetentionResponseV1.java | 95 +++
.../udt/FileMergeWorkItemResponseBatchV1.java | 80 +++
.../udt/FileMergeWorkItemResponseFileV1.java | 88 +++
.../udt/FileMergeWorkItemResponseV1.java | 79 +++
.../generated/udt/FindBatchesRequestV1.java | 84 +++
.../generated/udt/FindBatchesResponseV1.java | 95 +++
.../generated/udt/ListOffsetsRequestV1.java | 78 +++
.../generated/udt/ListOffsetsResponseV1.java | 89 +++
.../ReleaseFileMergeWorkItemResponseV1.java | 67 ++
.../generated/udt/paths/BatchInfoV1Path.java | 61 ++
.../udt/paths/BatchMetadataV1Path.java | 104 +++
.../udt/paths/CommitBatchRequestV1Path.java | 114 ++++
.../udt/paths/CommitBatchResponseV1Path.java | 78 +++
.../CommitFileMergeWorkItemBatchV1Path.java | 56 ++
...CommitFileMergeWorkItemResponseV1Path.java | 57 ++
.../udt/paths/DeleteRecordsRequestV1Path.java | 62 ++
.../paths/DeleteRecordsResponseV1Path.java | 68 ++
.../paths/EnforceRetentionRequestV1Path.java | 67 ++
.../paths/EnforceRetentionResponseV1Path.java | 79 +++
.../FileMergeWorkItemResponseBatchV1Path.java | 64 ++
.../FileMergeWorkItemResponseFileV1Path.java | 72 ++
.../FileMergeWorkItemResponseV1Path.java | 64 ++
.../udt/paths/FindBatchesRequestV1Path.java | 68 ++
.../udt/paths/FindBatchesResponseV1Path.java | 80 +++
.../udt/paths/ListOffsetsRequestV1Path.java | 62 ++
.../udt/paths/ListOffsetsResponseV1Path.java | 73 ++
...eleaseFileMergeWorkItemResponseV1Path.java | 50 ++
.../udt/records/BatchInfoV1Record.java | 93 +++
.../udt/records/BatchMetadataV1Record.java | 215 ++++++
.../records/CommitBatchRequestV1Record.java | 245 +++++++
.../records/CommitBatchResponseV1Record.java | 140 ++++
.../CommitFileMergeWorkItemBatchV1Record.java | 80 +++
...mmitFileMergeWorkItemResponseV1Record.java | 81 +++
.../records/DeleteRecordsRequestV1Record.java | 94 +++
.../DeleteRecordsResponseV1Record.java | 110 +++
.../EnforceRetentionRequestV1Record.java | 109 +++
.../EnforceRetentionResponseV1Record.java | 140 ++++
...ileMergeWorkItemResponseBatchV1Record.java | 95 +++
...FileMergeWorkItemResponseFileV1Record.java | 123 ++++
.../FileMergeWorkItemResponseV1Record.java | 95 +++
.../records/FindBatchesRequestV1Record.java | 111 +++
.../records/FindBatchesResponseV1Record.java | 140 ++++
.../records/ListOffsetsRequestV1Record.java | 94 +++
.../records/ListOffsetsResponseV1Record.java | 125 ++++
...easeFileMergeWorkItemResponseV1Record.java | 64 ++
106 files changed, 13485 insertions(+)
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/DefaultCatalog.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/DefaultSchema.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/Domains.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/Indexes.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/Keys.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/Routines.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/Tables.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/UDTs.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitBatchResponseErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitFileMergeWorkItemErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/DeleteRecordsResponseErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/EnforceRetentionResponseErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/FileReasonT.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/FileStateT.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/FindBatchesResponseErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/ListOffsetsResponseErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/enums/ReleaseFileMergeWorkItemErrorV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/BatchTimestamp.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/CommitFileMergeWorkItemV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteBatchV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteFilesV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteTopicV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/MarkFileToDeleteV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/routines/ReleaseFileMergeWorkItemV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/Batches.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/CommitFileV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/DeleteRecordsV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV2.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/FileMergeWorkItemFiles.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/FileMergeWorkItems.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/Files.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/FindBatchesV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/FindBatchesV2.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/GetFileMergeWorkItemV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/ListOffsetsV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/Logs.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/ProducerState.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/BatchesRecord.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/CommitFileV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/DeleteRecordsV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/EnforceRetentionV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/EnforceRetentionV2Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/FileMergeWorkItemFilesRecord.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/FileMergeWorkItemsRecord.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/FilesRecord.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/FindBatchesV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/FindBatchesV2Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/GetFileMergeWorkItemV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/ListOffsetsV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/LogsRecord.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/tables/records/ProducerStateRecord.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/BatchInfoV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/BatchMetadataV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/CommitBatchRequestV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/CommitBatchResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/CommitFileMergeWorkItemBatchV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/CommitFileMergeWorkItemResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/DeleteRecordsRequestV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/DeleteRecordsResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/EnforceRetentionRequestV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/EnforceRetentionResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/FileMergeWorkItemResponseBatchV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/FileMergeWorkItemResponseFileV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/FileMergeWorkItemResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/FindBatchesRequestV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/FindBatchesResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/ListOffsetsRequestV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/ListOffsetsResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/ReleaseFileMergeWorkItemResponseV1.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/BatchInfoV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/BatchMetadataV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/CommitBatchRequestV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/CommitBatchResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/CommitFileMergeWorkItemBatchV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/CommitFileMergeWorkItemResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/DeleteRecordsRequestV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/DeleteRecordsResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/EnforceRetentionRequestV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/EnforceRetentionResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/FileMergeWorkItemResponseBatchV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/FileMergeWorkItemResponseFileV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/FileMergeWorkItemResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/FindBatchesRequestV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/FindBatchesResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/ListOffsetsRequestV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/ListOffsetsResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/paths/ReleaseFileMergeWorkItemResponseV1Path.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/BatchInfoV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/BatchMetadataV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/CommitBatchRequestV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/CommitBatchResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/CommitFileMergeWorkItemBatchV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/CommitFileMergeWorkItemResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/DeleteRecordsRequestV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/DeleteRecordsResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/EnforceRetentionRequestV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/EnforceRetentionResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/FileMergeWorkItemResponseBatchV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/FileMergeWorkItemResponseFileV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/FileMergeWorkItemResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/FindBatchesRequestV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/FindBatchesResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/ListOffsetsRequestV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/ListOffsetsResponseV1Record.java
create mode 100644 storage/inkless/src/main/jooq/org/jooq/generated/udt/records/ReleaseFileMergeWorkItemResponseV1Record.java
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/DefaultCatalog.java b/storage/inkless/src/main/jooq/org/jooq/generated/DefaultCatalog.java
new file mode 100644
index 00000000000..069f4e68cd1
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/DefaultCatalog.java
@@ -0,0 +1,63 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import java.util.Arrays;
+import java.util.List;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Constants;
+import org.jooq.Schema;
+import org.jooq.impl.CatalogImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DefaultCatalog extends CatalogImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of DEFAULT_CATALOG
+ */
+ public static final DefaultCatalog DEFAULT_CATALOG = new DefaultCatalog();
+
+ /**
+ * The schema DEFAULT_SCHEMA.
+ */
+ public final DefaultSchema DEFAULT_SCHEMA = DefaultSchema.DEFAULT_SCHEMA;
+
+ /**
+ * No further instances allowed
+ */
+ private DefaultCatalog() {
+ super("");
+ }
+
+ @Override
+ public final List getSchemas() {
+ return Arrays.asList(
+ DefaultSchema.DEFAULT_SCHEMA
+ );
+ }
+
+ /**
+ * A reference to the 3.19 minor release of the code generator. If this
+ * doesn't compile, it's because the runtime library uses an older minor
+ * release, namely: 3.19. You can turn off the generation of this reference
+ * by specifying /configuration/generator/generate/jooqVersionReference
+ */
+ private static final String REQUIRE_RUNTIME_JOOQ_VERSION = Constants.VERSION_3_19;
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/DefaultSchema.java b/storage/inkless/src/main/jooq/org/jooq/generated/DefaultSchema.java
new file mode 100644
index 00000000000..0c708220a9c
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/DefaultSchema.java
@@ -0,0 +1,597 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import java.time.Instant;
+import java.util.Arrays;
+import java.util.List;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.Configuration;
+import org.jooq.Domain;
+import org.jooq.Field;
+import org.jooq.Result;
+import org.jooq.Table;
+import org.jooq.UDT;
+import org.jooq.generated.tables.Batches;
+import org.jooq.generated.tables.CommitFileV1;
+import org.jooq.generated.tables.DeleteRecordsV1;
+import org.jooq.generated.tables.EnforceRetentionV1;
+import org.jooq.generated.tables.EnforceRetentionV2;
+import org.jooq.generated.tables.FileMergeWorkItemFiles;
+import org.jooq.generated.tables.FileMergeWorkItems;
+import org.jooq.generated.tables.Files;
+import org.jooq.generated.tables.FindBatchesV1;
+import org.jooq.generated.tables.FindBatchesV2;
+import org.jooq.generated.tables.GetFileMergeWorkItemV1;
+import org.jooq.generated.tables.ListOffsetsV1;
+import org.jooq.generated.tables.Logs;
+import org.jooq.generated.tables.ProducerState;
+import org.jooq.generated.tables.records.CommitFileV1Record;
+import org.jooq.generated.tables.records.DeleteRecordsV1Record;
+import org.jooq.generated.tables.records.EnforceRetentionV1Record;
+import org.jooq.generated.tables.records.EnforceRetentionV2Record;
+import org.jooq.generated.tables.records.FindBatchesV1Record;
+import org.jooq.generated.tables.records.FindBatchesV2Record;
+import org.jooq.generated.tables.records.GetFileMergeWorkItemV1Record;
+import org.jooq.generated.tables.records.ListOffsetsV1Record;
+import org.jooq.generated.udt.BatchInfoV1;
+import org.jooq.generated.udt.BatchMetadataV1;
+import org.jooq.generated.udt.CommitBatchRequestV1;
+import org.jooq.generated.udt.CommitBatchResponseV1;
+import org.jooq.generated.udt.CommitFileMergeWorkItemBatchV1;
+import org.jooq.generated.udt.CommitFileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.DeleteRecordsRequestV1;
+import org.jooq.generated.udt.DeleteRecordsResponseV1;
+import org.jooq.generated.udt.EnforceRetentionRequestV1;
+import org.jooq.generated.udt.EnforceRetentionResponseV1;
+import org.jooq.generated.udt.FileMergeWorkItemResponseBatchV1;
+import org.jooq.generated.udt.FileMergeWorkItemResponseFileV1;
+import org.jooq.generated.udt.FileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.FindBatchesRequestV1;
+import org.jooq.generated.udt.FindBatchesResponseV1;
+import org.jooq.generated.udt.ListOffsetsRequestV1;
+import org.jooq.generated.udt.ListOffsetsResponseV1;
+import org.jooq.generated.udt.ReleaseFileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.records.CommitBatchRequestV1Record;
+import org.jooq.generated.udt.records.DeleteRecordsRequestV1Record;
+import org.jooq.generated.udt.records.EnforceRetentionRequestV1Record;
+import org.jooq.generated.udt.records.FindBatchesRequestV1Record;
+import org.jooq.generated.udt.records.ListOffsetsRequestV1Record;
+import org.jooq.impl.SchemaImpl;
+import org.jooq.types.YearToSecond;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DefaultSchema extends SchemaImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of DEFAULT_SCHEMA
+ */
+ public static final DefaultSchema DEFAULT_SCHEMA = new DefaultSchema();
+
+ /**
+ * The table batches.
+ */
+ public final Batches BATCHES = Batches.BATCHES;
+
+ /**
+ * The table commit_file_v1.
+ */
+ public final CommitFileV1 COMMIT_FILE_V1 = CommitFileV1.COMMIT_FILE_V1;
+
+ /**
+ * Call commit_file_v1.
+ */
+ public static Result COMMIT_FILE_V1(
+ Configuration configuration
+ , String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey
+ , argFormat
+ , argUploaderBrokerId
+ , argFileSize
+ , argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get commit_file_v1 as a table.
+ */
+ public static CommitFileV1 COMMIT_FILE_V1(
+ String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get commit_file_v1 as a table.
+ */
+ public static CommitFileV1 COMMIT_FILE_V1(
+ Field argObjectKey
+ , Field argFormat
+ , Field argUploaderBrokerId
+ , Field argFileSize
+ , Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * The table delete_records_v1.
+ */
+ public final DeleteRecordsV1 DELETE_RECORDS_V1 = DeleteRecordsV1.DELETE_RECORDS_V1;
+
+ /**
+ * Call delete_records_v1.
+ */
+ public static Result DELETE_RECORDS_V1(
+ Configuration configuration
+ , Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get delete_records_v1 as a table.
+ */
+ public static DeleteRecordsV1 DELETE_RECORDS_V1(
+ Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get delete_records_v1 as a table.
+ */
+ public static DeleteRecordsV1 DELETE_RECORDS_V1(
+ Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * The table enforce_retention_v1.
+ */
+ public final EnforceRetentionV1 ENFORCE_RETENTION_V1 = EnforceRetentionV1.ENFORCE_RETENTION_V1;
+
+ /**
+ * Call enforce_retention_v1.
+ */
+ public static Result ENFORCE_RETENTION_V1(
+ Configuration configuration
+ , Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get enforce_retention_v1 as a table.
+ */
+ public static EnforceRetentionV1 ENFORCE_RETENTION_V1(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get enforce_retention_v1 as a table.
+ */
+ public static EnforceRetentionV1 ENFORCE_RETENTION_V1(
+ Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * The table enforce_retention_v2.
+ */
+ public final EnforceRetentionV2 ENFORCE_RETENTION_V2 = EnforceRetentionV2.ENFORCE_RETENTION_V2;
+
+ /**
+ * Call enforce_retention_v2.
+ */
+ public static Result ENFORCE_RETENTION_V2(
+ Configuration configuration
+ , Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow
+ , argRequests
+ , maxBatchesPerRequest
+ )).fetch();
+ }
+
+ /**
+ * Get enforce_retention_v2 as a table.
+ */
+ public static EnforceRetentionV2 ENFORCE_RETENTION_V2(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ );
+ }
+
+ /**
+ * Get enforce_retention_v2 as a table.
+ */
+ public static EnforceRetentionV2 ENFORCE_RETENTION_V2(
+ Field argNow
+ , Field argRequests
+ , Field maxBatchesPerRequest
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ );
+ }
+
+ /**
+ * The table file_merge_work_item_files.
+ */
+ public final FileMergeWorkItemFiles FILE_MERGE_WORK_ITEM_FILES = FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES;
+
+ /**
+ * The table file_merge_work_items.
+ */
+ public final FileMergeWorkItems FILE_MERGE_WORK_ITEMS = FileMergeWorkItems.FILE_MERGE_WORK_ITEMS;
+
+ /**
+ * The table files.
+ */
+ public final Files FILES = Files.FILES;
+
+ /**
+ * The table find_batches_v1.
+ */
+ public final FindBatchesV1 FIND_BATCHES_V1 = FindBatchesV1.FIND_BATCHES_V1;
+
+ /**
+ * Call find_batches_v1.
+ */
+ public static Result FIND_BATCHES_V1(
+ Configuration configuration
+ , FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests
+ , fetchMaxBytes
+ )).fetch();
+ }
+
+ /**
+ * Get find_batches_v1 as a table.
+ */
+ public static FindBatchesV1 FIND_BATCHES_V1(
+ FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ ) {
+ return org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests,
+ fetchMaxBytes
+ );
+ }
+
+ /**
+ * Get find_batches_v1 as a table.
+ */
+ public static FindBatchesV1 FIND_BATCHES_V1(
+ Field argRequests
+ , Field fetchMaxBytes
+ ) {
+ return org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests,
+ fetchMaxBytes
+ );
+ }
+
+ /**
+ * The table find_batches_v2.
+ */
+ public final FindBatchesV2 FIND_BATCHES_V2 = FindBatchesV2.FIND_BATCHES_V2;
+
+ /**
+ * Call find_batches_v2.
+ */
+ public static Result FIND_BATCHES_V2(
+ Configuration configuration
+ , FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ , Integer maxBatchesPerPartition
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests
+ , fetchMaxBytes
+ , maxBatchesPerPartition
+ )).fetch();
+ }
+
+ /**
+ * Get find_batches_v2 as a table.
+ */
+ public static FindBatchesV2 FIND_BATCHES_V2(
+ FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ , Integer maxBatchesPerPartition
+ ) {
+ return org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests,
+ fetchMaxBytes,
+ maxBatchesPerPartition
+ );
+ }
+
+ /**
+ * Get find_batches_v2 as a table.
+ */
+ public static FindBatchesV2 FIND_BATCHES_V2(
+ Field argRequests
+ , Field fetchMaxBytes
+ , Field maxBatchesPerPartition
+ ) {
+ return org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests,
+ fetchMaxBytes,
+ maxBatchesPerPartition
+ );
+ }
+
+ /**
+ * The table get_file_merge_work_item_v1.
+ */
+ public final GetFileMergeWorkItemV1 GET_FILE_MERGE_WORK_ITEM_V1 = GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1;
+
+ /**
+ * Call get_file_merge_work_item_v1.
+ */
+ public static Result GET_FILE_MERGE_WORK_ITEM_V1(
+ Configuration configuration
+ , Instant argNow
+ , YearToSecond argExpirationInterval
+ , Long argMergeFileSizeThreshold
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow
+ , argExpirationInterval
+ , argMergeFileSizeThreshold
+ )).fetch();
+ }
+
+ /**
+ * Get get_file_merge_work_item_v1 as a table.
+ */
+ public static GetFileMergeWorkItemV1 GET_FILE_MERGE_WORK_ITEM_V1(
+ Instant argNow
+ , YearToSecond argExpirationInterval
+ , Long argMergeFileSizeThreshold
+ ) {
+ return org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow,
+ argExpirationInterval,
+ argMergeFileSizeThreshold
+ );
+ }
+
+ /**
+ * Get get_file_merge_work_item_v1 as a table.
+ */
+ public static GetFileMergeWorkItemV1 GET_FILE_MERGE_WORK_ITEM_V1(
+ Field argNow
+ , Field argExpirationInterval
+ , Field argMergeFileSizeThreshold
+ ) {
+ return org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow,
+ argExpirationInterval,
+ argMergeFileSizeThreshold
+ );
+ }
+
+ /**
+ * The table list_offsets_v1.
+ */
+ public final ListOffsetsV1 LIST_OFFSETS_V1 = ListOffsetsV1.LIST_OFFSETS_V1;
+
+ /**
+ * Call list_offsets_v1.
+ */
+ public static Result LIST_OFFSETS_V1(
+ Configuration configuration
+ , ListOffsetsRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get list_offsets_v1 as a table.
+ */
+ public static ListOffsetsV1 LIST_OFFSETS_V1(
+ ListOffsetsRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ );
+ }
+
+ /**
+ * Get list_offsets_v1 as a table.
+ */
+ public static ListOffsetsV1 LIST_OFFSETS_V1(
+ Field argRequests
+ ) {
+ return org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ );
+ }
+
+ /**
+ * The table logs.
+ */
+ public final Logs LOGS = Logs.LOGS;
+
+ /**
+ * The table producer_state.
+ */
+ public final ProducerState PRODUCER_STATE = ProducerState.PRODUCER_STATE;
+
+ /**
+ * No further instances allowed
+ */
+ private DefaultSchema() {
+ super("", null);
+ }
+
+
+ @Override
+ public Catalog getCatalog() {
+ return DefaultCatalog.DEFAULT_CATALOG;
+ }
+
+ @Override
+ public final List> getDomains() {
+ return Arrays.asList(
+ Domains.BIGINT_NOT_NULLABLE_T,
+ Domains.BROKER_ID_T,
+ Domains.BYTE_OFFSET_T,
+ Domains.BYTE_SIZE_T,
+ Domains.FORMAT_T,
+ Domains.MAGIC_T,
+ Domains.OBJECT_KEY_T,
+ Domains.OFFSET_NULLABLE_T,
+ Domains.OFFSET_T,
+ Domains.OFFSET_WITH_MINUS_ONE_T,
+ Domains.PARTITION_T,
+ Domains.PRODUCER_EPOCH_T,
+ Domains.PRODUCER_ID_T,
+ Domains.RETENTION_T,
+ Domains.SEQUENCE_T,
+ Domains.TIMESTAMP_T,
+ Domains.TIMESTAMP_TYPE_T,
+ Domains.TOPIC_ID_T,
+ Domains.TOPIC_NAME_T
+ );
+ }
+
+ @Override
+ public final List> getTables() {
+ return Arrays.asList(
+ Batches.BATCHES,
+ CommitFileV1.COMMIT_FILE_V1,
+ DeleteRecordsV1.DELETE_RECORDS_V1,
+ EnforceRetentionV1.ENFORCE_RETENTION_V1,
+ EnforceRetentionV2.ENFORCE_RETENTION_V2,
+ FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES,
+ FileMergeWorkItems.FILE_MERGE_WORK_ITEMS,
+ Files.FILES,
+ FindBatchesV1.FIND_BATCHES_V1,
+ FindBatchesV2.FIND_BATCHES_V2,
+ GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1,
+ ListOffsetsV1.LIST_OFFSETS_V1,
+ Logs.LOGS,
+ ProducerState.PRODUCER_STATE
+ );
+ }
+
+ @Override
+ public final List> getUDTs() {
+ return Arrays.asList(
+ BatchInfoV1.BATCH_INFO_V1,
+ BatchMetadataV1.BATCH_METADATA_V1,
+ CommitBatchRequestV1.COMMIT_BATCH_REQUEST_V1,
+ CommitBatchResponseV1.COMMIT_BATCH_RESPONSE_V1,
+ CommitFileMergeWorkItemBatchV1.COMMIT_FILE_MERGE_WORK_ITEM_BATCH_V1,
+ CommitFileMergeWorkItemResponseV1.COMMIT_FILE_MERGE_WORK_ITEM_RESPONSE_V1,
+ DeleteRecordsRequestV1.DELETE_RECORDS_REQUEST_V1,
+ DeleteRecordsResponseV1.DELETE_RECORDS_RESPONSE_V1,
+ EnforceRetentionRequestV1.ENFORCE_RETENTION_REQUEST_V1,
+ EnforceRetentionResponseV1.ENFORCE_RETENTION_RESPONSE_V1,
+ FileMergeWorkItemResponseBatchV1.FILE_MERGE_WORK_ITEM_RESPONSE_BATCH_V1,
+ FileMergeWorkItemResponseFileV1.FILE_MERGE_WORK_ITEM_RESPONSE_FILE_V1,
+ FileMergeWorkItemResponseV1.FILE_MERGE_WORK_ITEM_RESPONSE_V1,
+ FindBatchesRequestV1.FIND_BATCHES_REQUEST_V1,
+ FindBatchesResponseV1.FIND_BATCHES_RESPONSE_V1,
+ ListOffsetsRequestV1.LIST_OFFSETS_REQUEST_V1,
+ ListOffsetsResponseV1.LIST_OFFSETS_RESPONSE_V1,
+ ReleaseFileMergeWorkItemResponseV1.RELEASE_FILE_MERGE_WORK_ITEM_RESPONSE_V1
+ );
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/Domains.java b/storage/inkless/src/main/jooq/org/jooq/generated/Domains.java
new file mode 100644
index 00000000000..e26966afed7
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/Domains.java
@@ -0,0 +1,222 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import java.util.UUID;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Domain;
+import org.jooq.Schema;
+import org.jooq.impl.DSL;
+import org.jooq.impl.Internal;
+import org.jooq.impl.LazySchema;
+import org.jooq.impl.SQLDataType;
+
+
+/**
+ * Convenience access to all Domains in the default schema.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Domains {
+
+ /**
+ * The domain bigint_not_nullable_t.
+ */
+ public static final Domain BIGINT_NOT_NULLABLE_T = Internal.createDomain(
+ schema()
+ , DSL.name("bigint_not_nullable_t")
+ , SQLDataType.BIGINT
+ , Internal.createCheck(null, null, "CHECK ((VALUE IS NOT NULL))")
+ );
+
+ /**
+ * The domain broker_id_t.
+ */
+ public static final Domain BROKER_ID_T = Internal.createDomain(
+ schema()
+ , DSL.name("broker_id_t")
+ , SQLDataType.INTEGER.nullable(false)
+ );
+
+ /**
+ * The domain byte_offset_t.
+ */
+ public static final Domain BYTE_OFFSET_T = Internal.createDomain(
+ schema()
+ , DSL.name("byte_offset_t")
+ , SQLDataType.BIGINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= 0))")
+ );
+
+ /**
+ * The domain byte_size_t.
+ */
+ public static final Domain BYTE_SIZE_T = Internal.createDomain(
+ schema()
+ , DSL.name("byte_size_t")
+ , SQLDataType.BIGINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= 0))")
+ );
+
+ /**
+ * The domain format_t.
+ */
+ public static final Domain FORMAT_T = Internal.createDomain(
+ schema()
+ , DSL.name("format_t")
+ , SQLDataType.SMALLINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK (((VALUE >= 1) AND (VALUE <= 3)))")
+ );
+
+ /**
+ * The domain magic_t.
+ */
+ public static final Domain MAGIC_T = Internal.createDomain(
+ schema()
+ , DSL.name("magic_t")
+ , SQLDataType.SMALLINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK (((VALUE >= 0) AND (VALUE <= 2)))")
+ );
+
+ /**
+ * The domain object_key_t.
+ */
+ public static final Domain OBJECT_KEY_T = Internal.createDomain(
+ schema()
+ , DSL.name("object_key_t")
+ , SQLDataType.VARCHAR(1024).nullable(false)
+ );
+
+ /**
+ * The domain offset_nullable_t.
+ */
+ public static final Domain OFFSET_NULLABLE_T = Internal.createDomain(
+ schema()
+ , DSL.name("offset_nullable_t")
+ , SQLDataType.BIGINT
+ , Internal.createCheck(null, null, "CHECK (((VALUE IS NULL) OR (VALUE >= 0)))")
+ );
+
+ /**
+ * The domain offset_t.
+ */
+ public static final Domain OFFSET_T = Internal.createDomain(
+ schema()
+ , DSL.name("offset_t")
+ , SQLDataType.BIGINT
+ , Internal.createCheck(null, null, "CHECK ((VALUE IS NOT NULL))")
+ );
+
+ /**
+ * The domain offset_with_minus_one_t.
+ */
+ public static final Domain OFFSET_WITH_MINUS_ONE_T = Internal.createDomain(
+ schema()
+ , DSL.name("offset_with_minus_one_t")
+ , SQLDataType.BIGINT
+ , Internal.createCheck(null, null, "CHECK (((VALUE IS NOT NULL) AND (VALUE >= '-1'::integer)))")
+ );
+
+ /**
+ * The domain partition_t.
+ */
+ public static final Domain PARTITION_T = Internal.createDomain(
+ schema()
+ , DSL.name("partition_t")
+ , SQLDataType.INTEGER.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= 0))")
+ );
+
+ /**
+ * The domain producer_epoch_t.
+ */
+ public static final Domain PRODUCER_EPOCH_T = Internal.createDomain(
+ schema()
+ , DSL.name("producer_epoch_t")
+ , SQLDataType.SMALLINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= '-1'::integer))")
+ );
+
+ /**
+ * The domain producer_id_t.
+ */
+ public static final Domain PRODUCER_ID_T = Internal.createDomain(
+ schema()
+ , DSL.name("producer_id_t")
+ , SQLDataType.BIGINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= '-1'::integer))")
+ );
+
+ /**
+ * The domain retention_t.
+ */
+ public static final Domain RETENTION_T = Internal.createDomain(
+ schema()
+ , DSL.name("retention_t")
+ , SQLDataType.BIGINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= '-1'::integer))")
+ );
+
+ /**
+ * The domain sequence_t.
+ */
+ public static final Domain SEQUENCE_T = Internal.createDomain(
+ schema()
+ , DSL.name("sequence_t")
+ , SQLDataType.INTEGER.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= '-1'::integer))")
+ );
+
+ /**
+ * The domain timestamp_t.
+ */
+ public static final Domain TIMESTAMP_T = Internal.createDomain(
+ schema()
+ , DSL.name("timestamp_t")
+ , SQLDataType.BIGINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK ((VALUE >= '-5'::integer))")
+ );
+
+ /**
+ * The domain timestamp_type_t.
+ */
+ public static final Domain TIMESTAMP_TYPE_T = Internal.createDomain(
+ schema()
+ , DSL.name("timestamp_type_t")
+ , SQLDataType.SMALLINT.nullable(false)
+ , Internal.createCheck(null, null, "CHECK (((VALUE >= '-1'::integer) AND (VALUE <= 1)))")
+ );
+
+ /**
+ * The domain topic_id_t.
+ */
+ public static final Domain TOPIC_ID_T = Internal.createDomain(
+ schema()
+ , DSL.name("topic_id_t")
+ , SQLDataType.UUID.nullable(false)
+ );
+
+ /**
+ * The domain topic_name_t.
+ */
+ public static final Domain TOPIC_NAME_T = Internal.createDomain(
+ schema()
+ , DSL.name("topic_name_t")
+ , SQLDataType.VARCHAR(255).nullable(false)
+ );
+
+ private static final Schema schema() {
+ return new LazySchema(DSL.name(""), DSL.comment(""), () -> DefaultSchema.DEFAULT_SCHEMA);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/Indexes.java b/storage/inkless/src/main/jooq/org/jooq/generated/Indexes.java
new file mode 100644
index 00000000000..88d5ac62aa4
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/Indexes.java
@@ -0,0 +1,39 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Index;
+import org.jooq.OrderField;
+import org.jooq.generated.tables.Batches;
+import org.jooq.generated.tables.FileMergeWorkItemFiles;
+import org.jooq.generated.tables.Files;
+import org.jooq.impl.DSL;
+import org.jooq.impl.Internal;
+
+
+/**
+ * A class modelling indexes of tables in the default schema.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Indexes {
+
+ // -------------------------------------------------------------------------
+ // INDEX definitions
+ // -------------------------------------------------------------------------
+
+ public static final Index BATCHES_BY_FILE = Internal.createIndex(DSL.name("batches_by_file"), Batches.BATCHES, new OrderField[] { Batches.BATCHES.FILE_ID }, false);
+ public static final Index FILE_MERGE_WORK_ITEM_FILES_BY_FILE = Internal.createIndex(DSL.name("file_merge_work_item_files_by_file"), FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES, new OrderField[] { FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES.FILE_ID }, false);
+ public static final Index FILES_BY_STATE_ONLY_DELETING_IDX = Internal.createIndex(DSL.name("files_by_state_only_deleting_idx"), Files.FILES, new OrderField[] { Files.FILES.STATE }, false);
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/Keys.java b/storage/inkless/src/main/jooq/org/jooq/generated/Keys.java
new file mode 100644
index 00000000000..f6dc23baa32
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/Keys.java
@@ -0,0 +1,63 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.ForeignKey;
+import org.jooq.TableField;
+import org.jooq.UniqueKey;
+import org.jooq.generated.tables.Batches;
+import org.jooq.generated.tables.FileMergeWorkItemFiles;
+import org.jooq.generated.tables.FileMergeWorkItems;
+import org.jooq.generated.tables.Files;
+import org.jooq.generated.tables.Logs;
+import org.jooq.generated.tables.ProducerState;
+import org.jooq.generated.tables.records.BatchesRecord;
+import org.jooq.generated.tables.records.FileMergeWorkItemFilesRecord;
+import org.jooq.generated.tables.records.FileMergeWorkItemsRecord;
+import org.jooq.generated.tables.records.FilesRecord;
+import org.jooq.generated.tables.records.LogsRecord;
+import org.jooq.generated.tables.records.ProducerStateRecord;
+import org.jooq.impl.DSL;
+import org.jooq.impl.Internal;
+
+
+/**
+ * A class modelling foreign key relationships and constraints of tables in the
+ * default schema.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Keys {
+
+ // -------------------------------------------------------------------------
+ // UNIQUE and PRIMARY KEY definitions
+ // -------------------------------------------------------------------------
+
+ public static final UniqueKey BATCHES_PKEY = Internal.createUniqueKey(Batches.BATCHES, DSL.name("batches_pkey"), new TableField[] { Batches.BATCHES.BATCH_ID }, true);
+ public static final UniqueKey FILE_MERGE_WORK_ITEM_FILES_PKEY = Internal.createUniqueKey(FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES, DSL.name("file_merge_work_item_files_pkey"), new TableField[] { FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES.WORK_ITEM_ID, FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES.FILE_ID }, true);
+ public static final UniqueKey FILE_MERGE_WORK_ITEMS_PKEY = Internal.createUniqueKey(FileMergeWorkItems.FILE_MERGE_WORK_ITEMS, DSL.name("file_merge_work_items_pkey"), new TableField[] { FileMergeWorkItems.FILE_MERGE_WORK_ITEMS.WORK_ITEM_ID }, true);
+ public static final UniqueKey FILES_OBJECT_KEY_KEY = Internal.createUniqueKey(Files.FILES, DSL.name("files_object_key_key"), new TableField[] { Files.FILES.OBJECT_KEY }, true);
+ public static final UniqueKey FILES_PKEY = Internal.createUniqueKey(Files.FILES, DSL.name("files_pkey"), new TableField[] { Files.FILES.FILE_ID }, true);
+ public static final UniqueKey LOGS_PKEY = Internal.createUniqueKey(Logs.LOGS, DSL.name("logs_pkey"), new TableField[] { Logs.LOGS.TOPIC_ID, Logs.LOGS.PARTITION }, true);
+ public static final UniqueKey PRODUCER_STATE_PKEY = Internal.createUniqueKey(ProducerState.PRODUCER_STATE, DSL.name("producer_state_pkey"), new TableField[] { ProducerState.PRODUCER_STATE.TOPIC_ID, ProducerState.PRODUCER_STATE.PARTITION, ProducerState.PRODUCER_STATE.PRODUCER_ID, ProducerState.PRODUCER_STATE.ROW_ID }, true);
+
+ // -------------------------------------------------------------------------
+ // FOREIGN KEY definitions
+ // -------------------------------------------------------------------------
+
+ public static final ForeignKey BATCHES__FK_BATCHES_FILES = Internal.createForeignKey(Batches.BATCHES, DSL.name("fk_batches_files"), new TableField[] { Batches.BATCHES.FILE_ID }, Keys.FILES_PKEY, new TableField[] { Files.FILES.FILE_ID }, true);
+ public static final ForeignKey BATCHES__FK_BATCHES_LOGS = Internal.createForeignKey(Batches.BATCHES, DSL.name("fk_batches_logs"), new TableField[] { Batches.BATCHES.TOPIC_ID, Batches.BATCHES.PARTITION }, Keys.LOGS_PKEY, new TableField[] { Logs.LOGS.TOPIC_ID, Logs.LOGS.PARTITION }, true);
+ public static final ForeignKey FILE_MERGE_WORK_ITEM_FILES__FILE_MERGE_WORK_ITEM_FILES_FILE_ID_FKEY = Internal.createForeignKey(FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES, DSL.name("file_merge_work_item_files_file_id_fkey"), new TableField[] { FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES.FILE_ID }, Keys.FILES_PKEY, new TableField[] { Files.FILES.FILE_ID }, true);
+ public static final ForeignKey FILE_MERGE_WORK_ITEM_FILES__FILE_MERGE_WORK_ITEM_FILES_WORK_ITEM_ID_FKEY = Internal.createForeignKey(FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES, DSL.name("file_merge_work_item_files_work_item_id_fkey"), new TableField[] { FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES.WORK_ITEM_ID }, Keys.FILE_MERGE_WORK_ITEMS_PKEY, new TableField[] { FileMergeWorkItems.FILE_MERGE_WORK_ITEMS.WORK_ITEM_ID }, true);
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/Routines.java b/storage/inkless/src/main/jooq/org/jooq/generated/Routines.java
new file mode 100644
index 00000000000..c1ffa3eb6a5
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/Routines.java
@@ -0,0 +1,639 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import java.time.Instant;
+import java.util.UUID;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Configuration;
+import org.jooq.Field;
+import org.jooq.Result;
+import org.jooq.generated.routines.BatchTimestamp;
+import org.jooq.generated.routines.CommitFileMergeWorkItemV1;
+import org.jooq.generated.routines.DeleteBatchV1;
+import org.jooq.generated.routines.DeleteFilesV1;
+import org.jooq.generated.routines.DeleteTopicV1;
+import org.jooq.generated.routines.MarkFileToDeleteV1;
+import org.jooq.generated.routines.ReleaseFileMergeWorkItemV1;
+import org.jooq.generated.tables.CommitFileV1;
+import org.jooq.generated.tables.DeleteRecordsV1;
+import org.jooq.generated.tables.EnforceRetentionV1;
+import org.jooq.generated.tables.EnforceRetentionV2;
+import org.jooq.generated.tables.FindBatchesV1;
+import org.jooq.generated.tables.FindBatchesV2;
+import org.jooq.generated.tables.GetFileMergeWorkItemV1;
+import org.jooq.generated.tables.ListOffsetsV1;
+import org.jooq.generated.tables.records.CommitFileV1Record;
+import org.jooq.generated.tables.records.DeleteRecordsV1Record;
+import org.jooq.generated.tables.records.EnforceRetentionV1Record;
+import org.jooq.generated.tables.records.EnforceRetentionV2Record;
+import org.jooq.generated.tables.records.FindBatchesV1Record;
+import org.jooq.generated.tables.records.FindBatchesV2Record;
+import org.jooq.generated.tables.records.GetFileMergeWorkItemV1Record;
+import org.jooq.generated.tables.records.ListOffsetsV1Record;
+import org.jooq.generated.udt.records.CommitBatchRequestV1Record;
+import org.jooq.generated.udt.records.CommitFileMergeWorkItemBatchV1Record;
+import org.jooq.generated.udt.records.CommitFileMergeWorkItemResponseV1Record;
+import org.jooq.generated.udt.records.DeleteRecordsRequestV1Record;
+import org.jooq.generated.udt.records.EnforceRetentionRequestV1Record;
+import org.jooq.generated.udt.records.FindBatchesRequestV1Record;
+import org.jooq.generated.udt.records.ListOffsetsRequestV1Record;
+import org.jooq.generated.udt.records.ReleaseFileMergeWorkItemResponseV1Record;
+import org.jooq.types.YearToSecond;
+
+
+/**
+ * Convenience access to all stored procedures and functions in the default
+ * schema.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Routines {
+
+ /**
+ * Call batch_timestamp
+ */
+ public static Long batchTimestamp(
+ Configuration configuration
+ , Short argTimestampType
+ , Long argBatchMaxTimestamp
+ , Long argLogAppendTimestamp
+ ) {
+ BatchTimestamp f = new BatchTimestamp();
+ f.setArgTimestampType(argTimestampType);
+ f.setArgBatchMaxTimestamp(argBatchMaxTimestamp);
+ f.setArgLogAppendTimestamp(argLogAppendTimestamp);
+
+ f.execute(configuration);
+ return f.getReturnValue();
+ }
+
+ /**
+ * Get batch_timestamp as a field.
+ */
+ public static Field batchTimestamp(
+ Short argTimestampType
+ , Long argBatchMaxTimestamp
+ , Long argLogAppendTimestamp
+ ) {
+ BatchTimestamp f = new BatchTimestamp();
+ f.setArgTimestampType(argTimestampType);
+ f.setArgBatchMaxTimestamp(argBatchMaxTimestamp);
+ f.setArgLogAppendTimestamp(argLogAppendTimestamp);
+
+ return f.asField();
+ }
+
+ /**
+ * Get batch_timestamp as a field.
+ */
+ public static Field batchTimestamp(
+ Field argTimestampType
+ , Field argBatchMaxTimestamp
+ , Field argLogAppendTimestamp
+ ) {
+ BatchTimestamp f = new BatchTimestamp();
+ f.setArgTimestampType(argTimestampType);
+ f.setArgBatchMaxTimestamp(argBatchMaxTimestamp);
+ f.setArgLogAppendTimestamp(argLogAppendTimestamp);
+
+ return f.asField();
+ }
+
+ /**
+ * Call commit_file_merge_work_item_v1
+ */
+ public static CommitFileMergeWorkItemResponseV1Record commitFileMergeWorkItemV1(
+ Configuration configuration
+ , Instant argNow
+ , Long argExistingWorkItemId
+ , String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , CommitFileMergeWorkItemBatchV1Record[] argMergeFileBatches
+ ) {
+ CommitFileMergeWorkItemV1 f = new CommitFileMergeWorkItemV1();
+ f.setArgNow(argNow);
+ f.setArgExistingWorkItemId(argExistingWorkItemId);
+ f.setArgObjectKey(argObjectKey);
+ f.setArgFormat(argFormat);
+ f.setArgUploaderBrokerId(argUploaderBrokerId);
+ f.setArgFileSize(argFileSize);
+ f.setArgMergeFileBatches(argMergeFileBatches);
+
+ f.execute(configuration);
+ return f.getReturnValue();
+ }
+
+ /**
+ * Get commit_file_merge_work_item_v1 as a field.
+ */
+ public static Field commitFileMergeWorkItemV1(
+ Instant argNow
+ , Long argExistingWorkItemId
+ , String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , CommitFileMergeWorkItemBatchV1Record[] argMergeFileBatches
+ ) {
+ CommitFileMergeWorkItemV1 f = new CommitFileMergeWorkItemV1();
+ f.setArgNow(argNow);
+ f.setArgExistingWorkItemId(argExistingWorkItemId);
+ f.setArgObjectKey(argObjectKey);
+ f.setArgFormat(argFormat);
+ f.setArgUploaderBrokerId(argUploaderBrokerId);
+ f.setArgFileSize(argFileSize);
+ f.setArgMergeFileBatches(argMergeFileBatches);
+
+ return f.asField();
+ }
+
+ /**
+ * Get commit_file_merge_work_item_v1 as a field.
+ */
+ public static Field commitFileMergeWorkItemV1(
+ Field argNow
+ , Field argExistingWorkItemId
+ , Field argObjectKey
+ , Field argFormat
+ , Field argUploaderBrokerId
+ , Field argFileSize
+ , Field argMergeFileBatches
+ ) {
+ CommitFileMergeWorkItemV1 f = new CommitFileMergeWorkItemV1();
+ f.setArgNow(argNow);
+ f.setArgExistingWorkItemId(argExistingWorkItemId);
+ f.setArgObjectKey(argObjectKey);
+ f.setArgFormat(argFormat);
+ f.setArgUploaderBrokerId(argUploaderBrokerId);
+ f.setArgFileSize(argFileSize);
+ f.setArgMergeFileBatches(argMergeFileBatches);
+
+ return f.asField();
+ }
+
+ /**
+ * Call delete_batch_v1
+ */
+ public static void deleteBatchV1(
+ Configuration configuration
+ , Instant argNow
+ , Long argBatchId
+ ) {
+ DeleteBatchV1 p = new DeleteBatchV1();
+ p.setArgNow(argNow);
+ p.setArgBatchId(argBatchId);
+
+ p.execute(configuration);
+ }
+
+ /**
+ * Call delete_files_v1
+ */
+ public static void deleteFilesV1(
+ Configuration configuration
+ , String[] argPaths
+ ) {
+ DeleteFilesV1 p = new DeleteFilesV1();
+ p.setArgPaths(argPaths);
+
+ p.execute(configuration);
+ }
+
+ /**
+ * Call delete_topic_v1
+ */
+ public static void deleteTopicV1(
+ Configuration configuration
+ , Instant argNow
+ , UUID[] argTopicIds
+ ) {
+ DeleteTopicV1 p = new DeleteTopicV1();
+ p.setArgNow(argNow);
+ p.setArgTopicIds(argTopicIds);
+
+ p.execute(configuration);
+ }
+
+ /**
+ * Call mark_file_to_delete_v1
+ */
+ public static void markFileToDeleteV1(
+ Configuration configuration
+ , Instant argNow
+ , Long argFileId
+ ) {
+ MarkFileToDeleteV1 p = new MarkFileToDeleteV1();
+ p.setArgNow(argNow);
+ p.setArgFileId(argFileId);
+
+ p.execute(configuration);
+ }
+
+ /**
+ * Call release_file_merge_work_item_v1
+ */
+ public static ReleaseFileMergeWorkItemResponseV1Record releaseFileMergeWorkItemV1(
+ Configuration configuration
+ , Long argExistingWorkItemId
+ ) {
+ ReleaseFileMergeWorkItemV1 f = new ReleaseFileMergeWorkItemV1();
+ f.setArgExistingWorkItemId(argExistingWorkItemId);
+
+ f.execute(configuration);
+ return f.getReturnValue();
+ }
+
+ /**
+ * Get release_file_merge_work_item_v1 as a field.
+ */
+ public static Field releaseFileMergeWorkItemV1(
+ Long argExistingWorkItemId
+ ) {
+ ReleaseFileMergeWorkItemV1 f = new ReleaseFileMergeWorkItemV1();
+ f.setArgExistingWorkItemId(argExistingWorkItemId);
+
+ return f.asField();
+ }
+
+ /**
+ * Get release_file_merge_work_item_v1 as a field.
+ */
+ public static Field releaseFileMergeWorkItemV1(
+ Field argExistingWorkItemId
+ ) {
+ ReleaseFileMergeWorkItemV1 f = new ReleaseFileMergeWorkItemV1();
+ f.setArgExistingWorkItemId(argExistingWorkItemId);
+
+ return f.asField();
+ }
+
+ /**
+ * Call commit_file_v1.
+ */
+ public static Result commitFileV1(
+ Configuration configuration
+ , String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey
+ , argFormat
+ , argUploaderBrokerId
+ , argFileSize
+ , argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get commit_file_v1 as a table.
+ */
+ public static CommitFileV1 commitFileV1(
+ String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get commit_file_v1 as a table.
+ */
+ public static CommitFileV1 commitFileV1(
+ Field argObjectKey
+ , Field argFormat
+ , Field argUploaderBrokerId
+ , Field argFileSize
+ , Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Call delete_records_v1.
+ */
+ public static Result deleteRecordsV1(
+ Configuration configuration
+ , Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get delete_records_v1 as a table.
+ */
+ public static DeleteRecordsV1 deleteRecordsV1(
+ Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get delete_records_v1 as a table.
+ */
+ public static DeleteRecordsV1 deleteRecordsV1(
+ Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Call enforce_retention_v1.
+ */
+ public static Result enforceRetentionV1(
+ Configuration configuration
+ , Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get enforce_retention_v1 as a table.
+ */
+ public static EnforceRetentionV1 enforceRetentionV1(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get enforce_retention_v1 as a table.
+ */
+ public static EnforceRetentionV1 enforceRetentionV1(
+ Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Call enforce_retention_v2.
+ */
+ public static Result enforceRetentionV2(
+ Configuration configuration
+ , Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow
+ , argRequests
+ , maxBatchesPerRequest
+ )).fetch();
+ }
+
+ /**
+ * Get enforce_retention_v2 as a table.
+ */
+ public static EnforceRetentionV2 enforceRetentionV2(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ );
+ }
+
+ /**
+ * Get enforce_retention_v2 as a table.
+ */
+ public static EnforceRetentionV2 enforceRetentionV2(
+ Field argNow
+ , Field argRequests
+ , Field maxBatchesPerRequest
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ );
+ }
+
+ /**
+ * Call find_batches_v1.
+ */
+ public static Result findBatchesV1(
+ Configuration configuration
+ , FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests
+ , fetchMaxBytes
+ )).fetch();
+ }
+
+ /**
+ * Get find_batches_v1 as a table.
+ */
+ public static FindBatchesV1 findBatchesV1(
+ FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ ) {
+ return org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests,
+ fetchMaxBytes
+ );
+ }
+
+ /**
+ * Get find_batches_v1 as a table.
+ */
+ public static FindBatchesV1 findBatchesV1(
+ Field argRequests
+ , Field fetchMaxBytes
+ ) {
+ return org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests,
+ fetchMaxBytes
+ );
+ }
+
+ /**
+ * Call find_batches_v2.
+ */
+ public static Result findBatchesV2(
+ Configuration configuration
+ , FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ , Integer maxBatchesPerPartition
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests
+ , fetchMaxBytes
+ , maxBatchesPerPartition
+ )).fetch();
+ }
+
+ /**
+ * Get find_batches_v2 as a table.
+ */
+ public static FindBatchesV2 findBatchesV2(
+ FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ , Integer maxBatchesPerPartition
+ ) {
+ return org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests,
+ fetchMaxBytes,
+ maxBatchesPerPartition
+ );
+ }
+
+ /**
+ * Get find_batches_v2 as a table.
+ */
+ public static FindBatchesV2 findBatchesV2(
+ Field argRequests
+ , Field fetchMaxBytes
+ , Field maxBatchesPerPartition
+ ) {
+ return org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests,
+ fetchMaxBytes,
+ maxBatchesPerPartition
+ );
+ }
+
+ /**
+ * Call get_file_merge_work_item_v1.
+ */
+ public static Result getFileMergeWorkItemV1(
+ Configuration configuration
+ , Instant argNow
+ , YearToSecond argExpirationInterval
+ , Long argMergeFileSizeThreshold
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow
+ , argExpirationInterval
+ , argMergeFileSizeThreshold
+ )).fetch();
+ }
+
+ /**
+ * Get get_file_merge_work_item_v1 as a table.
+ */
+ public static GetFileMergeWorkItemV1 getFileMergeWorkItemV1(
+ Instant argNow
+ , YearToSecond argExpirationInterval
+ , Long argMergeFileSizeThreshold
+ ) {
+ return org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow,
+ argExpirationInterval,
+ argMergeFileSizeThreshold
+ );
+ }
+
+ /**
+ * Get get_file_merge_work_item_v1 as a table.
+ */
+ public static GetFileMergeWorkItemV1 getFileMergeWorkItemV1(
+ Field argNow
+ , Field argExpirationInterval
+ , Field argMergeFileSizeThreshold
+ ) {
+ return org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow,
+ argExpirationInterval,
+ argMergeFileSizeThreshold
+ );
+ }
+
+ /**
+ * Call list_offsets_v1.
+ */
+ public static Result listOffsetsV1(
+ Configuration configuration
+ , ListOffsetsRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get list_offsets_v1 as a table.
+ */
+ public static ListOffsetsV1 listOffsetsV1(
+ ListOffsetsRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ );
+ }
+
+ /**
+ * Get list_offsets_v1 as a table.
+ */
+ public static ListOffsetsV1 listOffsetsV1(
+ Field argRequests
+ ) {
+ return org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ );
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/Tables.java b/storage/inkless/src/main/jooq/org/jooq/generated/Tables.java
new file mode 100644
index 00000000000..002ae5bd3e1
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/Tables.java
@@ -0,0 +1,483 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Configuration;
+import org.jooq.Field;
+import org.jooq.Result;
+import org.jooq.generated.tables.Batches;
+import org.jooq.generated.tables.CommitFileV1;
+import org.jooq.generated.tables.DeleteRecordsV1;
+import org.jooq.generated.tables.EnforceRetentionV1;
+import org.jooq.generated.tables.EnforceRetentionV2;
+import org.jooq.generated.tables.FileMergeWorkItemFiles;
+import org.jooq.generated.tables.FileMergeWorkItems;
+import org.jooq.generated.tables.Files;
+import org.jooq.generated.tables.FindBatchesV1;
+import org.jooq.generated.tables.FindBatchesV2;
+import org.jooq.generated.tables.GetFileMergeWorkItemV1;
+import org.jooq.generated.tables.ListOffsetsV1;
+import org.jooq.generated.tables.Logs;
+import org.jooq.generated.tables.ProducerState;
+import org.jooq.generated.tables.records.CommitFileV1Record;
+import org.jooq.generated.tables.records.DeleteRecordsV1Record;
+import org.jooq.generated.tables.records.EnforceRetentionV1Record;
+import org.jooq.generated.tables.records.EnforceRetentionV2Record;
+import org.jooq.generated.tables.records.FindBatchesV1Record;
+import org.jooq.generated.tables.records.FindBatchesV2Record;
+import org.jooq.generated.tables.records.GetFileMergeWorkItemV1Record;
+import org.jooq.generated.tables.records.ListOffsetsV1Record;
+import org.jooq.generated.udt.records.CommitBatchRequestV1Record;
+import org.jooq.generated.udt.records.DeleteRecordsRequestV1Record;
+import org.jooq.generated.udt.records.EnforceRetentionRequestV1Record;
+import org.jooq.generated.udt.records.FindBatchesRequestV1Record;
+import org.jooq.generated.udt.records.ListOffsetsRequestV1Record;
+import org.jooq.types.YearToSecond;
+
+
+/**
+ * Convenience access to all tables in the default schema.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Tables {
+
+ /**
+ * The table batches.
+ */
+ public static final Batches BATCHES = Batches.BATCHES;
+
+ /**
+ * The table commit_file_v1.
+ */
+ public static final CommitFileV1 COMMIT_FILE_V1 = CommitFileV1.COMMIT_FILE_V1;
+
+ /**
+ * Call commit_file_v1.
+ */
+ public static Result COMMIT_FILE_V1(
+ Configuration configuration
+ , String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey
+ , argFormat
+ , argUploaderBrokerId
+ , argFileSize
+ , argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get commit_file_v1 as a table.
+ */
+ public static CommitFileV1 COMMIT_FILE_V1(
+ String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get commit_file_v1 as a table.
+ */
+ public static CommitFileV1 COMMIT_FILE_V1(
+ Field argObjectKey
+ , Field argFormat
+ , Field argUploaderBrokerId
+ , Field argFileSize
+ , Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.CommitFileV1.COMMIT_FILE_V1.call(
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * The table delete_records_v1.
+ */
+ public static final DeleteRecordsV1 DELETE_RECORDS_V1 = DeleteRecordsV1.DELETE_RECORDS_V1;
+
+ /**
+ * Call delete_records_v1.
+ */
+ public static Result DELETE_RECORDS_V1(
+ Configuration configuration
+ , Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get delete_records_v1 as a table.
+ */
+ public static DeleteRecordsV1 DELETE_RECORDS_V1(
+ Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get delete_records_v1 as a table.
+ */
+ public static DeleteRecordsV1 DELETE_RECORDS_V1(
+ Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.DeleteRecordsV1.DELETE_RECORDS_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * The table enforce_retention_v1.
+ */
+ public static final EnforceRetentionV1 ENFORCE_RETENTION_V1 = EnforceRetentionV1.ENFORCE_RETENTION_V1;
+
+ /**
+ * Call enforce_retention_v1.
+ */
+ public static Result ENFORCE_RETENTION_V1(
+ Configuration configuration
+ , Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow
+ , argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get enforce_retention_v1 as a table.
+ */
+ public static EnforceRetentionV1 ENFORCE_RETENTION_V1(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * Get enforce_retention_v1 as a table.
+ */
+ public static EnforceRetentionV1 ENFORCE_RETENTION_V1(
+ Field argNow
+ , Field argRequests
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV1.ENFORCE_RETENTION_V1.call(
+ argNow,
+ argRequests
+ );
+ }
+
+ /**
+ * The table enforce_retention_v2.
+ */
+ public static final EnforceRetentionV2 ENFORCE_RETENTION_V2 = EnforceRetentionV2.ENFORCE_RETENTION_V2;
+
+ /**
+ * Call enforce_retention_v2.
+ */
+ public static Result ENFORCE_RETENTION_V2(
+ Configuration configuration
+ , Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow
+ , argRequests
+ , maxBatchesPerRequest
+ )).fetch();
+ }
+
+ /**
+ * Get enforce_retention_v2 as a table.
+ */
+ public static EnforceRetentionV2 ENFORCE_RETENTION_V2(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ );
+ }
+
+ /**
+ * Get enforce_retention_v2 as a table.
+ */
+ public static EnforceRetentionV2 ENFORCE_RETENTION_V2(
+ Field argNow
+ , Field argRequests
+ , Field maxBatchesPerRequest
+ ) {
+ return org.jooq.generated.tables.EnforceRetentionV2.ENFORCE_RETENTION_V2.call(
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ );
+ }
+
+ /**
+ * The table file_merge_work_item_files.
+ */
+ public static final FileMergeWorkItemFiles FILE_MERGE_WORK_ITEM_FILES = FileMergeWorkItemFiles.FILE_MERGE_WORK_ITEM_FILES;
+
+ /**
+ * The table file_merge_work_items.
+ */
+ public static final FileMergeWorkItems FILE_MERGE_WORK_ITEMS = FileMergeWorkItems.FILE_MERGE_WORK_ITEMS;
+
+ /**
+ * The table files.
+ */
+ public static final Files FILES = Files.FILES;
+
+ /**
+ * The table find_batches_v1.
+ */
+ public static final FindBatchesV1 FIND_BATCHES_V1 = FindBatchesV1.FIND_BATCHES_V1;
+
+ /**
+ * Call find_batches_v1.
+ */
+ public static Result FIND_BATCHES_V1(
+ Configuration configuration
+ , FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests
+ , fetchMaxBytes
+ )).fetch();
+ }
+
+ /**
+ * Get find_batches_v1 as a table.
+ */
+ public static FindBatchesV1 FIND_BATCHES_V1(
+ FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ ) {
+ return org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests,
+ fetchMaxBytes
+ );
+ }
+
+ /**
+ * Get find_batches_v1 as a table.
+ */
+ public static FindBatchesV1 FIND_BATCHES_V1(
+ Field argRequests
+ , Field fetchMaxBytes
+ ) {
+ return org.jooq.generated.tables.FindBatchesV1.FIND_BATCHES_V1.call(
+ argRequests,
+ fetchMaxBytes
+ );
+ }
+
+ /**
+ * The table find_batches_v2.
+ */
+ public static final FindBatchesV2 FIND_BATCHES_V2 = FindBatchesV2.FIND_BATCHES_V2;
+
+ /**
+ * Call find_batches_v2.
+ */
+ public static Result FIND_BATCHES_V2(
+ Configuration configuration
+ , FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ , Integer maxBatchesPerPartition
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests
+ , fetchMaxBytes
+ , maxBatchesPerPartition
+ )).fetch();
+ }
+
+ /**
+ * Get find_batches_v2 as a table.
+ */
+ public static FindBatchesV2 FIND_BATCHES_V2(
+ FindBatchesRequestV1Record[] argRequests
+ , Integer fetchMaxBytes
+ , Integer maxBatchesPerPartition
+ ) {
+ return org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests,
+ fetchMaxBytes,
+ maxBatchesPerPartition
+ );
+ }
+
+ /**
+ * Get find_batches_v2 as a table.
+ */
+ public static FindBatchesV2 FIND_BATCHES_V2(
+ Field argRequests
+ , Field fetchMaxBytes
+ , Field maxBatchesPerPartition
+ ) {
+ return org.jooq.generated.tables.FindBatchesV2.FIND_BATCHES_V2.call(
+ argRequests,
+ fetchMaxBytes,
+ maxBatchesPerPartition
+ );
+ }
+
+ /**
+ * The table get_file_merge_work_item_v1.
+ */
+ public static final GetFileMergeWorkItemV1 GET_FILE_MERGE_WORK_ITEM_V1 = GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1;
+
+ /**
+ * Call get_file_merge_work_item_v1.
+ */
+ public static Result GET_FILE_MERGE_WORK_ITEM_V1(
+ Configuration configuration
+ , Instant argNow
+ , YearToSecond argExpirationInterval
+ , Long argMergeFileSizeThreshold
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow
+ , argExpirationInterval
+ , argMergeFileSizeThreshold
+ )).fetch();
+ }
+
+ /**
+ * Get get_file_merge_work_item_v1 as a table.
+ */
+ public static GetFileMergeWorkItemV1 GET_FILE_MERGE_WORK_ITEM_V1(
+ Instant argNow
+ , YearToSecond argExpirationInterval
+ , Long argMergeFileSizeThreshold
+ ) {
+ return org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow,
+ argExpirationInterval,
+ argMergeFileSizeThreshold
+ );
+ }
+
+ /**
+ * Get get_file_merge_work_item_v1 as a table.
+ */
+ public static GetFileMergeWorkItemV1 GET_FILE_MERGE_WORK_ITEM_V1(
+ Field argNow
+ , Field argExpirationInterval
+ , Field argMergeFileSizeThreshold
+ ) {
+ return org.jooq.generated.tables.GetFileMergeWorkItemV1.GET_FILE_MERGE_WORK_ITEM_V1.call(
+ argNow,
+ argExpirationInterval,
+ argMergeFileSizeThreshold
+ );
+ }
+
+ /**
+ * The table list_offsets_v1.
+ */
+ public static final ListOffsetsV1 LIST_OFFSETS_V1 = ListOffsetsV1.LIST_OFFSETS_V1;
+
+ /**
+ * Call list_offsets_v1.
+ */
+ public static Result LIST_OFFSETS_V1(
+ Configuration configuration
+ , ListOffsetsRequestV1Record[] argRequests
+ ) {
+ return configuration.dsl().selectFrom(org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ )).fetch();
+ }
+
+ /**
+ * Get list_offsets_v1 as a table.
+ */
+ public static ListOffsetsV1 LIST_OFFSETS_V1(
+ ListOffsetsRequestV1Record[] argRequests
+ ) {
+ return org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ );
+ }
+
+ /**
+ * Get list_offsets_v1 as a table.
+ */
+ public static ListOffsetsV1 LIST_OFFSETS_V1(
+ Field argRequests
+ ) {
+ return org.jooq.generated.tables.ListOffsetsV1.LIST_OFFSETS_V1.call(
+ argRequests
+ );
+ }
+
+ /**
+ * The table logs.
+ */
+ public static final Logs LOGS = Logs.LOGS;
+
+ /**
+ * The table producer_state.
+ */
+ public static final ProducerState PRODUCER_STATE = ProducerState.PRODUCER_STATE;
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/UDTs.java b/storage/inkless/src/main/jooq/org/jooq/generated/UDTs.java
new file mode 100644
index 00000000000..538da18e510
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/UDTs.java
@@ -0,0 +1,132 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.generated.udt.BatchInfoV1;
+import org.jooq.generated.udt.BatchMetadataV1;
+import org.jooq.generated.udt.CommitBatchRequestV1;
+import org.jooq.generated.udt.CommitBatchResponseV1;
+import org.jooq.generated.udt.CommitFileMergeWorkItemBatchV1;
+import org.jooq.generated.udt.CommitFileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.DeleteRecordsRequestV1;
+import org.jooq.generated.udt.DeleteRecordsResponseV1;
+import org.jooq.generated.udt.EnforceRetentionRequestV1;
+import org.jooq.generated.udt.EnforceRetentionResponseV1;
+import org.jooq.generated.udt.FileMergeWorkItemResponseBatchV1;
+import org.jooq.generated.udt.FileMergeWorkItemResponseFileV1;
+import org.jooq.generated.udt.FileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.FindBatchesRequestV1;
+import org.jooq.generated.udt.FindBatchesResponseV1;
+import org.jooq.generated.udt.ListOffsetsRequestV1;
+import org.jooq.generated.udt.ListOffsetsResponseV1;
+import org.jooq.generated.udt.ReleaseFileMergeWorkItemResponseV1;
+
+
+/**
+ * Convenience access to all UDTs in the default schema.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class UDTs {
+
+ /**
+ * The type batch_info_v1
+ */
+ public static final BatchInfoV1 BATCH_INFO_V1 = org.jooq.generated.udt.BatchInfoV1.BATCH_INFO_V1;
+
+ /**
+ * The type batch_metadata_v1
+ */
+ public static final BatchMetadataV1 BATCH_METADATA_V1 = org.jooq.generated.udt.BatchMetadataV1.BATCH_METADATA_V1;
+
+ /**
+ * The type commit_batch_request_v1
+ */
+ public static final CommitBatchRequestV1 COMMIT_BATCH_REQUEST_V1 = org.jooq.generated.udt.CommitBatchRequestV1.COMMIT_BATCH_REQUEST_V1;
+
+ /**
+ * The type commit_batch_response_v1
+ */
+ public static final CommitBatchResponseV1 COMMIT_BATCH_RESPONSE_V1 = org.jooq.generated.udt.CommitBatchResponseV1.COMMIT_BATCH_RESPONSE_V1;
+
+ /**
+ * The type commit_file_merge_work_item_batch_v1
+ */
+ public static final CommitFileMergeWorkItemBatchV1 COMMIT_FILE_MERGE_WORK_ITEM_BATCH_V1 = org.jooq.generated.udt.CommitFileMergeWorkItemBatchV1.COMMIT_FILE_MERGE_WORK_ITEM_BATCH_V1;
+
+ /**
+ * The type commit_file_merge_work_item_response_v1
+ */
+ public static final CommitFileMergeWorkItemResponseV1 COMMIT_FILE_MERGE_WORK_ITEM_RESPONSE_V1 = org.jooq.generated.udt.CommitFileMergeWorkItemResponseV1.COMMIT_FILE_MERGE_WORK_ITEM_RESPONSE_V1;
+
+ /**
+ * The type delete_records_request_v1
+ */
+ public static final DeleteRecordsRequestV1 DELETE_RECORDS_REQUEST_V1 = org.jooq.generated.udt.DeleteRecordsRequestV1.DELETE_RECORDS_REQUEST_V1;
+
+ /**
+ * The type delete_records_response_v1
+ */
+ public static final DeleteRecordsResponseV1 DELETE_RECORDS_RESPONSE_V1 = org.jooq.generated.udt.DeleteRecordsResponseV1.DELETE_RECORDS_RESPONSE_V1;
+
+ /**
+ * The type enforce_retention_request_v1
+ */
+ public static final EnforceRetentionRequestV1 ENFORCE_RETENTION_REQUEST_V1 = org.jooq.generated.udt.EnforceRetentionRequestV1.ENFORCE_RETENTION_REQUEST_V1;
+
+ /**
+ * The type enforce_retention_response_v1
+ */
+ public static final EnforceRetentionResponseV1 ENFORCE_RETENTION_RESPONSE_V1 = org.jooq.generated.udt.EnforceRetentionResponseV1.ENFORCE_RETENTION_RESPONSE_V1;
+
+ /**
+ * The type file_merge_work_item_response_batch_v1
+ */
+ public static final FileMergeWorkItemResponseBatchV1 FILE_MERGE_WORK_ITEM_RESPONSE_BATCH_V1 = org.jooq.generated.udt.FileMergeWorkItemResponseBatchV1.FILE_MERGE_WORK_ITEM_RESPONSE_BATCH_V1;
+
+ /**
+ * The type file_merge_work_item_response_file_v1
+ */
+ public static final FileMergeWorkItemResponseFileV1 FILE_MERGE_WORK_ITEM_RESPONSE_FILE_V1 = org.jooq.generated.udt.FileMergeWorkItemResponseFileV1.FILE_MERGE_WORK_ITEM_RESPONSE_FILE_V1;
+
+ /**
+ * The type file_merge_work_item_response_v1
+ */
+ public static final FileMergeWorkItemResponseV1 FILE_MERGE_WORK_ITEM_RESPONSE_V1 = org.jooq.generated.udt.FileMergeWorkItemResponseV1.FILE_MERGE_WORK_ITEM_RESPONSE_V1;
+
+ /**
+ * The type find_batches_request_v1
+ */
+ public static final FindBatchesRequestV1 FIND_BATCHES_REQUEST_V1 = org.jooq.generated.udt.FindBatchesRequestV1.FIND_BATCHES_REQUEST_V1;
+
+ /**
+ * The type find_batches_response_v1
+ */
+ public static final FindBatchesResponseV1 FIND_BATCHES_RESPONSE_V1 = org.jooq.generated.udt.FindBatchesResponseV1.FIND_BATCHES_RESPONSE_V1;
+
+ /**
+ * The type list_offsets_request_v1
+ */
+ public static final ListOffsetsRequestV1 LIST_OFFSETS_REQUEST_V1 = org.jooq.generated.udt.ListOffsetsRequestV1.LIST_OFFSETS_REQUEST_V1;
+
+ /**
+ * The type list_offsets_response_v1
+ */
+ public static final ListOffsetsResponseV1 LIST_OFFSETS_RESPONSE_V1 = org.jooq.generated.udt.ListOffsetsResponseV1.LIST_OFFSETS_RESPONSE_V1;
+
+ /**
+ * The type release_file_merge_work_item_response_v1
+ */
+ public static final ReleaseFileMergeWorkItemResponseV1 RELEASE_FILE_MERGE_WORK_ITEM_RESPONSE_V1 = org.jooq.generated.udt.ReleaseFileMergeWorkItemResponseV1.RELEASE_FILE_MERGE_WORK_ITEM_RESPONSE_V1;
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitBatchResponseErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitBatchResponseErrorV1.java
new file mode 100644
index 00000000000..37ea9d65dab
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitBatchResponseErrorV1.java
@@ -0,0 +1,73 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum CommitBatchResponseErrorV1 implements EnumType {
+
+ none("none"),
+
+ nonexistent_log("nonexistent_log"),
+
+ invalid_producer_epoch("invalid_producer_epoch"),
+
+ sequence_out_of_order("sequence_out_of_order"),
+
+ duplicate_batch("duplicate_batch");
+
+ private final String literal;
+
+ private CommitBatchResponseErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "commit_batch_response_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static CommitBatchResponseErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(CommitBatchResponseErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitFileMergeWorkItemErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitFileMergeWorkItemErrorV1.java
new file mode 100644
index 00000000000..56eb50e13db
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/CommitFileMergeWorkItemErrorV1.java
@@ -0,0 +1,71 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum CommitFileMergeWorkItemErrorV1 implements EnumType {
+
+ none("none"),
+
+ file_merge_work_item_not_found("file_merge_work_item_not_found"),
+
+ invalid_parent_batch_count("invalid_parent_batch_count"),
+
+ batch_not_part_of_work_item("batch_not_part_of_work_item");
+
+ private final String literal;
+
+ private CommitFileMergeWorkItemErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "commit_file_merge_work_item_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static CommitFileMergeWorkItemErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(CommitFileMergeWorkItemErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/DeleteRecordsResponseErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/DeleteRecordsResponseErrorV1.java
new file mode 100644
index 00000000000..e9058b3a560
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/DeleteRecordsResponseErrorV1.java
@@ -0,0 +1,67 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum DeleteRecordsResponseErrorV1 implements EnumType {
+
+ unknown_topic_or_partition("unknown_topic_or_partition"),
+
+ offset_out_of_range("offset_out_of_range");
+
+ private final String literal;
+
+ private DeleteRecordsResponseErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "delete_records_response_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static DeleteRecordsResponseErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(DeleteRecordsResponseErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/EnforceRetentionResponseErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/EnforceRetentionResponseErrorV1.java
new file mode 100644
index 00000000000..f1e76fc78b4
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/EnforceRetentionResponseErrorV1.java
@@ -0,0 +1,65 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum EnforceRetentionResponseErrorV1 implements EnumType {
+
+ unknown_topic_or_partition("unknown_topic_or_partition");
+
+ private final String literal;
+
+ private EnforceRetentionResponseErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "enforce_retention_response_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static EnforceRetentionResponseErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(EnforceRetentionResponseErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/FileReasonT.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/FileReasonT.java
new file mode 100644
index 00000000000..00db50dc420
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/FileReasonT.java
@@ -0,0 +1,67 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum FileReasonT implements EnumType {
+
+ produce("produce"),
+
+ merge("merge");
+
+ private final String literal;
+
+ private FileReasonT(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "file_reason_t";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static FileReasonT lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(FileReasonT.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/FileStateT.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/FileStateT.java
new file mode 100644
index 00000000000..bfd08c99b77
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/FileStateT.java
@@ -0,0 +1,67 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum FileStateT implements EnumType {
+
+ uploaded("uploaded"),
+
+ deleting("deleting");
+
+ private final String literal;
+
+ private FileStateT(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "file_state_t";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static FileStateT lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(FileStateT.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/FindBatchesResponseErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/FindBatchesResponseErrorV1.java
new file mode 100644
index 00000000000..c823224839d
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/FindBatchesResponseErrorV1.java
@@ -0,0 +1,67 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum FindBatchesResponseErrorV1 implements EnumType {
+
+ offset_out_of_range("offset_out_of_range"),
+
+ unknown_topic_or_partition("unknown_topic_or_partition");
+
+ private final String literal;
+
+ private FindBatchesResponseErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "find_batches_response_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static FindBatchesResponseErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(FindBatchesResponseErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/ListOffsetsResponseErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/ListOffsetsResponseErrorV1.java
new file mode 100644
index 00000000000..d8bd3bd54a1
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/ListOffsetsResponseErrorV1.java
@@ -0,0 +1,69 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum ListOffsetsResponseErrorV1 implements EnumType {
+
+ none("none"),
+
+ unknown_topic_or_partition("unknown_topic_or_partition"),
+
+ unsupported_special_timestamp("unsupported_special_timestamp");
+
+ private final String literal;
+
+ private ListOffsetsResponseErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "list_offsets_response_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static ListOffsetsResponseErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(ListOffsetsResponseErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/enums/ReleaseFileMergeWorkItemErrorV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/enums/ReleaseFileMergeWorkItemErrorV1.java
new file mode 100644
index 00000000000..9565efcc954
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/enums/ReleaseFileMergeWorkItemErrorV1.java
@@ -0,0 +1,67 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.enums;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Catalog;
+import org.jooq.EnumType;
+import org.jooq.Schema;
+import org.jooq.generated.DefaultSchema;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public enum ReleaseFileMergeWorkItemErrorV1 implements EnumType {
+
+ none("none"),
+
+ file_merge_work_item_not_found("file_merge_work_item_not_found");
+
+ private final String literal;
+
+ private ReleaseFileMergeWorkItemErrorV1(String literal) {
+ this.literal = literal;
+ }
+
+ @Override
+ public Catalog getCatalog() {
+ return getSchema().getCatalog();
+ }
+
+ @Override
+ public Schema getSchema() {
+ return DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public String getName() {
+ return "release_file_merge_work_item_error_v1";
+ }
+
+ @Override
+ public String getLiteral() {
+ return literal;
+ }
+
+ /**
+ * Lookup a value of this EnumType by its literal. Returns
+ * null, if no such value could be found, see {@link
+ * EnumType#lookupLiteral(Class, String)}.
+ */
+ public static ReleaseFileMergeWorkItemErrorV1 lookupLiteral(String literal) {
+ return EnumType.lookupLiteral(ReleaseFileMergeWorkItemErrorV1.class, literal);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/BatchTimestamp.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/BatchTimestamp.java
new file mode 100644
index 00000000000..ce2cdd37c0a
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/BatchTimestamp.java
@@ -0,0 +1,111 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Field;
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.Domains;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class BatchTimestamp extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter batch_timestamp.RETURN_VALUE.
+ */
+ public static final Parameter RETURN_VALUE = Internal.createParameter("RETURN_VALUE", Domains.TIMESTAMP_T.getDataType(), false, false);
+
+ /**
+ * The parameter batch_timestamp.arg_timestamp_type.
+ */
+ public static final Parameter ARG_TIMESTAMP_TYPE = Internal.createParameter("arg_timestamp_type", Domains.TIMESTAMP_TYPE_T.getDataType(), false, false);
+
+ /**
+ * The parameter batch_timestamp.arg_batch_max_timestamp.
+ */
+ public static final Parameter ARG_BATCH_MAX_TIMESTAMP = Internal.createParameter("arg_batch_max_timestamp", Domains.TIMESTAMP_T.getDataType(), false, false);
+
+ /**
+ * The parameter batch_timestamp.arg_log_append_timestamp.
+ */
+ public static final Parameter ARG_LOG_APPEND_TIMESTAMP = Internal.createParameter("arg_log_append_timestamp", Domains.TIMESTAMP_T.getDataType(), false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public BatchTimestamp() {
+ super("batch_timestamp", DefaultSchema.DEFAULT_SCHEMA, Domains.TIMESTAMP_T.getDataType());
+
+ setReturnParameter(RETURN_VALUE);
+ addInParameter(ARG_TIMESTAMP_TYPE);
+ addInParameter(ARG_BATCH_MAX_TIMESTAMP);
+ addInParameter(ARG_LOG_APPEND_TIMESTAMP);
+ }
+
+ /**
+ * Set the arg_timestamp_type parameter IN value to the routine
+ */
+ public void setArgTimestampType(Short value) {
+ setValue(ARG_TIMESTAMP_TYPE, value);
+ }
+
+ /**
+ * Set the arg_timestamp_type parameter to the function to be
+ * used with a {@link org.jooq.Select} statement
+ */
+ public void setArgTimestampType(Field field) {
+ setField(ARG_TIMESTAMP_TYPE, field);
+ }
+
+ /**
+ * Set the arg_batch_max_timestamp parameter IN value to the
+ * routine
+ */
+ public void setArgBatchMaxTimestamp(Long value) {
+ setValue(ARG_BATCH_MAX_TIMESTAMP, value);
+ }
+
+ /**
+ * Set the arg_batch_max_timestamp parameter to the function to
+ * be used with a {@link org.jooq.Select} statement
+ */
+ public void setArgBatchMaxTimestamp(Field field) {
+ setField(ARG_BATCH_MAX_TIMESTAMP, field);
+ }
+
+ /**
+ * Set the arg_log_append_timestamp parameter IN value to the
+ * routine
+ */
+ public void setArgLogAppendTimestamp(Long value) {
+ setValue(ARG_LOG_APPEND_TIMESTAMP, value);
+ }
+
+ /**
+ * Set the arg_log_append_timestamp parameter to the function
+ * to be used with a {@link org.jooq.Select} statement
+ */
+ public void setArgLogAppendTimestamp(Field field) {
+ setField(ARG_LOG_APPEND_TIMESTAMP, field);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/CommitFileMergeWorkItemV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/CommitFileMergeWorkItemV1.java
new file mode 100644
index 00000000000..6c3f99665e0
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/CommitFileMergeWorkItemV1.java
@@ -0,0 +1,208 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Field;
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.Domains;
+import org.jooq.generated.udt.CommitFileMergeWorkItemBatchV1;
+import org.jooq.generated.udt.CommitFileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.records.CommitFileMergeWorkItemBatchV1Record;
+import org.jooq.generated.udt.records.CommitFileMergeWorkItemResponseV1Record;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+import org.jooq.impl.SQLDataType;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class CommitFileMergeWorkItemV1 extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter commit_file_merge_work_item_v1.RETURN_VALUE.
+ */
+ public static final Parameter RETURN_VALUE = Internal.createParameter("RETURN_VALUE", CommitFileMergeWorkItemResponseV1.COMMIT_FILE_MERGE_WORK_ITEM_RESPONSE_V1.getDataType(), false, false);
+
+ /**
+ * The parameter commit_file_merge_work_item_v1.arg_now.
+ */
+ public static final Parameter ARG_NOW = Internal.createParameter("arg_now", SQLDataType.TIMESTAMPWITHTIMEZONE, false, false, new OffsetDateTimeToInstantConverter());
+
+ /**
+ * The parameter
+ * commit_file_merge_work_item_v1.arg_existing_work_item_id.
+ */
+ public static final Parameter ARG_EXISTING_WORK_ITEM_ID = Internal.createParameter("arg_existing_work_item_id", SQLDataType.BIGINT, false, false);
+
+ /**
+ * The parameter commit_file_merge_work_item_v1.arg_object_key.
+ */
+ public static final Parameter ARG_OBJECT_KEY = Internal.createParameter("arg_object_key", Domains.OBJECT_KEY_T.getDataType(), false, false);
+
+ /**
+ * The parameter commit_file_merge_work_item_v1.arg_format.
+ */
+ public static final Parameter ARG_FORMAT = Internal.createParameter("arg_format", Domains.FORMAT_T.getDataType(), false, false);
+
+ /**
+ * The parameter
+ * commit_file_merge_work_item_v1.arg_uploader_broker_id.
+ */
+ public static final Parameter ARG_UPLOADER_BROKER_ID = Internal.createParameter("arg_uploader_broker_id", Domains.BROKER_ID_T.getDataType(), false, false);
+
+ /**
+ * The parameter commit_file_merge_work_item_v1.arg_file_size.
+ */
+ public static final Parameter ARG_FILE_SIZE = Internal.createParameter("arg_file_size", Domains.BYTE_SIZE_T.getDataType(), false, false);
+
+ /**
+ * The parameter
+ * commit_file_merge_work_item_v1.arg_merge_file_batches.
+ */
+ public static final Parameter ARG_MERGE_FILE_BATCHES = Internal.createParameter("arg_merge_file_batches", CommitFileMergeWorkItemBatchV1.COMMIT_FILE_MERGE_WORK_ITEM_BATCH_V1.getDataType().array(), false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public CommitFileMergeWorkItemV1() {
+ super("commit_file_merge_work_item_v1", DefaultSchema.DEFAULT_SCHEMA, CommitFileMergeWorkItemResponseV1.COMMIT_FILE_MERGE_WORK_ITEM_RESPONSE_V1.getDataType());
+
+ setReturnParameter(RETURN_VALUE);
+ addInParameter(ARG_NOW);
+ addInParameter(ARG_EXISTING_WORK_ITEM_ID);
+ addInParameter(ARG_OBJECT_KEY);
+ addInParameter(ARG_FORMAT);
+ addInParameter(ARG_UPLOADER_BROKER_ID);
+ addInParameter(ARG_FILE_SIZE);
+ addInParameter(ARG_MERGE_FILE_BATCHES);
+ }
+
+ /**
+ * Set the arg_now parameter IN value to the routine
+ */
+ public void setArgNow(Instant value) {
+ setValue(ARG_NOW, value);
+ }
+
+ /**
+ * Set the arg_now parameter to the function to be used with a
+ * {@link org.jooq.Select} statement
+ */
+ public void setArgNow(Field field) {
+ setField(ARG_NOW, field);
+ }
+
+ /**
+ * Set the arg_existing_work_item_id parameter IN value to the
+ * routine
+ */
+ public void setArgExistingWorkItemId(Long value) {
+ setValue(ARG_EXISTING_WORK_ITEM_ID, value);
+ }
+
+ /**
+ * Set the arg_existing_work_item_id parameter to the function
+ * to be used with a {@link org.jooq.Select} statement
+ */
+ public void setArgExistingWorkItemId(Field field) {
+ setField(ARG_EXISTING_WORK_ITEM_ID, field);
+ }
+
+ /**
+ * Set the arg_object_key parameter IN value to the routine
+ */
+ public void setArgObjectKey(String value) {
+ setValue(ARG_OBJECT_KEY, value);
+ }
+
+ /**
+ * Set the arg_object_key parameter to the function to be used
+ * with a {@link org.jooq.Select} statement
+ */
+ public void setArgObjectKey(Field field) {
+ setField(ARG_OBJECT_KEY, field);
+ }
+
+ /**
+ * Set the arg_format parameter IN value to the routine
+ */
+ public void setArgFormat(Short value) {
+ setValue(ARG_FORMAT, value);
+ }
+
+ /**
+ * Set the arg_format parameter to the function to be used with
+ * a {@link org.jooq.Select} statement
+ */
+ public void setArgFormat(Field field) {
+ setField(ARG_FORMAT, field);
+ }
+
+ /**
+ * Set the arg_uploader_broker_id parameter IN value to the
+ * routine
+ */
+ public void setArgUploaderBrokerId(Integer value) {
+ setValue(ARG_UPLOADER_BROKER_ID, value);
+ }
+
+ /**
+ * Set the arg_uploader_broker_id parameter to the function to
+ * be used with a {@link org.jooq.Select} statement
+ */
+ public void setArgUploaderBrokerId(Field field) {
+ setField(ARG_UPLOADER_BROKER_ID, field);
+ }
+
+ /**
+ * Set the arg_file_size parameter IN value to the routine
+ */
+ public void setArgFileSize(Long value) {
+ setValue(ARG_FILE_SIZE, value);
+ }
+
+ /**
+ * Set the arg_file_size parameter to the function to be used
+ * with a {@link org.jooq.Select} statement
+ */
+ public void setArgFileSize(Field field) {
+ setField(ARG_FILE_SIZE, field);
+ }
+
+ /**
+ * Set the arg_merge_file_batches parameter IN value to the
+ * routine
+ */
+ public void setArgMergeFileBatches(CommitFileMergeWorkItemBatchV1Record[] value) {
+ setValue(ARG_MERGE_FILE_BATCHES, value);
+ }
+
+ /**
+ * Set the arg_merge_file_batches parameter to the function to
+ * be used with a {@link org.jooq.Select} statement
+ */
+ public void setArgMergeFileBatches(Field field) {
+ setField(ARG_MERGE_FILE_BATCHES, field);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteBatchV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteBatchV1.java
new file mode 100644
index 00000000000..be3a959de89
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteBatchV1.java
@@ -0,0 +1,69 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+import org.jooq.impl.SQLDataType;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DeleteBatchV1 extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter delete_batch_v1.arg_now.
+ */
+ public static final Parameter ARG_NOW = Internal.createParameter("arg_now", SQLDataType.TIMESTAMPWITHTIMEZONE, false, false, new OffsetDateTimeToInstantConverter());
+
+ /**
+ * The parameter delete_batch_v1.arg_batch_id.
+ */
+ public static final Parameter ARG_BATCH_ID = Internal.createParameter("arg_batch_id", SQLDataType.BIGINT, false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public DeleteBatchV1() {
+ super("delete_batch_v1", DefaultSchema.DEFAULT_SCHEMA);
+
+ addInParameter(ARG_NOW);
+ addInParameter(ARG_BATCH_ID);
+ }
+
+ /**
+ * Set the arg_now parameter IN value to the routine
+ */
+ public void setArgNow(Instant value) {
+ setValue(ARG_NOW, value);
+ }
+
+ /**
+ * Set the arg_batch_id parameter IN value to the routine
+ */
+ public void setArgBatchId(Long value) {
+ setValue(ARG_BATCH_ID, value);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteFilesV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteFilesV1.java
new file mode 100644
index 00000000000..c7d2c6f96fb
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteFilesV1.java
@@ -0,0 +1,52 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.Domains;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DeleteFilesV1 extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter delete_files_v1.arg_paths.
+ */
+ public static final Parameter ARG_PATHS = Internal.createParameter("arg_paths", Domains.OBJECT_KEY_T.getDataType().array(), false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public DeleteFilesV1() {
+ super("delete_files_v1", DefaultSchema.DEFAULT_SCHEMA);
+
+ addInParameter(ARG_PATHS);
+ }
+
+ /**
+ * Set the arg_paths parameter IN value to the routine
+ */
+ public void setArgPaths(String[] value) {
+ setValue(ARG_PATHS, value);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteTopicV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteTopicV1.java
new file mode 100644
index 00000000000..d273fee7686
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/DeleteTopicV1.java
@@ -0,0 +1,70 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+import java.util.UUID;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+import org.jooq.impl.SQLDataType;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DeleteTopicV1 extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter delete_topic_v1.arg_now.
+ */
+ public static final Parameter ARG_NOW = Internal.createParameter("arg_now", SQLDataType.TIMESTAMPWITHTIMEZONE, false, false, new OffsetDateTimeToInstantConverter());
+
+ /**
+ * The parameter delete_topic_v1.arg_topic_ids.
+ */
+ public static final Parameter ARG_TOPIC_IDS = Internal.createParameter("arg_topic_ids", SQLDataType.UUID.array(), false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public DeleteTopicV1() {
+ super("delete_topic_v1", DefaultSchema.DEFAULT_SCHEMA);
+
+ addInParameter(ARG_NOW);
+ addInParameter(ARG_TOPIC_IDS);
+ }
+
+ /**
+ * Set the arg_now parameter IN value to the routine
+ */
+ public void setArgNow(Instant value) {
+ setValue(ARG_NOW, value);
+ }
+
+ /**
+ * Set the arg_topic_ids parameter IN value to the routine
+ */
+ public void setArgTopicIds(UUID[] value) {
+ setValue(ARG_TOPIC_IDS, value);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/MarkFileToDeleteV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/MarkFileToDeleteV1.java
new file mode 100644
index 00000000000..e090875e2ed
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/MarkFileToDeleteV1.java
@@ -0,0 +1,69 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+import org.jooq.impl.SQLDataType;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class MarkFileToDeleteV1 extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter mark_file_to_delete_v1.arg_now.
+ */
+ public static final Parameter ARG_NOW = Internal.createParameter("arg_now", SQLDataType.TIMESTAMPWITHTIMEZONE, false, false, new OffsetDateTimeToInstantConverter());
+
+ /**
+ * The parameter mark_file_to_delete_v1.arg_file_id.
+ */
+ public static final Parameter ARG_FILE_ID = Internal.createParameter("arg_file_id", SQLDataType.BIGINT, false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public MarkFileToDeleteV1() {
+ super("mark_file_to_delete_v1", DefaultSchema.DEFAULT_SCHEMA);
+
+ addInParameter(ARG_NOW);
+ addInParameter(ARG_FILE_ID);
+ }
+
+ /**
+ * Set the arg_now parameter IN value to the routine
+ */
+ public void setArgNow(Instant value) {
+ setValue(ARG_NOW, value);
+ }
+
+ /**
+ * Set the arg_file_id parameter IN value to the routine
+ */
+ public void setArgFileId(Long value) {
+ setValue(ARG_FILE_ID, value);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/routines/ReleaseFileMergeWorkItemV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/routines/ReleaseFileMergeWorkItemV1.java
new file mode 100644
index 00000000000..3081fe53d8b
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/routines/ReleaseFileMergeWorkItemV1.java
@@ -0,0 +1,71 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.routines;
+
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Field;
+import org.jooq.Parameter;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.udt.ReleaseFileMergeWorkItemResponseV1;
+import org.jooq.generated.udt.records.ReleaseFileMergeWorkItemResponseV1Record;
+import org.jooq.impl.AbstractRoutine;
+import org.jooq.impl.Internal;
+import org.jooq.impl.SQLDataType;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class ReleaseFileMergeWorkItemV1 extends AbstractRoutine {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The parameter release_file_merge_work_item_v1.RETURN_VALUE.
+ */
+ public static final Parameter RETURN_VALUE = Internal.createParameter("RETURN_VALUE", ReleaseFileMergeWorkItemResponseV1.RELEASE_FILE_MERGE_WORK_ITEM_RESPONSE_V1.getDataType(), false, false);
+
+ /**
+ * The parameter
+ * release_file_merge_work_item_v1.arg_existing_work_item_id.
+ */
+ public static final Parameter ARG_EXISTING_WORK_ITEM_ID = Internal.createParameter("arg_existing_work_item_id", SQLDataType.BIGINT, false, false);
+
+ /**
+ * Create a new routine call instance
+ */
+ public ReleaseFileMergeWorkItemV1() {
+ super("release_file_merge_work_item_v1", DefaultSchema.DEFAULT_SCHEMA, ReleaseFileMergeWorkItemResponseV1.RELEASE_FILE_MERGE_WORK_ITEM_RESPONSE_V1.getDataType());
+
+ setReturnParameter(RETURN_VALUE);
+ addInParameter(ARG_EXISTING_WORK_ITEM_ID);
+ }
+
+ /**
+ * Set the arg_existing_work_item_id parameter IN value to the
+ * routine
+ */
+ public void setArgExistingWorkItemId(Long value) {
+ setValue(ARG_EXISTING_WORK_ITEM_ID, value);
+ }
+
+ /**
+ * Set the arg_existing_work_item_id parameter to the function
+ * to be used with a {@link org.jooq.Select} statement
+ */
+ public void setArgExistingWorkItemId(Field field) {
+ setField(ARG_EXISTING_WORK_ITEM_ID, field);
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/tables/Batches.java b/storage/inkless/src/main/jooq/org/jooq/generated/tables/Batches.java
new file mode 100644
index 00000000000..e568c8ed3f8
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/tables/Batches.java
@@ -0,0 +1,379 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.tables;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.ShortToTimestampTypeConverter;
+import io.aiven.inkless.control_plane.postgres.converters.UUIDtoUuidConverter;
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+
+import javax.annotation.processing.Generated;
+
+import org.apache.kafka.common.Uuid;
+import org.apache.kafka.common.record.TimestampType;
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.ForeignKey;
+import org.jooq.Identity;
+import org.jooq.Index;
+import org.jooq.InverseForeignKey;
+import org.jooq.Name;
+import org.jooq.Path;
+import org.jooq.PlainSQL;
+import org.jooq.QueryPart;
+import org.jooq.Record;
+import org.jooq.SQL;
+import org.jooq.Schema;
+import org.jooq.Select;
+import org.jooq.Stringly;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.UniqueKey;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.Domains;
+import org.jooq.generated.Indexes;
+import org.jooq.generated.Keys;
+import org.jooq.generated.tables.Files.FilesPath;
+import org.jooq.generated.tables.Logs.LogsPath;
+import org.jooq.generated.tables.records.BatchesRecord;
+import org.jooq.impl.DSL;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Batches extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of batches
+ */
+ public static final Batches BATCHES = new Batches();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return BatchesRecord.class;
+ }
+
+ /**
+ * The column batches.batch_id.
+ */
+ public final TableField BATCH_ID = createField(DSL.name("batch_id"), SQLDataType.BIGINT.nullable(false).identity(true), this, "");
+
+ /**
+ * The column batches.magic.
+ */
+ public final TableField MAGIC = createField(DSL.name("magic"), Domains.MAGIC_T.getDataType().nullable(false), this, "");
+
+ /**
+ * The column batches.topic_id.
+ */
+ public final TableField TOPIC_ID = createField(DSL.name("topic_id"), SQLDataType.UUID.nullable(false), this, "", new UUIDtoUuidConverter());
+
+ /**
+ * The column batches.partition.
+ */
+ public final TableField PARTITION = createField(DSL.name("partition"), Domains.PARTITION_T.getDataType().nullable(false), this, "");
+
+ /**
+ * The column batches.base_offset.
+ */
+ public final TableField BASE_OFFSET = createField(DSL.name("base_offset"), Domains.OFFSET_T.getDataType(), this, "");
+
+ /**
+ * The column batches.last_offset.
+ */
+ public final TableField LAST_OFFSET = createField(DSL.name("last_offset"), Domains.OFFSET_T.getDataType(), this, "");
+
+ /**
+ * The column batches.file_id.
+ */
+ public final TableField FILE_ID = createField(DSL.name("file_id"), SQLDataType.BIGINT.nullable(false), this, "");
+
+ /**
+ * The column batches.byte_offset.
+ */
+ public final TableField BYTE_OFFSET = createField(DSL.name("byte_offset"), Domains.BYTE_OFFSET_T.getDataType().nullable(false), this, "");
+
+ /**
+ * The column batches.byte_size.
+ */
+ public final TableField BYTE_SIZE = createField(DSL.name("byte_size"), Domains.BYTE_SIZE_T.getDataType().nullable(false), this, "");
+
+ /**
+ * The column batches.timestamp_type.
+ */
+ public final TableField TIMESTAMP_TYPE = createField(DSL.name("timestamp_type"), Domains.TIMESTAMP_TYPE_T.getDataType().nullable(false), this, "", new ShortToTimestampTypeConverter());
+
+ /**
+ * The column batches.log_append_timestamp.
+ */
+ public final TableField LOG_APPEND_TIMESTAMP = createField(DSL.name("log_append_timestamp"), Domains.TIMESTAMP_T.getDataType().nullable(false), this, "");
+
+ /**
+ * The column batches.batch_max_timestamp.
+ */
+ public final TableField BATCH_MAX_TIMESTAMP = createField(DSL.name("batch_max_timestamp"), Domains.TIMESTAMP_T.getDataType().nullable(false), this, "");
+
+ private Batches(Name alias, Table aliased) {
+ this(alias, aliased, (Field>[]) null, null);
+ }
+
+ private Batches(Name alias, Table aliased, Field>[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.table(), where);
+ }
+
+ /**
+ * Create an aliased batches table reference
+ */
+ public Batches(String alias) {
+ this(DSL.name(alias), BATCHES);
+ }
+
+ /**
+ * Create an aliased batches table reference
+ */
+ public Batches(Name alias) {
+ this(alias, BATCHES);
+ }
+
+ /**
+ * Create a batches table reference
+ */
+ public Batches() {
+ this(DSL.name("batches"), null);
+ }
+
+ public Batches(Table path, ForeignKey childPath, InverseForeignKey parentPath) {
+ super(path, childPath, parentPath, BATCHES);
+ }
+
+ /**
+ * A subtype implementing {@link Path} for simplified path-based joins.
+ */
+ @Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+ )
+ public static class BatchesPath extends Batches implements Path {
+
+ private static final long serialVersionUID = 1L;
+ public BatchesPath(Table path, ForeignKey childPath, InverseForeignKey parentPath) {
+ super(path, childPath, parentPath);
+ }
+ private BatchesPath(Name alias, Table aliased) {
+ super(alias, aliased);
+ }
+
+ @Override
+ public BatchesPath as(String alias) {
+ return new BatchesPath(DSL.name(alias), this);
+ }
+
+ @Override
+ public BatchesPath as(Name alias) {
+ return new BatchesPath(alias, this);
+ }
+
+ @Override
+ public BatchesPath as(Table> alias) {
+ return new BatchesPath(alias.getQualifiedName(), this);
+ }
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public List getIndexes() {
+ return Arrays.asList(Indexes.BATCHES_BY_FILE);
+ }
+
+ @Override
+ public Identity getIdentity() {
+ return (Identity) super.getIdentity();
+ }
+
+ @Override
+ public UniqueKey getPrimaryKey() {
+ return Keys.BATCHES_PKEY;
+ }
+
+ @Override
+ public List> getReferences() {
+ return Arrays.asList(Keys.BATCHES__FK_BATCHES_FILES, Keys.BATCHES__FK_BATCHES_LOGS);
+ }
+
+ private transient FilesPath _files;
+
+ /**
+ * Get the implicit join path to the public.files table.
+ */
+ public FilesPath files() {
+ if (_files == null)
+ _files = new FilesPath(this, Keys.BATCHES__FK_BATCHES_FILES, null);
+
+ return _files;
+ }
+
+ private transient LogsPath _logs;
+
+ /**
+ * Get the implicit join path to the public.logs table.
+ */
+ public LogsPath logs() {
+ if (_logs == null)
+ _logs = new LogsPath(this, Keys.BATCHES__FK_BATCHES_LOGS, null);
+
+ return _logs;
+ }
+
+ @Override
+ public Batches as(String alias) {
+ return new Batches(DSL.name(alias), this);
+ }
+
+ @Override
+ public Batches as(Name alias) {
+ return new Batches(alias, this);
+ }
+
+ @Override
+ public Batches as(Table> alias) {
+ return new Batches(alias.getQualifiedName(), this);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Batches rename(String name) {
+ return new Batches(DSL.name(name), null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Batches rename(Name name) {
+ return new Batches(name, null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Batches rename(Table> name) {
+ return new Batches(name.getQualifiedName(), null);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Batches where(Condition condition) {
+ return new Batches(getQualifiedName(), aliased() ? this : null, null, condition);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Batches where(Collection extends Condition> conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Batches where(Condition... conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Batches where(Field condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Batches where(SQL condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Batches where(@Stringly.SQL String condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Batches where(@Stringly.SQL String condition, Object... binds) {
+ return where(DSL.condition(condition, binds));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Batches where(@Stringly.SQL String condition, QueryPart... parts) {
+ return where(DSL.condition(condition, parts));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Batches whereExists(Select> select) {
+ return where(DSL.exists(select));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Batches whereNotExists(Select> select) {
+ return where(DSL.notExists(select));
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/tables/CommitFileV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/tables/CommitFileV1.java
new file mode 100644
index 00000000000..fddad5aaed4
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/tables/CommitFileV1.java
@@ -0,0 +1,200 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.tables;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.Schema;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.Domains;
+import org.jooq.generated.tables.records.CommitFileV1Record;
+import org.jooq.generated.udt.CommitBatchRequestV1;
+import org.jooq.generated.udt.records.CommitBatchRequestV1Record;
+import org.jooq.impl.DSL;
+import org.jooq.impl.DefaultDataType;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class CommitFileV1 extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of commit_file_v1
+ */
+ public static final CommitFileV1 COMMIT_FILE_V1 = new CommitFileV1();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return CommitFileV1Record.class;
+ }
+
+ /**
+ * @deprecated Unknown data type. If this is a qualified, user-defined type,
+ * it may have been excluded from code generation. If this is a built-in
+ * type, you can define an explicit {@link org.jooq.Binding} to specify how
+ * this type should be handled. Deprecation can be turned off using
+ * {@literal } in your code generator
+ * configuration.
+ */
+ @Deprecated
+ public final TableField COMMIT_FILE_V1_ = createField(DSL.name("commit_file_v1"), DefaultDataType.getDefaultDataType("\"commit_batch_response_v1\""), this, "");
+
+ private CommitFileV1(Name alias, Table aliased) {
+ this(alias, aliased, new Field[] {
+ DSL.val(null, Domains.OBJECT_KEY_T.getDataType()),
+ DSL.val(null, Domains.FORMAT_T.getDataType()),
+ DSL.val(null, Domains.BROKER_ID_T.getDataType()),
+ DSL.val(null, Domains.BYTE_SIZE_T.getDataType()),
+ DSL.val(null, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(null, CommitBatchRequestV1.COMMIT_BATCH_REQUEST_V1.getDataType().array())
+ });
+ }
+
+ private CommitFileV1(Name alias, Table aliased, Field>[] parameters) {
+ this(alias, aliased, parameters, null);
+ }
+
+ private CommitFileV1(Name alias, Table aliased, Field>[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.function(), where);
+ }
+
+ /**
+ * Create an aliased commit_file_v1 table reference
+ */
+ public CommitFileV1(String alias) {
+ this(DSL.name(alias), COMMIT_FILE_V1);
+ }
+
+ /**
+ * Create an aliased commit_file_v1 table reference
+ */
+ public CommitFileV1(Name alias) {
+ this(alias, COMMIT_FILE_V1);
+ }
+
+ /**
+ * Create a commit_file_v1 table reference
+ */
+ public CommitFileV1() {
+ this(DSL.name("commit_file_v1"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public CommitFileV1 as(String alias) {
+ return new CommitFileV1(DSL.name(alias), this, parameters);
+ }
+
+ @Override
+ public CommitFileV1 as(Name alias) {
+ return new CommitFileV1(alias, this, parameters);
+ }
+
+ @Override
+ public CommitFileV1 as(Table> alias) {
+ return new CommitFileV1(alias.getQualifiedName(), this, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public CommitFileV1 rename(String name) {
+ return new CommitFileV1(DSL.name(name), null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public CommitFileV1 rename(Name name) {
+ return new CommitFileV1(name, null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public CommitFileV1 rename(Table> name) {
+ return new CommitFileV1(name.getQualifiedName(), null, parameters);
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public CommitFileV1 call(
+ String argObjectKey
+ , Short argFormat
+ , Integer argUploaderBrokerId
+ , Long argFileSize
+ , Instant argNow
+ , CommitBatchRequestV1Record[] argRequests
+ ) {
+ CommitFileV1 result = new CommitFileV1(DSL.name("commit_file_v1"), null, new Field[] {
+ DSL.val(argObjectKey, Domains.OBJECT_KEY_T.getDataType()),
+ DSL.val(argFormat, Domains.FORMAT_T.getDataType()),
+ DSL.val(argUploaderBrokerId, Domains.BROKER_ID_T.getDataType()),
+ DSL.val(argFileSize, Domains.BYTE_SIZE_T.getDataType()),
+ DSL.val(argNow, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(argRequests, CommitBatchRequestV1.COMMIT_BATCH_REQUEST_V1.getDataType().array())
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public CommitFileV1 call(
+ Field argObjectKey
+ , Field argFormat
+ , Field argUploaderBrokerId
+ , Field argFileSize
+ , Field argNow
+ , Field argRequests
+ ) {
+ CommitFileV1 result = new CommitFileV1(DSL.name("commit_file_v1"), null, new Field[] {
+ argObjectKey,
+ argFormat,
+ argUploaderBrokerId,
+ argFileSize,
+ argNow,
+ argRequests
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/tables/DeleteRecordsV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/tables/DeleteRecordsV1.java
new file mode 100644
index 00000000000..5866860286a
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/tables/DeleteRecordsV1.java
@@ -0,0 +1,179 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.tables;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.Schema;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.tables.records.DeleteRecordsV1Record;
+import org.jooq.generated.udt.DeleteRecordsRequestV1;
+import org.jooq.generated.udt.records.DeleteRecordsRequestV1Record;
+import org.jooq.impl.DSL;
+import org.jooq.impl.DefaultDataType;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DeleteRecordsV1 extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of delete_records_v1
+ */
+ public static final DeleteRecordsV1 DELETE_RECORDS_V1 = new DeleteRecordsV1();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return DeleteRecordsV1Record.class;
+ }
+
+ /**
+ * @deprecated Unknown data type. If this is a qualified, user-defined type,
+ * it may have been excluded from code generation. If this is a built-in
+ * type, you can define an explicit {@link org.jooq.Binding} to specify how
+ * this type should be handled. Deprecation can be turned off using
+ * {@literal } in your code generator
+ * configuration.
+ */
+ @Deprecated
+ public final TableField DELETE_RECORDS_V1_ = createField(DSL.name("delete_records_v1"), DefaultDataType.getDefaultDataType("\"delete_records_response_v1\""), this, "");
+
+ private DeleteRecordsV1(Name alias, Table aliased) {
+ this(alias, aliased, new Field[] {
+ DSL.val(null, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(null, DeleteRecordsRequestV1.DELETE_RECORDS_REQUEST_V1.getDataType().array())
+ });
+ }
+
+ private DeleteRecordsV1(Name alias, Table aliased, Field>[] parameters) {
+ this(alias, aliased, parameters, null);
+ }
+
+ private DeleteRecordsV1(Name alias, Table aliased, Field>[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.function(), where);
+ }
+
+ /**
+ * Create an aliased delete_records_v1 table reference
+ */
+ public DeleteRecordsV1(String alias) {
+ this(DSL.name(alias), DELETE_RECORDS_V1);
+ }
+
+ /**
+ * Create an aliased delete_records_v1 table reference
+ */
+ public DeleteRecordsV1(Name alias) {
+ this(alias, DELETE_RECORDS_V1);
+ }
+
+ /**
+ * Create a delete_records_v1 table reference
+ */
+ public DeleteRecordsV1() {
+ this(DSL.name("delete_records_v1"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public DeleteRecordsV1 as(String alias) {
+ return new DeleteRecordsV1(DSL.name(alias), this, parameters);
+ }
+
+ @Override
+ public DeleteRecordsV1 as(Name alias) {
+ return new DeleteRecordsV1(alias, this, parameters);
+ }
+
+ @Override
+ public DeleteRecordsV1 as(Table> alias) {
+ return new DeleteRecordsV1(alias.getQualifiedName(), this, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public DeleteRecordsV1 rename(String name) {
+ return new DeleteRecordsV1(DSL.name(name), null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public DeleteRecordsV1 rename(Name name) {
+ return new DeleteRecordsV1(name, null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public DeleteRecordsV1 rename(Table> name) {
+ return new DeleteRecordsV1(name.getQualifiedName(), null, parameters);
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public DeleteRecordsV1 call(
+ Instant argNow
+ , DeleteRecordsRequestV1Record[] argRequests
+ ) {
+ DeleteRecordsV1 result = new DeleteRecordsV1(DSL.name("delete_records_v1"), null, new Field[] {
+ DSL.val(argNow, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(argRequests, DeleteRecordsRequestV1.DELETE_RECORDS_REQUEST_V1.getDataType().array())
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public DeleteRecordsV1 call(
+ Field argNow
+ , Field argRequests
+ ) {
+ DeleteRecordsV1 result = new DeleteRecordsV1(DSL.name("delete_records_v1"), null, new Field[] {
+ argNow,
+ argRequests
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV1.java b/storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV1.java
new file mode 100644
index 00000000000..d0f75232a4e
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV1.java
@@ -0,0 +1,179 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.tables;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.Schema;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.tables.records.EnforceRetentionV1Record;
+import org.jooq.generated.udt.EnforceRetentionRequestV1;
+import org.jooq.generated.udt.records.EnforceRetentionRequestV1Record;
+import org.jooq.impl.DSL;
+import org.jooq.impl.DefaultDataType;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class EnforceRetentionV1 extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of enforce_retention_v1
+ */
+ public static final EnforceRetentionV1 ENFORCE_RETENTION_V1 = new EnforceRetentionV1();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return EnforceRetentionV1Record.class;
+ }
+
+ /**
+ * @deprecated Unknown data type. If this is a qualified, user-defined type,
+ * it may have been excluded from code generation. If this is a built-in
+ * type, you can define an explicit {@link org.jooq.Binding} to specify how
+ * this type should be handled. Deprecation can be turned off using
+ * {@literal } in your code generator
+ * configuration.
+ */
+ @Deprecated
+ public final TableField ENFORCE_RETENTION_V1_ = createField(DSL.name("enforce_retention_v1"), DefaultDataType.getDefaultDataType("\"enforce_retention_response_v1\""), this, "");
+
+ private EnforceRetentionV1(Name alias, Table aliased) {
+ this(alias, aliased, new Field[] {
+ DSL.val(null, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(null, EnforceRetentionRequestV1.ENFORCE_RETENTION_REQUEST_V1.getDataType().array())
+ });
+ }
+
+ private EnforceRetentionV1(Name alias, Table aliased, Field>[] parameters) {
+ this(alias, aliased, parameters, null);
+ }
+
+ private EnforceRetentionV1(Name alias, Table aliased, Field>[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.function(), where);
+ }
+
+ /**
+ * Create an aliased enforce_retention_v1 table reference
+ */
+ public EnforceRetentionV1(String alias) {
+ this(DSL.name(alias), ENFORCE_RETENTION_V1);
+ }
+
+ /**
+ * Create an aliased enforce_retention_v1 table reference
+ */
+ public EnforceRetentionV1(Name alias) {
+ this(alias, ENFORCE_RETENTION_V1);
+ }
+
+ /**
+ * Create a enforce_retention_v1 table reference
+ */
+ public EnforceRetentionV1() {
+ this(DSL.name("enforce_retention_v1"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public EnforceRetentionV1 as(String alias) {
+ return new EnforceRetentionV1(DSL.name(alias), this, parameters);
+ }
+
+ @Override
+ public EnforceRetentionV1 as(Name alias) {
+ return new EnforceRetentionV1(alias, this, parameters);
+ }
+
+ @Override
+ public EnforceRetentionV1 as(Table> alias) {
+ return new EnforceRetentionV1(alias.getQualifiedName(), this, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public EnforceRetentionV1 rename(String name) {
+ return new EnforceRetentionV1(DSL.name(name), null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public EnforceRetentionV1 rename(Name name) {
+ return new EnforceRetentionV1(name, null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public EnforceRetentionV1 rename(Table> name) {
+ return new EnforceRetentionV1(name.getQualifiedName(), null, parameters);
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public EnforceRetentionV1 call(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ ) {
+ EnforceRetentionV1 result = new EnforceRetentionV1(DSL.name("enforce_retention_v1"), null, new Field[] {
+ DSL.val(argNow, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(argRequests, EnforceRetentionRequestV1.ENFORCE_RETENTION_REQUEST_V1.getDataType().array())
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public EnforceRetentionV1 call(
+ Field argNow
+ , Field argRequests
+ ) {
+ EnforceRetentionV1 result = new EnforceRetentionV1(DSL.name("enforce_retention_v1"), null, new Field[] {
+ argNow,
+ argRequests
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV2.java b/storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV2.java
new file mode 100644
index 00000000000..71bbe1cceaa
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/tables/EnforceRetentionV2.java
@@ -0,0 +1,184 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.tables;
+
+
+import io.aiven.inkless.control_plane.postgres.converters.OffsetDateTimeToInstantConverter;
+
+import java.time.Instant;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.Schema;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.tables.records.EnforceRetentionV2Record;
+import org.jooq.generated.udt.EnforceRetentionRequestV1;
+import org.jooq.generated.udt.records.EnforceRetentionRequestV1Record;
+import org.jooq.impl.DSL;
+import org.jooq.impl.DefaultDataType;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class EnforceRetentionV2 extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of enforce_retention_v2
+ */
+ public static final EnforceRetentionV2 ENFORCE_RETENTION_V2 = new EnforceRetentionV2();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return EnforceRetentionV2Record.class;
+ }
+
+ /**
+ * @deprecated Unknown data type. If this is a qualified, user-defined type,
+ * it may have been excluded from code generation. If this is a built-in
+ * type, you can define an explicit {@link org.jooq.Binding} to specify how
+ * this type should be handled. Deprecation can be turned off using
+ * {@literal } in your code generator
+ * configuration.
+ */
+ @Deprecated
+ public final TableField ENFORCE_RETENTION_V2_ = createField(DSL.name("enforce_retention_v2"), DefaultDataType.getDefaultDataType("\"enforce_retention_response_v1\""), this, "");
+
+ private EnforceRetentionV2(Name alias, Table aliased) {
+ this(alias, aliased, new Field[] {
+ DSL.val(null, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(null, EnforceRetentionRequestV1.ENFORCE_RETENTION_REQUEST_V1.getDataType().array()),
+ DSL.val(null, SQLDataType.INTEGER.defaultValue(DSL.field(DSL.raw("0"), SQLDataType.INTEGER)))
+ });
+ }
+
+ private EnforceRetentionV2(Name alias, Table aliased, Field>[] parameters) {
+ this(alias, aliased, parameters, null);
+ }
+
+ private EnforceRetentionV2(Name alias, Table aliased, Field>[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.function(), where);
+ }
+
+ /**
+ * Create an aliased enforce_retention_v2 table reference
+ */
+ public EnforceRetentionV2(String alias) {
+ this(DSL.name(alias), ENFORCE_RETENTION_V2);
+ }
+
+ /**
+ * Create an aliased enforce_retention_v2 table reference
+ */
+ public EnforceRetentionV2(Name alias) {
+ this(alias, ENFORCE_RETENTION_V2);
+ }
+
+ /**
+ * Create a enforce_retention_v2 table reference
+ */
+ public EnforceRetentionV2() {
+ this(DSL.name("enforce_retention_v2"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : DefaultSchema.DEFAULT_SCHEMA;
+ }
+
+ @Override
+ public EnforceRetentionV2 as(String alias) {
+ return new EnforceRetentionV2(DSL.name(alias), this, parameters);
+ }
+
+ @Override
+ public EnforceRetentionV2 as(Name alias) {
+ return new EnforceRetentionV2(alias, this, parameters);
+ }
+
+ @Override
+ public EnforceRetentionV2 as(Table> alias) {
+ return new EnforceRetentionV2(alias.getQualifiedName(), this, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public EnforceRetentionV2 rename(String name) {
+ return new EnforceRetentionV2(DSL.name(name), null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public EnforceRetentionV2 rename(Name name) {
+ return new EnforceRetentionV2(name, null, parameters);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public EnforceRetentionV2 rename(Table> name) {
+ return new EnforceRetentionV2(name.getQualifiedName(), null, parameters);
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public EnforceRetentionV2 call(
+ Instant argNow
+ , EnforceRetentionRequestV1Record[] argRequests
+ , Integer maxBatchesPerRequest
+ ) {
+ EnforceRetentionV2 result = new EnforceRetentionV2(DSL.name("enforce_retention_v2"), null, new Field[] {
+ DSL.val(argNow, SQLDataType.TIMESTAMPWITHTIMEZONE.asConvertedDataType(new OffsetDateTimeToInstantConverter())),
+ DSL.val(argRequests, EnforceRetentionRequestV1.ENFORCE_RETENTION_REQUEST_V1.getDataType().array()),
+ DSL.val(maxBatchesPerRequest, SQLDataType.INTEGER.defaultValue(DSL.field(DSL.raw("0"), SQLDataType.INTEGER)))
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+
+ /**
+ * Call this table-valued function
+ */
+ public EnforceRetentionV2 call(
+ Field argNow
+ , Field argRequests
+ , Field maxBatchesPerRequest
+ ) {
+ EnforceRetentionV2 result = new EnforceRetentionV2(DSL.name("enforce_retention_v2"), null, new Field[] {
+ argNow,
+ argRequests,
+ maxBatchesPerRequest
+ });
+
+ return aliased() ? result.as(getUnqualifiedName()) : result;
+ }
+}
diff --git a/storage/inkless/src/main/jooq/org/jooq/generated/tables/FileMergeWorkItemFiles.java b/storage/inkless/src/main/jooq/org/jooq/generated/tables/FileMergeWorkItemFiles.java
new file mode 100644
index 00000000000..0cb0f2297fa
--- /dev/null
+++ b/storage/inkless/src/main/jooq/org/jooq/generated/tables/FileMergeWorkItemFiles.java
@@ -0,0 +1,318 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package org.jooq.generated.tables;
+
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+
+import javax.annotation.processing.Generated;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.ForeignKey;
+import org.jooq.Index;
+import org.jooq.InverseForeignKey;
+import org.jooq.Name;
+import org.jooq.Path;
+import org.jooq.PlainSQL;
+import org.jooq.QueryPart;
+import org.jooq.Record;
+import org.jooq.SQL;
+import org.jooq.Schema;
+import org.jooq.Select;
+import org.jooq.Stringly;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.UniqueKey;
+import org.jooq.generated.DefaultSchema;
+import org.jooq.generated.Indexes;
+import org.jooq.generated.Keys;
+import org.jooq.generated.tables.FileMergeWorkItems.FileMergeWorkItemsPath;
+import org.jooq.generated.tables.Files.FilesPath;
+import org.jooq.generated.tables.records.FileMergeWorkItemFilesRecord;
+import org.jooq.impl.DSL;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@Generated(
+ value = {
+ "https://www.jooq.org",
+ "jOOQ version:3.19.17",
+ "schema version:10"
+ },
+ comments = "This class is generated by jOOQ"
+)
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class FileMergeWorkItemFiles extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of file_merge_work_item_files
+ */
+ public static final FileMergeWorkItemFiles FILE_MERGE_WORK_ITEM_FILES = new FileMergeWorkItemFiles();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return FileMergeWorkItemFilesRecord.class;
+ }
+
+ /**
+ * The column