---

mziccard · web-flow · commit bcb47df7f4f1 · 2016-08-09T14:42:52.000+02:00
yaml --- r: 5005 b: refs/heads/master c: 0637c80 h: refs/heads/master i: 5003: edf55bf
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 8d76e73c1d6fb63380c5c37094a7370feffb540b
+refs/heads/master: 0637c80cc23938e4bbfa6304005f975a319648b5
 refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
 refs/heads/gh-pages: 7406918e071dd2c5677a638ae2a06e7592b6542c
 refs/heads/pubsub-alpha: d6bbd32eed6cb48cda8d6798ee70ddd6bfc1f07d
diff --git a/trunk/gcloud-java-bigquery/src/main/java/com/google/cloud/bigquery/StandardTableDefinition.java b/trunk/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);
     }
   }
 
