Skip to content

Instantly share code, notes, and snippets.

/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
@rdblue
rdblue / flink_iceberg_diff_1.14_to_1.15.diff
Created May 3, 2022 15:50 — forked from kbendick/flink_iceberg_diff_1.14_to_1.15.txt
Propsed Iceberg Support for Flink 1.15 Diff from Iceberg Flink 1.14
POST /v1/namespaces/ns/tables/t/scans
{ "filter": { "type": "in", "term": "x", "values": [1, 2, 3] }, "select": ["x", "a.b"]}
{ "scan-id": 1, "shards": { "id": 1, "manifests": ["C"] }, { "id": 2, "manifests": ["D"] } }
POST /v1/namespaces/ns/tables/t/scans?scan-id=1
{ "shard": { "id": 1, "manifests": ["C"] }, "filter": {"type": "in", "term": "x", "values": [1, 2, 3] } }
{ "file-scan-tasks": [...] }