kzk

/*
 * Description
Using Groonga as Inverted-Index library.

* TODO
- Not to store document contents (possible?).
- Store documents with scores, and order with scores in the index.
- Store documents with sections
- Store documents with positions
- Separate writer/reader function

kzk

public class MyWritableComparable implements WritableComparable<MyWritableComparable> {
  // Some data
  private int counter;
  private long timestamp;
      
  public void write(DataOutput out) throws IOException {
    out.writeInt(counter);
    out.writeLong(timestamp);
  }
      

kzk

public class MyWritable implements Writable {
  // Some data    
  private int counter;
  private long timestamp;
      
  public void write(DataOutput out) throws IOException {
    out.writeInt(counter);
    out.writeLong(timestamp);
  }
      

kzk

package net.kzk9;

import java.io.IOException;
import java.util.StringTokenizer;

import org.apache.hadoop.util.GenericOptionsParser;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;

kzk

class ExistingClass implements MessagePackTemplateProvider {
    // no serialization is needed;
    Logger LOG;
    string internal_data;

    // data
    int a;
    int b;
    string c;
    

kzk

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

public class Main {
    public static class MyClass {
        public String s;
        public int v;

kzk

import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;

import org.apache.hadoop.io.BytesWritable;
import org.apache.hadoop.io.WritableComparable;

import org.msgpack.MessagePack;

public class MessagePackWritable<C> implements WritableComparable<MessagePackWritable<C>> {

kzk

import org.msgpack.MessagePack;
import org.msgpack.annotation.MessagePackMessage;

public class Main {
    @MessagePackMessage
        public static class MyClass {
        public String str;
     }

    public static void main(String[] args) {

kzk

#include <event.h>
#include <evhttp.h>
#include <pthread.h>
#include <errno.h>
#include <string.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <iostream>

kzk

//
// 2010/11/06 Kazuki Ohta <[email protected]>
// Single-Threaded HTTPServer using evhttp
//

#include <event.h>
#include <evhttp.h>
#include <unistd.h>

namespace servers {