KPLRecordReader¶

class dragon.vm.dali.ops.KPLRecordReader(
  path,
  features,
  pipeline,
  shard_id=0,
  num_shards=1,
  random_shuffle=False,
  initial_fill=1024,
  **kwargs
)[source]¶

Read examples from the KPLRecord.

Examples:

class MyPipeline(dali.Pipeline):

    def __init__():
        super(MyPipeline, self).__init__()
        # Assume the we have the following data:
        # /data/root.data
        # /data/root.index
        # /data/root.meta
        self.reader = dali.ops.KPLRecordReader(
            path='/data'
            features=('image', 'label'),
            pipeline=self,
            # Shuffle locally in the next ``initial_fill`` examples
            # It turns to be weak with the decreasing of ``initial_fill``
            # and disabled if ``initial_fill`` is set to **1**
            random_shuffle=True,
            initial_fill=1024,
        )

    def iter_step(self):
        self.reader.feed_inputs()

    def define_graph(self):
        inputs = self.reader()