Skip to content
This repository has been archived by the owner on Feb 12, 2022. It is now read-only.

Commit

Permalink
Refactor variable name.
Browse files Browse the repository at this point in the history
  • Loading branch information
bsura committed Aug 23, 2016
1 parent a7a9327 commit ed4365b
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -94,15 +94,15 @@ public class AsyncHbaseSchemaService extends DefaultService implements SchemaSer
@SLF4JTypeListener.InjectLogger
private Logger _logger;
private final HBaseClient _client;
private final boolean syncPut;
private final boolean _syncPut;

//~ Constructors *********************************************************************************************************************************

@Inject
private AsyncHbaseSchemaService(SystemConfiguration systemConfig) {
super(systemConfig);

syncPut = Boolean.getBoolean(systemConfig.getValue(Property.HBASE_SYNC_PUT.getName(), Property.HBASE_SYNC_PUT.getDefaultValue()));
_syncPut = Boolean.getBoolean(systemConfig.getValue(Property.HBASE_SYNC_PUT.getName(), Property.HBASE_SYNC_PUT.getDefaultValue()));

Config config = new Config();

Expand Down Expand Up @@ -556,7 +556,7 @@ private void _put(String tableName, String rowKeyStr) {
final PutRequest put = new PutRequest(Bytes.toBytes(tableName), Bytes.toBytes(rowKeyStr), COLUMN_FAMILY, COLUMN_QUALIFIER, CELL_VALUE);
Deferred<Object> deferred = _client.put(put);

if(syncPut) {
if(_syncPut) {
deferred.addCallback(new Callback<Object, Object>() {
@Override
public Object call(Object arg) throws Exception {
Expand Down

0 comments on commit ed4365b

Please sign in to comment.