Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Accumulo >> mail # user >> BatchWriter not working


Copy link to this message
-
BatchWriter not working
I'm trying to write a simple Accumulo insertion with a BatchWriter, based on this document: http://accumulo.apache.org/1.4/user_manual/Writing_Accumulo_Clients.html. I have a running Accumulo instance with a table "table" and can add and remove records using the shell. But I run the following code, and there is no output at all and nothing inserted:

        String instanceName = "instance";
        String zooServers = "localhost:2181";
        Instance instance = new ZooKeeperInstance(instanceName, zooServers);

        Connector connector = instance.getConnector("root", "secret");

        Text rowId = new Text("row1");
        Text colFam = new Text("myColFam");
        Text colQual = new Text("myColQual");
        ColumnVisibility vis = new ColumnVisibility("public");
        long timestamp = System.currentTimeMillis();
        Value value = new Value("Hello World!".getBytes());

        Mutation mutation = new Mutation(rowId);
        mutation.put(colFam, colQual, vis, timestamp, value);

        BatchWriterConfig config = new BatchWriterConfig();
        long memBuf = 1000000L;
        long timeout = 1000L;
        int numThreads = 10;
        config.setMaxMemory(memBuf);
        config.setTimeout(timeout, TimeUnit.MILLISECONDS);
        config.setMaxWriteThreads(numThreads);

        BatchWriter writer = connector.createBatchWriter("table", config);

        writer.addMutation(mutation);

        writer.close();
Why isn't this working?

Thanks,
Mike