Apply to speak at TensorFlow World. Deadline April 23rd. Propose talk

tft.QuantilesCombiner

Class QuantilesCombiner

Computes quantiles on the PCollection.

This implementation is based on go/squawd. For additional details on the algorithm, such as streaming and summary, see also http://web.cs.ucla.edu/~weiwang/paper/SSDBM07_2.pdf

__init__

__init__(
    num_quantiles,
    epsilon,
    bucket_numpy_dtype,
    always_return_num_quantiles=False,
    has_weights=False,
    output_shape=None,
    include_max_and_min=False
)

Properties

accumulator_coder

Methods

add_input

add_input(
    summary,
    next_input
)

create_accumulator

create_accumulator()

extract_output

extract_output(summary)

initialize_local_state

initialize_local_state(tf_config=None)

Called by the CombineFnWrapper's init method.

This can be used to set non-pickleable local state. It is used in conjunction with overriding reduce so this state is not pickled. This method must be called prior to any other method.

Args:

  • tf_config: (optional) A tf.ConfigProto

merge_accumulators

merge_accumulators(summaries)

output_tensor_infos

output_tensor_infos()