Hi,
the directed output via the split and select methods are indeed only
available in the DataStream API. Thus, in order to achieve the same with
the DataSet API, you would have to apply multiple filters, as you've
already written.
The result of the select call will only be sent to the same task
Sorry i think i misunderstand the issue. But it seams DataStream partition
the data by some field and when i select that field only one taskmanager
processing the data. I can achieve same result when i use filter.Below is
the code piece:
import org.apache.flink.api.java.io.TextInputFormat
import
