本文整理了Java中org.apache.gobblin.source.workunit.Extract.setProp()
方法的一些代码示例,展示了Extract.setProp()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Extract.setProp()
方法的具体详情如下:
包路径:org.apache.gobblin.source.workunit.Extract
类名称:Extract
方法名:setProp
暂无
代码示例来源:origin: apache/incubator-gobblin
/**
* Set a (non-globally) unique ID for this {@link Extract}.
*
* @param extractId unique ID for this {@link Extract}
*/
public void setExtractId(String extractId) {
setProp(ConfigurationKeys.EXTRACT_EXTRACT_ID_KEY, extractId);
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Set full drop date from the given time.
*
* @param extractFullRunTime full extract time
* @deprecated It is recommend to set this information in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void setFullTrue(long extractFullRunTime) {
setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);
setProp(ConfigurationKeys.EXTRACT_FULL_RUN_TIME_KEY, extractFullRunTime);
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Set delta fields.
*
* <p>
* The order of delta fields does not matter.
* </p>
*
* @param deltaFieldName delta field names
* @deprecated It is recommended to set delta fields in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void setDeltaFields(String... deltaFieldName) {
setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, Joiner.on(",").join(deltaFieldName));
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Set primary keys.
*
* <p>
* The order of primary keys does not matter.
* </p>
*
* @param primaryKeyFieldName primary key names
* @deprecated It is recommended to set primary keys in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void setPrimaryKeys(String... primaryKeyFieldName) {
setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, Joiner.on(",").join(primaryKeyFieldName));
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Add more primary keys to the existing set of primary keys.
*
* @param primaryKeyFieldName primary key names
* @deprecated @deprecated It is recommended to add primary keys in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void addPrimaryKey(String... primaryKeyFieldName) {
StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, ""));
Joiner.on(",").appendTo(sb, primaryKeyFieldName);
setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, sb.toString());
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Add more delta fields to the existing set of delta fields.
*
* @param deltaFieldName delta field names
* @deprecated It is recommended to add delta fields in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void addDeltaField(String... deltaFieldName) {
StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, ""));
Joiner.on(",").appendTo(sb, deltaFieldName);
setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, sb.toString());
}
代码示例来源:origin: apache/incubator-gobblin
extract.setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Set a (non-globally) unique ID for this {@link Extract}.
*
* @param extractId unique ID for this {@link Extract}
*/
public void setExtractId(String extractId) {
setProp(ConfigurationKeys.EXTRACT_EXTRACT_ID_KEY, extractId);
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Set full drop date from the given time.
*
* @param extractFullRunTime full extract time
* @deprecated It is recommend to set this information in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void setFullTrue(long extractFullRunTime) {
setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);
setProp(ConfigurationKeys.EXTRACT_FULL_RUN_TIME_KEY, extractFullRunTime);
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Set primary keys.
*
* <p>
* The order of primary keys does not matter.
* </p>
*
* @param primaryKeyFieldName primary key names
* @deprecated It is recommended to set primary keys in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void setPrimaryKeys(String... primaryKeyFieldName) {
setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, Joiner.on(",").join(primaryKeyFieldName));
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Set delta fields.
*
* <p>
* The order of delta fields does not matter.
* </p>
*
* @param deltaFieldName delta field names
* @deprecated It is recommended to set delta fields in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void setDeltaFields(String... deltaFieldName) {
setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, Joiner.on(",").join(deltaFieldName));
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Add more delta fields to the existing set of delta fields.
*
* @param deltaFieldName delta field names
* @deprecated It is recommended to add delta fields in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void addDeltaField(String... deltaFieldName) {
StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, ""));
Joiner.on(",").appendTo(sb, deltaFieldName);
setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, sb.toString());
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Add more primary keys to the existing set of primary keys.
*
* @param primaryKeyFieldName primary key names
* @deprecated @deprecated It is recommended to add primary keys in {@code WorkUnit} instead of {@code Extract}.
*/
@Deprecated
public void addPrimaryKey(String... primaryKeyFieldName) {
StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, ""));
Joiner.on(",").appendTo(sb, primaryKeyFieldName);
setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, sb.toString());
}
代码示例来源:origin: org.apache.gobblin/gobblin-kafka-common
extract.setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);
内容来源于网络,如有侵权,请联系作者删除!