org.apache.gobblin.source.workunit.Extract.setProp()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(133)

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

Extract.setProp介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-gobblin

  1. /**
  2. * Set a (non-globally) unique ID for this {@link Extract}.
  3. *
  4. * @param extractId unique ID for this {@link Extract}
  5. */
  6. public void setExtractId(String extractId) {
  7. setProp(ConfigurationKeys.EXTRACT_EXTRACT_ID_KEY, extractId);
  8. }

代码示例来源:origin: apache/incubator-gobblin

  1. /**
  2. * Set full drop date from the given time.
  3. *
  4. * @param extractFullRunTime full extract time
  5. * @deprecated It is recommend to set this information in {@code WorkUnit} instead of {@code Extract}.
  6. */
  7. @Deprecated
  8. public void setFullTrue(long extractFullRunTime) {
  9. setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);
  10. setProp(ConfigurationKeys.EXTRACT_FULL_RUN_TIME_KEY, extractFullRunTime);
  11. }

代码示例来源:origin: apache/incubator-gobblin

  1. /**
  2. * Set delta fields.
  3. *
  4. * <p>
  5. * The order of delta fields does not matter.
  6. * </p>
  7. *
  8. * @param deltaFieldName delta field names
  9. * @deprecated It is recommended to set delta fields in {@code WorkUnit} instead of {@code Extract}.
  10. */
  11. @Deprecated
  12. public void setDeltaFields(String... deltaFieldName) {
  13. setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, Joiner.on(",").join(deltaFieldName));
  14. }

代码示例来源:origin: apache/incubator-gobblin

  1. /**
  2. * Set primary keys.
  3. *
  4. * <p>
  5. * The order of primary keys does not matter.
  6. * </p>
  7. *
  8. * @param primaryKeyFieldName primary key names
  9. * @deprecated It is recommended to set primary keys in {@code WorkUnit} instead of {@code Extract}.
  10. */
  11. @Deprecated
  12. public void setPrimaryKeys(String... primaryKeyFieldName) {
  13. setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, Joiner.on(",").join(primaryKeyFieldName));
  14. }

代码示例来源:origin: apache/incubator-gobblin

  1. /**
  2. * Add more primary keys to the existing set of primary keys.
  3. *
  4. * @param primaryKeyFieldName primary key names
  5. * @deprecated @deprecated It is recommended to add primary keys in {@code WorkUnit} instead of {@code Extract}.
  6. */
  7. @Deprecated
  8. public void addPrimaryKey(String... primaryKeyFieldName) {
  9. StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, ""));
  10. Joiner.on(",").appendTo(sb, primaryKeyFieldName);
  11. setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, sb.toString());
  12. }

代码示例来源:origin: apache/incubator-gobblin

  1. /**
  2. * Add more delta fields to the existing set of delta fields.
  3. *
  4. * @param deltaFieldName delta field names
  5. * @deprecated It is recommended to add delta fields in {@code WorkUnit} instead of {@code Extract}.
  6. */
  7. @Deprecated
  8. public void addDeltaField(String... deltaFieldName) {
  9. StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, ""));
  10. Joiner.on(",").appendTo(sb, deltaFieldName);
  11. setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, sb.toString());
  12. }

代码示例来源:origin: apache/incubator-gobblin

  1. extract.setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);

代码示例来源:origin: org.apache.gobblin/gobblin-api

  1. /**
  2. * Set a (non-globally) unique ID for this {@link Extract}.
  3. *
  4. * @param extractId unique ID for this {@link Extract}
  5. */
  6. public void setExtractId(String extractId) {
  7. setProp(ConfigurationKeys.EXTRACT_EXTRACT_ID_KEY, extractId);
  8. }

代码示例来源:origin: org.apache.gobblin/gobblin-api

  1. /**
  2. * Set full drop date from the given time.
  3. *
  4. * @param extractFullRunTime full extract time
  5. * @deprecated It is recommend to set this information in {@code WorkUnit} instead of {@code Extract}.
  6. */
  7. @Deprecated
  8. public void setFullTrue(long extractFullRunTime) {
  9. setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);
  10. setProp(ConfigurationKeys.EXTRACT_FULL_RUN_TIME_KEY, extractFullRunTime);
  11. }

代码示例来源:origin: org.apache.gobblin/gobblin-api

  1. /**
  2. * Set primary keys.
  3. *
  4. * <p>
  5. * The order of primary keys does not matter.
  6. * </p>
  7. *
  8. * @param primaryKeyFieldName primary key names
  9. * @deprecated It is recommended to set primary keys in {@code WorkUnit} instead of {@code Extract}.
  10. */
  11. @Deprecated
  12. public void setPrimaryKeys(String... primaryKeyFieldName) {
  13. setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, Joiner.on(",").join(primaryKeyFieldName));
  14. }

代码示例来源:origin: org.apache.gobblin/gobblin-api

  1. /**
  2. * Set delta fields.
  3. *
  4. * <p>
  5. * The order of delta fields does not matter.
  6. * </p>
  7. *
  8. * @param deltaFieldName delta field names
  9. * @deprecated It is recommended to set delta fields in {@code WorkUnit} instead of {@code Extract}.
  10. */
  11. @Deprecated
  12. public void setDeltaFields(String... deltaFieldName) {
  13. setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, Joiner.on(",").join(deltaFieldName));
  14. }

代码示例来源:origin: org.apache.gobblin/gobblin-api

  1. /**
  2. * Add more delta fields to the existing set of delta fields.
  3. *
  4. * @param deltaFieldName delta field names
  5. * @deprecated It is recommended to add delta fields in {@code WorkUnit} instead of {@code Extract}.
  6. */
  7. @Deprecated
  8. public void addDeltaField(String... deltaFieldName) {
  9. StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, ""));
  10. Joiner.on(",").appendTo(sb, deltaFieldName);
  11. setProp(ConfigurationKeys.EXTRACT_DELTA_FIELDS_KEY, sb.toString());
  12. }

代码示例来源:origin: org.apache.gobblin/gobblin-api

  1. /**
  2. * Add more primary keys to the existing set of primary keys.
  3. *
  4. * @param primaryKeyFieldName primary key names
  5. * @deprecated @deprecated It is recommended to add primary keys in {@code WorkUnit} instead of {@code Extract}.
  6. */
  7. @Deprecated
  8. public void addPrimaryKey(String... primaryKeyFieldName) {
  9. StringBuilder sb = new StringBuilder(getProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, ""));
  10. Joiner.on(",").appendTo(sb, primaryKeyFieldName);
  11. setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY, sb.toString());
  12. }

代码示例来源:origin: org.apache.gobblin/gobblin-kafka-common

  1. extract.setProp(ConfigurationKeys.EXTRACT_IS_FULL_KEY, true);

相关文章