code: @Override
      public void onExecute(StreamMessage input)
      {
          // データ保存前実行処理を実行
          onStoreBefore(input);
  
          K storeKey = null;
          try
          {
              storeKey = this.mapper.convertToKey(input);
          }
          catch (ConvertFailException ex)
          {
              String messageFormat = "Tuple convert to key failed. Trash tuple. : InputTuple={0}";
              String errorMessage = MessageFormat.format(messageFormat, input.toString());
              logger.warn(errorMessage, ex);
              return;
          }
  
          V storeValue = null;
          try
          {
              storeValue = this.mapper.convertToValue(input);
          }
          catch (ConvertFailException ex)
          {
              String messageFormat = "Tuple convert to value failed. Trash tuple. : InputTuple={0}";
              String errorMessage = MessageFormat.format(messageFormat, input.toString());
              logger.warn(errorMessage, ex);
              return;
          }
  
          try
          {
              this.cacheHelper.getCache().put(storeKey, storeValue);
          }
          catch (Exception ex)
          {
              String messageFormat = "Cache store failed. Trash tuple. : InputTuple={0}";
              String errorMessage = MessageFormat.format(messageFormat, input.toString());
              logger.warn(errorMessage, ex);
              return;
          }
  
          // データ保存後実行処理を実行
          onStoreAfter(input, storeKey, storeValue);
  
      }
docs: {@inheritDoc}