Add runner logs

googleapis · Jan 6, 2025 · 8398f1d · 8398f1d
1 parent 3d65bca
commit 8398f1d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AbstractReadContext.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AbstractReadContext.java
@@ -924,6 +924,7 @@ ResultSet readInternalWithOptions(
       Iterable<String> columns,
       final Options readOptions,
       ByteString partitionToken) {
+    System.out.println("readInternalWithOptions");
     beforeReadOrQuery();
     final ReadRequest.Builder builder =
         ReadRequest.newBuilder()
@@ -991,6 +992,7 @@ CloseableIterator<PartialResultSet> startStream(
                     getTransactionChannelHint(),
                     isRouteToLeader());
             session.markUsed(clock.instant());
+            System.out.println("startStream");
             stream.setCall(call, /* withBeginTransaction = */ builder.getTransaction().hasBegin());
             call.request(prefetchChunks);
             return stream;

diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/ResumableStreamIterator.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/ResumableStreamIterator.java
@@ -325,6 +325,7 @@ private void startGrpcStreaming() {
       try (IScope scope = tracer.withSpan(span)) {
         // When start a new stream set the Span as current to make the gRPC Span a child of
         // this Span.
+        System.out.println("startGrpcStreaming");
         stream = checkNotNull(startStream(resumeToken, streamMessageListener));
       }
     }