hadoop - Script de cerdo para leer la tabla de Cassandra

apache-pig thrift

Question

Tratando de escribir un script de Pig que extraerá datos de una tabla de Cassandra. El script de Pig se ve así:

REGISTER ./cassandra-all-2.0.8.39.jar
REGISTER ./datastax-agent-4.1.4-standalone.jar
REGISTER ./cassandra-driver-core-2.0.2.1.jar
REGISTER ./apache-cassandra-thrift-2.0.12.jar

A = LOAD ''cql://username:password/mykeyspace/mycolumnfamily'' 
    USING org.apache.cassandra.hadoop.pig.CqlStorage() 
    AS (user_id:long, fname:chararray, last_update_date:chararray, lname:chararray); 
DUMP A;

Sigo recibiendo el siguiente mensaje:

java.lang.NoSuchMethodError: org.apache.cassandra.thrift.ITransportFactory.supportedOptions () Ljava / util / Set

Hasta ahora probé la siguiente versión de '' cassandra- thrift .jar'': 2.0.8.39, 2.0.12, 2.1.2. Ninguno de ellos ha ayudado.

Nota: Las siguientes variables de entorno se han establecido fuera de este script:

export PIG_INITIAL_ADDRESS=machine-name
export PIG_RPC_PORT=9160
export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner

¿Alguna sugerencia?