volatile_data_operation_param.py 1.1 KB

123456789101112131415161718192021222324252627282930
  1. # Copyright Materialize, Inc. and contributors. All rights reserved.
  2. #
  3. # Use of this software is governed by the Business Source License
  4. # included in the LICENSE file at the root of this repository.
  5. #
  6. # As of the Change Date specified in that file, in accordance with
  7. # the Business Source License, use of this software will be governed
  8. # by the Apache License, Version 2.0.
  9. from materialize.output_consistency.data_type.data_type_category import DataTypeCategory
  10. from materialize.output_consistency.expression.expression import Expression
  11. from materialize.output_consistency.generators.arg_context import ArgContext
  12. from materialize.output_consistency.operation.operation_param import OperationParam
  13. from materialize.output_consistency.selection.randomized_picker import RandomizedPicker
  14. class VolatileDataOperationParam(OperationParam):
  15. def __init__(
  16. self,
  17. type_category: DataTypeCategory,
  18. optional: bool = False,
  19. ):
  20. super().__init__(type_category, optional)
  21. def generate_expression(
  22. self, arg_context: ArgContext, randomized_picker: RandomizedPicker
  23. ) -> Expression:
  24. raise NotImplementedError