Skip to content

Commit

Permalink
resolve conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
JackieTien97 committed Nov 13, 2024
2 parents 022c8cb + 3aef6ad commit 449cd54
Show file tree
Hide file tree
Showing 66 changed files with 2,170 additions and 374 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,24 @@ public CommonConfig setCompressor(String compressor) {
return this;
}

@Override
public CommonConfig setEncryptFlag(boolean encryptFlag) {
setProperty("encrypt_flag", String.valueOf(encryptFlag));
return this;
}

@Override
public CommonConfig setEncryptType(String encryptType) {
setProperty("encrypt_type", encryptType);
return this;
}

@Override
public CommonConfig setEncryptKeyPath(String encryptKeyPath) {
setProperty("encrypt_key_path", encryptKeyPath);
return this;
}

@Override
public CommonConfig setUdfMemoryBudgetInMB(float udfCollectorMemoryBudgetInMB) {
// udf_memory_budget_in_mb
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,27 @@ public CommonConfig setCompressor(String compressor) {
return this;
}

@Override
public CommonConfig setEncryptFlag(boolean encryptFlag) {
cnConfig.setProperty("encrypt_flag", String.valueOf(encryptFlag));
dnConfig.setProperty("encrypt_flag", String.valueOf(encryptFlag));
return this;
}

@Override
public CommonConfig setEncryptType(String encryptType) {
cnConfig.setProperty("encrypt_type", encryptType);
dnConfig.setProperty("encrypt_type", encryptType);
return this;
}

@Override
public CommonConfig setEncryptKeyPath(String encryptKeyPath) {
cnConfig.setProperty("encrypt_key_path", encryptKeyPath);
dnConfig.setProperty("encrypt_key_path", encryptKeyPath);
return this;
}

@Override
public CommonConfig setConfigRegionRatisRPCLeaderElectionTimeoutMaxMs(int maxMs) {
cnConfig.setConfigRegionRatisRPCLeaderElectionTimeoutMaxMs(maxMs);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,21 @@ public CommonConfig setCompressor(String compressor) {
return this;
}

@Override
public CommonConfig setEncryptFlag(boolean encryptFlag) {
return this;
}

@Override
public CommonConfig setEncryptType(String encryptType) {
return this;
}

@Override
public CommonConfig setEncryptKeyPath(String encryptKeyPath) {
return this;
}

@Override
public CommonConfig setConfigRegionRatisRPCLeaderElectionTimeoutMaxMs(int maxMs) {
return this;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,12 @@ public interface CommonConfig {

CommonConfig setCompressor(String compressor);

CommonConfig setEncryptFlag(boolean encryptFlag);

CommonConfig setEncryptType(String encryptType);

CommonConfig setEncryptKeyPath(String encryptKeyPath);

CommonConfig setConfigRegionRatisRPCLeaderElectionTimeoutMaxMs(int maxMs);

CommonConfig setUdfMemoryBudgetInMB(float udfCollectorMemoryBudgetInMB);
Expand Down
Loading

0 comments on commit 449cd54

Please sign in to comment.