本文整理了Java中org.apache.gobblin.source.workunit.Extract.getProp()
方法的一些代码示例,展示了Extract.getProp()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Extract.getProp()
方法的具体详情如下:
包路径:org.apache.gobblin.source.workunit.Extract
类名称:Extract
方法名:getProp
暂无
代码示例来源:origin: apache/incubator-gobblin
/**
* Get the dot-separated namespace of the table.
*
* @return dot-separated namespace of the table
*/
public String getNamespace() {
return getProp(ConfigurationKeys.EXTRACT_NAMESPACE_NAME_KEY, "");
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Get the name of the table.
*
* @return name of the table
*/
public String getTable() {
return getProp(ConfigurationKeys.EXTRACT_TABLE_NAME_KEY, "");
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Get a (non-globally) unique ID for this {@link Extract}.
*
* @return unique ID for this {@link Extract}
*/
public String getExtractId() {
return getProp(ConfigurationKeys.EXTRACT_EXTRACT_ID_KEY, "");
}
代码示例来源:origin: apache/incubator-gobblin
@Override
public String getProp(String key, String def) {
String value = super.getProp(key);
if (value == null) {
value = this.extract.getProp(key, def);
}
return value;
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Get the {@link TableType} of the table.
*
* @return {@link TableType} of the table
*/
public TableType getType() {
return TableType.valueOf(getProp(ConfigurationKeys.EXTRACT_TABLE_TYPE_KEY));
}
代码示例来源: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: org.apache.gobblin/gobblin-api
/**
* Get a (non-globally) unique ID for this {@link Extract}.
*
* @return unique ID for this {@link Extract}
*/
public String getExtractId() {
return getProp(ConfigurationKeys.EXTRACT_EXTRACT_ID_KEY, "");
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Get the dot-separated namespace of the table.
*
* @return dot-separated namespace of the table
*/
public String getNamespace() {
return getProp(ConfigurationKeys.EXTRACT_NAMESPACE_NAME_KEY, "");
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Get the name of the table.
*
* @return name of the table
*/
public String getTable() {
return getProp(ConfigurationKeys.EXTRACT_TABLE_NAME_KEY, "");
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
@Override
public String getProp(String key, String def) {
String value = super.getProp(key);
if (value == null) {
value = this.extract.getProp(key, def);
}
return value;
}
代码示例来源:origin: org.apache.gobblin/gobblin-api
/**
* Get the {@link TableType} of the table.
*
* @return {@link TableType} of the table
*/
public TableType getType() {
return TableType.valueOf(getProp(ConfigurationKeys.EXTRACT_TABLE_TYPE_KEY));
}
代码示例来源: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());
}
内容来源于网络,如有侵权,请联系作者删除!