Examples of toJSONString()

Examples of com.linkedin.databus.core.data_model.DatabusSubscription.toJsonString()

505
506
507
508
509
510
511
512
513
514
515
        realSub = new DatabusSubscription(
            sub.getPhysicalSource(), sub.getPhysicalPartition(),
            new LogicalSourceId(new LogicalSource(sourceEntry.getId().intValue(), ls.getName()),
                                sub.getLogicalPartition().getId()));
      }
      sb.append(realSub.toJsonString());
      first = false;
    }
    sb.append("]");
    return sb.toString();
  }
View Full Code Here

Examples of com.linkedin.databus.core.data_model.PhysicalPartition.toJsonString()

203
204
205
206
207
208
209
210
211
212
213
    ObjectMapper mapper = new ObjectMapper();
    Map<String, String> map = mapper.readValue(
        new ByteArrayInputStream(serialCpMult.getBytes(Charset.defaultCharset())), new TypeReference<Map<String, String>>(){});
    map.put("NonJsonKey", "Some value");
    map.put("cursorPartition", ppart.toJsonString());
    ByteArrayOutputStream bs = new ByteArrayOutputStream();
    mapper.writeValue(bs, map);
    cpMultCopy = new CheckpointMult(bs.toString());

    assertEquals(cpMultCopy.getCursorPartition(), ppart);
View Full Code Here

Examples of com.spotify.helios.common.descriptors.Job.toJsonString()

85
86
87
88
89
90
91
92
93
94
95
        .setPorts(ports)
        .setRegistration(registration)
        .setVolumes(volumes)
        .setCreatingUser(TEST_USER);
    final Job job = builder.build();
    final String jobConfigJsonString = job.toJsonString();

    // Create temporary job config file
    final File file = temporaryFolder.newFile();
    final String absolutePath = file.getAbsolutePath();
View Full Code Here

Examples of com.spotify.helios.common.protocol.CreateJobResponse.toJsonString()

193
194
195
196
197
198
199
200
201
202
203
        if (!json) {
          out.printf("Unknown job: %s%n", templateJobId);
        } else {
          CreateJobResponse createJobResponse =
              new CreateJobResponse(CreateJobResponse.Status.UNKNOWN_JOB, null, null);
          out.printf(createJobResponse.toJsonString());
        }
        return 1;
      } else if (jobs.size() > 1) {
        if (!json) {
          out.printf("Ambiguous job reference: %s%n", templateJobId);
View Full Code Here

Examples of com.spotify.helios.common.protocol.JobDeployResponse.toJsonString()

98
99
100
101
102
103
104
105
106
107
108
      final JobDeployResponse result = client.deploy(job, host).get();
      if (result.getStatus() == JobDeployResponse.Status.OK) {
        if (!json) {
          out.printf("done%n");
        } else {
          out.printf(result.toJsonString());
        }
      } else {
        if (!json) {
          out.printf("failed: %s%n", result);
        } else {
View Full Code Here

Examples of com.spotify.helios.common.protocol.JobUndeployResponse.toJsonString()

119
120
121
122
123
124
125
126
127
128
129
      final JobUndeployResponse response = client.undeploy(jobId, host).get();
      if (response.getStatus() == JobUndeployResponse.Status.OK) {
        if (!json) {
          out.println("done");
        } else {
          out.printf(response.toJsonString());
        }
      } else {
        if (!json) {
          out.println("failed: " + response);
        } else {
View Full Code Here

Examples of com.trendrr.oss.DynMap.toJSONString()

400
401
402
403
404
405
406
407
408
409
410
      }
    }
   
   
   
    System.out.println(mp.toJSONString());
   
    return mp;
  }
 
  public List<DynMap> getStrestDoc(String java) {
View Full Code Here

Examples of de.agilecoders.wicket.extensions.markup.html.bootstrap.form.typeaheadV10.bloodhound.BloodhoundConfig.toJsonString()

54
55
56
57
58
59
60
61
62
63
64
        BloodhoundConfig config = new BloodhoundConfig();
        config.withRemote(remote);

        String expected = "{\"datumTokenizer\":function(d) { return Bloodhound.tokenizers.whitespace(d.value); },\"queryTokenizer\":Bloodhound.tokenizers.whitespace,\"remote\":\"{\\\"wildcard\\\":\\\"%FOO\\\",\\\"url\\\":\\\"foo\\\"}\"}";
        assertEquals(expected, config.toJsonString());

    }
    @Test
    public void testSimpleRemote() {
View Full Code Here

Examples of edu.brown.api.results.BenchmarkComponentResults.toJSONString()

880
881
882
883
884
885
886
887
888
889
890
    }

    protected void answerPoll() {
        BenchmarkComponentResults copy = this.m_txnStats.copy();
        this.m_txnStats.clear(false);
        this.printControlMessage(m_controlState, copy.toJSONString());
    }
   
    protected void answerDumpTxns() {
        ResponseEntries copy = new ResponseEntries(this.m_responseEntries);
        this.m_responseEntries.clear();
View Full Code Here

Examples of edu.brown.api.results.ResponseEntries.toJSONString()

886
887
888
889
890
891
892
893
894
895
896
    }
   
    protected void answerDumpTxns() {
        ResponseEntries copy = new ResponseEntries(this.m_responseEntries);
        this.m_responseEntries.clear();
        this.printControlMessage(ControlState.DUMPING, copy.toJSONString());
    }
   
    protected void answerOk() {
        this.printControlMessage(m_controlState, "OK");
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.