def _in_split(ex, split_ids):
    if ((not split_ids) or (tf.compat.as_text(ex['id']) in split_ids)):
        beam.metrics.Metrics.counter(split, 'in-split').inc()
        return True
    return False
def _in_split(ex, split_ids):
    if ((not split_ids) or (tf.compat.as_text(ex['id']) in split_ids)):
        beam.metrics.Metrics.counter(split, 'in-split').inc()
        return True
    return False