作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中gobblin.source.workunit.WorkUnit.getExtract()
方法的一些代码示例,展示了WorkUnit.getExtract()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkUnit.getExtract()
方法的具体详情如下:
包路径:gobblin.source.workunit.WorkUnit
类名称: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);
本文整理了Java中gobblin.source.workunit.WorkUnit.getExtract()方法的一些代码示例,展示了WorkUnit.getExtract()的具体用法。这些代码示
我是一名优秀的程序员,十分优秀!