You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by zi...@apache.org on 2023/02/17 01:33:44 UTC
[gobblin] branch master updated: Make GobblinMCEWriter constructor public (#3647)
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 <ra...@gmail.com>
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<>();