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 fc2c98b517cf4ae297176a5e6c54c3cd820664f2 Author: Jennifer Dai <[email protected]> AuthorDate: Mon Sep 23 13:33:54 2019 -0700 Preprocess changes --- .../pinot/hadoop/job/SegmentPreprocessingJob.java | 51 ++++++++++++++++++--- .../.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, 46 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..89946ed 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,51 @@ 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; + } + + @Nullable + protected TableConfig getTableConfig() + throws IOException { + try (ControllerRestApi controllerRestApi = getControllerRestApi()) { + return controllerRestApi != null ? controllerRestApi.getTableConfig() : null; + } + } + + protected org.apache.pinot.common.data.Schema getSchema() + throws IOException { + try (ControllerRestApi controllerRestApi = getControllerRestApi()) { + if (controllerRestApi != null) { + return controllerRestApi.getSchema(); + } else { + throw new RuntimeException("Could not get schema"); + } + } + } + + /** + * Can be overridden to set additional job properties. + */ + @SuppressWarnings("unused") + protected void addAdditionalJobProperties(Job job) { + } + 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: [email protected] For additional commands, e-mail: [email protected]
