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

Extract.getTable介绍

[英]Get the name of the table.
[中]获取表的名称。

代码示例

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

@Override
public int hashCode() {
 return (this.getNamespace() + this.getTable() + this.getExtractId()).hashCode();
}

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

@Override
public boolean equals(Object object) {
 if (!(object instanceof Extract)) {
  return false;
 }
 Extract other = (Extract) object;
 return super.equals(other) && this.getNamespace().equals(other.getNamespace())
   && this.getTable().equals(other.getTable()) && this.getExtractId().equals(other.getExtractId());
}

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

/**
 * Get the writer output file path corresponding to this {@link Extract}.
 *
 * @return writer output file path corresponding to this {@link Extract}
 * @deprecated As {@code this.getIsFull} is deprecated.
 */
@Deprecated
public String getOutputFilePath() {
 return this.getNamespace().replaceAll("\\.", "/") + "/" + this.getTable() + "/" + this.getExtractId() + "_"
   + (this.getIsFull() ? "full" : "append");
}

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

@Override
public MessageType convertSchema(JsonArray inputSchema, WorkUnitState workUnit)
  throws SchemaConversionException {
 String fieldName = workUnit.getExtract().getTable();
 JsonSchema jsonSchema = new JsonSchema(inputSchema);
 jsonSchema.setColumnName(fieldName);
 recordConverter = new RecordConverter(jsonSchema, ROOT);
 return (MessageType) recordConverter.schema();
}

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

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

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

@Override
public Schema convertSchema(JsonArray schema, WorkUnitState workUnit)
  throws SchemaConversionException {
 try {
  JsonSchema jsonSchema = new JsonSchema(schema);
  jsonSchema.setColumnName(workUnit.getExtract().getTable());
  recordConverter = new RecordConverter(jsonSchema, workUnit, workUnit.getExtract().getNamespace());
 } catch (UnsupportedDateTypeException e) {
  throw new SchemaConversionException(e);
 }
 Schema recordSchema = recordConverter.schema();
 if (workUnit
   .getPropAsBoolean(CONVERTER_AVRO_NULLIFY_FIELDS_ENABLED, DEFAULT_CONVERTER_AVRO_NULLIFY_FIELDS_ENABLED)) {
  return this.generateSchemaWithNullifiedField(workUnit, recordSchema);
 }
 return recordSchema;
}

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

Extract extract = this.getExtract();
table.setNamespace(extract.getNamespace());
table.setName(extract.getTable());
if (extract.hasType()) {
 table.setType(TableTypeEnum.valueOf(extract.getType().name()));

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

@Override
public boolean equals(Object object) {
 if (!(object instanceof Extract)) {
  return false;
 }
 Extract other = (Extract) object;
 return super.equals(other) && this.getNamespace().equals(other.getNamespace())
   && this.getTable().equals(other.getTable()) && this.getExtractId().equals(other.getExtractId());
}

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

@Override
public int hashCode() {
 return (this.getNamespace() + this.getTable() + this.getExtractId()).hashCode();
}

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

/**
 * Get the writer output file path corresponding to this {@link Extract}.
 *
 * @return writer output file path corresponding to this {@link Extract}
 * @deprecated As {@code this.getIsFull} is deprecated.
 */
@Deprecated
public String getOutputFilePath() {
 return this.getNamespace().replaceAll("\\.", "/") + "/" + this.getTable() + "/" + this.getExtractId() + "_"
   + (this.getIsFull() ? "full" : "append");
}

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

@Override
public MessageType convertSchema(JsonArray inputSchema, WorkUnitState workUnit)
  throws SchemaConversionException {
 String fieldName = workUnit.getExtract().getTable();
 JsonSchema jsonSchema = new JsonSchema(inputSchema);
 jsonSchema.setColumnName(fieldName);
 recordConverter = new RecordConverter(jsonSchema, ROOT);
 return (MessageType) recordConverter.schema();
}

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

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

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

@Override
public Schema convertSchema(JsonArray schema, WorkUnitState workUnit)
  throws SchemaConversionException {
 try {
  JsonSchema jsonSchema = new JsonSchema(schema);
  jsonSchema.setColumnName(workUnit.getExtract().getTable());
  recordConverter = new RecordConverter(jsonSchema, workUnit, workUnit.getExtract().getNamespace());
 } catch (UnsupportedDateTypeException e) {
  throw new SchemaConversionException(e);
 }
 Schema recordSchema = recordConverter.schema();
 if (workUnit
   .getPropAsBoolean(CONVERTER_AVRO_NULLIFY_FIELDS_ENABLED, DEFAULT_CONVERTER_AVRO_NULLIFY_FIELDS_ENABLED)) {
  return this.generateSchemaWithNullifiedField(workUnit, recordSchema);
 }
 return recordSchema;
}

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

Extract extract = this.getExtract();
table.setNamespace(extract.getNamespace());
table.setName(extract.getTable());
if (extract.hasType()) {
 table.setType(TableTypeEnum.valueOf(extract.getType().name()));