; L541: if (str == null) { L542: return null; L543: } L544: return new String[] { str }; L545: } L546: L547: protected LocalDateTime toLocalDateTime(Object value) { L548: return DfTypeUtil.toLocalDateTime(value); L549: } L550: L551: protected Date toDate(Object value) { L552: return DfTypeUtil.toDate(value); L553: } L554: L555: protected SearchHits getSearchHits(final SearchResponse response) { L556: SearchHits hits = response.getHits();...

mapEntry(Range.closed(20, 22), "umbrella")); L58: } L59: L60: @Override L61: public Map<Range<Integer>, String> create(Object... elements) { L62: RangeMap<Integer, String> rangeMap = TreeRangeMap.create(); L63: for (Object o : elements) { L64: @SuppressWarnings("unchecked") L65: Entry<Range<Integer>, String> entry = (Entry<Range<Integer>, String>) o; L66: ...

*/ L30:@ElementTypesAreNonnullByDefault L31:public class DeadEvent { L32: L33: private final Object source; L34: private final Object event; L35: L36: /** L37: * Creates a new DeadEvent. L38: * L39: * @param source object broadcasting the DeadEvent (generally the {@link EventBus}). L40: * @param event the event that could not be delivered. L41: */ L42: public DeadEvent(Object source, Object event) { L43: this.source = checkNotNull(source); L44: this.event = checkNotNull(event);...

L36:@GwtIncompatible L37:public final class SafeTreeSet<E> implements Serializable, NavigableSet<E> { L38: @SuppressWarnings("unchecked") L39: private static final Comparator<Object> NATURAL_ORDER = L40: new Comparator<Object>() { L41: @Override L42: public int compare(Object o1, Object o2) { L43: return ((Comparable<Object>) o1).compareTo(o2); L44: } L45: }; L46: L47: private final NavigableSet<E> delegate; L48: L49: public SafeTreeSet() { L50: this(new TreeSet<E>());...

simulate late connection pool failures. L65: */ L66: object DisconnectAfterRequest : SocketPolicy L67: L68: /** L69: * Half close connection (InputStream for client) after reading the request but before L70: * writing the response. Use this to simulate late connection pool failures. L71: */ L72: object HalfCloseAfterRequest : SocketPolicy L73: L74: /** Close connection after reading half of the request body (if present). */ L75: object DisconnectDuringRequestBody : SocketPolicy L76: L77:...

{ L36: } L37: L38: public static <T> T getValue(final Map<String, Object> doc, final String key, final Class<T> clazz, final T defaultValue) { L39: final T value = getValue(doc, key, clazz); L40: if (value == null) { L41: return defaultValue; L42: } L43: return value; L44: } L45: L46: @SuppressWarnings("unchecked") L47: public static <T> T getValue(final Map<String, Object> doc, final String key, final Class<T> clazz) { L48: if (doc == null...

extends SampleElements<Integer> { L89: public Ints() { L90: // elements aren't sorted, to better test SortedSet iteration ordering L91: super(1, 0, 2, 3, 4); L92: } L93: } L94: L95: public static <K extends @Nullable Object, V extends @Nullable Object> L96: SampleElements<Entry<K, V>> mapEntries(SampleElements<K> keys, SampleElements<V> values) { L97: return new SampleElements<>( L98: mapEntry(keys.e0(), values.e0()), L99: mapEntry(keys.e1(), values.e1()), L100:...

systemHelper.getCurrentTime(); L84: final CrawlingInfoHelper crawlingInfoHelper = ComponentUtil.getCrawlingInfoHelper(); L85: final LanguageHelper languageHelper = ComponentUtil.getLanguageHelper(); L86: final List<Map<String, Object>> docList = body.documents.stream().map(doc -> { L87: if (!doc.containsKey(indexFieldContentLength)) { L88: long contentLength = 0; L89: if (doc.get(indexFieldTitle) instanceof final String title) { L90: ...

L129: L130: @Override L131: public List<Short> create(Object... elements) { L132: Short[] array = new Short[elements.length]; L133: short i = 0; L134: for (Object e : elements) { L135: array[i++] = (Short) e; L136: } L137: return create(array); L138: } L139: L140: /** L141: * Creates a new collection containing the given elements; implement this method instead of L142: * {@link #create(Object...)}. L143: */ L144: protected abstract List<Short>...

L129: L130: @Override L131: public List<Long> create(Object... elements) { L132: Long[] array = new Long[elements.length]; L133: int i = 0; L134: for (Object e : elements) { L135: array[i++] = (Long) e; L136: } L137: return create(array); L138: } L139: L140: /** L141: * Creates a new collection containing the given elements; implement this method instead of L142: * {@link #create(Object...)}. L143: */ L144: protected abstract List<Long> create(Long[]...