如何在datastax驱动程序创建的RetryPolicy线程中保留上下文

import com.datastax.driver.core.policies.RetryPolicy;

public class MyRetryPolicy implements RetryPolicy {
    private static ThreadLocal<String> context = new ThreadLocal<>();

    public static void setContext(String value) {
        context.set(value);
    }

    public static String getContext() {
        return context.get();
    }

    public static void clearContext() {
        context.remove();
    }

    @Override
    public RetryDecision onReadTimeout(
            Statement statement,
            ConsistencyLevel cl,
            int requiredResponses,
            int receivedResponses,
            boolean dataRetrieved,
            int nbRetry) {
        String currentContext = getContext();
        // 在这里可以使用currentContext进行上下文相关的操作
        // ...

        return RetryDecision.retry(cl);
    }

    // 其他RetryPolicy方法的实现...
}

// 设置上下文值
MyRetryPolicy.setContext("myContext");

// 创建Cluster和Session
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
Session session = cluster.connect();

// 使用自定义RetryPolicy
session.execute("SELECT * FROM my_table").setRetryPolicy(new MyRetryPolicy());

// 清除上下文值
MyRetryPolicy.clearContext();