Segment extends MapTransformer<Segment> implements SegmentParams <Segment> { public Segment() { this(null); } Segment();  Segment(Params params);   }
@Test public void testSegment() throws Exception { Row[] rows = new Row[] { Row.of(1, "别人复习是查漏补缺") }; Table data = MLEnvironmentFactory.getDefault().createBatchTable(rows, new String[] {"id", "sentence"}); Table dataStream = MLEnvironmentFactory.getDefault().createStreamTable(rows, new String[] {"id", "sentence"}); Segment op = new Segment() .setSelectedCol("sentence") .setOutputCol("output"); Table res = op.transform(data); List <String> list = MLEnvironmentFactory.getDefault().getBatchTableEnvironment().toDataSet(res.select("output"), String.class) .collect(); Assert.assertEquals(list.toArray(new String[0]), new String[] {"别人 复习 是 查漏 补缺"}); res = op.transform(dataStream); DataStreamConversionUtil.fromTable(MLEnvironmentFactory.DEFAULT_ML_ENVIRONMENT_ID,res).print(); MLEnvironmentFactory.getDefault().getStreamExecutionEnvironment().execute(); }