THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); FileSource<MyType> theSource = new ParquetFileSource("fs:///path/to/dir", AvroParquet.forSpecific(MyType.class)); DataStream<MyType> stream = env.continuousSource(theSource); DataStream<MyType> boundedStream = env.boundedSource(theSource); // this would be an option once we add bounded streams to the DataStream API BoundedDataStream<MyType> batch = env.boundedSource(theSource); |
...