public static ExecutionInfo convert()

in core/src/main/java/com/datastax/dse/driver/internal/core/graph/GraphExecutionInfoConverter.java [49:133]
71 lines of code
1 McCabe index (conditional complexity)

  public static ExecutionInfo convert(
      com.datastax.dse.driver.api.core.graph.GraphExecutionInfo graphExecutionInfo) {
    return new ExecutionInfo() {

      @NonNull
      @Override
      public Request getRequest() {
        return graphExecutionInfo.getStatement();
      }

      @NonNull
      @Override
      public Statement<?> getStatement() {
        throw new ClassCastException("GraphStatement cannot be cast to Statement");
      }

      @Nullable
      @Override
      public Node getCoordinator() {
        return graphExecutionInfo.getCoordinator();
      }

      @Override
      public int getSpeculativeExecutionCount() {
        return graphExecutionInfo.getSpeculativeExecutionCount();
      }

      @Override
      public int getSuccessfulExecutionIndex() {
        return graphExecutionInfo.getSuccessfulExecutionIndex();
      }

      @NonNull
      @Override
      public List<Entry<Node, Throwable>> getErrors() {
        return graphExecutionInfo.getErrors();
      }

      @Nullable
      @Override
      public ByteBuffer getPagingState() {
        return null;
      }

      @NonNull
      @Override
      public List<String> getWarnings() {
        return graphExecutionInfo.getWarnings();
      }

      @NonNull
      @Override
      public Map<String, ByteBuffer> getIncomingPayload() {
        return graphExecutionInfo.getIncomingPayload();
      }

      @Override
      public boolean isSchemaInAgreement() {
        return true;
      }

      @Nullable
      @Override
      public UUID getTracingId() {
        return null;
      }

      @NonNull
      @Override
      public CompletionStage<QueryTrace> getQueryTraceAsync() {
        return CompletableFutures.failedFuture(
            new IllegalStateException("Tracing was disabled for this request"));
      }

      @Override
      public int getResponseSizeInBytes() {
        return -1;
      }

      @Override
      public int getCompressedResponseSizeInBytes() {
        return -1;
      }
    };
  }