interface TableEnvironment {
	/** Get model from catalog path. */
    Model fromModelPath(String path);

	/** Construct model from model descriptor. */
    Model from(ModelDescriptor descriptor);
}

/**
 * Model object describe model resource definition and key functions to operate on model and table.
 */
interface Model {
	/** Return resolved model input schema. */
    ResolvedSchema getResolvedInputSchema();

	/** Return resolved model output schema. */
    ResolvedSchema getResolvedOutputSchema();

    /** Returns underlying logical representation of this model. */
    QueryOperation getQueryOperation();

    /*
	 * Predict function without runtime options.
     *
     * Will convert table, input columns to expression for call expression
     */
    Table predict(Table table, ColumnList inputColumns);

	/**
     * Predict function with runtime options. Options can include if it's async run and batch size, timeout etc.
	 */
    Table predict(Table table, ColumnList inputColumns, Map<String, String> options);

	/**
	 * Evaluate function without runtime options.
	 */
    Table evaluate(Table table, ColumnList labelColumn, ColumnList inputColumns);

	/**
	 * Evaluate function with runtime options.
	 */
    Table evaluate(Table table, ColumnList labelColumn, ColumnList inputColumns, Map<String, String> options);

    /*
     * Create ModelReferenceExpression to use Model as call argument.
     */
    ApiExpression asArgument(String name);
}

/*
 * Holds ModelSourceQueryOperation. Similar to TableRefereneExpression.
 */
public final class ModelReferenceExpression implements ResolvedExpression {
    private final String name;
    private final QueryOperation queryOperation;
}

/*
 * Holds resolved model. Similar to SourceQueryOperation.
 */
public class ModelSourceQueryOperation implements QueryOperation {
    private final ContextResolvedModel contextResolvedModel;
}

public interface QueryOperationVisitor<T> {
    T visit(BuiltinFunctionQueryOperation function);
}

class ColumnLists {
    public static ColumnList of(String... names) {
        return of(Arrays.asList(names);
    }
}

Model myModel = TableEnvironment.fromModelPath("my_model");
Table inputTable = TableEnvironment.from("input_table");
Table evalTable = TableEnvironment.from("evaluate_table");

Table prediction = myModel.predict(inputTable, ColumnList.of("input_col1", "input_col2"));
For(Row result : prediction.execute().collect()) {
	System.out.println(result);
}

Table evaluation = myModel.evaluate(evalTable, ColumnList.of("label_col"), ColumList.of("input_col1", "input_col2"));
For(Row result : evaluation.execute().collect()) {
	System.out.println(result);
}