@@ -78,12 +78,12 @@ private boolean isSqlQuoteIdentifierRequiredFor(String name) {
7878 }
7979
8080 @ Override
81- public CharSequence apply (IN input , Schema <IN , ?> schema ) {
81+ public CharSequence apply (@ Nullable IN input , Schema <IN , ?> schema ) {
8282 return apply (input , schema , 0 );
8383 }
8484
8585 @ Override
86- public CharSequence apply (IN input , Schema <IN , ?> schema , long rowId ) {
86+ public CharSequence apply (@ Nullable IN input , Schema <IN , ?> schema , long rowId ) {
8787 //noinspection unchecked
8888 Field <?, ? extends CharSequence >[] fields = (Field <?, ? extends CharSequence >[]) schema .getFields ();
8989 if (fields .length == 0 ) {
@@ -106,7 +106,7 @@ public CharSequence apply(IN input, Schema<IN, ?> schema, long rowId) {
106106 }
107107 }
108108
109- private String addValues (IN input , Field <?, ?>[] fields , Boolean isRoot ) {
109+ private String addValues (@ Nullable IN input , Field <?, ?>[] fields , Boolean isRoot ) {
110110 StringJoiner result = new StringJoiner (", " );
111111 for (int i = 0 ; i < fields .length ; i ++) {
112112
@@ -433,7 +433,7 @@ public Stream<CharSequence> generateStream(final Schema<IN, ?> schema, long limi
433433 }
434434 }
435435
436- private String generateSeparatedStatements (Schema <IN , ?> schema , List <IN > inputs , int limit ) {
436+ private String generateSeparatedStatements (Schema <IN , ?> schema , @ Nullable List <IN > inputs , int limit ) {
437437 StringJoiner data = new StringJoiner (LINE_SEPARATOR );
438438 limit = inputs != null ? Math .min (limit , inputs .size ()) : limit ;
439439 for (int i = 0 ; i < limit ; i ++) {
0 commit comments