create temporary function sb_j as 'com.test.SubFunction';


CREATE TABLE sourceTable (
    id int,
    java_c string
) WITH (
  'connector' = 'datagen'
);

CREATE  TABLE sinkTable
WITH (
    'connector' = 'print'
)
LIKE sourceTable (EXCLUDING ALL);


insert into sinkTable select id,sb_j(java_c) from sourceTable;
