Dear Jay,
1 - a) To use Flink Streaming all you need to do is to have it as a
dependency as described in the documentation. [1] This would build it
against the last snapshot that we have deployed which is updated on every
successful continuous integration build (typically multiple times a day).
If
Hi flink.
I've been attempting to build a flink-streaming application using the
0.10-SNAPSHOT from head.
I notice that flink-streaming is hidden under "flink-staging"
1) What is the right way to build a flink-streaming app against head, and
what is the purpose of the flink-staging directory?
You need to do something like this:
public class YourInputFormat extends FileInputFormat {
private boolean objectRead;
@Override
public FileInputSplit[] createInputSplits(int minNumSplits) {
// Create one FileInputSplit for each file you want to read.
// Check FileInputForma
