danielcweeks commented on code in PR #8976:
URL: https://github.com/apache/iceberg/pull/8976#discussion_r1493075652
##
core/src/test/java/org/apache/iceberg/rest/RESTCatalogAdapter.java:
##
@@ -105,6 +105,8 @@ enum HTTPMethod {
enum Route {
TOKENS(HTTPMethod.POST, "v1/
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493074229
##
format/spec.md:
##
@@ -1237,17 +1237,36 @@ Content file (data or delete) is serialized as a JSON
object according to the fo
| **`equality-ids`** |`JSON lis
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493072836
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -355,71 +475,90 @@ int findVersion() {
* an attempt will be made to delete
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493071466
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -355,71 +475,90 @@ int findVersion() {
* an attempt will be made to delete
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493071273
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jack
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493068494
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -149,26 +183,71 @@ public void commit(TableMetadata base, TableMetadata
metada
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493067836
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -149,26 +183,71 @@ public void commit(TableMetadata base, TableMetadata
metada
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493067372
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -129,6 +132,27 @@ public TableMetadata refresh() {
@Override
public voi
danielcweeks commented on code in PR #8976:
URL: https://github.com/apache/iceberg/pull/8976#discussion_r1493066567
##
core/src/main/java/org/apache/iceberg/rest/HTTPClient.java:
##
@@ -204,17 +204,28 @@ private static void throwFailure(
throw new RESTException("Unhandled e
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493066170
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -59,7 +61,7 @@
*/
public class HadoopTableOperations implements TableOperati
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493066170
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -59,7 +61,7 @@
*/
public class HadoopTableOperations implements TableOperati
anupam-saini commented on code in PR #433:
URL: https://github.com/apache/iceberg-python/pull/433#discussion_r1493065425
##
pyiceberg/schema.py:
##
@@ -1213,34 +1213,50 @@ def build_position_accessors(schema_or_type:
Union[Schema, IcebergType]) -> Dict
return visit(schema_
danielcweeks commented on code in PR #8976:
URL: https://github.com/apache/iceberg/pull/8976#discussion_r1493063230
##
core/src/main/java/org/apache/iceberg/rest/auth/OAuth2Util.java:
##
@@ -361,6 +392,23 @@ public static class AuthSession {
private final String credential;
emkornfield commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493059452
##
format/spec.md:
##
@@ -1237,17 +1237,36 @@ Content file (data or delete) is serialized as a JSON
object according to the fo
| **`equality-ids`** |`JSON l
anupam-saini commented on PR #433:
URL: https://github.com/apache/iceberg-python/pull/433#issuecomment-1949447704
Thank you @Fokko for taking time to explain in such great detail. Now it
makes much more sense to have this part of the Catalog API. Made changes as
suggested.
--
This is an
syun64 commented on code in PR #433:
URL: https://github.com/apache/iceberg-python/pull/433#discussion_r1493052840
##
pyiceberg/schema.py:
##
@@ -1213,34 +1213,50 @@ def build_position_accessors(schema_or_type:
Union[Schema, IcebergType]) -> Dict
return visit(schema_or_typ
RussellSpitzer commented on code in PR #9546:
URL: https://github.com/apache/iceberg/pull/9546#discussion_r1493050575
##
core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java:
##
@@ -53,13 +54,15 @@
import org.slf4j.LoggerFactory;
/**
- * TableOperations im
anupam-saini commented on code in PR #433:
URL: https://github.com/apache/iceberg-python/pull/433#discussion_r1493051291
##
pyiceberg/schema.py:
##
@@ -1213,34 +1213,50 @@ def build_position_accessors(schema_or_type:
Union[Schema, IcebergType]) -> Dict
return visit(schema_
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493050495
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jack
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493034865
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jack
dependabot[bot] closed pull request #319: Build: Bump pytest from 7.4.4 to 8.0.0
URL: https://github.com/apache/iceberg-python/pull/319
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific co
dependabot[bot] commented on PR #319:
URL: https://github.com/apache/iceberg-python/pull/319#issuecomment-1949437791
Superseded by #439.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specif
dependabot[bot] opened a new pull request, #439:
URL: https://github.com/apache/iceberg-python/pull/439
Bumps [pytest](https://github.com/pytest-dev/pytest) from 7.4.4 to 8.0.1.
Release notes
Sourced from https://github.com/pytest-dev/pytest/releases";>pytest's
releases.
8.0
danielcweeks commented on code in PR #436:
URL: https://github.com/apache/iceberg-python/pull/436#discussion_r1493048345
##
pyiceberg/catalog/rest.py:
##
@@ -237,6 +237,7 @@ def _create_session(self) -> Session:
session.headers["Content-type"] = "application/json"
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493034865
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jack
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493034865
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jack
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493037575
##
format/spec.md:
##
@@ -1237,17 +1237,36 @@ Content file (data or delete) is serialized as a JSON
object according to the fo
| **`equality-ids`** |`JSON lis
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493037575
##
format/spec.md:
##
@@ -1237,17 +1237,36 @@ Content file (data or delete) is serialized as a JSON
object according to the fo
| **`equality-ids`** |`JSON lis
tkent commented on issue #3010:
URL: https://github.com/apache/iceberg/issues/3010#issuecomment-1949418909
:wave: Recording one solution to this error. I ran into this using an Azure
databricks cluster and the underlying error was what @RussellSpitzer noted.
However, the runtime JAR for ice
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1493034865
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jack
geruh commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1493023248
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type: boo
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1493018795
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1493017978
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1493017691
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1493016912
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1493011625
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
syun64 opened a new issue, #438:
URL: https://github.com/apache/iceberg-python/issues/438
### Feature Request / Improvement
In Spark SQL, we have the ability to combine the table overwrite using AS
SELECT statement, with create_table or replace_table, as an atomic operation.
Do
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1492981360
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1492980261
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1492979601
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1492979077
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1492976199
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
jackye1995 commented on code in PR #9717:
URL: https://github.com/apache/iceberg/pull/9717#discussion_r1492973284
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3324,6 +3348,211 @@ components:
type: integer
format: int64
+BooleanTypeValue:
+ type
syun64 closed issue #429: Minimum Requirement of Data File Name in Apache
Iceberg?
URL: https://github.com/apache/iceberg-python/issues/429
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specif
syun64 commented on issue #429:
URL: https://github.com/apache/iceberg-python/issues/429#issuecomment-1949301152
I like the idea! This is definitely helpful, and I think this opens up a lot
more options when looking to use other engines in parallelizing writes.
--
This is an automated mes
JFinis opened a new issue, #9740:
URL: https://github.com/apache/iceberg/issues/9740
### Apache Iceberg version
1.4.3 (latest release)
### Query engine
None
### Please describe the bug 🐞
I'm referring to the definition of `field_summary`, which is as follows
paulpaul1076 commented on issue #9679:
URL: https://github.com/apache/iceberg/issues/9679#issuecomment-1949240582
@nastra unfortunately this doesn't seem to be the only reason for the
content-length exception. We now discovered that it still fails, even though I
stopped using the direct str
jackye1995 closed issue #9604: InMemoryCatalog's FiloIO in memory map isn't
persistent in RestCatalog
URL: https://github.com/apache/iceberg/issues/9604
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
JFinis opened a new issue, #9739:
URL: https://github.com/apache/iceberg/issues/9739
### Apache Iceberg version
None
### Query engine
None
### Please describe the bug 🐞
The spec is inconsistent with respect to the `partition_spec_id` column.
Here the spec n
rahil-c commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1492856785
##
open-api/rest-catalog-open-api.yaml:
##
@@ -532,6 +532,100 @@ paths:
5XX:
$ref: '#/components/responses/ServerErrorResponse'
+ /v1/{prefix}/na
rahil-c commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1492851000
##
open-api/rest-catalog-open-api.yaml:
##
@@ -532,6 +532,100 @@ paths:
5XX:
$ref: '#/components/responses/ServerErrorResponse'
+ /v1/{prefix}/na
rahil-c commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1492847929
##
open-api/rest-catalog-open-api.py:
##
@@ -905,6 +973,28 @@ class CreateTableRequest(BaseModel):
properties: Optional[Dict[str, str]] = None
+class PlanConte
emkornfield commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1492846630
##
format/spec.md:
##
@@ -1237,17 +1237,36 @@ Content file (data or delete) is serialized as a JSON
object according to the fo
| **`equality-ids`** |`JSON l
rahil-c commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1492846298
##
open-api/rest-catalog-open-api.py:
##
@@ -905,6 +973,28 @@ class CreateTableRequest(BaseModel):
properties: Optional[Dict[str, str]] = None
+class PlanConte
rahil-c commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1492845781
##
open-api/rest-catalog-open-api.py:
##
@@ -905,6 +973,28 @@ class CreateTableRequest(BaseModel):
properties: Optional[Dict[str, str]] = None
+class PlanConte
pvary commented on code in PR #9735:
URL: https://github.com/apache/iceberg/pull/9735#discussion_r149288
##
core/src/main/java/org/apache/iceberg/MetadataTableUtils.java:
##
@@ -32,9 +32,16 @@ public static boolean hasMetadataTableName(TableIdentifier
identifier) {
publi
pvary commented on code in PR #9735:
URL: https://github.com/apache/iceberg/pull/9735#discussion_r1492832463
##
core/src/main/java/org/apache/iceberg/MetadataTableUtils.java:
##
@@ -32,9 +32,16 @@ public static boolean hasMetadataTableName(TableIdentifier
identifier) {
publi
pvary commented on code in PR #9735:
URL: https://github.com/apache/iceberg/pull/9735#discussion_r1492831999
##
core/src/test/java/org/apache/iceberg/hadoop/TestTableSerialization.java:
##
@@ -153,6 +163,22 @@ public void testSerializableMetadataTablesPlanning()
throws IOExcept
adevore3 commented on issue #9738:
URL: https://github.com/apache/iceberg/issues/9738#issuecomment-1949035999
I forgot to mention I did try to register KryoSerializer folowing this SOF:
https://stackoverflow.com/questions/52562671/registering-classes-with-kryo-via-sparksession-in-spark-2
do
rdblue commented on code in PR #9732:
URL: https://github.com/apache/iceberg/pull/9732#discussion_r1492829614
##
core/src/main/java/org/apache/iceberg/TableMetadata.java:
##
@@ -1246,7 +1246,6 @@ public Builder setRef(String name, SnapshotRef ref) {
public Builder removeRef
adevore3 opened a new issue, #9738:
URL: https://github.com/apache/iceberg/issues/9738
### Apache Iceberg version
None
### Query engine
None
### Please describe the bug 🐞
We were upgrading to spark 3.4.1 when we ran into this issue. Currently
running on spa
jackye1995 commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1492816128
##
core/src/main/java/org/apache/iceberg/FileScanTaskParser.java:
##
@@ -21,116 +21,84 @@
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jac
rahil-c commented on code in PR #9660:
URL: https://github.com/apache/iceberg/pull/9660#discussion_r1492800015
##
open-api/rest-catalog-open-api.yaml:
##
@@ -1581,6 +1616,12 @@ components:
type: string
example: [ "accounting", "tax" ]
+NextPageToken:
+
rahil-c commented on code in PR #9660:
URL: https://github.com/apache/iceberg/pull/9660#discussion_r1492798196
##
open-api/rest-catalog-open-api.yaml:
##
@@ -1482,6 +1490,33 @@ components:
explode: false
example: "vended-credentials,remote-signing"
+page-toke
szehon-ho commented on code in PR #9735:
URL: https://github.com/apache/iceberg/pull/9735#discussion_r1492792745
##
core/src/main/java/org/apache/iceberg/SerializableTable.java:
##
@@ -388,6 +388,12 @@ public Transaction newTransaction() {
throw new UnsupportedOperationExce
rdblue merged PR #9234:
URL: https://github.com/apache/iceberg/pull/9234
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apac
rahil-c commented on code in PR #9660:
URL: https://github.com/apache/iceberg/pull/9660#discussion_r1492792266
##
open-api/rest-catalog-open-api.yaml:
##
@@ -1482,6 +1490,33 @@ components:
explode: false
example: "vended-credentials,remote-signing"
+page-toke
rdblue commented on PR #9234:
URL: https://github.com/apache/iceberg/pull/9234#issuecomment-1948966275
Thanks, @nastra!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To u
rdblue commented on code in PR #9725:
URL: https://github.com/apache/iceberg/pull/9725#discussion_r1492788744
##
core/src/test/java/org/apache/iceberg/view/TestViewMetadata.java:
##
@@ -63,8 +62,11 @@ public void testExpiration() {
ViewVersion v2 = newViewVersion(2, "select
namrathamyske opened a new issue, #9737:
URL: https://github.com/apache/iceberg/issues/9737
### Apache Iceberg version
main (development)
### Query engine
None
### Please describe the bug 🐞
regarding this PR: https://github.com/apache/iceberg/pull/9131 - th
namrathamyske closed issue #9659: Updating a property map in a iceberg table
URL: https://github.com/apache/iceberg/issues/9659
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
amogh-jahagirdar commented on code in PR #9732:
URL: https://github.com/apache/iceberg/pull/9732#discussion_r1492738591
##
core/src/main/java/org/apache/iceberg/TableMetadata.java:
##
@@ -1246,7 +1246,6 @@ public Builder setRef(String name, SnapshotRef ref) {
public Builder
amogh-jahagirdar commented on code in PR #9732:
URL: https://github.com/apache/iceberg/pull/9732#discussion_r1492738591
##
core/src/main/java/org/apache/iceberg/TableMetadata.java:
##
@@ -1246,7 +1246,6 @@ public Builder setRef(String name, SnapshotRef ref) {
public Builder
amogh-jahagirdar commented on issue #9723:
URL: https://github.com/apache/iceberg/issues/9723#issuecomment-1948850563
I did a little investigation as well, I'm not sure the original context on
why the snapshot log was being cleared. But here are my thoughts:
It does indeed some like w
stevenzwu commented on code in PR #9728:
URL: https://github.com/apache/iceberg/pull/9728#discussion_r1492723658
##
core/src/main/java/org/apache/iceberg/BaseFileScanTaskParser.java:
##
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or m
nastra merged PR #197:
URL: https://github.com/apache/iceberg-rust/pull/197
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.a
Fokko merged PR #67:
URL: https://github.com/apache/iceberg-go/pull/67
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache
RussellSpitzer commented on code in PR #9691:
URL: https://github.com/apache/iceberg/pull/9691#discussion_r1492708091
##
core/src/main/java/org/apache/iceberg/avro/AvroIterable.java:
##
@@ -150,7 +153,7 @@ public D next(D reuse) {
try {
return reader.next(reuse);
pvary opened a new pull request, #9735:
URL: https://github.com/apache/iceberg/pull/9735
Currently it is not possible to create metadata tables above serialized
tables. This could be useful as a general feature, and specifically it is
needed if we want to create Flink jobs to run table main
RussellSpitzer commented on code in PR #9691:
URL: https://github.com/apache/iceberg/pull/9691#discussion_r1492701634
##
core/src/main/java/org/apache/iceberg/avro/AvroIterable.java:
##
@@ -150,7 +153,7 @@ public D next(D reuse) {
try {
return reader.next(reuse);
RussellSpitzer commented on code in PR #9691:
URL: https://github.com/apache/iceberg/pull/9691#discussion_r1492700348
##
core/src/main/java/org/apache/iceberg/avro/AvroIterable.java:
##
@@ -150,7 +153,7 @@ public D next(D reuse) {
try {
return reader.next(reuse);
manuzhang commented on code in PR #9551:
URL: https://github.com/apache/iceberg/pull/9551#discussion_r1492670868
##
spark/v3.5/spark-extensions/src/test/java/org/apache/iceberg/spark/extensions/SparkRowLevelOperationsTestBase.java:
##
@@ -166,6 +166,28 @@ public static Object[][
manuzhang commented on code in PR #9724:
URL: https://github.com/apache/iceberg/pull/9724#discussion_r1492660971
##
api/src/main/java/org/apache/iceberg/actions/RewriteDataFiles.java:
##
@@ -99,6 +99,20 @@ public interface RewriteDataFiles
boolean USE_STARTING_SEQUENCE_NUMB
ZENOTME opened a new pull request, #199:
URL: https://github.com/apache/iceberg-rust/pull/199
This PR aims to complete #125. After #66, we prepared the plan
file(metadata) for the scan. This PR will uses these plan file to construct the
stream for read record batch.
This PR also cha
manuzhang commented on code in PR #9724:
URL: https://github.com/apache/iceberg/pull/9724#discussion_r1492660971
##
api/src/main/java/org/apache/iceberg/actions/RewriteDataFiles.java:
##
@@ -99,6 +99,20 @@ public interface RewriteDataFiles
boolean USE_STARTING_SEQUENCE_NUMB
ZENOTME commented on PR #199:
URL: https://github.com/apache/iceberg-rust/pull/199#issuecomment-1948677398
For now, it just a draft for changed interface. I will complete them if this
interface looks well.
--
This is an automated message from the Apache Git Service.
To respond to the mess
ZENOTME commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492447476
##
crates/iceberg/src/writer/file_writer/parquet_writer.rs:
##
@@ -0,0 +1,385 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contribut
ZENOTME commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492450927
##
crates/iceberg/src/writer/file_writer/track_writer.rs:
##
@@ -0,0 +1,72 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor
ZENOTME commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492447476
##
crates/iceberg/src/writer/file_writer/parquet_writer.rs:
##
@@ -0,0 +1,385 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contribut
ZENOTME commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492446872
##
crates/iceberg/src/writer/file_writer/parquet_writer.rs:
##
@@ -0,0 +1,385 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contribut
jbonofre commented on PR #9666:
URL: https://github.com/apache/iceberg/pull/9666#issuecomment-1948376773
@bitsondatadev @Fokko thoughts about this PR ? Thanks !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
ZENOTME commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492445165
##
crates/iceberg/src/writer/file_writer/location_generator.rs:
##
@@ -0,0 +1,99 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contri
Xuanwo commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492439815
##
crates/iceberg/src/io.rs:
##
@@ -240,9 +241,9 @@ impl InputFile {
}
/// Trait for writing file.
-pub trait FileWrite: AsyncWrite {}
+pub trait FileWrite: Async
jbonofre commented on PR #9487:
URL: https://github.com/apache/iceberg/pull/9487#issuecomment-1948364274
@nastra yes, actually, I plan to improve `V0` / `V1` and more support in a
separate PR introducing `JdbcAdapter` allowing us to adapt to different backend
(like I did here
https://githu
ZENOTME commented on code in PR #176:
URL: https://github.com/apache/iceberg-rust/pull/176#discussion_r1492434129
##
crates/iceberg/src/io.rs:
##
@@ -240,9 +241,9 @@ impl InputFile {
}
/// Trait for writing file.
-pub trait FileWrite: AsyncWrite {}
+pub trait FileWrite: Asyn
nastra commented on code in PR #9487:
URL: https://github.com/apache/iceberg/pull/9487#discussion_r1492427645
##
core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java:
##
@@ -81,85 +114,242 @@ final class JdbcUtil {
+ TABLE_NAME
+ ")"
+ ")";
-
nastra commented on code in PR #9487:
URL: https://github.com/apache/iceberg/pull/9487#discussion_r1492412706
##
core/src/main/java/org/apache/iceberg/jdbc/JdbcUtil.java:
##
@@ -25,31 +25,62 @@
import java.util.Map;
import java.util.Properties;
import java.util.Set;
+import o
nastra commented on code in PR #9487:
URL: https://github.com/apache/iceberg/pull/9487#discussion_r1492410874
##
core/src/test/java/org/apache/iceberg/jdbc/TestJdbcCatalog.java:
##
@@ -158,6 +161,92 @@ public void testInitialize() {
jdbcCatalog.initialize("test_jdbc_catalog
nastra commented on code in PR #9487:
URL: https://github.com/apache/iceberg/pull/9487#discussion_r1492409536
##
core/src/main/java/org/apache/iceberg/jdbc/JdbcTableOperations.java:
##
@@ -182,18 +177,23 @@ private void createTable(String newMetadataLocation)
throws SQLExceptio
Fokko commented on PR #415:
URL: https://github.com/apache/iceberg-python/pull/415#issuecomment-1948321931
@hussein-awala Thanks! You're right, and I think
`create_table_if_not_exists` would be a cleaner solution, see #406.
--
This is an automated message from the Apache Git Service.
To
1 - 100 of 115 matches
Mail list logo