gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-21 07:53:05 27 4
gpt4 key购买 nike

本文整理了Java中gobblin.source.workunit.WorkUnit.getExtract()方法的一些代码示例,展示了WorkUnit.getExtract()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkUnit.getExtract()方法的具体详情如下:
包路径:gobblin.source.workunit.WorkUnit
类名称:WorkUnit
方法名:getExtract

WorkUnit.getExtract介绍

[英]Get the Extract associated with this WorkUnit.
[中]获取与此工作单元关联的摘录。

代码示例

代码示例来源:origin: com.linkedin.gobblin/gobblin-api

/**
 * Get the {@link gobblin.source.workunit.Extract} associated with the {@link WorkUnit}.
 *
 * @return {@link gobblin.source.workunit.Extract} associated with the {@link WorkUnit}
 */
public Extract getExtract() {
 return new Extract(this.workUnit.getExtract());
}

代码示例来源:origin: com.linkedin.gobblin/gobblin-api

/**
 * Copy constructor.
 *
 * @param other the other {@link WorkUnit} instance
 *
 * @deprecated Use {@link #copyOf(WorkUnit)}
 */
@Deprecated
public WorkUnit(WorkUnit other) {
 super.addAll(other);
 this.extract = other.getExtract();
}

代码示例来源:origin: com.linkedin.gobblin/gobblin-api

public ImmutableWorkUnit(WorkUnit workUnit) {
 super(workUnit.getExtract());
 // Only copy the specProperties from the given workUnit.
 Properties specificPropertiesCopy = new Properties();
 specificPropertiesCopy.putAll(workUnit.getSpecProperties());
 super.setProps(workUnit.getCommonProperties(), specificPropertiesCopy);
}

代码示例来源:origin: com.linkedin.gobblin/gobblin-utility

/**
 * Creates the default {@link Path} for the {@link ConfigurationKeys#WRITER_FILE_PATH} key.
 * @param numBranches is the total number of branches for the given {@link State}.
 * @param branchId is the id for the specific branch that the {@link gobblin.writer.DataWriter} will write to.
 * @return a {@link Path} specifying the directory where the {@link gobblin.writer.DataWriter} will write to.
 */
public static Path getDefaultWriterFilePath(State state, int numBranches, int branchId) {
 if (state instanceof WorkUnitState) {
  WorkUnitState workUnitState = (WorkUnitState) state;
  return new Path(ForkOperatorUtils.getPathForBranch(workUnitState, workUnitState.getExtract().getOutputFilePath(),
    numBranches, branchId));
 } else if (state instanceof WorkUnit) {
  WorkUnit workUnit = (WorkUnit) state;
  return new Path(ForkOperatorUtils.getPathForBranch(workUnit, workUnit.getExtract().getOutputFilePath(),
    numBranches, branchId));
 }
 throw new RuntimeException("In order to get the default value for " + ConfigurationKeys.WRITER_FILE_PATH
   + " the given state must be of type " + WorkUnitState.class.getName() + " or " + WorkUnit.class.getName());
}

代码示例来源:origin: com.linkedin.gobblin/gobblin-api

Extract previousExtract = pre.getWorkunit().getExtract();
if (previousExtract.getNamespace().equals(namespace) && previousExtract.getTable().equals(table)) {
 this.previousTableState.addAll(pre);

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com