@Test
public void testFitStreamTable() {

	Long id = MLEnvironmentFactory.getNewMLEnvironmentId();
	MLEnvironment env = MLEnvironmentFactory.get(id);
	DataStream<Integer> input = env.getStreamExecutionEnvironment().fromElements(1, 2, 3);
	Table table = env.getStreamTableEnvironment().fromDataStream(input);
	FakeTransFormer transFormer = new FakeTransFormer();
	transFormer.setMLEnvironmentId(id);
	transFormer.transform(env.getStreamTableEnvironment(), table);
	Assert.assertFalse(transFormer.batchTransformed);
	Assert.assertTrue(transFormer.streamTransformed);
}