Source code for cluster.data.data_node

from cluster.common.common_node import WorkFlowCommonNode

[docs]class DataNode(WorkFlowCommonNode):
    """

    """

[docs]    def run(self, conf_data):
        pass

    def _init_node_parm(self, node_id):
        pass

    def _set_progress_state(self):
        pass

[docs]    def load_data(self, node_id, parm = 'all'):
        pass

[docs]    def multi_load_data(self, node_id, parm = 'all'):
        pass