Re: [PR] PartitionKey [iceberg-python]

2024-02-27 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1504733892 ## pyiceberg/partitioning.py: ## @@ -215,3 +236,54 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-27 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1504603226 ## pyiceberg/partitioning.py: ## @@ -215,3 +236,54 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-27 Thread via GitHub
Fokko commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1504543693 ## pyiceberg/partitioning.py: ## @@ -215,3 +236,54 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-22 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1499922547 ## pyiceberg/partitioning.py: ## @@ -215,3 +236,54 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-22 Thread via GitHub
syun64 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1499729828 ## pyiceberg/partitioning.py: ## @@ -215,3 +236,54 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-22 Thread via GitHub
jqin61 commented on PR #453: URL: https://github.com/apache/iceberg-python/pull/453#issuecomment-1959848004 > @jqin61 I wanted to do a second round, but I think you forgot to push? :) Hi Fokko sorry for the delayed push of the fixes. It took a little time to think through how to use t

Re: [PR] PartitionKey [iceberg-python]

2024-02-22 Thread via GitHub
Fokko commented on PR #453: URL: https://github.com/apache/iceberg-python/pull/453#issuecomment-1959113816 @jqin61 I wanted to do a second round, but I think you forgot to push? :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

Re: [PR] PartitionKey [iceberg-python]

2024-02-21 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1498025856 ## pyiceberg/partitioning.py: ## @@ -215,3 +240,53 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-21 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1498024911 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-21 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1498023132 ## pyiceberg/partitioning.py: ## @@ -215,3 +240,53 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-21 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1498019488 ## pyiceberg/partitioning.py: ## @@ -193,6 +197,27 @@ def partition_type(self, schema: Schema) -> StructType: nested_fields.append(NestedField(field.fi

Re: [PR] PartitionKey [iceberg-python]

2024-02-21 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1498016056 ## pyiceberg/partitioning.py: ## @@ -193,6 +197,27 @@ def partition_type(self, schema: Schema) -> StructType: nested_fields.append(NestedField(field.fi

Re: [PR] PartitionKey [iceberg-python]

2024-02-21 Thread via GitHub
Fokko commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1497670291 ## pyiceberg/partitioning.py: ## @@ -193,6 +197,27 @@ def partition_type(self, schema: Schema) -> StructType: nested_fields.append(NestedField(field.fie

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496932026 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496930464 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496928516 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496928516 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496926708 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496925205 ## tests/integration/test_partitioning_key.py: ## @@ -0,0 +1,722 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agr

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 commented on code in PR #453: URL: https://github.com/apache/iceberg-python/pull/453#discussion_r1496923619 ## pyiceberg/partitioning.py: ## @@ -215,3 +240,53 @@ def assign_fresh_partition_spec_ids(spec: PartitionSpec, old_schema: Schema, fre ) )

Re: [PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
Fokko commented on PR #453: URL: https://github.com/apache/iceberg-python/pull/453#issuecomment-1955191403 @jqin61 Nice! Thanks for working on this. It is getting late here, but this is on my list for tomorrow 👍 -- This is an automated message from the Apache Git Service. To respond to t

[PR] PartitionKey [iceberg-python]

2024-02-20 Thread via GitHub
jqin61 opened a new pull request, #453: URL: https://github.com/apache/iceberg-python/pull/453 **Scope** Add PartitionKey class which: 1. is used to hold the raw partition field and values. This is for partitioned write. 2. converts the python values into iceberg-typed values. 3.