File tree Expand file tree Collapse file tree 2 files changed +20
-3
lines changed
src/main/java/tech/ydb/spark/connector Expand file tree Collapse file tree 2 files changed +20
-3
lines changed Original file line number Diff line number Diff line change 1+ package tech .ydb .spark .connector ;
2+
3+ import org .apache .spark .sql .connector .write .RowLevelOperation ;
4+ import org .apache .spark .sql .connector .write .RowLevelOperationBuilder ;
5+
6+ /**
7+ *
8+ * @author zinal
9+ */
10+ public class YdbRowLevelBuilder implements RowLevelOperationBuilder {
11+
12+ @ Override
13+ public RowLevelOperation build () {
14+ throw new UnsupportedOperationException ("Not supported yet." );
15+ }
16+
17+ }
Original file line number Diff line number Diff line change @@ -108,7 +108,7 @@ private static GrpcTransportBuilder applyAuthSettings(GrpcTransportBuilder build
108108 CloudAuthHelper .getAuthProviderFromEnviron ());
109109 break ;
110110 case META :
111- builder = builder .withAuthProvider (opt -> CloudAuthIdentity .metadataIdentity ());
111+ builder = builder .withAuthProvider (( opt ) -> CloudAuthIdentity .metadataIdentity (null ));
112112 break ;
113113 case STATIC :
114114 builder = builder .withAuthProvider (
@@ -119,14 +119,14 @@ private static GrpcTransportBuilder applyAuthSettings(GrpcTransportBuilder build
119119 if (keyFile != null ) {
120120 final String v = keyFile ;
121121 builder = builder .withAuthProvider ((opt ) -> {
122- return CloudAuthIdentity .serviceAccountIdentity (Paths .get (v ));
122+ return CloudAuthIdentity .serviceAccountIdentity (Paths .get (v ), null );
123123 });
124124 } else {
125125 keyFile = props .get (AUTH_SAKEY_TEXT );
126126 if (keyFile != null ) {
127127 final String v = keyFile ;
128128 builder = builder .withAuthProvider ((opt ) -> {
129- return CloudAuthIdentity .serviceAccountIdentity (v );
129+ return CloudAuthIdentity .serviceAccountIdentity (v , null );
130130 });
131131 }
132132 }
You can’t perform that action at this time.
0 commit comments