• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Python test_dimensions.create_uncompressed_text_dimension函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中tests.common.test_dimensions.create_uncompressed_text_dimension函数的典型用法代码示例。如果您正苦于以下问题:Python create_uncompressed_text_dimension函数的具体用法?Python create_uncompressed_text_dimension怎么用?Python create_uncompressed_text_dimension使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了create_uncompressed_text_dimension函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: add_test_dimensions

  def add_test_dimensions(cls):
    super(TestKuduMemLimits, cls).add_test_dimensions()

    # add mem_limit as a test dimension.
    new_dimension = TestDimension('mem_limit', *TestKuduMemLimits.TEST_LIMITS)
    cls.TestMatrix.add_dimension(new_dimension)
    cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:mbrukman,项目名称:apache-impala,代码行数:7,代码来源:test_kudu.py


示例2: add_test_dimensions

 def add_test_dimensions(cls):
   super(TestComputeStats, cls).add_test_dimensions()
   cls.TestMatrix.add_dimension(create_exec_option_dimension(
     disable_codegen_options=[False], exec_single_node_option=[100]))
   # Do not run these tests using all dimensions because the expected results
   # are different for different file formats.
   cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:ibmsoe,项目名称:ImpalaPPC,代码行数:7,代码来源:test_compute_stats.py


示例3: add_test_dimensions

 def add_test_dimensions(cls):
   super(TestInsertQueries, cls).add_test_dimensions()
   # Fix the exec_option vector to have a single value. This is needed should we decide
   # to run the insert tests in parallel (otherwise there will be two tests inserting
   # into the same table at the same time for the same file format).
   # TODO: When we do decide to run these tests in parallel we could create unique temp
   # tables for each test case to resolve the concurrency problems.
   if cls.exploration_strategy() == 'core':
     cls.TestMatrix.add_dimension(create_exec_option_dimension(
         cluster_sizes=[0], disable_codegen_options=[False], batch_sizes=[0],
         sync_ddl=[0]))
     cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
   else:
     cls.TestMatrix.add_dimension(create_exec_option_dimension(
         cluster_sizes=[0], disable_codegen_options=[False], batch_sizes=[0, 1, 16],
         sync_ddl=[0, 1]))
     cls.TestMatrix.add_dimension(TestDimension("compression_codec", *PARQUET_CODECS));
     # Insert is currently only supported for text and parquet
     # For parquet, we want to iterate through all the compression codecs
     # TODO: each column in parquet can have a different codec.  We could
     # test all the codecs in one table/file with some additional flags.
     cls.TestMatrix.add_constraint(lambda v:\
         v.get_value('table_format').file_format == 'parquet' or \
           (v.get_value('table_format').file_format == 'text' and \
           v.get_value('compression_codec') == 'none'))
     cls.TestMatrix.add_constraint(lambda v:\
         v.get_value('table_format').compression_codec == 'none')
     # Only test other batch sizes for uncompressed parquet to keep the execution time
     # within reasonable bounds.
     cls.TestMatrix.add_constraint(lambda v:\
         v.get_value('exec_option')['batch_size'] == 0 or \
           (v.get_value('table_format').file_format == 'parquet' and \
           v.get_value('compression_codec') == 'none'))
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:33,代码来源:test_insert.py


示例4: 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


示例5: 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


示例6: 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


示例7: add_test_dimensions

 def add_test_dimensions(cls):
   super(TestUdfExecution, cls).add_test_dimensions()
   cls.TestMatrix.add_dimension(
       create_exec_option_dimension_from_dict({"disable_codegen" : [False, True],
         "exec_single_node_rows_threshold" : [0,100],
         "enable_expr_rewrites" : [False, True]}))
   # There is no reason to run these tests using all dimensions.
   cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:8,代码来源:test_udfs.py


示例8: add_test_dimensions

  def add_test_dimensions(cls):
    super(TestAggregationQueries, cls).add_test_dimensions()

    cls.TestMatrix.add_dimension(
      create_exec_option_dimension(disable_codegen_options=[False, True]))

    if cls.exploration_strategy() == 'core':
      cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:cloudera,项目名称:recordservice,代码行数:8,代码来源:test_aggregation.py


示例9: add_test_dimensions

 def add_test_dimensions(cls):
   super(TestShowCreateTable, cls).add_test_dimensions()
   # don't use any exec options, running exactly once is fine
   cls.TestMatrix.clear_dimension('exec_option')
   # There is no reason to run these tests using all dimensions.
   cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
   cls.TestMatrix.add_constraint(lambda v:
       v.get_value('table_format').file_format == 'text' and
       v.get_value('table_format').compression_codec == 'none')
开发者ID:cchanning,项目名称:incubator-impala,代码行数:9,代码来源:test_show_create_table.py


示例10: 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


