This is an automated email from the ASF dual-hosted git repository.
chenliang613 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/carbondata.git
The following commit(s) were added to refs/heads/master by this push:
new 39dd8cec14 [ISSUE-4313] Add @Override for override method of
processing module (#4314) (#4324)
39dd8cec14 is described below
commit 39dd8cec146c962ba166a0f6e72c71af2f786b56
Author: Bo Xu <[email protected]>
AuthorDate: Thu Oct 19 15:51:30 2023 +0800
[ISSUE-4313] Add @Override for override method of processing module (#4314)
(#4324)
---
.../java/org/apache/carbondata/sdk/file/AvroCarbonWriter.java | 4 ++--
.../main/java/org/apache/carbondata/sdk/file/CSVCarbonWriter.java | 4 ++--
.../java/org/apache/carbondata/sdk/file/CarbonReaderBuilder.java | 6 +++---
.../java/org/apache/carbondata/sdk/file/JsonCarbonWriter.java | 4 ++--
.../org/apache/carbondata/sdk/file/arrow/ArrowFieldWriter.java | 8 ++++----
5 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/AvroCarbonWriter.java
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/AvroCarbonWriter.java
index c3b3c1da38..081bc3c749 100644
--- a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/AvroCarbonWriter.java
+++ b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/AvroCarbonWriter.java
@@ -95,8 +95,8 @@ import org.apache.log4j.Logger;
JobID jobId = new JobID(UUID.randomUUID().toString(), 0);
Random random = new Random();
TaskID task = new TaskID(jobId, TaskType.MAP, random.nextInt());
- TaskAttemptID attemptID = new TaskAttemptID(task, random.nextInt());
- TaskAttemptContextImpl context = new TaskAttemptContextImpl(hadoopConf,
attemptID);
+ TaskAttemptID attemptId = new TaskAttemptID(task, random.nextInt());
+ TaskAttemptContextImpl context = new TaskAttemptContextImpl(hadoopConf,
attemptId);
this.recordWriter = format.getRecordWriter(context);
this.context = context;
this.writable = new ObjectArrayWritable();
diff --git
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CSVCarbonWriter.java
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CSVCarbonWriter.java
index 4851e102af..7a5fe86884 100644
--- a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CSVCarbonWriter.java
+++ b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CSVCarbonWriter.java
@@ -63,8 +63,8 @@ class CSVCarbonWriter extends CarbonWriter {
JobID jobId = new JobID(UUID.randomUUID().toString(), 0);
Random random = new Random();
TaskID task = new TaskID(jobId, TaskType.MAP, random.nextInt());
- TaskAttemptID attemptID = new TaskAttemptID(task, random.nextInt());
- TaskAttemptContextImpl context = new TaskAttemptContextImpl(hadoopConf,
attemptID);
+ TaskAttemptID attemptId = new TaskAttemptID(task, random.nextInt());
+ TaskAttemptContextImpl context = new TaskAttemptContextImpl(hadoopConf,
attemptId);
this.recordWriter = format.getRecordWriter(context);
this.context = context;
this.writable = new ObjectArrayWritable();
diff --git
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CarbonReaderBuilder.java
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CarbonReaderBuilder.java
index 6f4922a26b..b2427cd6b4 100644
---
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CarbonReaderBuilder.java
+++
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/CarbonReaderBuilder.java
@@ -441,19 +441,19 @@ public class CarbonReaderBuilder {
throws IOException, InterruptedException {
CarbonFileInputFormat format = this.prepareFileInputFormat(job, false,
true);
long sum = 0;
- boolean isIUDTable = false;
+ boolean isIudTable = false;
if (!StringUtils.isEmpty(this.tablePath)) {
// Check if update or delete happened on the table.
CarbonFile emptyMetadataFile = FileFactory.getCarbonFile(this.tablePath +
CarbonCommonConstants.FILE_SEPARATOR +
CarbonCommonConstants.CARBON_SDK_EMPTY_METADATA_PATH,
this.hadoopConf);
if (emptyMetadataFile.exists() && emptyMetadataFile.isDirectory()) {
- isIUDTable = true;
+ isIudTable = true;
}
}
// if filter exists or IUD happened then read the total number of rows
after
// building carbon reader else get the row count from the details info of
each splits.
- if (this.filterExpression != null || isIUDTable) {
+ if (this.filterExpression != null || isIudTable) {
RecordReader reader = null;
CarbonReader carbonReader = null;
for (InputSplit split : splits) {
diff --git
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/JsonCarbonWriter.java
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/JsonCarbonWriter.java
index 560a292446..6f7aa1c378 100644
--- a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/JsonCarbonWriter.java
+++ b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/JsonCarbonWriter.java
@@ -70,8 +70,8 @@ public class JsonCarbonWriter extends CarbonWriter {
JobID jobId = new JobID(UUID.randomUUID().toString(), 0);
Random random = new Random();
TaskID task = new TaskID(jobId, TaskType.MAP, random.nextInt());
- TaskAttemptID attemptID = new TaskAttemptID(task, random.nextInt());
- TaskAttemptContextImpl context = new TaskAttemptContextImpl(configuration,
attemptID);
+ TaskAttemptID attemptId = new TaskAttemptID(task, random.nextInt());
+ TaskAttemptContextImpl context = new TaskAttemptContextImpl(configuration,
attemptId);
this.recordWriter = outputFormat.getRecordWriter(context);
this.context = context;
this.writable = new ObjectArrayWritable();
diff --git
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/arrow/ArrowFieldWriter.java
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/arrow/ArrowFieldWriter.java
index b6443c6227..35029626af 100644
---
a/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/arrow/ArrowFieldWriter.java
+++
b/sdk/sdk/src/main/java/org/apache/carbondata/sdk/file/arrow/ArrowFieldWriter.java
@@ -226,21 +226,21 @@ class DateWriter extends ArrowFieldWriter {
}
class TimeStampWriter extends ArrowFieldWriter {
- private TimeStampMicroTZVector timeStampMicroTZVector;
+ private TimeStampMicroTZVector timeStampMicroTzVector;
public TimeStampWriter(TimeStampMicroTZVector timeStampMicroTZVector) {
super(timeStampMicroTZVector);
- this.timeStampMicroTZVector = timeStampMicroTZVector;
+ this.timeStampMicroTzVector = timeStampMicroTZVector;
}
@Override
public void setNull() {
- this.timeStampMicroTZVector.setNull(count);
+ this.timeStampMicroTzVector.setNull(count);
}
@Override
public void setValue(Object data, int ordinal) {
- this.timeStampMicroTZVector.setSafe(count, (long)data);
+ this.timeStampMicroTzVector.setSafe(count, (long)data);
}
}
