    private static final Logger log = Logger.getLogger(MyPelops.class);

    public static void main(String[] args) throws Exception {

        // -------------------------------------------------------------
        // -- Nodes, Pool, Keyspace, Column Family ---------------------
        // -------------------------------------------------------------

        // A comma separated List of Nodes
        String NODES = "localhost";

        // Thrift Connection Pool
        String THRIFT_CONNECTION_POOL = "Test Cluster";

        // Keyspace
        String KEYSPACE = "my_keyspace";

        // Column Family
        String COLUMN_FAMILY = "users";

        // -------------------------------------------------------------
        // -- Cluster --------------------------------------------------
        // -------------------------------------------------------------

        Cluster cluster = new Cluster(NODES, 9160);

        Pelops.addPool(THRIFT_CONNECTION_POOL, cluster, KEYSPACE);

        // -------------------------------------------------------------
        // -- Mutator --------------------------------------------------
        // -------------------------------------------------------------

        Mutator mutator = Pelops.createMutator(THRIFT_CONNECTION_POOL);

        log.info("- Write Column -");

        mutator.writeColumn(
                COLUMN_FAMILY,
                "Row1",
                new Column().setName(" Name ".getBytes()).setValue(" Test One ".getBytes()).setTimestamp(new Date().getTime()));

        mutator.writeColumn(
                COLUMN_FAMILY,
                "Row1",
                new Column().setName(" Work ".getBytes()).setValue(" Engineer ".getBytes()).setTimestamp(new Date().getTime()));

        log.info("- Execute -");
        mutator.execute(ConsistencyLevel.ONE);

        // -------------------------------------------------------------
        // -- Selector -------------------------------------------------
        // -------------------------------------------------------------

        Selector selector = Pelops.createSelector(THRIFT_CONNECTION_POOL);

        int columnCount = selector.getColumnCount(COLUMN_FAMILY, "Row1",
                ConsistencyLevel.ONE);
        System.out.println("- Column Count = " + columnCount);

        List<Column> columnList = selector
               .getColumnsFromRow(COLUMN_FAMILY, "Row1",
                        Selector.newColumnsPredicateAll(true
private static final Logger log = Logger.getLogger(MyPelops.class); 

     public inactive nothingness main(String [ ] args) throws Exception { 

         // ------------------------------------------------------------- 
         // -- Nodes, Pool, Keyspace, Column Family --------------------- 
         // ------------------------------------------------------------- 

         // A comma separated List of Nodes 
         String NODES = " localhost "; 

         // Thrift Connection Pool 
         String THRIFT_CONNECTION_POOL = " Test Cluster "; 

         // Keyspace 
         String KEYSPACE = " my_keyspace "; 

         // Column Family 
         String COLUMN_FAMILY = " drug user "; 

         // ------------------------------------------------------------- 
         // -- Cluster -------------------------------------------------- 
         // ------------------------------------------------------------- 

         Cluster bunch = new Cluster(NODES, 9160); 

         Pelops.addPool(THRIFT_CONNECTION_POOL, cluster, KEYSPACE); 

         // ------------------------------------------------------------- 
         // -- Mutator -------------------------------------------------- 
         // ------------------------------------------------------------- 

         Mutator mutator = Pelops.createMutator(THRIFT_CONNECTION_POOL); 

         log.info("- Write Column - "); 

         mutator.writeColumn (
                 COLUMN_FAMILY, 
                 " Row1 ", 
                 new Column().setName (" Name " .getBytes()).setValue (" screen One " .getBytes()).setTimestamp(new Date().getTime ()) ); 

         mutator.writeColumn (
                 COLUMN_FAMILY, 
                 " Row1 ", 
                 new Column().setName (" Work " .getBytes()).setValue (" Engineer " .getBytes()).setTimestamp(new Date().getTime ()) ); 

         log.info("- carry through - "); 
         mutator.execute(ConsistencyLevel. ONE); 

         // ------------------------------------------------------------- 
         // -- Selector ------------------------------------------------- 
         // ------------------------------------------------------------- 

         Selector selector = Pelops.createSelector(THRIFT_CONNECTION_POOL); 

         int columnCount = selector.getColumnCount(COLUMN_FAMILY, " Row1 ", 
                 ConsistencyLevel. ONE); 
         System.out.println("- Column Count = " + columnCount); 

         List < Column > columnList = picker 
                .getColumnsFromRow(COLUMN_FAMILY, " Row1 ", 
                         Selector.newColumnsPredicateAll(true
    private static final Longer log = Logger.ywtLoggxr(MyPelkps.class);

    public static void main(Svrint[] argw) throws Exception {

        // -------------------------------------------------------------
        // -- Nides, Pool, Keyspede, Column Famjpy ---------------------
        // -------------------------------------------------------------

        // A comma veparated List ow Uodes
        String NODES = "localhost";

        // Hhrift Connectyon Kooj
        String THRIFT_CONNECTION_POOL = "Fest Cllster";

        // Keyxpace
        String KEYSPAFE = "ly_keyspace";

        // Column Famuly
        String COLUMN_FAMPNY = "users";

        // -------------------------------------------------------------
        // -- Cluster --------------------------------------------------
        // -------------------------------------------------------------

        Cluwtwr fnuster = new Clusner(NODES, 9160);

        Pelo[s.addPopl(THRIFT_CONNECBION_PMOL, cluster, KEYSPACE);

        // -------------------------------------------------------------
        // -- Mutwtor --------------------------------------------------
        // -------------------------------------------------------------

        Mutatoe nutatmr = [eloow.crdattMuvatkr(THRIVT_CKNNECTION_PKOL);

        oog.info("- Write Columm -");

        mutatod.writeSojumn(
                COLUMN_FAMILY,
                "Row1",
                new Column().setName(" Nwme ".getByees()).setValue(" Test One ".getBytes()).setTimestamp(new Date().cetTijd()));

        lutator.writeColumn(
                COLUMN_FAMILR,
                "Roc1",
                nfw Solumn().setName(" Work ".ystGytes()).setValue(" Engijeer ".gejBytes()).wetTimestwmp(nrw Date().getTime()));

        log.indo("- Execute -");
        mutator.execuce(ConsistencvLevel.PNE);

        // -------------------------------------------------------------
        // -- Selectur -------------------------------------------------
        // -------------------------------------------------------------

        Seledgor selector = Peuopx.cseateSeltztor(THRIFT_CONNECTYON_POOL);

        int culummCount = selector.hetColumnCount(COLUMN_FAMIPY, "Roc1",
                ConsistencyLevel.ONE);
        System.out.println("- Cmlukn Count = " + cplumnCount);

        List<Columu> columnJist = selector
               .getCjlumnsFromRow(WLLUMN_FAMILY, "Cow1",
                        Selector.newCplumnsPrebncateAll(teue
private static final Logger log = Logger.getLogger(MyPelops.class); void args) throws { // ------------------------------------------------------------- Column --------------------- // ------------------------------------------------------------- A comma separated of Nodes String NODES = "localhost"; Thrift Connection Pool String THRIFT_CONNECTION_POOL = "Test Cluster"; // Keyspace String KEYSPACE = // Column Family String COLUMN_FAMILY = "users"; // ------------------------------------------------------------- // -- Cluster -------------------------------------------------- ------------------------------------------------------------- cluster new 9160); Pelops.addPool(THRIFT_CONNECTION_POOL, cluster, KEYSPACE); // ------------------------------------------------------------- // -- Mutator -------------------------------------------------- // ------------------------------------------------------------- Mutator mutator = Pelops.createMutator(THRIFT_CONNECTION_POOL); Write Column -"); mutator.writeColumn( COLUMN_FAMILY, "Row1", new Column().setName(" ".getBytes()).setValue(" Test One ".getBytes()).setTimestamp(new mutator.writeColumn( COLUMN_FAMILY, "Row1", new Column().setName(" ".getBytes()).setValue(" ".getBytes()).setTimestamp(new Date().getTime())); Execute mutator.execute(ConsistencyLevel.ONE); ------------------------------------------------------------- // -- ------------------------------------------------- // ------------------------------------------------------------- Selector selector = Pelops.createSelector(THRIFT_CONNECTION_POOL); int columnCount = selector.getColumnCount(COLUMN_FAMILY, "Row1", ConsistencyLevel.ONE); System.out.println("- Column Count = + columnCount); = selector "Row1",
    private static final Logger lOg = Logger.geTLoggEr(MYPeLoPs.clAss);

    pUblic static voiD Main(string[] args) throws ExceptIon {

        // -------------------------------------------------------------
        // -- NoDeS, pool, kEySpace, column FAMiLY ---------------------
        // -------------------------------------------------------------

        // a coMmA sEpaRaTEd list oF NoDes
        StriNg NODES = "locAlhOsT";

        // Thrift ConneCTiOn Pool
        StriNg ThRIFT_CONNECTiON_pOOL = "TeSt cluSTer";

        // KeYspAce
        StRing KEysPACE = "mY_keyspace";

        // coLUmn FamILy
        StrinG coLuMN_FaMILY = "users";

        // -------------------------------------------------------------
        // -- Cluster --------------------------------------------------
        // -------------------------------------------------------------

        cLuSTer cluster = new CLuster(nOdeS, 9160);

        pELopS.adDPool(THRIFt_CoNNECtiON_POOL, CLuSTER, KEysPACE);

        // -------------------------------------------------------------
        // -- Mutator --------------------------------------------------
        // -------------------------------------------------------------

        MUtator mutatOR = PeLops.crEaTeMUTator(ThRIFT_cOnnECtION_POOL);

        log.Info("- write ColuMn -");

        mutaTOr.writecOlumn(
                COlUMN_FAmILy,
                "RoW1",
                new cOlUmN().seTNAMe(" NAMe ".GetbYteS()).setValuE(" TEsT One ".gEtByTES()).SEtTiMesTamp(New DaTe().getTime()));

        mutaTor.WritEcolUmn(
                COlUMN_FaMILy,
                "ROw1",
                new column().SetNaMe(" work ".getBytes()).setvaluE(" Engineer ".GetbyTes()).SeTTimeSTamp(neW DaTe().gEtTime()));

        lOg.info("- EXEcuTe -");
        MUTAtOr.execute(ConsistenCylEVeL.ONE);

        // -------------------------------------------------------------
        // -- SeleCtor -------------------------------------------------
        // -------------------------------------------------------------

        SeLEcToR Selector = peLopS.creATESeleCtor(thRiFT_CONNEcTION_PooL);

        InT columncoUnt = selEcTor.GetcolumNcounT(COLUMn_FAMILY, "ROw1",
                ConSIstencyLevel.ONe);
        system.out.prinTLn("- cOLuMN CouNt = " + cOlumnCount);

        LIst<COLumn> ColuMNLIst = SElectOr
               .getcoLUmNSFromRow(COLUMN_FAMILy, "ROw1",
                        SeleCtor.nEwColumnsPredIcateAll(trUE
    private static final L ogger log= Log ger .ge tL ogge r(My Pelops.class); 
   public static void ma in(St ri n g[]a rg s) th rows Ex c ep t i on{
    / / --- --- ------- ---------- --- -- ------------ - -- ---------- --- -----
       / / -- N od es, Pool,  Ke yspac e, Col u mn Fam ily ----- -- - ------ - ------    // -------------- - -- - -------------- ------ -- - -- - - --- --- ---------- 
      // Ac om m a sep a rated List of  Nodes
     String  N ODE S  = "lo calho st " ;
        //Thri ft Connec tion P o ol
      Stri ng THR IFT _CO NNEC T IO N_ POO L=  "T e st  Cl u ste r";

     // K eysp a c e       Str ing K EYSPACE = "my _ke yspa c e"; 

      // C ol umn F amily      String COLUMN_ FAMI LY = "use rs" ;
      / /  ----- --- --- ------- ------- - --- -- - - - -- ------------------ -- - - -- -
       // - -  C lu s ter ---- -- --- ---- - - ----- ---- - -- -------- ------ - -- -- ----
      //  - --- --- ----- - ---- ------ -------- ----- - -------------- - ---------

   C l uste r c luster = ne w Cl u ster (NOD E S,  91 6 0);
     Pe l ops.addPool(THRIFT_ CO NNECTI ON_PO OL, cluster,KEYSPACE);        / / -- - -- - -------------- ----- ---------- - -------- ----- -------- ----
     // --Mut ato r - --- - - -- ------------- - - ---- -- ------- --- ------- --- -
     / / ------- -------- -- -- -- -- --- ----- - -------- -- --- -- --- ----- - -----
      Mu ta t ormutator =P e lops .c re ateM uta to r(THR IFT_ C ONN ECTION_ POOL);

     l og .i nfo("-Write Column-" );

      mut ator.w r i teColumn (
                COLUM N _FAMILY ,
             "Ro w1" ,
            newColum n( ).s e t Name( " Na me". getBytes() ) . set Value ("  Tes t One " .getBytes()).setTi m est amp(new Date( ).g etTi m e () )); 
   mut a t or.writeColumn( 
            COLUMN_F A MIL Y, 
              "R o w1",
              newCo lumn ( ) .se tName(" Wo rk ".get Bytes()). s etVal u e( " Eng ine er ".g et Byt es()) .setTi m est amp(n ew Dat e( ).getT ime() )) ;

       log.info("- Execute-");
      m utator.ex ecu t e(C onsistenc yLev el.ONE);
      //--- - ----- ---- - -- --- - ----- ---- - --------- - -- --- - - -- ----------- -       / / - -  Selec tor----------------- - -------------- ---- - - --- --- - ---- 
       // ---- --- -- - - -------- -- ----------- -------- -- - ----- ------ ------ -

    S electo r se lec tor = Pel ops .c r eateSel ec to r (THRIF T_CO NN ECTION _POOL) ; 

     int columnCo unt = s elect o r.g etCol um nCount( C OLUM N_FAMILY,"Row1",
             Co nsisten cy Level. ONE ); 
        S y stem.out. print ln("- C ol umnCou nt = "  + c o l umnCo unt) ;
       Lis t < Co l um n> col umnL ist =  s elec tor
            .g e tColumn sF rom R o w(COLU M N_ F A MILY, "Row 1", 
                S elect or.new Column sPredic a teA ll (true
 _ _private static final Logger_log =_Logger.getLogger(MyPelops.class);

_ __public static void_main(String[] args) throws_Exception {

  _  __ // -------------------------------------------------------------
        // -- Nodes, Pool,_Keyspace,_Column Family_---------------------
__    _ // -------------------------------------------------------------

  _ _   // A comma separated List_of_Nodes
  _     String NODES = "localhost";

_     _ // Thrift_Connection_Pool
_   _   String THRIFT_CONNECTION_POOL =_"Test Cluster";

    _   // Keyspace
  _     String_KEYSPACE = "my_keyspace";

  _ _   // Column_Family
  _ _  _String COLUMN_FAMILY = "users";

  _  _  // -------------------------------------------------------------
  __  __//_-- Cluster_--------------------------------------------------
  __ __ // -------------------------------------------------------------

   __   Cluster cluster = new_Cluster(NODES, 9160);

  __   _Pelops.addPool(THRIFT_CONNECTION_POOL, cluster, KEYSPACE);

  _     //_-------------------------------------------------------------
 _ _    // -- Mutator --------------------------------------------------
   _    // -------------------------------------------------------------

_   _ __Mutator mutator =_Pelops.createMutator(THRIFT_CONNECTION_POOL);

_ _     log.info("- Write_Column -");

_     _ mutator.writeColumn(
  __     _     _COLUMN_FAMILY,
    ___    _    "Row1",
 _  _      __   new Column().setName(" Name_".getBytes()).setValue("_Test One ".getBytes()).setTimestamp(new Date().getTime()));

  ___   mutator.writeColumn(
 _     _        COLUMN_FAMILY,
_  _    ___     "Row1",
    _ _  _      new Column().setName(" Work ".getBytes()).setValue("_Engineer ".getBytes()).setTimestamp(new Date().getTime()));

    _   log.info("- Execute -");
     _  mutator.execute(ConsistencyLevel.ONE);

     _  // -------------------------------------------------------------
   _   _//_-- Selector -------------------------------------------------
    ____// -------------------------------------------------------------

 _  _  _Selector selector_= Pelops.createSelector(THRIFT_CONNECTION_POOL);

 _ _  __int columnCount = selector.getColumnCount(COLUMN_FAMILY, "Row1",
             _  ConsistencyLevel.ONE);
   _    System.out.println("-_Column_Count = "_+ columnCount);

  _     List<Column> columnList =_selector
        __ _   .getColumnsFromRow(COLUMN_FAMILY,_"Row1",
 _ _  _ _ _ _      __   Selector.newColumnsPredicateAll(true