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.

Reply via email to