in ingest/src/main/java/com/microsoft/azure/kusto/ingest/result/IngestionStatus.java [213:255]
public static IngestionStatus fromEntity(TableEntity tableEntity) {
IngestionStatus ingestionStatus = new IngestionStatus();
Object ingestionSourceId = tableEntity.getProperty("IngestionSourceId");
ingestionStatus.setIngestionSourceId(ingestionSourceId == null ? null : (UUID) ingestionSourceId);
ingestionStatus.setDatabase((String) tableEntity.getProperty("Database"));
ingestionStatus.setTable((String) tableEntity.getProperty("Table"));
Object operationId = tableEntity.getProperty("OperationId");
ingestionStatus.setOperationId(ingestionSourceId == null ? null : (UUID) operationId);
Object status = tableEntity.getProperty("Status");
if (status instanceof String) {
ingestionStatus.setStatus((String) status);
} else {
ingestionStatus.setStatus((OperationStatus) status);
}
Object activityId = tableEntity.getProperty("ActivityId");
ingestionStatus.setActivityId(ingestionSourceId == null ? null : (UUID) activityId);
ingestionStatus.setFailureStatus((String) tableEntity.getProperty("FailureStatus"));
Object originatesFromUpdatePolicy = tableEntity.getProperty("OriginatesFromUpdatePolicy");
ingestionStatus.setOriginatesFromUpdatePolicy(originatesFromUpdatePolicy != null && (boolean) originatesFromUpdatePolicy);
ingestionStatus.setIngestionSourcePath((String) tableEntity.getProperty("IngestionSourcePath"));
Object errorCode = tableEntity.getProperty("ErrorCode");
if (errorCode != null) {
ingestionStatus.setErrorCode((String) errorCode);
}
ingestionStatus.setDetails((String) tableEntity.getProperty("Details"));
Object updatedOn = tableEntity.getProperty("UpdatedOn");
if (updatedOn instanceof OffsetDateTime) {
ingestionStatus.setUpdatedOn(((OffsetDateTime) updatedOn).toInstant());
} else {
ingestionStatus.setUpdatedOn((Instant) updatedOn);
}
return ingestionStatus;
}