private void initialize() {
        cfName = config.getTable();

        if (!ArrayUtils.isEmpty(config.getInputColumns())) {
            columns = StringUtils.join(config.getInputColumns(), ",");
        }

        partitioner = Utils.newTypeInstance(config.getPartitionerClassName(), IPartitioner.class);

        try {
            session = createConnection();

            retrieveKeys();
        } catch (Exception e) {
            throw new DeepIOException(e);
        }

        rowIterator = new RowIterator();
    }
private void initialize ( ) { cfName = config . getTable ( ) ; if ( ! ArrayUtils . isEmpty ( config . getInputColumns ( ) ) ) { columns = StringUtils . join ( config . getInputColumns ( ) , "," ) ; } partitioner = Utils . newTypeInstance ( config . getPartitionerClassName ( ) , IPartitioner . class ) ; try { session = createConnection ( ) ; retrieveKeys ( ) ; } catch ( Exception e ) { throw new DeepIOException ( e ) ; } rowIterator = new RowIterator ( ) ; }
Initialized this object.
<p>
Creates a new client and row iterator.
</p>