This is an automated email from the ASF dual-hosted git repository.
zihanli58 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 1b556d293 Make GobblinMCEWriter constructor public (#3647)
1b556d293 is described below
commit 1b556d293124d40bfc73c301e4c39103c25f8f0e
Author: Limian (Raymond) Zhang <[email protected]>
AuthorDate: Thu Feb 16 18:33:38 2023 -0700
Make GobblinMCEWriter constructor public (#3647)
---
.../main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java
b/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java
index 5f77f14cf..c7a7a5481 100644
---
a/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java
+++
b/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java
@@ -138,7 +138,7 @@ public class GobblinMCEWriter implements
DataWriter<GenericRecord> {
long gmceHighWatermark;
}
- GobblinMCEWriter(DataWriterBuilder<Schema, GenericRecord> builder, State
properties) throws IOException {
+ public GobblinMCEWriter(DataWriterBuilder<Schema, GenericRecord> builder,
State properties) throws IOException {
newSpecsMaps = new HashMap<>();
oldSpecsMaps = new HashMap<>();
metadataWriters = new ArrayList<>();