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<>();