public void acceptPrimaryKeyMap(Entity entity, Map<String, ? extends Object> primaryKeyMap) { L199: } L200: L201: @Override L202: public void acceptAllColumnMap(Entity entity, Map<String, ? extends Object> allColumnMap) { L203: } L204: L205: @Override L206: public Map<String, Object> extractPrimaryKeyMap(Entity entity) { L207: return null; L208: } L209: L210: @Override L211: public Map<String, Object> extractAllColumnMap(Entity entity) { L212: return null; L213:...

logger.debug("The number of an added document is {}.", documentSize.get()); L142: } L143: L144: } L145: L146: protected Map<String, Object> ingest(final DataStoreParams paramMap, final Map<String, Object> dataMap) { L147: if (ingestFactory == null) { L148: return dataMap; L149: } L150: Map<String, Object> target = dataMap; L151: for (final Ingester ingester : ingestFactory.getIngesters()) { L152: try { L153: target =...

L31:public class ChainBenchmark { L32: L33: @Param({"1", "2", "3", "4", "5", "6"}) L34: int length; L35: L36: private Segment<Object, Object> segment; L37: private ReferenceEntry<Object, Object> head; L38: private @Nullable ReferenceEntry<Object, Object> chain; L39: L40: @SuppressWarnings("GuardedBy") L41: @BeforeExperiment L42: void setUp() { L43: LocalCache<Object, Object> cache = L44: new LocalCache<>(CacheBuilder.newBuilder().concurrencyLevel(1), null); L45: segment = cache.segments[0];...

checkNotNull(interfaceType); L48: checkNotNull(timeoutUnit); L49: return target; // ha ha L50: } L51: L52: @CanIgnoreReturnValue // TODO(kak): consider removing this L53: @Override L54: @ParametricNullness L55: public <T extends @Nullable Object> T callWithTimeout( L56: Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) throws ExecutionException { L57: checkNotNull(callable); L58: checkNotNull(timeoutUnit); L59: try { L60: return callable.call(); L61: ...

Source L84: // ====== L85: @Override L86: public Map<String, Object> toSource() { L87: Map<String, Object> sourceMap = new HashMap<>(); L88: if (createdBy != null) { L89: addFieldToSource(sourceMap, "createdBy", createdBy); L90: } L91: if (createdTime != null) { L92: addFieldToSource(sourceMap,...

the Android flavor of Guava). The field is declared with a type of {@code Object} to avoid L45: * compatibility problems on Android VMs. The corresponding accessor method, however, can have the L46: * more specific return type as long as users are careful to guard calls to it with version checks L47: * or reflection: Android VMs ignore the types of elements that aren't used. L48: */ L49: private final @Nullable Object annotatedType; L50: L51: Parameter( L52: Invokable<?, ?> declaration,...

econdRequestHttp1() { L215: enableProtocol(Protocol.HTTP_1_1) L216: L217: server.enqueue(MockResponse(code = 200, body = "Req1")) L218: server.enqueue(MockResponse(code = 200, body = "Req2")) L219: L220: val eventListener = L221: object : EventListener() { L222: var socket: SSLSocket? = null L223: var closed = false L224: L225: override fun connectionAcquired( L226: call: Call, L227: connection: Connection, L228: ) { L229: socket...

"scheduled_job"; L65: } L66: L67: @Override L68: public ScheduledJobDbm asDBMeta() { L69: return ScheduledJobDbm.getInstance(); L70: } L71: L72: @Override L73: protected <RESULT extends ScheduledJob> RESULT createEntity(Map<String, Object> source, Class<? extends RESULT> entityType) { L74: try { L75: final RESULT result = entityType.newInstance(); L76: result.setAvailable(DfTypeUtil.toBoolean(source.get("available"))); L77: result.setCrawler...

ssages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, "doc is required")); L122: } L123: validateFields(body.doc, this::throwValidationErrorApi); L124: body.crudMode = CrudMode.CREATE; L125: final Map<String, Object> doc = getDoc(body).map(entity -> { L126: try { L127: entity.putAll(fessConfig.convertToStorableDoc(body.doc)); L128: L129: final String newId = ComponentUtil.getCrawlingInfoHelper().generateId(entity); L130:...

method for L54: * {@link org.codelibs.core.convert.BinaryConversionUtil#toBinary(java.lang.Object)} L55: * . L56: */ L57: @Test L58: public void testToBinaryException() { L59: exception.expect(ClIllegalArgumentException.class); L60: exception.expectMessage(is("[ECL0009]argument[o] is illegal. because class java.lang.Object.")); L61: BinaryConversionUtil.toBinary(new Object()); L62: } L63: L64:}...