OTCPayerClassicalPlusTimeline.java

  1. package org.drip.sample.mporfixfloat;

  3. import java.util.ArrayList;
  4. import java.util.List;
  5. import java.util.Map;

  7. import org.drip.analytics.date.DateUtil;
  8. import org.drip.analytics.date.JulianDate;
  9. import org.drip.exposure.csatimeline.AndersenPykhtinSokolLag;
  10. import org.drip.exposure.csatimeline.LastFlowDates;
  11. import org.drip.exposure.evolver.EntityDynamicsContainer;
  12. import org.drip.exposure.evolver.LatentStateDynamicsContainer;
  13. import org.drip.exposure.evolver.LatentStateVertexContainer;
  14. import org.drip.exposure.evolver.PrimarySecurity;
  15. import org.drip.exposure.evolver.PrimarySecurityDynamicsContainer;
  16. import org.drip.exposure.evolver.TerminalLatentState;
  17. import org.drip.exposure.generator.FixFloatMPoR;
  18. import org.drip.exposure.mpor.PathVariationMarginTrajectoryEstimator;
  19. import org.drip.exposure.mpor.VariationMarginTradeVertexExposure;
  20. import org.drip.exposure.universe.LatentStateWeiner;
  21. import org.drip.exposure.universe.MarketPath;
  22. import org.drip.exposure.universe.MarketVertex;
  23. import org.drip.exposure.universe.MarketVertexGenerator;
  24. import org.drip.market.otc.FixedFloatSwapConvention;
  25. import org.drip.market.otc.IBORFixedFloatContainer;
  26. import org.drip.measure.crng.RandomNumberGenerator;
  27. import org.drip.measure.discrete.CorrelatedPathVertexDimension;
  28. import org.drip.measure.dynamics.DiffusionEvaluatorLinear;
  29. import org.drip.measure.dynamics.DiffusionEvaluatorLogarithmic;
  30. import org.drip.measure.dynamics.HazardJumpEvaluator;
  31. import org.drip.measure.process.DiffusionEvolver;
  32. import org.drip.measure.process.JumpDiffusionEvolver;
  33. import org.drip.numerical.common.FormatUtil;
  34. import org.drip.numerical.linearalgebra.Matrix;
  35. import org.drip.product.rates.FixFloatComponent;
  36. import org.drip.service.env.EnvManager;
  37. import org.drip.state.identifier.CSALabel;
  38. import org.drip.state.identifier.EntityFundingLabel;
  39. import org.drip.state.identifier.EntityHazardLabel;
  40. import org.drip.state.identifier.EntityRecoveryLabel;
  41. import org.drip.state.identifier.ForwardLabel;
  42. import org.drip.state.identifier.LatentStateLabel;
  43. import org.drip.state.identifier.OvernightLabel;

  45. /*
  46.  * -*- mode: java; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
  47.  */

  49. /*!
  50.  * Copyright (C) 2019 Lakshmi Krishnamurthy
  51.  * Copyright (C) 2018 Lakshmi Krishnamurthy
  52.  * 
  53.  *  This file is part of DROP, an open-source library targeting risk, transaction costs, exposure, margin
  54.  *      calculations, valuation adjustment, and portfolio construction within and across fixed income,
  55.  *      credit, commodity, equity, FX, and structured products.
  56.  *  
  57.  *      https://lakshmidrip.github.io/DROP/
  58.  *  
  59.  *  DROP is composed of three modules:
  60.  *  
  61.  *  - DROP Analytics Core - https://lakshmidrip.github.io/DROP-Analytics-Core/
  62.  *  - DROP Portfolio Core - https://lakshmidrip.github.io/DROP-Portfolio-Core/
  63.  *  - DROP Numerical Core - https://lakshmidrip.github.io/DROP-Numerical-Core/
  64.  * 
  65.  *  DROP Analytics Core implements libraries for the following:
  66.  *  - Fixed Income Analytics
  67.  *  - Asset Backed Analytics
  68.  *  - XVA Analytics
  69.  *  - Exposure and Margin Analytics
  70.  * 
  71.  *  DROP Portfolio Core implements libraries for the following:
  72.  *  - Asset Allocation Analytics
  73.  *  - Transaction Cost Analytics
  74.  * 
  75.  *  DROP Numerical Core implements libraries for the following:
  76.  *  - Statistical Learning
  77.  *  - Numerical Optimizer
  78.  *  - Spline Builder
  79.  *  - Algorithm Support
  80.  * 
  81.  *  Documentation for DROP is Spread Over:
  82.  * 
  83.  *  - Main                     => https://lakshmidrip.github.io/DROP/
  84.  *  - Wiki                     => https://github.com/lakshmiDRIP/DROP/wiki
  85.  *  - GitHub                   => https://github.com/lakshmiDRIP/DROP
  86.  *  - Repo Layout Taxonomy     => https://github.com/lakshmiDRIP/DROP/blob/master/Taxonomy.md
  87.  *  - Javadoc                  => https://lakshmidrip.github.io/DROP/Javadoc/index.html
  88.  *  - Technical Specifications => https://github.com/lakshmiDRIP/DROP/tree/master/Docs/Internal
  89.  *  - Release Versions         => https://lakshmidrip.github.io/DROP/version.html
  90.  *  - Community Credits        => https://lakshmidrip.github.io/DROP/credits.html
  91.  *  - Issues Catalog           => https://github.com/lakshmiDRIP/DROP/issues
  92.  *  - JUnit                    => https://lakshmidrip.github.io/DROP/junit/index.html
  93.  *  - Jacoco                   => https://lakshmidrip.github.io/DROP/jacoco/index.html
  94.  * 
  95.  *  Licensed under the Apache License, Version 2.0 (the "License");
  96.  *      you may not use this file except in compliance with the License.
  97.  *   
  98.  *  You may obtain a copy of the License at
  99.  *      http://www.apache.org/licenses/LICENSE-2.0
  100.  *  
  101.  *  Unless required by applicable law or agreed to in writing, software
  102.  *      distributed under the License is distributed on an "AS IS" BASIS,
  103.  *      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  104.  *  
  105.  *  See the License for the specific language governing permissions and
  106.  *      limitations under the License.
  107.  */

  109. /**
  110.  * <i>OTCPayerClassicalPlusTimeline</i> displays the MPoR-related Exposure Metrics Suite for the given OTC
  111.  * Payer Swap on a Daily Grid using the "Classical+" CSA Timeline of Andersen, Pykhtin, and Sokol (2017). The
  112.  * References are:
  113.  *  
  114.  * <br><br>
  115.  *  <ul>
  116.  *      <li>
  117.  *          Andersen, L. B. G., M. Pykhtin, and A. Sokol (2017a): Re-thinking Margin Period of Risk
  118.  *              https://papers.ssrn.com/sol3/papers.cfm?abstract_id=2902737 <b>eSSRN</b>
  119.  *      </li>
  120.  *      <li>
  121.  *          Albanese, C., and L. Andersen (2014): Accounting for OTC Derivatives: Funding Adjustments and the
  122.  *              Re-Hypothecation Option https://papers.ssrn.com/sol3/papers.cfm?abstract_id=2482955
  123.  *              <b>eSSRN</b>
  124.  *      </li>
  125.  *      <li>
  126.  *          Anfuso, F., D. Aziz, P. Giltinan, and K Loukopoulus (2017): A Sound Modeling and Back-testing
  127.  *              Framework for Forecasting Initial Margin Requirements
  128.  *              https://papers.ssrn.com/sol3/papers.cfm?abstract_id=2716279 <b>eSSRN</b>
  129.  *      </li>
  130.  *      <li>
  131.  *          Burgard, C., and M. Kjaer (2017): Derivatives Funding, Netting, and Accounting
  132.  *              https://papers.ssrn.com/sol3/papers.cfm?abstract_id=2534011 <b>eSSRN</b>
  133.  *      </li>
  134.  *      <li>
  135.  *          Piterbarg, V. (2010): Funding Beyond Discounting: Collateral Agreements and Derivatives Pricing
  136.  *              <i>Risk</i> <b>21 (2)</b> 97-102
  137.  *      </li>
  138.  *  </ul>
  139.  *  
  140.  * <br><br>
  141.  *  <ul>
  142.  *      <li><b>Module </b> = <a href = "https://github.com/lakshmiDRIP/DROP/tree/master/AnalyticsCore.md">Analytics Core Module</a></li>
  143.  *      <li><b>Library</b> = <a href = "https://github.com/lakshmiDRIP/DROP/tree/master/ExposureAnalyticsLibrary.md">Exposure Analytics Library</a></li>
  144.  *      <li><b>Project</b> = <a href = "https://github.com/lakshmiDRIP/DROP/tree/master/src/main/java/org/drip/sample/README.md">Sample</a></li>
  145.  *      <li><b>Package</b> = <a href = "https://github.com/lakshmiDRIP/DROP/tree/master/src/main/java/org/drip/sample/mporfixfloat/README.md">OTC Fix-Float MPoR Estimate</a></li>
  146.  *  </ul>
  147.  * <br><br>
  148.  * 
  149.  * @author Lakshmi Krishnamurthy
  150.  */

  152. public class OTCPayerClassicalPlusTimeline
  153. {

  155.     private static final FixFloatComponent OTCIRS (
  156.         final JulianDate spotDate,
  157.         final String currency,
  158.         final String maturityTenor,
  159.         final double coupon)
  160.     {
  161.         FixedFloatSwapConvention ffConv = IBORFixedFloatContainer.ConventionFromJurisdiction (
  162.             currency,
  163.             "ALL",
  164.             maturityTenor,
  165.             "MAIN"
  166.         );

  168.         return ffConv.createFixFloatComponent (
  169.             spotDate,
  170.             maturityTenor,
  171.             coupon,
  172.             0.,
  173.             1.
  174.         );
  175.     }

  177.     private static final PrimarySecurity OvernightReplicator (
  178.         final String currency,
  179.         final List<LatentStateLabel> latentStateLabelList)
  180.         throws Exception
  181.     {
  182.         double overnightReplicatorDrift = 0.0025;
  183.         double overnightReplicatorVolatility = 0.001;
  184.         double overnightReplicatorRepo = 0.0;

  186.         LatentStateLabel overnightLabel = OvernightLabel.Create (currency);

  188.         latentStateLabelList.add (overnightLabel);

  190.         return new PrimarySecurity (
  191.             currency + "_OVERNIGHT",
  192.             overnightLabel,
  193.             new DiffusionEvolver (
  194.                 DiffusionEvaluatorLogarithmic.Standard (
  195.                     overnightReplicatorDrift,
  196.                     overnightReplicatorVolatility
  197.                 )
  198.             ),
  199.             overnightReplicatorRepo
  200.         );
  201.     }

  203.     private static final PrimarySecurity CSAReplicator (
  204.         final String currency,
  205.         final List<LatentStateLabel> latentStateLabelList)
  206.         throws Exception
  207.     {
  208.         double csaReplicatorDrift = 0.01;
  209.         double csaReplicatorVolatility = 0.002;
  210.         double csaReplicatorRepo = 0.005;

  212.         LatentStateLabel csaLabel = CSALabel.ISDA (currency);

  214.         latentStateLabelList.add (csaLabel);

  216.         return new PrimarySecurity (
  217.             currency + "_CSA",
  218.             csaLabel,
  219.             new DiffusionEvolver (
  220.                 DiffusionEvaluatorLogarithmic.Standard (
  221.                     csaReplicatorDrift,
  222.                     csaReplicatorVolatility
  223.                 )
  224.             ),
  225.             csaReplicatorRepo
  226.         );
  227.     }

  229.     private static final PrimarySecurity DealerSeniorFundingReplicator (
  230.         final String currency,
  231.         final String dealer,
  232.         final List<LatentStateLabel> latentStateLabelList)
  233.         throws Exception
  234.     {
  235.         double dealerSeniorFundingReplicatorDrift = 0.03;
  236.         double dealerSeniorFundingReplicatorVolatility = 0.002;
  237.         double dealerSeniorFundingReplicatorRepo = 0.028;

  239.         LatentStateLabel dealerSeniorFundingLabel = EntityFundingLabel.Senior (
  240.             dealer,
  241.             currency
  242.         );

  244.         latentStateLabelList.add (dealerSeniorFundingLabel);

  246.         return new PrimarySecurity (
  247.             dealer + "_" + currency + "_SENIOR_ZERO",
  248.             dealerSeniorFundingLabel,
  249.             new JumpDiffusionEvolver (
  250.                 DiffusionEvaluatorLogarithmic.Standard (
  251.                     dealerSeniorFundingReplicatorDrift,
  252.                     dealerSeniorFundingReplicatorVolatility
  253.                 ),
  254.                 HazardJumpEvaluator.Standard (
  255.                     0.3,
  256.                     0.45
  257.                 )
  258.             ),
  259.             dealerSeniorFundingReplicatorRepo
  260.         );
  261.     }

  263.     private static final PrimarySecurity DealerSubordinateFundingReplicator (
  264.         final String currency,
  265.         final String dealer,
  266.         final List<LatentStateLabel> latentStateLabelList)
  267.         throws Exception
  268.     {
  269.         double dealerSubordinateFundingReplicatorDrift = 0.045;
  270.         double dealerSubordinateFundingReplicatorVolatility = 0.002;
  271.         double dealerSubordinateFundingReplicatorRepo = 0.028;

  273.         LatentStateLabel dealerSubordinateFundingLabel = EntityFundingLabel.Subordinate (
  274.             dealer,
  275.             currency
  276.         );

  278.         latentStateLabelList.add (dealerSubordinateFundingLabel);

  280.         return new PrimarySecurity (
  281.             dealer + "_" + currency + "_SUBORDINATE_ZERO",
  282.             dealerSubordinateFundingLabel,
  283.             new JumpDiffusionEvolver (
  284.                 DiffusionEvaluatorLogarithmic.Standard (
  285.                     dealerSubordinateFundingReplicatorDrift,
  286.                     dealerSubordinateFundingReplicatorVolatility
  287.                 ),
  288.                 HazardJumpEvaluator.Standard (
  289.                     0.3,
  290.                     0.25
  291.                 )
  292.             ),
  293.             dealerSubordinateFundingReplicatorRepo
  294.         );
  295.     }

  297.     private static final PrimarySecurity ClientFundingReplicator (
  298.         final String currency,
  299.         final String client,
  300.         final List<LatentStateLabel> latentStateLabelList)
  301.         throws Exception
  302.     {
  303.         double clientFundingReplicatorDrift = 0.03;
  304.         double clientFundingReplicatorVolatility = 0.003;
  305.         double clientFundingReplicatorRepo = 0.028;

  307.         LatentStateLabel clientFundingLabel = EntityFundingLabel.Senior (
  308.             client,
  309.             currency
  310.         );

  312.         latentStateLabelList.add (clientFundingLabel);

  314.         return new PrimarySecurity (
  315.             client + "_" + currency + "_SENIOR_ZERO",
  316.             clientFundingLabel,
  317.             new JumpDiffusionEvolver (
  318.                 DiffusionEvaluatorLogarithmic.Standard (
  319.                     clientFundingReplicatorDrift,
  320.                     clientFundingReplicatorVolatility
  321.                 ),
  322.                 HazardJumpEvaluator.Standard (
  323.                     0.5,
  324.                     0.30
  325.                 )
  326.             ),
  327.             clientFundingReplicatorRepo
  328.         );
  329.     }

  331.     private static final TerminalLatentState DealerHazard (
  332.         final String currency,
  333.         final String dealer,
  334.         final List<LatentStateLabel> latentStateLabelList)
  335.         throws Exception
  336.     {
  337.         double dealerHazardDrift = 0.0002;
  338.         double dealerHazardVolatility = 0.02;

  340.         LatentStateLabel dealerHazardLabel = EntityHazardLabel.Standard (
  341.             dealer,
  342.             currency
  343.         );

  345.         latentStateLabelList.add (dealerHazardLabel);

  347.         return new TerminalLatentState (
  348.             dealerHazardLabel,
  349.             new DiffusionEvolver (
  350.                 DiffusionEvaluatorLogarithmic.Standard (
  351.                     dealerHazardDrift,
  352.                     dealerHazardVolatility
  353.                 )
  354.             )
  355.         );
  356.     }

  358.     private static final TerminalLatentState DealerRecovery (
  359.         final String currency,
  360.         final String dealer,
  361.         final List<LatentStateLabel> latentStateLabelList)
  362.         throws Exception
  363.     {
  364.         double dealerRecoveryDrift = 0.0002;
  365.         double dealerRecoveryVolatility = 0.02;

  367.         LatentStateLabel dealerRecoveryLabel = EntityRecoveryLabel.Senior (
  368.             dealer,
  369.             currency
  370.         );

  372.         latentStateLabelList.add (dealerRecoveryLabel);

  374.         return new TerminalLatentState (
  375.             dealerRecoveryLabel,
  376.             new DiffusionEvolver (
  377.                 DiffusionEvaluatorLogarithmic.Standard (
  378.                     dealerRecoveryDrift,
  379.                     dealerRecoveryVolatility
  380.                 )
  381.             )
  382.         );
  383.     }

  385.     private static final TerminalLatentState ClientHazard (
  386.         final String currency,
  387.         final String client,
  388.         final List<LatentStateLabel> latentStateLabelList)
  389.         throws Exception
  390.     {
  391.         double clientHazardDrift = 0.0002;
  392.         double clientHazardVolatility = 0.02;

  394.         LatentStateLabel clientHazardLabel = EntityHazardLabel.Standard (
  395.             client,
  396.             currency
  397.         );

  399.         latentStateLabelList.add (clientHazardLabel);

  401.         return new TerminalLatentState (
  402.             clientHazardLabel,
  403.             new DiffusionEvolver (
  404.                 DiffusionEvaluatorLogarithmic.Standard (
  405.                     clientHazardDrift,
  406.                     clientHazardVolatility
  407.                 )
  408.             )
  409.         );
  410.     }

  412.     private static final TerminalLatentState ClientRecovery (
  413.         final String currency,
  414.         final String client,
  415.         final List<LatentStateLabel> latentStateLabelList)
  416.         throws Exception
  417.     {
  418.         double clientRecoveryDrift = 0.0002;
  419.         double clientRecoveryVolatility = 0.02;

  421.         LatentStateLabel clientRecoveryLabel = EntityRecoveryLabel.Senior (
  422.             client,
  423.             currency
  424.         );

  426.         latentStateLabelList.add (clientRecoveryLabel);

  428.         return new TerminalLatentState (
  429.             clientRecoveryLabel,
  430.             new DiffusionEvolver (
  431.                 DiffusionEvaluatorLogarithmic.Standard (
  432.                     clientRecoveryDrift,
  433.                     clientRecoveryVolatility
  434.                 )
  435.             )
  436.         );
  437.     }

  439.     private static final EntityDynamicsContainer EntityEvolver (
  440.         final String currency,
  441.         final String dealer,
  442.         final String client,
  443.         final List<LatentStateLabel> latentStateLabelList)
  444.         throws Exception
  445.     {
  446.         return new EntityDynamicsContainer (
  447.             DealerHazard (
  448.                 currency,
  449.                 dealer,
  450.                 latentStateLabelList
  451.             ),
  452.             DealerRecovery (
  453.                 currency,
  454.                 dealer,
  455.                 latentStateLabelList
  456.             ),
  457.             null,
  458.             ClientHazard (
  459.                 currency,
  460.                 client,
  461.                 latentStateLabelList
  462.             ),
  463.             ClientRecovery (
  464.                 currency,
  465.                 client,
  466.                 latentStateLabelList
  467.             )
  468.         );
  469.     }

  471.     private static final PrimarySecurityDynamicsContainer PrimarySecurityEvolver (
  472.         final String currency,
  473.         final String dealer,
  474.         final String client,
  475.         final List<LatentStateLabel> latentStateLabelList)
  476.         throws Exception
  477.     {
  478.         return new PrimarySecurityDynamicsContainer (
  479.             null,
  480.             OvernightReplicator (
  481.                 currency,
  482.                 latentStateLabelList
  483.             ),
  484.             CSAReplicator (
  485.                 currency,
  486.                 latentStateLabelList
  487.             ),
  488.             DealerSeniorFundingReplicator (
  489.                 currency,
  490.                 dealer,
  491.                 latentStateLabelList
  492.             ),
  493.             DealerSubordinateFundingReplicator (
  494.                 currency,
  495.                 dealer,
  496.                 latentStateLabelList
  497.             ),
  498.             ClientFundingReplicator (
  499.                 currency,
  500.                 client,
  501.                 latentStateLabelList
  502.             )
  503.         );
  504.     }

  506.     private static final LatentStateDynamicsContainer LatentStateEvolver (
  507.         final ForwardLabel forwardLabel,
  508.         final List<LatentStateLabel> latentStateLabelList)
  509.         throws Exception
  510.     {
  511.         double otcFixFloatNumeraireDrift = 0.0;
  512.         double otcFixFloatNumeraireVolatility = 0.25;

  514.         latentStateLabelList.add (forwardLabel);

  516.         LatentStateDynamicsContainer latentStateDynamicsContainer = new LatentStateDynamicsContainer();

  518.         latentStateDynamicsContainer.addForward (
  519.             new TerminalLatentState (
  520.                 forwardLabel,
  521.                 new DiffusionEvolver (
  522.                     DiffusionEvaluatorLinear.Standard (
  523.                         otcFixFloatNumeraireDrift,
  524.                         otcFixFloatNumeraireVolatility
  525.                     )
  526.                 )
  527.             )
  528.         );

  530.         return latentStateDynamicsContainer;
  531.     }

  533.     private static final MarketVertexGenerator ConstructMarketVertexGenerator (
  534.         final JulianDate spotDate,
  535.         final String exposureSamplingTenor,
  536.         final int exposureSamplingNodeCount,
  537.         final String currency,
  538.         final String dealer,
  539.         final String client,
  540.         final ForwardLabel forwardLabel,
  541.         final List<LatentStateLabel> latentStateLabelList)
  542.         throws Exception
  543.     {
  544.         JulianDate terminationDate = spotDate;
  545.         int[] eventVertexArray = new int[exposureSamplingNodeCount];

  547.         for (int i = 0; i < exposureSamplingNodeCount; ++i)
  548.         {
  549.             terminationDate = terminationDate.addTenor (exposureSamplingTenor);

  551.             eventVertexArray[i] = terminationDate.julian();
  552.         }

  554.         return new MarketVertexGenerator (
  555.             spotDate.julian(),
  556.             eventVertexArray,
  557.             EntityEvolver (
  558.                 currency,
  559.                 dealer,
  560.                 client,
  561.                 latentStateLabelList
  562.             ),
  563.             PrimarySecurityEvolver (
  564.                 currency,
  565.                 dealer,
  566.                 client,
  567.                 latentStateLabelList
  568.             ),
  569.             LatentStateEvolver (
  570.                 forwardLabel,
  571.                 latentStateLabelList
  572.             )
  573.         );
  574.     }

  576.     public static final void main (
  577.         final String[] args)
  578.         throws Exception
  579.     {
  580.         EnvManager.InitEnv ("");

  582.         JulianDate spotDate = DateUtil.CreateFromYMD (
  583.             2018,
  584.             DateUtil.APRIL,
  585.             19
  586.         );

  588.         int pathCount = 1000;
  589.         String exposurePeriodTenor = "1D";
  590.         int exposurePeriodCount = 390;
  591.         int vertexGenerationPeriodCount = exposurePeriodCount + 10;
  592.         String currency = "USD";
  593.         String dealer = "NOM";
  594.         String client = "SSGA";
  595.         double[][] correlationMatrix = new double[][]
  596.         {
  597.             {1.00, 0.00, 0.20, 0.15, 0.05, 0.00, 0.00, 0.00, 0.00, 0.00}, // #0  DEALER HAZARD
  598.             {0.00, 1.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00}, // #1  DEALER SENIOR RECOVERY
  599.             {0.20, 0.00, 1.00, 0.13, 0.25, 0.00, 0.00, 0.00, 0.00, 0.00}, // #2  CLIENT HAZARD
  600.             {0.15, 0.00, 0.13, 1.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00}, // #3  CLIENT RECOVERY
  601.             {0.05, 0.00, 0.25, 0.00, 1.00, 0.00, 0.00, 0.00, 0.00, 0.00}, // #4  OVERNIGHT REPLICATOR
  602.             {0.00, 0.00, 0.00, 0.00, 0.00, 1.00, 0.00, 0.00, 0.00, 0.00}, // #5  CSA REPLICATOR
  603.             {0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 1.00, 0.00, 0.00, 0.00}, // #6  DEALER SENIOR FUNDING REPLICATOR
  604.             {0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 1.00, 0.00, 0.00}, // #7  DEALER SUBORDINATE FUNDING REPLICATOR
  605.             {0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 1.00, 0.00}, // #8  CLIENT FUNDING REPLICATOR
  606.             {0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 0.00, 1.00}, // #9  FORWARD NUMERAIRE
  607.         };
  608.         String fixFloatMaturityTenor = "1Y";
  609.         double fixFloatCoupon = 0.02;
  610.         double fixFloatNotional = -1.e+06;

  612.         ForwardLabel forwardLabel = ForwardLabel.Create (
  613.             currency,
  614.             "3M"
  615.         );

  617.         List<LatentStateLabel> latentStateLabelList = new ArrayList<LatentStateLabel>();

  619.         MarketVertexGenerator marketVertexGenerator = ConstructMarketVertexGenerator (
  620.             spotDate,
  621.             exposurePeriodTenor,
  622.             vertexGenerationPeriodCount,
  623.             currency,
  624.             dealer,
  625.             client,
  626.             forwardLabel,
  627.             latentStateLabelList
  628.         );

  630.         LatentStateVertexContainer latentStateVertexContainer = new LatentStateVertexContainer();

  632.         latentStateVertexContainer.add (
  633.             ForwardLabel.Create (
  634.                 currency,
  635.                 "3M"
  636.             ),
  637.             0.02
  638.         );

  640.         MarketVertex initialMarketVertex = MarketVertex.Epochal (
  641.             spotDate,
  642.             1.000,              // dblOvernightNumeraireInitial
  643.             1.000,              // dblCSANumeraire
  644.             0.015,              // dblBankHazardRate
  645.             0.400,              // dblBankRecoveryRate
  646.             0.015 / (1 - 0.40), // dblBankFundingSpread
  647.             0.030,              // dblCounterPartyHazardRate
  648.             0.300,              // dblCounterPartyRecoveryRate
  649.             0.030 / (1 - 0.30), // dblCounterPartyFundingSpread
  650.             latentStateVertexContainer
  651.         );

  653.         AndersenPykhtinSokolLag andersenPykhtinSokolLag = AndersenPykhtinSokolLag.ClassicalPlus();

  655.         FixFloatComponent fixFloatComponent = OTCIRS (
  656.             spotDate,
  657.             currency,
  658.             fixFloatMaturityTenor,
  659.             fixFloatCoupon
  660.         );

  662.         FixFloatMPoR fixFloatMPoR = new FixFloatMPoR (
  663.             fixFloatComponent,
  664.             fixFloatNotional
  665.         );

  667.         CorrelatedPathVertexDimension correlatedPathVertexDimension = new CorrelatedPathVertexDimension (
  668.             new RandomNumberGenerator(),
  669.             correlationMatrix,
  670.             vertexGenerationPeriodCount,
  671.             1,
  672.             true,
  673.             null
  674.         );

  676.         JulianDate exposureDate = spotDate;
  677.         int[] exposureDateArray = new int[exposurePeriodCount + 1];
  678.         int[] variationMarginGapEndDateArray = new int[exposurePeriodCount + 1];
  679.         int[] variationMarginGapStartDateArray = new int[exposurePeriodCount + 1];
  680.         double[] tradePaymentGapArray = new double[exposurePeriodCount + 1];
  681.         double[] variationMarginGapArray = new double[exposurePeriodCount + 1];
  682.         double[] clientTradePaymentGapArray = new double[exposurePeriodCount + 1];
  683.         double[] collateralizedExposureArray = new double[exposurePeriodCount + 1];
  684.         double[] variationMarginPostingArray = new double[exposurePeriodCount + 1];
  685.         double[] variationMarginEstimateArray = new double[exposurePeriodCount + 1];
  686.         double[] clientDealerTradePaymentGapArray = new double[exposurePeriodCount + 1];
  687.         double[] collateralizedPositiveExposureArray = new double[exposurePeriodCount + 1];
  688.         int[] clientTradePaymentGapEndDateArray = new int[exposurePeriodCount + 1];
  689.         int[] clientTradePaymentGapStartDateArray = new int[exposurePeriodCount + 1];
  690.         int[] clientDealerTradePaymentGapEndDateArray = new int[exposurePeriodCount + 1];
  691.         int[] clientDealerTradePaymentGapStartDateArray = new int[exposurePeriodCount + 1];

  693.         for (int i = 0; i <= exposurePeriodCount; ++i)
  694.         {
  695.             tradePaymentGapArray[i] = 0.;
  696.             variationMarginGapArray[i] = 0.;
  697.             clientTradePaymentGapArray[i] = 0.;
  698.             collateralizedExposureArray[i] = 0.;
  699.             variationMarginPostingArray[i] = 0.;
  700.             variationMarginEstimateArray[i] = 0.;
  701.             clientDealerTradePaymentGapArray[i] = 0.;
  702.             collateralizedPositiveExposureArray[i] = 0.;

  704.             exposureDateArray[i] = exposureDate.julian();

  706.             exposureDate = exposureDate.addTenor (exposurePeriodTenor);
  707.         }

  709.         for (int pathIndex = 0; pathIndex < pathCount; ++pathIndex)
  710.         {
  711.             MarketPath marketPath = new MarketPath (
  712.                 marketVertexGenerator.marketVertex (
  713.                     initialMarketVertex,
  714.                     LatentStateWeiner.FromUnitRandom (
  715.                         latentStateLabelList,
  716.                         Matrix.Transpose (correlatedPathVertexDimension.straightPathVertexRd().flatform())
  717.                     )
  718.                 )
  719.             );

  721.             PathVariationMarginTrajectoryEstimator marginTradeFlowTrajectory =
  722.                 PathVariationMarginTrajectoryEstimator.Standard (
  723.                     exposureDateArray,
  724.                     currency,
  725.                     fixFloatMPoR,
  726.                     marketPath,
  727.                     andersenPykhtinSokolLag
  728.                 );

  730.             Map<Integer, VariationMarginTradeVertexExposure> mapMarginTradeFlowEntry =
  731.                 marginTradeFlowTrajectory.trajectory();

  733.             for (int i = 0; i <= exposurePeriodCount; ++i)
  734.             {
  735.                 VariationMarginTradeVertexExposure marginTradeFlowEntry = mapMarginTradeFlowEntry.get (exposureDateArray[i]);

  737.                 LastFlowDates lastFlowDates = marginTradeFlowEntry.lastFlowDates();

  739.                 tradePaymentGapArray[i] += marginTradeFlowEntry.tradePaymentGap();

  741.                 clientTradePaymentGapArray[i] += marginTradeFlowEntry.clientTradePaymentGap();

  743.                 clientDealerTradePaymentGapArray[i] += marginTradeFlowEntry.clientDealerTradePaymentGap();

  745.                 collateralizedExposureArray[i] += marginTradeFlowEntry.collateralizedExposure();

  747.                 collateralizedPositiveExposureArray[i] += marginTradeFlowEntry.collateralizedPositiveExposure();

  749.                 variationMarginEstimateArray[i] += marginTradeFlowEntry.variationMarginEstimate();

  751.                 variationMarginPostingArray[i] += marginTradeFlowEntry.variationMarginPosting();

  753.                 variationMarginGapArray[i] += marginTradeFlowEntry.variationMarginGap();

  755.                 variationMarginGapStartDateArray[i] = lastFlowDates.clientVariationMarginPosting().julian();

  757.                 variationMarginGapEndDateArray[i] = lastFlowDates.dealerVariationMarginPosting().julian();

  759.                 clientTradePaymentGapStartDateArray[i] = lastFlowDates.clientTradePayment().julian();

  761.                 clientTradePaymentGapEndDateArray[i] = lastFlowDates.dealerTradePayment().julian();

  763.                 clientDealerTradePaymentGapStartDateArray[i] = lastFlowDates.dealerTradePayment().julian();

  765.                 clientDealerTradePaymentGapEndDateArray[i] = lastFlowDates.variationMarginPeriodEnd().julian();
  766.             }
  767.         }

  769.         System.out.println();

  771.         System.out.println ("\t|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------||");

  773.         System.out.println ("\t|                                                                            FIXED STREAM MARGIN/TRADE FLOW EXPOSURES AND DATES                                                                               ||");

  775.         System.out.println ("\t|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------||");

  777.         System.out.println ("\t|                                                                                                                                                                                                             ||");

  779.         System.out.println ("\t|  L -> R:                                                                                                                                                                                                    ||");

  781.         System.out.println ("\t|                                                                                                                                                                                                             ||");

  783.         System.out.println ("\t|    - Exposure Date                                                                                                                                                                                          ||");

  785.         System.out.println ("\t|    - Variation Margin Gap Start Date                                                                                                                                                                        ||");

  787.         System.out.println ("\t|    - Variation Margin Gap End Date                                                                                                                                                                          ||");

  789.         System.out.println ("\t|    - Variation Margin Estimate                                                                                                                                                                              ||");

  791.         System.out.println ("\t|    - Variation Margin Posting                                                                                                                                                                               ||");

  793.         System.out.println ("\t|    - Variation Margin Gap                                                                                                                                                                                   ||");

  795.         System.out.println ("\t|    - Client Trade Payment Gap Start Date                                                                                                                                                                    ||");

  797.         System.out.println ("\t|    - Client Trade Payment Gap End Date                                                                                                                                                                      ||");

  799.         System.out.println ("\t|    - Client Trade Payment Gap                                                                                                                                                                               ||");

  801.         System.out.println ("\t|    - Net Trade Payment Gap Start Date                                                                                                                                                                       ||");

  803.         System.out.println ("\t|    - Net Trade Payment Gap End Date                                                                                                                                                                         ||");

  805.         System.out.println ("\t|    - Net Trade Payment Gap                                                                                                                                                                                  ||");

  807.         System.out.println ("\t|    - Trade Payment Gap                                                                                                                                                                                      ||");

  809.         System.out.println ("\t|    - Exposure                                                                                                                                                                                               ||");

  811.         System.out.println ("\t|    - Positive Exposure                                                                                                                                                                                      ||");

  813.         System.out.println ("\t|                                                                                                                                                                                                             ||");

  815.         System.out.println ("\t|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------||");

  817.         for (int i = 0; i <= exposurePeriodCount; ++i)
  818.         {
  819.             System.out.println (
  820.                 "\t| [" +
  821.                 new JulianDate (exposureDateArray[i]) + "] => [" +
  822.                 new JulianDate (variationMarginGapStartDateArray[i]) + " -> " +
  823.                 new JulianDate (variationMarginGapEndDateArray[i]) + "] | " +
  824.                 FormatUtil.FormatDouble (variationMarginEstimateArray[i] / pathCount, 5, 2, 1) + " | " +
  825.                 FormatUtil.FormatDouble (variationMarginPostingArray[i] / pathCount, 5, 2, 1) + " | " +
  826.                 FormatUtil.FormatDouble (variationMarginGapArray[i] / pathCount, 5, 2, 1) + " | [" +
  827.                 new JulianDate (clientTradePaymentGapStartDateArray[i]) + " -> " +
  828.                 new JulianDate (clientTradePaymentGapEndDateArray[i]) + "] | " +
  829.                 FormatUtil.FormatDouble (clientTradePaymentGapArray[i] / pathCount, 5, 2, 1) + " | [" +
  830.                 new JulianDate (clientDealerTradePaymentGapStartDateArray[i]) + " -> " +
  831.                 new JulianDate (clientDealerTradePaymentGapEndDateArray[i]) + "] | " +
  832.                 FormatUtil.FormatDouble (clientDealerTradePaymentGapArray[i] / pathCount, 5, 2, 1) + " | " +
  833.                 FormatUtil.FormatDouble (tradePaymentGapArray[i] / pathCount, 5, 2, 1) + " | " +
  834.                 FormatUtil.FormatDouble (collateralizedExposureArray[i] / pathCount, 5, 2, 1) + " | " +
  835.                 FormatUtil.FormatDouble (collateralizedPositiveExposureArray[i] / pathCount, 5, 2, 1) + " ||"
  836.             );
  837.         }

  839.         System.out.println ("\t|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------||");

  841.         EnvManager.TerminateEnv();
  842.     }
  843. }
Created with JaCoCo 0.7.9.201702052155