code: @Override
      protected KmeansDataSet getState(String baseKey, Long txId, int partitionIndex,
              boolean isSelfPartition) throws IOException
      {
          String targetKey = null;
  
          // 指定された条件のクラスタ状態を取得する。取得結果がnull、または不正だった場合はnullとして扱う。
          // 自分自身のパーティションと異なるパーティションの値を取得する場合、最新の状態値保存TransatctionIdを取得し用いる。
          if (isSelfPartition == true)
          {
              targetKey = Joiner.on("_").skipNulls().join(
                      Arrays.asList(baseKey, txId, partitionIndex));
          }
          else
          {
              String txIdKey = Joiner.on("_").skipNulls().join(Arrays.asList(baseKey, partitionIndex));
              Long anotherTxId = this.txIdCache.get(txIdKey);
              targetKey = Joiner.on("_").skipNulls().join(
                      Arrays.asList(baseKey, anotherTxId, partitionIndex));
          }
  
          KmeansDataSet targetValue = this.stateCache.get(targetKey);
          return targetValue;
      }
docs: {@inheritDoc}