本文整理汇总了Python中tests.common.test_dimensions.create_single_exec_option_dimension函数的典型用法代码示例。如果您正苦于以下问题:Python create_single_exec_option_dimension函数的具体用法?Python create_single_exec_option_dimension怎么用?Python create_single_exec_option_dimension使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了create_single_exec_option_dimension函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: add_test_dimensions
def add_test_dimensions(cls):
super(TestComputeStats, cls).add_test_dimensions()
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension())
# Do not run these tests using all dimensions because the expected results
# are different for different file formats.
cls.ImpalaTestMatrix.add_dimension(
create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:apache,项目名称:incubator-impala,代码行数:7,代码来源:test_compute_stats.py
示例2: add_test_dimensions
def add_test_dimensions(cls):
super(TestHdfsCachingDdl, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
cls.TestMatrix.add_constraint(lambda v:\
v.get_value('table_format').file_format == 'text' and \
v.get_value('table_format').compression_codec == 'none')
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:7,代码来源:test_hdfs_caching.py
示例3: add_test_dimensions
def add_test_dimensions(cls):
super(TestHiddenFiles, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
# Only run in exhaustive mode on hdfs since this test takes a long time.
if cls.exploration_strategy() != 'exhaustive' and not IS_S3:
cls.TestMatrix.clear()
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:7,代码来源:test_hidden_files.py
示例4: add_test_dimensions
def add_test_dimensions(cls):
super(TestRefreshPartition, cls).add_test_dimensions()
# There is no reason to run these tests using all dimensions.
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension())
cls.ImpalaTestMatrix.add_dimension(
create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:michaelhkw,项目名称:Impala,代码行数:7,代码来源:test_refresh_partition.py
示例5: add_test_dimensions
def add_test_dimensions(cls):
super(TestMultipleFilesystems, cls).add_test_dimensions()
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension())
cls.ImpalaTestMatrix.add_constraint(lambda v:\
v.get_value('table_format').file_format == 'text' and \
v.get_value('table_format').compression_codec == 'none')
开发者ID:apache,项目名称:incubator-impala,代码行数:7,代码来源:test_multiple_filesystems.py
示例6: add_test_dimensions
def add_test_dimensions(cls):
super(TestCodegenMemLimit, cls).add_test_dimensions()
# Run with num_nodes=1 to avoid races between fragments allocating memory.
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension(
num_nodes=1, disable_codegen_rows_threshold=0))
# Only run the query for parquet
cls.ImpalaTestMatrix.add_constraint(
lambda v: v.get_value('table_format').file_format == 'parquet')
开发者ID:apache,项目名称:incubator-impala,代码行数:8,代码来源:test_query_mem_limit.py
示例7: add_test_dimensions
def add_test_dimensions(cls):
super(TestUnsupportedTableWriters, cls).add_test_dimensions()
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension())
# This class tests different formats, but doesn't use constraints.
# The constraint added below is only to make sure that the test file runs once.
cls.ImpalaTestMatrix.add_constraint(lambda v:
(v.get_value('table_format').file_format =='text' and
v.get_value('table_format').compression_codec == 'none'))
开发者ID:apache,项目名称:incubator-impala,代码行数:8,代码来源:test_compressed_formats.py
示例8: add_test_dimensions
def add_test_dimensions(cls):
super(TestCatalogServiceClient, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# There is no reason to run these tests using all dimensions.
cls.TestMatrix.add_constraint(lambda v:\
v.get_value('table_format').file_format == 'parquet' and\
v.get_value('table_format').compression_codec == 'none')
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:8,代码来源:test_catalog_service_client.py
示例9: add_test_dimensions
def add_test_dimensions(cls):
super(TestPartitioning, cls).add_test_dimensions()
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension())
# There is no reason to run these tests using all dimensions.
cls.ImpalaTestMatrix.add_constraint(lambda v:\
v.get_value('table_format').file_format == 'text' and\
v.get_value('table_format').compression_codec == 'none')
开发者ID:apache,项目名称:incubator-impala,代码行数:8,代码来源:test_partitioning.py
示例10: add_test_dimensions
def add_test_dimensions(cls):
super(TestUnmatchedSchema, cls).add_test_dimensions()
# TODO: Does it add anything to enumerate all the supported compression codecs
# for each table format?
cls.TestMatrix.add_dimension(cls.create_table_info_dimension("exhaustive"))
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# Avro has a more advanced schema evolution process which is covered in more depth
# in the test_avro_schema_evolution test suite.
cls.TestMatrix.add_constraint(lambda v: v.get_value("table_format").file_format != "avro")
开发者ID:nagyist,项目名称:Impala,代码行数:9,代码来源:test_scanners_all_table_formats.py
示例11: add_test_dimensions
def add_test_dimensions(cls):
super(TestUdfs, cls).add_test_dimensions()
# Without limiting the test suite to a single exec option, the tests will fail
# because the same test case may be executed in parallel with different exec option
# values leading to conflicting DDL ops.
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# There is no reason to run these tests using all dimensions.
cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:cchanning,项目名称:incubator-impala,代码行数:9,代码来源:test_udfs.py
示例12: add_test_dimensions
def add_test_dimensions(cls):
super(TestTableWriters, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# This class tests many formats, but doesn't use the contraints
# Each format is tested within one test file, we constrain to text/none
# as each test file only needs to be run once.
cls.TestMatrix.add_constraint(lambda v:
(v.get_value('table_format').file_format =='text' and
v.get_value('table_format').compression_codec == 'none'))
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:9,代码来源:test_compressed_formats.py
示例13: add_test_dimensions
def add_test_dimensions(cls):
super(TestTpchQuery, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# The tpch tests take a long time to execute so restrict the combinations they
# execute over.
# TODO: the planner tests are based on text and need this.
if cls.exploration_strategy() == 'core':
cls.TestMatrix.add_constraint(lambda v:\
v.get_value('table_format').file_format in ['text', 'parquet', 'kudu'])
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:10,代码来源:test_tpch_queries.py
示例14: add_test_dimensions
def add_test_dimensions(cls):
super(TestTpcdsInsert, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
cls.TestMatrix.add_constraint(lambda v:\
is_supported_insert_format(v.get_value('table_format')))
if cls.exploration_strategy() == 'core' and not pytest.config.option.table_formats:
# Don't run on core, unless the user explicitly wants to validate a specific table
# format. Each test vector takes > 30s to complete and it doesn't add much
# additional coverage on top of what's in the functional insert test suite
cls.TestMatrix.add_constraint(lambda v: False);
开发者ID:cchanning,项目名称:incubator-impala,代码行数:10,代码来源:test_tpcds_queries.py
示例15: add_test_dimensions
def add_test_dimensions(cls):
super(TestHmsIntegration, cls).add_test_dimensions()
if cls.exploration_strategy() != 'exhaustive':
pytest.skip("Should only run in exhaustive due to long execution time.")
# There is no reason to run these tests using all dimensions.
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
cls.TestMatrix.add_dimension(
create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:cchanning,项目名称:incubator-impala,代码行数:10,代码来源:test_hms_integration.py
示例16: add_test_dimensions
def add_test_dimensions(cls):
super(TestAdmissionController, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# There's no reason to test this on other file formats/compression codecs right now
cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
cls.TestMatrix.add_dimension(TestDimension("num_queries", *NUM_QUERIES))
cls.TestMatrix.add_dimension(TestDimension("round_robin_submission", *ROUND_ROBIN_SUBMISSION))
cls.TestMatrix.add_dimension(TestDimension("submission_delay_ms", *SUBMISSION_DELAY_MS))
if cls.exploration_strategy() == "core":
cls.TestMatrix.add_constraint(lambda v: v.get_value("submission_delay_ms") == 0)
cls.TestMatrix.add_constraint(lambda v: v.get_value("num_queries") == 30)
cls.TestMatrix.add_constraint(lambda v: v.get_value("round_robin_submission") == True)
开发者ID:hepip,项目名称:Impala,代码行数:15,代码来源:test_admission_controller.py
示例17: add_test_dimensions
def add_test_dimensions(cls):
super(TestAdmissionController, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
cls.TestMatrix.add_dimension(TestDimension('num_queries', *NUM_QUERIES))
cls.TestMatrix.add_dimension(
TestDimension('round_robin_submission', *ROUND_ROBIN_SUBMISSION))
# There's no reason to test this on other file formats/compression codecs right now
cls.TestMatrix.add_constraint(lambda v:\
v.get_value('table_format').file_format == 'text' and\
v.get_value('table_format').compression_codec == 'none')
cls.TestMatrix.add_dimension(
TestDimension('submission_delay_ms', *SUBMISSION_DELAY_MS))
if cls.exploration_strategy() == 'core':
cls.TestMatrix.add_constraint(lambda v: v.get_value('submission_delay_ms') == 0)
开发者ID:YasuoShinomiya,项目名称:Impala,代码行数:16,代码来源:test_admission_controller.py
示例18: add_test_dimensions
def add_test_dimensions(cls):
super(TestHdfsEncryption, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
PARTITIONED = [True, False]
# For 'core', just test loading from a directory that is encrypted.
KEY_LOAD_DIR = ["testkey1"]
KEY_TBL_DIR = [None]
if cls.exploration_strategy() == 'exhaustive':
KEY_LOAD_DIR = [None, "testkey1", "testkey2"]
KEY_TBL_DIR = [None, "testkey1", "testkey2"]
cls.TestMatrix.add_dimension(TestDimension('partitioned', *PARTITIONED))
cls.TestMatrix.add_dimension(TestDimension('key_load_dir', *KEY_LOAD_DIR))
cls.TestMatrix.add_dimension(TestDimension('key_tbl_dir', *KEY_TBL_DIR))
cls.TestMatrix.add_constraint(lambda v:\
v.get_value('key_load_dir') is not None or\
v.get_value('key_tbl_dir') is not None)
开发者ID:cchanning,项目名称:incubator-impala,代码行数:20,代码来源:test_hdfs_encryption.py
示例19: add_test_dimensions
def add_test_dimensions(cls):
super(TestAdmissionController, cls).add_test_dimensions()
cls.TestMatrix.add_dimension(create_single_exec_option_dimension())
# There's no reason to test this on other file formats/compression codecs right now
cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:ZhuChaoyu,项目名称:Impala,代码行数:5,代码来源:test_admission_controller.py
示例20: add_test_dimensions
def add_test_dimensions(cls):
super(TestScanMemLimit, cls).add_test_dimensions()
cls.ImpalaTestMatrix.add_dimension(create_single_exec_option_dimension())
cls.ImpalaTestMatrix.add_dimension(create_avro_snappy_dimension(cls.get_workload()))
开发者ID:timarmstrong,项目名称:incubator-impala,代码行数:4,代码来源:test_mem_usage_scaling.py
注:本文中的tests.common.test_dimensions.create_single_exec_option_dimension函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论