We have a bunch of TODOs to infer the channelId and to add them in we shall need to infer the channelId from both SpannerRpc.Option.CHANNEL_HINT and spanner.getOptions().getNumChannels() like we do here
|
int getChannel() { |
|
Long channelHint = (Long) delegate.getOptions().get(SpannerRpc.Option.CHANNEL_HINT); |
|
return channelHint == null |
|
? 0 |
|
: (int) (channelHint % sessionClient.getSpanner().getOptions().getNumChannels()); |
|
} |
Please assign this issue to me.