You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by je...@apache.org on 2019/09/24 18:45:04 UTC
[incubator-pinot] 01/01: Preprocess changes
This is an automated email from the ASF dual-hosted git repository.
jenniferdai pushed a commit to branch preprocess
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 6cb86b3303ec686911878bfd7ce538a0fdb686e1
Author: Jennifer Dai <jd...@linkedin.com>
AuthorDate: Mon Sep 23 13:33:54 2019 -0700
Preprocess changes
---
.../pinot/hadoop/job/SegmentPreprocessingJob.java | 25 +++++++++++++++------
.../.On_Time_On_Time_Performance_2014_10.avro.crc | Bin 0 -> 41552 bytes
.../On_Time_On_Time_Performance_2014_10.avro | Bin 0 -> 5317292 bytes
.../AirTime.dict | Bin 0 -> 1444 bytes
.../AirTime.sv.unsorted.fwd | Bin 0 -> 10454 bytes
.../ArrDel15.dict | Bin 0 -> 12 bytes
.../ArrDel15.sv.unsorted.fwd | Bin 0 -> 2323 bytes
.../DaysSinceEpoch.dict | Bin 0 -> 124 bytes
.../DaysSinceEpoch.sv.sorted.fwd | Bin 0 -> 248 bytes
.../DepTime.dict | Bin 0 -> 4516 bytes
.../DepTime.sv.unsorted.fwd | Bin 0 -> 12777 bytes
.../DepTimeBlk.dict | 1 +
.../DepTimeBlk.sv.unsorted.fwd | Bin 0 -> 5808 bytes
.../DestCityMarketID.dict | Bin 0 -> 1048 bytes
.../DestCityMarketID.sv.unsorted.fwd | Bin 0 -> 10454 bytes
.../DivActualElapsedTime.dict | Bin 0 -> 1388 bytes
.../DivActualElapsedTime.sv.unsorted.fwd | Bin 0 -> 10454 bytes
.../DivAirportSeqIDs.dict | Bin 0 -> 600 bytes
.../DivAirportSeqIDs.mv.fwd | Bin 0 -> 52360 bytes
.../DivTotalGTimes.dict | Bin 0 -> 1040 bytes
.../DivTotalGTimes.mv.fwd | Bin 0 -> 52360 bytes
.../DivWheelsOffs.dict | Bin 0 -> 2068 bytes
.../DivWheelsOffs.mv.fwd | Bin 0 -> 63975 bytes
.../DivWheelsOns.dict | Bin 0 -> 2348 bytes
.../DivWheelsOns.mv.fwd | Bin 0 -> 63975 bytes
.../FlightNum.dict | Bin 0 -> 18188 bytes
.../FlightNum.sv.unsorted.fwd | Bin 0 -> 15100 bytes
.../LateAircraftDelay.dict | Bin 0 -> 616 bytes
.../LateAircraftDelay.sv.unsorted.fwd | Bin 0 -> 9292 bytes
.../Month.dict | Bin 0 -> 4 bytes
.../Origin.dict | 1 +
.../Origin.sv.unsorted.fwd | Bin 0 -> 10454 bytes
.../Quarter.dict | Bin 0 -> 4 bytes
.../Quarter.sv.sorted.fwd | Bin 0 -> 8 bytes
34 files changed, 20 insertions(+), 7 deletions(-)
diff --git a/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/SegmentPreprocessingJob.java b/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/SegmentPreprocessingJob.java
index 942fb6d..83381fc 100644
--- a/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/SegmentPreprocessingJob.java
+++ b/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/SegmentPreprocessingJob.java
@@ -27,6 +27,7 @@ import java.util.Map;
import java.util.Properties;
import java.util.Set;
import java.util.zip.GZIPInputStream;
+import javax.annotation.Nullable;
import org.apache.avro.Schema;
import org.apache.avro.file.DataFileStream;
import org.apache.avro.generic.GenericDatumReader;
@@ -87,7 +88,7 @@ public class SegmentPreprocessingJob extends BaseSegmentJob {
private final Path _inputSegmentDir;
private final Path _preprocessedOutputDir;
protected final String _rawTableName;
- protected final List<PushLocation> _pushLocations;
+ protected List<PushLocation> _pushLocations;
// Optional.
private final Path _pathToDependencyJar;
@@ -115,9 +116,7 @@ public class SegmentPreprocessingJob extends BaseSegmentJob {
_pushLocations =
PushLocation.getPushLocations(StringUtils.split(pushHostsString, ','), Integer.parseInt(pushPortString));
} else {
- throw new RuntimeException(String
- .format("Push location is mis-configured! %s: %s, %s: %s", JobConfigConstants.PUSH_TO_HOSTS, pushHostsString,
- JobConfigConstants.PUSH_TO_PORT, pushPortString));
+ _pushLocations = null;
}
_logger.info("*********************************************************************");
@@ -375,13 +374,25 @@ public class SegmentPreprocessingJob extends BaseSegmentJob {
fieldSet.add(hashCodeField);
}
+ /**
+ * Can be overridden to provide custom controller Rest API.
+ */
+ @Nullable
+ protected ControllerRestApi getControllerRestApi() {
+ return _pushLocations != null ? new DefaultControllerRestApi(_pushLocations, _rawTableName) : null;
+ }
+
private void setTableConfigAndSchema() throws IOException {
// If push locations, table config, and schema are not configured, this does not necessarily mean that segments
// cannot be created. We should allow the user to go to the next step rather than failing the job.
Preconditions.checkState(!_pushLocations.isEmpty(), "Push locations cannot be empty.");
- try(ControllerRestApi controllerRestApi = new DefaultControllerRestApi(_pushLocations, _rawTableName)) {
- _tableConfig = controllerRestApi.getTableConfig();
- _pinotTableSchema = controllerRestApi.getSchema();
+ try(ControllerRestApi controllerRestApi = getControllerRestApi()) {
+ if (controllerRestApi != null) {
+ _tableConfig = controllerRestApi.getTableConfig();
+ _pinotTableSchema = controllerRestApi.getSchema();
+ } else {
+ throw new RuntimeException("Controller REST API not initialized");
+ }
}
Preconditions.checkState(_tableConfig != null, "Table config cannot be null.");
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/inputData/.On_Time_On_Time_Performance_2014_10.avro.crc b/pinot-integration-tests/pinot_hadoop_tmp/inputData/.On_Time_On_Time_Performance_2014_10.avro.crc
new file mode 100644
index 0000000..eda2ff5
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/inputData/.On_Time_On_Time_Performance_2014_10.avro.crc differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/inputData/On_Time_On_Time_Performance_2014_10.avro b/pinot-integration-tests/pinot_hadoop_tmp/inputData/On_Time_On_Time_Performance_2014_10.avro
new file mode 100644
index 0000000..1e54c9f
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/inputData/On_Time_On_Time_Performance_2014_10.avro differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/AirTime.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/AirTime.dict
new file mode 100644
index 0000000..bcf7eb1
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/AirTime.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/AirTime.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/AirTime.sv.unsorted.fwd
new file mode 100644
index 0000000..bbef441
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/AirTime.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/ArrDel15.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/ArrDel15.dict
new file mode 100644
index 0000000..15f1f37
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/ArrDel15.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/ArrDel15.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/ArrDel15.sv.unsorted.fwd
new file mode 100644
index 0000000..3c2da8a
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/ArrDel15.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DaysSinceEpoch.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DaysSinceEpoch.dict
new file mode 100644
index 0000000..7c44f0d
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DaysSinceEpoch.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DaysSinceEpoch.sv.sorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DaysSinceEpoch.sv.sorted.fwd
new file mode 100644
index 0000000..d6a47f8
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DaysSinceEpoch.sv.sorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTime.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTime.dict
new file mode 100644
index 0000000..754b16b
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTime.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTime.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTime.sv.unsorted.fwd
new file mode 100644
index 0000000..269a9e4
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTime.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTimeBlk.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTimeBlk.dict
new file mode 100644
index 0000000..40ec41f
--- /dev/null
+++ b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTimeBlk.dict
@@ -0,0 +1 @@
+0001-05590600-06590700-07590800-08590900-09591000-10591100-11591200-12591300-13591400-14591500-15591600-16591700-17591800-18591900-19592000-20592100-21592200-22592300-2359
\ No newline at end of file
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTimeBlk.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTimeBlk.sv.unsorted.fwd
new file mode 100644
index 0000000..f9979c0
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DepTimeBlk.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DestCityMarketID.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DestCityMarketID.dict
new file mode 100644
index 0000000..2fbc489
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DestCityMarketID.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DestCityMarketID.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DestCityMarketID.sv.unsorted.fwd
new file mode 100644
index 0000000..bbef441
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DestCityMarketID.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivActualElapsedTime.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivActualElapsedTime.dict
new file mode 100644
index 0000000..9d1e75c
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivActualElapsedTime.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivActualElapsedTime.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivActualElapsedTime.sv.unsorted.fwd
new file mode 100644
index 0000000..bbef441
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivActualElapsedTime.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivAirportSeqIDs.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivAirportSeqIDs.dict
new file mode 100644
index 0000000..e7af4fe
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivAirportSeqIDs.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivAirportSeqIDs.mv.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivAirportSeqIDs.mv.fwd
new file mode 100644
index 0000000..4217f13
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivAirportSeqIDs.mv.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivTotalGTimes.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivTotalGTimes.dict
new file mode 100644
index 0000000..dfe2bc0
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivTotalGTimes.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivTotalGTimes.mv.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivTotalGTimes.mv.fwd
new file mode 100644
index 0000000..4217f13
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivTotalGTimes.mv.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOffs.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOffs.dict
new file mode 100644
index 0000000..a885756
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOffs.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOffs.mv.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOffs.mv.fwd
new file mode 100644
index 0000000..e97a2a4
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOffs.mv.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOns.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOns.dict
new file mode 100644
index 0000000..4e2d4f8
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOns.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOns.mv.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOns.mv.fwd
new file mode 100644
index 0000000..e97a2a4
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/DivWheelsOns.mv.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/FlightNum.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/FlightNum.dict
new file mode 100644
index 0000000..6fc66e7
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/FlightNum.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/FlightNum.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/FlightNum.sv.unsorted.fwd
new file mode 100644
index 0000000..47efb45
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/FlightNum.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/LateAircraftDelay.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/LateAircraftDelay.dict
new file mode 100644
index 0000000..d19e9b0
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/LateAircraftDelay.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/LateAircraftDelay.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/LateAircraftDelay.sv.unsorted.fwd
new file mode 100644
index 0000000..66600b6
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/LateAircraftDelay.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Month.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Month.dict
new file mode 100644
index 0000000..aa315f1
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Month.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Origin.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Origin.dict
new file mode 100644
index 0000000..cf26551
--- /dev/null
+++ b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Origin.dict
@@ -0,0 +1 @@
+ABEABIABQABRABYACKACTACVACYADQAEXAGSALBALOAMAANCAPNASEATLATWAUSAVLAVPAZOBDLBETBFLBGRBHMBILBISBJIBMIBNABOIBOSBPTBQKBQNBROBRWBTMBTRBTVBUFBURBWIBZNCAECAKCDCCDVCECCHACHOCHSCICCIDCLDCLECLLCLTCMHCMICMXCNYCODCOSCOUCPRCRPCRWCVGCWADABDALDAYDBQDCADENDFWDHNDIKDLHDRODSMDTWDVLEAUECPEKOELMELPERIEUGEVVEWNEWREYWFAIFARFATFAYFCAFLGFLLFNTFSDFSMFWAGCCGCKGEGGJTGNVGPTGRBGRIGRKGRRGSOGSPGTFGTRGUCGUMHIBHLNHNLHOUHPNHRLHSVHYSIADIAHICTIDAILGILMIMTINDINLISNISPITOJACJANJAXJFKJLNJNUKOAKTNLANLARLASLAWLAXLBBLCHLEXLFTLGA [...]
\ No newline at end of file
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Origin.sv.unsorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Origin.sv.unsorted.fwd
new file mode 100644
index 0000000..bbef441
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Origin.sv.unsorted.fwd differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Quarter.dict b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Quarter.dict
new file mode 100644
index 0000000..ded2df2
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Quarter.dict differ
diff --git a/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Quarter.sv.sorted.fwd b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Quarter.sv.sorted.fwd
new file mode 100644
index 0000000..1b1cb4d
Binary files /dev/null and b/pinot-integration-tests/pinot_hadoop_tmp/segments/tmp-1568139829380--6120390252134451091/Quarter.sv.sorted.fwd differ
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org