Hello Beam dev, I'm working on a distributed data processing engine that supports Beam dataflow program, and investigating how to take split location into consideration when scheduling 'read' task for HDFS source.
Is there any way to get split location information from HadoopInputFormatBoundedSource, without using Java reflection? Since 'inputSplit' field in 'HadoopInputFormatBoundedSource' class is private one, I can see no way to access Hadoop split information other than using reflection. Thanks.