Adds an SdkHarnessOption that controls whether logging is redirected through the FnApi (#33418)
* Add an SdkHarnessOption that controls whether logging is redirected through the FnApi logging service. Redirection through the logging service is enabled by default. * Add an SdkHarnessOption that controls whether logging is redirected through the FnApi logging service. Redirection through the FnApi is enabled by default. * include license in new files * fix ManagedChannel dep * fix invalid conversions * fix missing imports * fix type mismatch * fix up tests * continue to use anyOf when logViaFnApi is enabled * More comments on the new SdkHarnessOption. DataflowRunner.run() forces the option to 'enabled'.
显示
- runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java 3 个添加, 0 个删除...java/org/apache/beam/runners/dataflow/DataflowRunner.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/options/SdkHarnessOptions.java 10 个添加, 0 个删除...n/java/org/apache/beam/sdk/options/SdkHarnessOptions.java
- sdks/java/harness/jmh/src/main/java/org/apache/beam/fn/harness/jmh/logging/BeamFnLoggingClientBenchmark.java 4 个添加, 2 个删除.../fn/harness/jmh/logging/BeamFnLoggingClientBenchmark.java
- sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java 10 个添加, 4 个删除...s/src/main/java/org/apache/beam/fn/harness/FnHarness.java
- sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java 3 个添加, 2 个删除...g/apache/beam/fn/harness/logging/BeamFnLoggingClient.java
- sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/LoggingClient.java 25 个添加, 0 个删除...ava/org/apache/beam/fn/harness/logging/LoggingClient.java
- sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/LoggingClientFactory.java 59 个添加, 0 个删除.../apache/beam/fn/harness/logging/LoggingClientFactory.java
- sdks/java/harness/src/test/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistryTest.java 4 个添加, 3 个删除...beam/fn/harness/data/PCollectionConsumerRegistryTest.java
加载中