Skip to content
This repository was archived by the owner on Aug 22, 2025. It is now read-only.

Commit fadfd46

Browse files
author
Luca Rosellini
committed
initializes default read/write consistency level correctly
1 parent 9c59b08 commit fadfd46

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

StratioDeep/src/main/java/com/stratio/deep/config/impl/GenericDeepJobConfig.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,13 @@
1212
import com.stratio.deep.cql.DeepConfigHelper;
1313
import com.stratio.deep.entity.Cell;
1414
import com.stratio.deep.entity.Cells;
15-
import com.stratio.deep.exception.*;
15+
import com.stratio.deep.exception.DeepIOException;
16+
import com.stratio.deep.exception.DeepIllegalAccessException;
17+
import com.stratio.deep.exception.DeepIndexNotFoundException;
18+
import com.stratio.deep.exception.DeepNoSuchFieldException;
1619
import com.stratio.deep.util.Constants;
1720
import com.stratio.deep.util.Utils;
21+
import org.apache.cassandra.db.ConsistencyLevel;
1822
import org.apache.cassandra.dht.IPartitioner;
1923
import org.apache.cassandra.hadoop.ConfigHelper;
2024
import org.apache.cassandra.hadoop.cql3.CqlConfigHelper;
@@ -100,12 +104,12 @@ public abstract class GenericDeepJobConfig<T> implements IDeepJobConfig<T> {
100104
/**
101105
* Default read consistency level. Defaults to LOCAL_ONE.
102106
*/
103-
private String readConsistencyLevel;
107+
private String readConsistencyLevel = ConsistencyLevel.LOCAL_ONE.name();
104108

105109
/**
106110
* Default write consistency level. Defaults to LOCAL_ONE.
107111
*/
108-
private String writeConsistencyLevel;
112+
private String writeConsistencyLevel = ConsistencyLevel.LOCAL_ONE.name();
109113

110114
/**
111115
* Enables/Disables auto-creation of column family when writing to Cassandra.

0 commit comments

Comments
 (0)