---

mziccard · web-flow · commit b234b118e0cf · 2016-08-09T14:42:52.000+02:00
yaml --- r: 7479 b: refs/heads/tswast-patch-1 c: 0637c80 h: refs/heads/master i: 7477: ed7b685 7475: eca350c 7471: 7610d01
diff --git a/[refs] b/[refs]
@@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
 refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
 refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
 refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
-refs/heads/tswast-patch-1: 8d76e73c1d6fb63380c5c37094a7370feffb540b
+refs/heads/tswast-patch-1: 0637c80cc23938e4bbfa6304005f975a319648b5
 refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b
diff --git a/branches/tswast-patch-1/gcloud-java-bigquery/src/main/java/com/google/cloud/bigquery/StandardTableDefinition.java b/branches/tswast-patch-1/gcloud-java-bigquery/src/main/java/com/google/cloud/bigquery/StandardTableDefinition.java
@@ -53,9 +53,9 @@ public static class StreamingBuffer implements Serializable {
     private static final long serialVersionUID = 822027055549277843L;
     private final long estimatedRows;
     private final long estimatedBytes;
-    private final long oldestEntryTime;
+    private final Long oldestEntryTime;
 
-    StreamingBuffer(long estimatedRows, long estimatedBytes, long oldestEntryTime) {
+    StreamingBuffer(long estimatedRows, long estimatedBytes, Long oldestEntryTime) {
       this.estimatedRows = estimatedRows;
       this.estimatedBytes = estimatedBytes;
       this.oldestEntryTime = oldestEntryTime;
@@ -77,9 +77,9 @@ public long estimatedBytes() {
 
     /**
      * Returns the timestamp of the oldest entry in the streaming buffer, in milliseconds since
-     * epoch.
+     * epoch. Returns {@code null} if the streaming buffer is empty.
      */
-    public long oldestEntryTime() {
+    public Long oldestEntryTime() {
       return oldestEntryTime;
     }
 
@@ -111,9 +111,13 @@ Streamingbuffer toPb() {
     }
 
     static StreamingBuffer fromPb(Streamingbuffer streamingBufferPb) {
+      Long oldestEntryTime = null;
+      if (streamingBufferPb.getOldestEntryTime() != null) {
+        oldestEntryTime = streamingBufferPb.getOldestEntryTime().longValue();
+      }
       return new StreamingBuffer(streamingBufferPb.getEstimatedRows().longValue(),
           streamingBufferPb.getEstimatedBytes().longValue(),
-          streamingBufferPb.getOldestEntryTime().longValue());
+          oldestEntryTime);
     }
   }
 