示例11: add_test_dimensions

  def add_test_dimensions(cls):
    super(TestViewCompatibility, cls).add_test_dimensions()

    if cls.exploration_strategy() != 'exhaustive':
      pytest.skip("Should only run in exhaustive due to long execution time.")

    # don't use any exec options, running exactly once is fine
    cls.TestMatrix.clear_dimension('exec_option')
    # There is no reason to run these tests using all dimensions.
    cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:10,代码来源:test_views_compatibility.py


示例12: 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


示例13: add_test_dimensions

  def add_test_dimensions(cls):
    super(TestExprLimits, cls).add_test_dimensions()
    if cls.exploration_strategy() != 'exhaustive':
      # Ensure the test runs with codegen enabled and disabled, even when the
      # exploration strategy is not exhaustive.
      cls.TestMatrix.clear_dimension('exec_option')
      cls.TestMatrix.add_dimension(create_exec_option_dimension(
          cluster_sizes=[0], disable_codegen_options=[False, True], batch_sizes=[0]))

    # 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,代码行数:11,代码来源:test_exprs.py


示例14: add_test_dimensions

 def add_test_dimensions(cls):
   super(TestInsertQueriesWithPermutation, cls).add_test_dimensions()
   # Fix the exec_option vector to have a single value. This is needed should we decide
   # to run the insert tests in parallel (otherwise there will be two tests inserting
   # into the same table at the same time for the same file format).
   # TODO: When we do decide to run these tests in parallel we could create unique temp
   # tables for each test case to resolve the concurrency problems.
   # TODO: do we need to run with multiple file formats? This seems to be really
   # targeting FE behavior.
   cls.TestMatrix.add_dimension(create_exec_option_dimension(
       cluster_sizes=[0], disable_codegen_options=[False], batch_sizes=[0]))
   cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:12,代码来源:test_insert_permutation.py


示例15: add_test_dimensions

  def add_test_dimensions(cls):
    super(TestMetadataQueryStatements, cls).add_test_dimensions()
    sync_ddl_opts = [0, 1]
    if cls.exploration_strategy() != 'exhaustive':
      # Cut down on test runtime by only running with SYNC_DDL=0
      sync_ddl_opts = [0]

    cls.TestMatrix.add_dimension(create_exec_option_dimension(
        cluster_sizes=ALL_NODES_ONLY,
        disable_codegen_options=[False],
        batch_sizes=[0],
        sync_ddl=sync_ddl_opts))
    cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:13,代码来源:test_metadata_query_statements.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(TestDdlBase, cls).add_test_dimensions()
    sync_ddl_opts = [0, 1]
    if cls.exploration_strategy() != 'exhaustive':
      # Only run with sync_ddl on exhaustive since it increases test runtime.
      sync_ddl_opts = [0]

    cls.TestMatrix.add_dimension(create_exec_option_dimension(
        cluster_sizes=ALL_NODES_ONLY,
        disable_codegen_options=[False],
        batch_sizes=[0],
        sync_ddl=sync_ddl_opts))

    # 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,代码行数:15,代码来源:test_ddl_base.py


示例18: add_test_dimensions

  def add_test_dimensions(cls):
    super(TestQueryMemLimit, cls).add_test_dimensions()
    # Only run the query for text
    cls.TestMatrix.add_dimension(create_uncompressed_text_dimension(cls.get_workload()))

    # add mem_limit as a test dimension.
    if cls.exploration_strategy() == 'core':
      cls.TestMatrix.add_dimension(\
          TestDimension('mem_limit', *TestQueryMemLimit.MEM_LIMITS_CORE))
    else:
      cls.TestMatrix.add_dimension(\
          TestDimension('mem_limit', *TestQueryMemLimit.MEM_LIMITS))

    # Make query a test dimension so we can support more queries.
    cls.TestMatrix.add_dimension(TestDimension('query', *TestQueryMemLimit.QUERIES))
    # This query takes a very long time to finish with a bound on the batch_size.
    # Remove the bound on the batch size.
    cls.TestMatrix.add_constraint(lambda v: v.get_value('exec_option')['batch_size'] == 0)
开发者ID:attilajeges,项目名称:incubator-impala,代码行数:18,代码来源:test_query_mem_limit.py


示例19: 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


示例20: add_test_dimensions

 def add_test_dimensions(cls):
   super(TestResultVerifier, cls).add_test_dimensions()
   cls.ImpalaTestMatrix.add_dimension(
       create_uncompressed_text_dimension(cls.get_workload()))
开发者ID:apache,项目名称:incubator-impala,代码行数:4,代码来源:test_result_verifier.py



注:本文中的tests.common.test_dimensions.create_uncompressed_text_dimension函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python utils.capture_out函数代码示例发布时间:2022-05-27
下一篇:
Python test_dimensions.create_single_exec_option_dimension函数代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap