pavel-drabushevich

@XmlRootElement
@Document(collection = "user")
@PersistenceCapable
@View
public class User {

    @Id
    @JsonIgnore(true)
    private String id;
    private String username;

pavel-drabushevich

	private String streamToString(InputStream is) throws IOException
	{
		final char[] buffer = new char[0x10000];
		final StringBuilder out = new StringBuilder();
		InputStreamReader in = null;
                try {
                    in = new InputStreamReader(is);
		    int read;
		    while((read = in.read(buffer)) > 0) {
		        out.append(buffer, 0, read);

pavel-drabushevich

Document doc = document(
    keys("comments"), 
    values(asList(
            document(keys("content", "date"), values("test1", date("14/01/2011"))),
            document(keys("content", "date"), values("test2", date("12/01/2011"))))));

Of cource it was refactored to:
private Document comment(final String content, final String dateStr) {
    return document(keys("content", "date"), values(content, date(dateStr)));
}

pavel-drabushevich

public Record addParserResult() {
  Record record = new RecordImpl();
  record.clear();
  ((RecordImpl) record)
    .setRecordsReceived(((RecordImpl) record)
      .getRecordsReceived() + this.getRecordsReceived());
  ((RecordImpl) record).setRecordsWritten(((RecordImpl) record)
    .getRecordsWritten() + this.getRecordsWritten());
  ((RecordImpl) record)
    .setHeardChangeMessage(((RecordImpl) record)

pavel-drabushevich

using System;

namespace CodeAsData
{
    public class Pair
    {
        static void Main(string[] args)
        {
            var pair = create(1, 'a');
            Console.WriteLine(key(pair) + ":" + value(pair));