@@ -0,0 +1,148 @@
+package io.rodeo.chute;%0A%0Apublic interface StreamProcessor %7B%0A%09public void process(TableSchema schema, Row oldRow, Row newRow, StreamPosition pos);%0A%7D%0A

Add StreamProcessor implementation