Method __init__

tensorpack/dataflow/parallel.py:482–484

(self, ds, socket="/tmp/plasma")

    Experimental.
    """
    def __init__(self, ds, socket="/tmp/plasma"):
        self._socket = socket
        super(PlasmaPutData, self).__init__(ds)

    def reset_state(self):
        super(PlasmaPutData, self).reset_state()