':param endpoint_data: A dict of partition data.'

def __init__(self, endpoint_data):

    if ('partitions' not in endpoint_data):
        raise ValueError('Missing    "partitions"    in    endpoint    data')
    self._endpoint_data = endpoint_data
