apache_beam.runners.interactive.testing package

Subpackages

• apache_beam.runners.interactive.testing.integration package
  • Submodules
    • apache_beam.runners.interactive.testing.integration.notebook_executor module
      • NotebookExecutor
      • IFrameParser
    • apache_beam.runners.interactive.testing.integration.screen_diff module
      • ScreenDiffIntegrationTestEnvironment
      • should_skip()
      • BaseTestCase

Submodules

• apache_beam.runners.interactive.testing.mock_env module
  • isolated_env()
  • mock_create_cluster()
• apache_beam.runners.interactive.testing.mock_ipython module
  • mock_get_ipython()
• apache_beam.runners.interactive.testing.pipeline_assertion module
  • assert_pipeline_equal()
  • assert_pipeline_proto_equal()
  • assert_pipeline_proto_contain_top_level_transform()
  • assert_pipeline_proto_not_contain_top_level_transform()
• apache_beam.runners.interactive.testing.test_cache_manager module
  • InMemoryCache
    • InMemoryCache.exists()
    • InMemoryCache.read()
    • InMemoryCache.write()
    • InMemoryCache.save_pcoder()
    • InMemoryCache.load_pcoder()
    • InMemoryCache.cleanup()
    • InMemoryCache.clear()
    • InMemoryCache.source()
    • InMemoryCache.sink()
    • InMemoryCache.size()
  • NoopSink
    • NoopSink.expand()
  • FileRecordsBuilder
    • FileRecordsBuilder.add_element()
    • FileRecordsBuilder.advance_watermark()
    • FileRecordsBuilder.advance_processing_time()
    • FileRecordsBuilder.build()