本文整理了Java中org.jooq.Field.minus()
方法的一些代码示例,展示了Field.minus()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Field.minus()
方法的具体详情如下:
包路径:org.jooq.Field
类名称:Field
方法名:minus
[英]An alias for #sub(Number).
[中]#sub(Number)的别名。
代码示例来源:origin: my2iu/Jinq
@Override public ColumnExpressions<?> mathOpValue(TypedValue.MathOpValue val, Void in) throws TypedValueVisitorException
{
ColumnExpressions<?> left = val.left.visit(this, in);
ColumnExpressions<?> right = val.right.visit(this, in);
Field leftField = (Field)left.getOnlyColumn();
Field rightField = (Field)right.getOnlyColumn();
Field resultField;
switch(val.op)
{
case minus: resultField = leftField.minus(rightField); break;
case plus: resultField = leftField.plus(rightField); break;
case mul: resultField = leftField.mul(rightField); break;
default:
throw new TypedValueVisitorException("Unknown math operator");
}
return ColumnExpressions.singleColumn(left.reader, resultField);
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
@Override
public void performTask() {
Field<Timestamp> cutoff = currentTimestamp().minus(field("interval '10 minutes'"));
int n = watchdogDao.failStalled(cutoff);
log.info("run -> {} command(s) are timed out", n);
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
private void failStalled() {
Field<Timestamp> cutOff = currentTimestamp().minus(interval(MAX_STALLED_AGE));
dao.transaction(tx -> {
List<String> ids = dao.pollStalled(tx, cutOff);
for(String id : ids) {
dao.fail(tx, id);
log.info("failStalled -> marked as failed: {}", id);
}
});
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
@Override
public void run() {
watchdogDao.transaction(tx -> {
Field<Timestamp> cutOff = currentTimestamp().minus(interval(cfg.getMaxStalledAge()));
List<ProcessKey> pks = watchdogDao.pollStalled(tx, POTENTIAL_STALLED_STATUSES, cutOff, 1);
for (ProcessKey pk : pks) {
queueDao.updateAgentId(tx, pk, null, ProcessStatus.FAILED);
logManager.warn(pk, "Process stalled, no heartbeat for more than a minute");
log.info("processStalled -> marked as failed: {}", pk);
}
});
}
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
@Override
public void run() {
watchdogDao.transaction(tx -> {
Field<Timestamp> cutOff = currentTimestamp().minus(interval(cfg.getMaxStartFailureAge()));
List<ProcessKey> pks = watchdogDao.pollStalled(tx, FAILED_TO_START_STATUSES, cutOff, 1);
for (ProcessKey pk : pks) {
queueDao.updateAgentId(tx, pk, null, ProcessStatus.FAILED);
logManager.warn(pk, "Process failed to start");
log.info("processStartFailures -> marked as failed: {}", pk);
}
});
}
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
@Override
public void run() {
Field<Timestamp> maxAge = currentTimestamp().minus(interval(cfg.getMaxFailureHandlingAge()));
for (PollEntry e : POLL_ENTRIES) {
List<ProcessEntry> parents = watchdogDao.poll(e, maxAge, 1);
for (ProcessEntry parent : parents) {
process(e, parent);
}
}
}
代码示例来源:origin: com.openle.module.lambda/lambda
@Override public ColumnExpressions<?> mathOpValue(TypedValue.MathOpValue val, Void in) throws TypedValueVisitorException
{
ColumnExpressions<?> left = val.left.visit(this, in);
ColumnExpressions<?> right = val.right.visit(this, in);
Field leftField = (Field)left.getOnlyColumn();
Field rightField = (Field)right.getOnlyColumn();
Field resultField;
switch(val.op)
{
case minus: resultField = leftField.minus(rightField); break;
case plus: resultField = leftField.plus(rightField); break;
case mul: resultField = leftField.mul(rightField); break;
default:
throw new TypedValueVisitorException("Unknown math operator");
}
return ColumnExpressions.singleColumn(left.reader, resultField);
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
public boolean removeMeta(PartialProcessKey processKey, String key) {
UUID instanceId = processKey.getInstanceId();
return txResult(tx -> {
Field<String> v = field("{0}", String.class, PROCESS_QUEUE.META).minus(value(key));
int i = tx.update(PROCESS_QUEUE)
.set(PROCESS_QUEUE.META, v)
.where(PROCESS_QUEUE.INSTANCE_ID.eq(instanceId))
.execute();
return i == 1;
});
}
代码示例来源:origin: com.walmartlabs.concord.server/concord-server
public List<ApiKeyEntry> poll(int days) {
return txResult(tx ->
tx.select(API_KEYS.KEY_ID,
API_KEYS.KEY_NAME,
API_KEYS.EXPIRED_AT,
API_KEYS.USER_ID)
.from(API_KEYS)
.where(API_KEYS.EXPIRED_AT.isNotNull()
.and(currentTimestamp().greaterOrEqual(trunc(API_KEYS.EXPIRED_AT).minus(days))
.and(API_KEYS.LAST_NOTIFIED_AT.isNull()
.or(API_KEYS.LAST_NOTIFIED_AT.lessOrEqual(API_KEYS.EXPIRED_AT.minus(days))))))
.fetch(this::toEntry));
}
内容来源于网络,如有侵权,请联系作者删除!