Add support for exporting null timestamp

PiperOrigin-RevId: 364932785
tkyoo0627 · Mar 25, 2021 · 136fded · 136fded
1 parent c8c5b15
commit 136fded
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java b/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java
@@ -69,9 +69,12 @@ public GenericRecord convert(Struct row) {
           break;
         case LONG:
           if (spannerType.equals("TIMESTAMP")) {
-            Timestamp ts = row.getTimestamp(fieldName);
-            long microSeconds = TimeUnit.SECONDS.toMicros(ts.getSeconds())
-                + TimeUnit.NANOSECONDS.toMicros(ts.getNanos());
+            long microSeconds=0L;
+            if (!nullValue) {
+              Timestamp ts = row.getTimestamp(fieldName);
+              microSeconds = TimeUnit.SECONDS.toMicros(ts.getSeconds())
+                  + TimeUnit.NANOSECONDS.toMicros(ts.getNanos());
+            }
             builder.set(field, nullValue ? null : microSeconds);
           } else {
             builder.set(field, nullValue ? null : row.getLong(fieldName));