Major Description
Right now "insert into" from the samza sql is parsed out and handled differently than other sql operators like projections, filtering and such. It would be ideal if insert into is converted into an equivalent calcite relational Node which is then converted into sendTo operator of samza stream graph.