astyanax

import com.netflix.astyanax.AstyanaxContext;
import com.netflix.astyanax.Keyspace;
import com.netflix.astyanax.connectionpool.NodeDiscoveryType;
import com.netflix.astyanax.connectionpool.impl.ConnectionPoolConfigurationImpl;
import com.netflix.astyanax.connectionpool.impl.CountingConnectionPoolMonitor;
import com.netflix.astyanax.impl.AstyanaxConfigurationImpl;
import com.netflix.astyanax.model.ColumnFamily;
import com.netflix.astyanax.model.Rows;
import com.netflix.astyanax.serializers.StringSerializer;

public class AstyanaxExample {
    public static void main(String[] args) {
        AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
            .forCluster("Test Cluster")
            .forKeyspace("test_keyspace")
            .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE))
            .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
                .setPort(9160)
                .setMaxConnsPerHost(10)
                .setSeeds("127.0.0.1:9160"))
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());

        context.start();
        Keyspace keyspace = context.getEntity();

        ColumnFamily<String, String> cf = new ColumnFamily<>(
            "Standard1", // Column Family Name
            StringSerializer.get(), // Key Serializer
            StringSerializer.get()  // Column Serializer
        );

        Rows<String, String> rows = keyspace.prepareQuery(cf)
            .getKey("key1")
            .execute()
            .getResult();

        for (Row<String, String> row : rows) {
            System.out.println("Row key: " + row.getKey());
            for (Column<String> column : row.getColumns()) {
                System.out.println("Column name: " + column.getName() + ", value: " + column.getStringValue());
            }
        }

        context.shutdown();
    }
}