This is an automated email from the ASF dual-hosted git repository.
boyuanz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 8de3288 [BEAM-10925] Add interface for SQL Java scalar UDF. (#13305)
new 554d254 Track transform processing thread in Java SDK harness and set log entry
transform id field.
new a6ba301 Add javadoc
new 23b2007 Add tracking to other ProcessElement methods
new 945e794 Use LoadingCache instead of ConcurrentHashMap to limit the size for thread
tracker
new 857d41f Address comment
new c8d9d1d Fix checkstyle
new 6869dfa Merge pull request #13533 from [BEAM-11474] Track transform processing thread
in Java SDK harness and set log entry field
The 30000 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 27 ++++++++++++
.../harness/TransformProcessingThreadTracker.java | 49 ++++++++++++++++++++++
.../fn/harness/logging/BeamFnLoggingClient.java | 8 ++++
3 files changed, 84 insertions(+)
create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/TransformProcessingThreadTracker.java
|