gobblin.source.workunit.WorkUnit.contains()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-21 08:03:05 26 4

/**
 * Get the low {@link Watermark} as a {@link JsonElement}.
 *
 * @return a {@link JsonElement} representing the low {@link Watermark} or
 *         {@code null} if the low {@link Watermark} is not set.
 */
public JsonElement getLowWatermark() {
 if (!contains(ConfigurationKeys.WATERMARK_INTERVAL_VALUE_KEY)) {
  return null;
 }
 return JSON_PARSER.parse(getProp(ConfigurationKeys.WATERMARK_INTERVAL_VALUE_KEY)).getAsJsonObject()
   .get(WatermarkInterval.LOW_WATERMARK_TO_JSON_KEY);
}

@Override
public boolean contains(String key) {
 return super.contains(key) || this.workUnit.contains(key) || this.jobState.contains(key);
}

@Override
 public boolean apply(WorkUnit workUnit) {
  if (workUnit instanceof MultiWorkUnit) {
   Preconditions.checkArgument(!workUnit.contains(ConfigurationKeys.WORK_UNIT_SKIP_KEY),
     "Error: MultiWorkUnit cannot be skipped");
   for (WorkUnit wu : ((MultiWorkUnit) workUnit).getWorkUnits()) {
    Preconditions.checkArgument(!wu.contains(ConfigurationKeys.WORK_UNIT_SKIP_KEY),
      "Error: MultiWorkUnit cannot contain skipped WorkUnit");
   }
  }
  if (workUnit.getPropAsBoolean(ConfigurationKeys.WORK_UNIT_SKIP_KEY, false)) {
   WorkUnitState workUnitState = new WorkUnitState(workUnit, this.jobState);
   workUnitState.setWorkingState(WorkUnitState.WorkingState.SKIPPED);
   this.jobState.addSkippedTaskState(new TaskState(workUnitState));
   return false;
  }
  return true;
 }
}

private static void computeAndSetWorkUnitGuid(WorkUnit workUnit)
  throws IOException {
 Guid guid = Guid.fromStrings(workUnit.contains(ConfigurationKeys.CONVERTER_CLASSES_KEY) ? workUnit
   .getProp(ConfigurationKeys.CONVERTER_CLASSES_KEY) : "");
 setWorkUnitGuid(workUnit, guid.append(deserializeCopyEntity(workUnit)));
}

26 4 0

• gobblin.source.workunit.WorkUnit.readFields()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.readFields()方法的一些代码示例，展示了WorkUnit.readFields()的具体用法。这些代码示

• gobblin.source.workunit.WorkUnit.createEmpty()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.createEmpty()方法的一些代码示例，展示了WorkUnit.createEmpty()的具体用法。这些代

• gobblin.source.workunit.WorkUnit.getExtract()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.getExtract()方法的一些代码示例，展示了WorkUnit.getExtract()的具体用法。这些代码示

• gobblin.source.workunit.WorkUnit.getLowWatermark()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.getLowWatermark()方法的一些代码示例，展示了WorkUnit.getLowWatermark()的

• gobblin.source.workunit.WorkUnit.setProp()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.setProp()方法的一些代码示例，展示了WorkUnit.setProp()的具体用法。这些代码示例主要来源于

• gobblin.source.workunit.WorkUnit.contains()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.contains()方法的一些代码示例，展示了WorkUnit.contains()的具体用法。这些代码示例主要来

• gobblin.source.workunit.WorkUnit.setId()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.setId()方法的一些代码示例，展示了WorkUnit.setId()的具体用法。这些代码示例主要来源于Gith

• gobblin.source.workunit.WorkUnit.()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.()方法的一些代码示例，展示了WorkUnit.()的具体用法。这些代码示例主要来源于Github/Stackov

• gobblin.source.workunit.WorkUnit.getProperties()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.getProperties()方法的一些代码示例，展示了WorkUnit.getProperties()的具体用法

• gobblin.source.workunit.WorkUnit.getExpectedHighWatermark()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.getExpectedHighWatermark()方法的一些代码示例，展示了WorkUnit.getExpect

• gobblin.source.workunit.WorkUnit.getPropAsLong()方法的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit.getPropAsLong()方法的一些代码示例，展示了WorkUnit.getPropAsLong()的具体用法

• gobblin.source.workunit.WorkUnit类的使用及代码示例

  本文整理了Java中gobblin.source.workunit.WorkUnit类的一些代码示例，展示了WorkUnit类的具体用法。这些代码示例主要来源于Github/Stackoverflow

• org.apache.gobblin.source.workunit.WorkUnitStream类的使用及代码示例

  本文整理了Java中org.apache.gobblin.source.workunit.WorkUnitStream类的一些代码示例，展示了WorkUnitStream类的具体用法。这些代码示例主要

• org.apache.gobblin.source.workunit.WorkUnitStream.isFiniteStream()方法的使用及代码示例

  本文整理了Java中org.apache.gobblin.source.workunit.WorkUnitStream.isFiniteStream()方法的一些代码示例，展示了WorkUnitStr

• org.apache.gobblin.source.workunit.WorkUnitStream.transform()方法的使用及代码示例

  本文整理了Java中org.apache.gobblin.source.workunit.WorkUnitStream.transform()方法的一些代码示例，展示了WorkUnitStream.t

• org.apache.gobblin.source.workunit.WorkUnitStream.isSafeToMaterialize()方法的使用及代码示例

  本文整理了Java中org.apache.gobblin.source.workunit.WorkUnitStream.isSafeToMaterialize()方法的一些代码示例，展示了WorkUn

• org.apache.gobblin.source.workunit.WorkUnitStream.getWorkUnits()方法的使用及代码示例

  本文整理了Java中org.apache.gobblin.source.workunit.WorkUnitStream.getWorkUnits()方法的一些代码示例，展示了WorkUnitStrea

• org.apache.gobblin.source.workunit.WorkUnitStream.getMaterializedWorkUnitCollection()方法的使用及代码示例

  本文整理了Java中org.apache.gobblin.source.workunit.WorkUnitStream.getMaterializedWorkUnitCollection()方法的一些