tft_beam.analyzer_cache.DatasetKey

A key for a dataset used for analysis.

tft_beam.analyzer_cache.DatasetKey(
    dataset_key: Union[str, object], is_cached: bool = True
) -> 'DatasetKey'

key A namedtuple alias for field number 0
is_cached A namedtuple alias for field number 1

Methods

is_flattened_dataset_key

View source

is_flattened_dataset_key() -> bool

non_cacheable

View source

non_cacheable() -> 'DatasetKey'

Creates a non cacheable dataset key, for which no cache will be produced.