public static boolean isPortable(SamzaPipelineOptions options) {
    Map<String, String> override = options.getConfigOverride();
    if (override == null) {
      return false;
    }

    return Boolean.parseBoolean(override.getOrDefault(BEAM_PORTABLE_MODE, "false"));
  }
@Test
  public void testPortableMode() {
    SamzaPipelineOptions mockOptions = mock(SamzaPipelineOptions.class);
    Map<String, String> config = new HashMap<>();
    config.put(PortableConfigUtils.BEAM_PORTABLE_MODE, "true");
    doReturn(config).when(mockOptions).getConfigOverride();
    Assert.assertTrue(
        "Expected true for portable runner", PortableConfigUtils.isPortable(mockOptions));
  }