blueflood-core/src/main/java/com/rackspacecloud/blueflood/io/IOContainer.java
public static synchronized IOContainer fromConfig() {
        if ( FROM_CONFIG_INSTANCE == null ) {

            String driver = configuration.getStringProperty(CoreConfig.CASSANDRA_DRIVER);
            LOG.info(String.format("Using driver %s", driver));

            boolean isRecordingDelayedMetrics = configuration.getBooleanProperty(CoreConfig.RECORD_DELAYED_METRICS);
            LOG.info(String.format("Recording delayed metrics: %s", isRecordingDelayedMetrics));

            boolean isDtxIngestBatchEnabled = configuration.getBooleanProperty(CoreConfig.ENABLE_DTX_INGEST_BATCH);
            LOG.info(String.format("Datastax Ingest batch enabled: %s", isDtxIngestBatchEnabled));

            FROM_CONFIG_INSTANCE = new IOContainer(DriverType.getDriverType(driver),
                                            isRecordingDelayedMetrics,
                                            isDtxIngestBatchEnabled);
        }

        return FROM_CONFIG_INSTANCE;
    }
public static synchronized IOContainer fromConfig() {
        if ( FROM_CONFIG_INSTANCE == null ) {

            String driver = configuration.getStringProperty(CoreConfig.CASSANDRA_DRIVER);
            LOG.info(String.format("Using driver %s", driver));

            boolean isRecordingDelayedMetrics = configuration.getBooleanProperty(CoreConfig.RECORD_DELAYED_METRICS);
            LOG.info(String.format("Recording delayed metrics: %s", isRecordingDelayedMetrics));

            boolean isDtxIngestBatchEnabled = configuration.getBooleanProperty(CoreConfig.ENABLE_DTX_INGEST_BATCH);
            LOG.info(String.format("Datastax Ingest batch enabled: %s", isDtxIngestBatchEnabled));

            FROM_CONFIG_INSTANCE = new IOContainer(DriverType.getDriverType(driver),
                                            isRecordingDelayedMetrics,
                                            isDtxIngestBatchEnabled);
        }

        return FROM_CONFIG_INSTANCE;
    }
public static synchronized IOContainer fromConfig ( ) { if ( FROM_CONFIG_INSTANCE == null ) { String driver = configuration . getStringProperty ( CoreConfig . CASSANDRA_DRIVER ) ; LOG . info ( String . format ( "Using driver %s" , driver ) ) ; boolean isRecordingDelayedMetrics = configuration . getBooleanProperty ( CoreConfig . RECORD_DELAYED_METRICS ) ; LOG . info ( String . format ( "Recording delayed metrics: %s" , isRecordingDelayedMetrics ) ) ; boolean isDtxIngestBatchEnabled = configuration . getBooleanProperty ( CoreConfig . ENABLE_DTX_INGEST_BATCH ) ; LOG . info ( String . format ( "Datastax Ingest batch enabled: %s" , isDtxIngestBatchEnabled ) ) ; FROM_CONFIG_INSTANCE = new IOContainer ( DriverType . getDriverType ( driver ) , isRecordingDelayedMetrics , isDtxIngestBatchEnabled ) ; } return FROM_CONFIG_INSTANCE ; }
Returns an instance of this class based on what configuration says our
driver should be.

@return IOContainer
Returns an instance of this class based on what configuration says our driver should be .