Skip to content

Commit 6b68ba0

Browse files
committed
updates
1 parent e34370a commit 6b68ba0

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

sdks/java/io/delta/build.gradle

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@ def parquet_version = "1.16.0"
3333

3434
dependencies {
3535
implementation project(path: ":sdks:java:core", configuration: "shadow")
36-
implementation project(path: ":model:pipeline", configuration: "shadow")
3736
implementation library.java.delta_kernel_api
3837
implementation library.java.delta_kernel_defaults
3938

sdks/java/io/delta/src/main/java/org/apache/beam/sdk/io/delta/DeltaReadSchemaTransformProvider.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import java.util.List;
2727
import java.util.Map;
2828
import org.apache.beam.model.pipeline.v1.ExternalTransforms;
29+
import org.apache.beam.sdk.io.delta.DeltaReadSchemaTransformProvider.Configuration;
2930
import org.apache.beam.sdk.schemas.AutoValueSchema;
3031
import org.apache.beam.sdk.schemas.NoSuchSchemaException;
3132
import org.apache.beam.sdk.schemas.SchemaRegistry;
@@ -67,7 +68,8 @@ static class DeltaReadSchemaTransform extends SchemaTransform {
6768
private final Configuration configuration;
6869

6970
DeltaReadSchemaTransform(Configuration configuration) {
70-
this.configuration = configuration;
71+
this.configuration =
72+
java.util.Objects.requireNonNull(configuration, "configuration cannot be null");
7173
}
7274

7375
Row getConfigurationRow() {

0 commit comments

Comments
 (0)