I am running a query against two topics and calculating the results. In the main class:

tableEnv.createTemporaryView("tbl1", stream1);
tableEnv.createTemporaryView("tbl2", stream2);
String data_query = "select ....";
Table raw_table = tableEnv.sqlQuery(data_query);
DataStream<Row> mystream = tableEnv.toDataStream(raw_table);
mystream.process(new DataProcessor()).setParallelism(4);

In ProcessFucntion class:

public class DataProcessor extends ProcessFunction<Row, List<double[][]>> {
public void processElement(Row row, ProcessFunction<Row, List<double[][]>>.Context context, Collector<List<double[][]>> collector) throws Exception {
        int id = Integer.parseInt("" + row.getField(0));
        String data1 = ((String) (row.getField(1)));
        String data2 = ((String) (row.getField(2)));
double[][] results = DataUtils.compute(id, data1, data2);
}

My questions: 1. How to send the results to the output? 2. How to access the output from the main file?