Adds support for reading binary Ion 1.1 timestamps.

src/com/amazon/ion/Timestamp.java

@@ -676,6 +676,19 @@ else if (shouldCheckFraction)
                              offset, APPLY_OFFSET_NO, CHECK_FRACTION_YES);
     }
 
+    /**
+     * @return a new Timestamp from the given components in local time, without validating the fractional seconds.
+     */
+    @Deprecated
+    public static Timestamp _private_createFromLocalTimeFieldsUnchecked(Precision p, int year, int month, int day,
+                                                                        int hour, int minute, int second,
+                                                                        BigDecimal frac, Integer offset)
+    {
+        return new Timestamp(p, year, month, day,
+                             hour, minute, second, frac,
+                             offset, APPLY_OFFSET_YES, CHECK_FRACTION_NO);
+    }
+
     /**
      * Creates a new Timestamp from a {@link Calendar}, preserving the
      * {@link Calendar}'s precision and local offset from UTC.

src/com/amazon/ion/impl/IonCursorBinary.java

@@ -948,7 +948,10 @@ private long uncheckedReadFlexUInt_1_1() {
      */
     private long slowReadFlexUInt_1_1() {
         // TODO perf: try 1-byte special case checks. Least-significant bits of 1 indicate 1-byte
-        int currentByte = slowPeekByte();
+        int currentByte = slowReadByte();
+        if (currentByte < 0) {
+            return -1;
+        }
         if (currentByte == 0) {
             throw new IonException("Found a VarUInt that was too large to fit in a `long`");
         }
@@ -1262,6 +1265,9 @@ private boolean uncheckedReadHeader(final int typeIdByte, final boolean isAnnota
             if (endIndex > limit) {
                 isValueIncomplete = true;
             }
+            if (minorVersion == 1 && valueTid.isNull && valueTid.length > 0) {
+                valueTid = IonTypeID.NULL_TYPE_IDS_1_1[buffer[(int)(peekIndex++) & SINGLE_BYTE_MASK]];
+            }
         }
         markerToSet.typeId = valueTid;
         if (event == Event.START_CONTAINER) {
@@ -1306,6 +1312,13 @@ private boolean slowReadHeader(final int typeIdByte, final boolean isAnnotated,
             }
             return true;
         }
+        if (minorVersion == 1 && valueTid.isNull && valueTid.length > 0) {
+            int nullTypeIndex = slowReadByte();
+            if (nullTypeIndex < 0) {
+                return true;
+            }
+            valueTid = IonTypeID.NULL_TYPE_IDS_1_1[nullTypeIndex];
+        }
         markerToSet.typeId = valueTid;
         if (checkpointLocation == CheckpointLocation.AFTER_SCALAR_HEADER) {
             return true;
@@ -1335,11 +1348,6 @@ private boolean slowReadValueHeader(IonTypeID valueTid, boolean isAnnotated, Mar
         if (valueTid.isDelimited) {
             endIndex = DELIMITED_MARKER;
         } else if (valueTid.variableLength) {
-            // At this point the value must be at least 2 more bytes: 1 for the smallest-possible value length
-            // and 1 for the smallest-possible value representation.
-            if (!fillAt(peekIndex, 2)) {
-                return true;
-            }
             valueLength = minorVersion == 0 ? slowReadVarUInt_1_0() : slowReadFlexUInt_1_1();
             if (valueLength < 0) {
                 return true;

src/com/amazon/ion/impl/IonReaderContinuableApplicationBinary.java

@@ -902,7 +902,7 @@ private enum State {
     boolean startsWithIonSymbolTable() {
         long savedPeekIndex = peekIndex;
         peekIndex = annotationSequenceMarker.startIndex;
-        int sid = minorVersion == 0 ? readVarUInt_1_0() : readVarUInt_1_1();
+        int sid = minorVersion == 0 ? readVarUInt_1_0() : (int) readFlexUInt_1_1();
         peekIndex = savedPeekIndex;
         return ION_SYMBOL_TABLE_SID == sid;
     }