This is an automated email from the ASF dual-hosted git repository.
jenniferdai pushed a commit to branch hadoopParamFileFormat
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/hadoopParamFileFormat by this
push:
new 43c80d1 Changing initialize methods
43c80d1 is described below
commit 43c80d16a10e100d12972e3b99d36abd659ae507
Author: Jennifer Dai <[email protected]>
AuthorDate: Thu Mar 7 13:41:28 2019 -0800
Changing initialize methods
---
.../java/org/apache/pinot/core/data/readers/CSVRecordReader.java | 6 +++---
.../java/org/apache/pinot/core/data/readers/JSONRecordReader.java | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/readers/CSVRecordReader.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/readers/CSVRecordReader.java
index 0891ceb..00cce5d 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/readers/CSVRecordReader.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/readers/CSVRecordReader.java
@@ -90,7 +90,7 @@ public class CSVRecordReader implements RecordReader {
_multiValueDelimiter = config.getMultiValueDelimiter();
}
- initialize();
+ init();
}
@Override
@@ -98,7 +98,7 @@ public class CSVRecordReader implements RecordReader {
}
- private void initialize()
+ private void init()
throws IOException {
_parser = _format.parse(RecordReaderUtils.getBufferedReader(_dataFile));
_iterator = _parser.iterator();
@@ -137,7 +137,7 @@ public class CSVRecordReader implements RecordReader {
public void rewind()
throws IOException {
_parser.close();
- initialize();
+ init();
}
@Override
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/readers/JSONRecordReader.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/readers/JSONRecordReader.java
index bab959a..23ec05b 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/readers/JSONRecordReader.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/readers/JSONRecordReader.java
@@ -51,10 +51,10 @@ public class JSONRecordReader implements RecordReader {
_schema = schema;
_fieldSpecs = RecordReaderUtils.extractFieldSpecs(schema);
- initialize();
+ init();
}
- private void initialize()
+ private void init()
throws IOException {
_parser =
_factory.createParser(RecordReaderUtils.getBufferedReader(_dataFile));
try {
@@ -100,7 +100,7 @@ public class JSONRecordReader implements RecordReader {
public void rewind()
throws IOException {
_parser.close();
- initialize();
+ init();
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
