gql

query getRecipeDefs {
  getDataFlowRecipeDefinitions {
    name
    type
    inputs {
      ... on SingleDataFlowRecipeIO {
        name
      }
    }
    params {
      label
      name
      tooltip
      type
      dataType
      validations {
        operation
      }
      emittedFields {
        name
      }
      fieldParams {
        ... on DataFlowRecipeFileFieldParams {
          extentions
        }
      }
    }
  }
}

query getGraphNotebookURL($graphID: ID!) {
  getGraphNotebookURL(id: $graphID)
}

query getGraph($graphID: ID!) {
  getDataFlowGraph(id: $graphID) {
    result {
      id
      recipes {
        id
        name
        inputs {
          sourceOutputName
          source {
            id
          }
        }
        outputs {
          id
          outputName
          # asyncResultSet {
          #   loadingStatus
          #   rows {
          #     data
          #   }
          # }
          # asyncResultSchema {
          #   columns {
          #     name
          #     type
          #   }
          # }
          # asyncResultStatistics {
          #   statistics {
          #     name
          #     value
          #   }
          # }
          # asyncResultHistogram {
          #   values {
          #     count
          #     bin {
          #       ... on DataFlowHistogramNumericBin {
          #         start
          #         end
          #       }
          #       ... on DataFlowHistogramCategoricalBin {
          #         key
          #       }
          #     }
          #   }
          # }
        }
      }
    }
  }
}

query getGraphRecipes($graphID: ID!){
  getDataFlowGraph(id: $graphID) {
    result {
      recipes {
        type
        id
      }
    }
  }
}

mutation createGraph {
  createGraph {
    result {
      id
    }
  }
}

mutation addReadRecipe1($graphID: ID!) {
  addRecipe(input: {graphID: $graphID, name: "reader", type: "spark.read_incorta", inputs: [], params: [{key: "readTableName", value: "Demo.SINTS"}]}) {
    result {
      id
      recipes {
        inputs {
          source {
            id
          }
          sourceOutputName
        }
        id
        type
        outputs {
          id
        }
      }
    }
  }
}

mutation addReadRecipe2($graphID: ID!) {
  addRecipe(input: {graphID: $graphID, name: "reader2", type: "spark.read_incorta", inputs: [], params: [{key: "readTableName", value: "Demo.MINTS"}]}) {
    result {
      id
      recipes {
        inputs {
          source {
            id
          }
          sourceOutputName
        }
        id
        type
        outputs {
          id
        }
      }
    }
  }
}


mutation addJoinRecipe(
  $graphID: ID!
  $sourceRecipeID1:ID!
  $sourceRecipeID2:ID!
) {
  addRecipe(input: {graphID: $graphID, name: "joiner2", type: "spark.join",
    inputs: [
    {sourceRecipeID:$sourceRecipeID1, sourceOutputName:"0"},
    {sourceRecipeID:$sourceRecipeID2, sourceOutputName:"0"}
  ],
    params: [{key: "expressions", value: "reader.id == reader2.id2"}, {key:"join_type", value:"inner"}]}) {
    result {
      id
      recipes {
        inputs {
          source {
            id
          }
          sourceOutputName
        }
        id
        type
        outputs {
          id
        }
      }
    }
  }
}

mutation addSaveRecipe(
  $graphID: ID!
	$recipeID:ID!
) {
  addRecipe(input: {graphID: $graphID, name: "saver", type: "spark.save",
    inputs: [
    {
      sourceRecipeID: $recipeID,
      sourceOutputName:"0"
    }
  ],
    params: []}) {
    result {
      id
      recipes {
        inputs {
          source {
            id
          }
          sourceOutputName
        }
        id
        type
        outputs {
          id
        }
      }
    }
  }
}

mutation deleteRecipe($recipeID: ID!) {
  deleteRecipe(id: $recipeID) {
    result {
      id
      recipes {
        type
				id
      }
    }
  }
}

query getRecipeResult($resultID: ID!) {
  getDataFlowRecipeResult(id: $resultID) {
    result {
      asyncResultSet {
        rows {
          data
        }
      }
      asyncResultSchema {
        columns {
          name
          type
        }
      }
      asyncResultHistogram {
        values {
          count
          bin {
            ... on DataFlowHistogramNumericBin {
              start
              end
            }
            ... on DataFlowHistogramCategoricalBin {
              key
            }
          }
        }
      }
    }
  }
}