final Entity entity = entityList.get(i); L471: if (entity instanceof EsAbstractEntity) { L472: ((EsAbstractEntity) entity).asDocMeta().id(itemResponse.getId()); L473: } L474: results[i] = itemResponse.isFailed() ? 0 : 1; L475: } L476: return results; L477: } L478: L479: // to suppress xacceptUpdateColumnModifiedPropertiesIfNeeds()'s specify process L480: @Override L481: protected UpdateOption<CB> createPlainUpdateOption() { L482:...

L504: try { L505: ByteStreams.exhaust(decodingStream); L506: fail("Expected DecodingException"); L507: } catch (DecodingException expected) { L508: // Don't assert on the expectedMessage; the messages for exceptions thrown from the L509: // decoding stream may differ from the messages for the decode methods. L510: } catch (IOException e) { L511: fail("Expected DecodingException but got: " + e); L512: } L513: } L514: };...

*/ L92:@GwtCompatible(emulated = true) L93:@ElementTypesAreNonnullByDefault L94:public final class ArrayTable<R, C, V> extends AbstractTable<R, C, @Nullable V> L95: implements Serializable { L96: L97: /** L98: * Creates an {@code ArrayTable} filled with {@code null}. L99: * L100: * @param rowKeys row keys that may be stored in the generated table L101: * @param columnKeys column keys that may be stored in the generated table L102: * @throws NullPointerException if any of the provided...

arbitraryConstantInstanceOrNull(Class<T> type) { L385: Field[] fields = type.getDeclaredFields(); L386: Arrays.sort(fields, BY_FIELD_NAME); L387: for (Field field : fields) { L388: if (Modifier.isPublic(field.getModifiers()) L389: && Modifier.isStatic(field.getModifiers()) L390: && Modifier.isFinal(field.getModifiers())) { L391: if (field.getGenericType() == field.getType() && type.isAssignableFrom(field.getType())) { L392: field.setAccessible(true);...

<i>type</i> offering meaningful behavioral guarantees. This is substantially different from the L82: * case of (say) {@link HashSet}, which is an <i>implementation</i>, with semantics that were L83: * largely defined by its supertype. L84: * L85: * <p>For field types and method return types, you should generally use the immutable type (such as L86: * {@link ImmutableList}) instead of the general collection interface type (such as {@link List}). L87: * This communicates to your callers all of the semantic...

L550: // positive). L551: bloomFilter.put(key); L552: // False negative should *never* happen. L553: assertThat(bloomFilter.mightContain(key)).isTrue(); L554: L555: // If this check ever fails, that means we need to either bump the L556: // number of expected insertions or don't run the test for so long. L557: // Don't forget, the bloom filter slowly saturates over time and the L558: // expected false...

null; L896: L897: void set(T value) { L898: this.set = true; L899: this.value = value; L900: } L901: L902: T get() { L903: /* L904: * requireNonNull is safe because we call get() only if we've previously called set(). L905: * L906: * (For further discussion of nullness, see the comment above the method.) L907: */ L908: return requireNonNull(value); L909: } L910: } L911: OptionalState state = new OptionalState();...

non-reified type or has bounds, {@code forDependants} is used to do further resolution, which L318: * doesn't try to resolve any type variable on generic declarations that are already being L319: * resolved. L320: * L321: * <p>Should only be called and overridden by {@link #resolve(TypeVariable)}. L322: */ L323: Type resolveInternal(TypeVariable<?> var, TypeTable forDependants) { L324: Type type = map.get(new TypeVariableKey(var)); L325: if (type == null) { L326: Type[]...

methods but behave like tryEnterXxx in some scenarios. L175: */ L176: private static boolean isEnterIf(Method method) { L177: return method.getName().startsWith("enterIf"); L178: } L179: L180: /** Identifies all waitForXxx methods, which must be called while occupying the monitor. */ L181: private static boolean isWaitFor(Method method) { L182: return method.getName().startsWith("waitFor"); L183: } L184: L185: /** Determines whether the given method takes a Guard as its first parameter. */...

multiple reasons to abnormally close this stream (such as both peers closing it L87: * near-simultaneously) then this is the first reason known to this peer. L88: */ L89: internal var errorCode: ErrorCode? = null L90: get() = this.withLock { field } L91: L92: /** The exception that explains [errorCode]. Null if no exception was provided. */ L93: internal var errorException: IOException? = null L94: L95: init { L96: if (headers != null) { L97: check(!isLocallyInitiated) { "locally-initiated...