File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -139,7 +139,7 @@ public FlinkPulsarSink<T> build(){
139
139
140
140
private final PulsarSerializationSchema <T > serializationSchema ;
141
141
142
- public FlinkPulsarSink (final Builder <T > builder ) {
142
+ private FlinkPulsarSink (final Builder <T > builder ) {
143
143
super (
144
144
new FlinkPulsarSinkBase .Config <T >()
145
145
.withAdminUrl (builder .adminUrl )
Original file line number Diff line number Diff line change @@ -302,7 +302,7 @@ public FlinkPulsarSource<T> build(){
302
302
303
303
private final CryptoKeyReader cryptoKeyReader ;
304
304
305
- public FlinkPulsarSource (final Builder <T > builder ) {
305
+ private FlinkPulsarSource (final Builder <T > builder ) {
306
306
this .adminUrl = checkNotNull (builder .adminUrl );
307
307
this .clientConfigurationData = checkNotNull (builder .clientConf );
308
308
this .deserializer = builder .deserializer ;
You can’t perform that action at this time.
0 commit comments