[NO ISSUE] Incremental cleanup of deprecated exception ctors Change-Id: I1e7c3655828fc6530cef83ea502a6cfbf41acddf Reviewed-on: https://asterix-gerrit.ics.uci.edu/2533 Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Contrib: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Reviewed-by: Murtadha Hubail <mhub...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/6453ecf2 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/6453ecf2 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/6453ecf2 Branch: refs/heads/release-0.9.4-pre-rc Commit: 6453ecf2f0dff1ec1306c8c5c1e4f81a27755431 Parents: f3784bb Author: Michael Blow <mb...@apache.org> Authored: Tue Mar 27 00:00:28 2018 -0400 Committer: Michael Blow <mb...@apache.org> Committed: Tue Mar 27 14:32:35 2018 -0700 ---------------------------------------------------------------------- .../asterix/app/result/ResultPrinter.java | 4 ++-- .../asterix/app/translator/QueryTranslator.java | 2 +- .../src/test/resources/runtimets/testsuite.xml | 4 ++-- .../common/config/AsterixProperties.java | 2 +- .../context/PrimaryIndexOperationTracker.java | 2 +- .../LSMInsertDeleteOperatorNodePushable.java | 2 +- .../dataflow/FeedStreamDataFlowController.java | 2 +- .../dataflow/RecordDataFlowController.java | 2 +- .../dataflow/StreamDataFlowController.java | 2 +- .../external/dataset/adapter/LookupAdapter.java | 4 ++-- .../external/feed/dataflow/FrameSpiller.java | 6 +++--- .../external/indexing/FileOffsetIndexer.java | 4 ++-- .../external/indexing/IndexingScheduler.java | 6 +++--- .../indexing/RecordColumnarIndexer.java | 4 ++-- .../external/input/HDFSDataSourceFactory.java | 2 +- .../record/reader/hdfs/HDFSRecordReader.java | 2 +- .../reader/rss/RSSRecordReaderFactory.java | 2 +- .../stream/StreamRecordReaderFactory.java | 4 +--- .../reader/twitter/TwitterPullRecordReader.java | 2 +- .../twitter/TwitterRecordReaderFactory.java | 2 +- .../external/input/stream/HDFSInputStream.java | 2 +- .../library/ExternalFunctionProvider.java | 6 +++--- .../external/library/java/base/JObject.java | 2 +- .../external/library/java/base/JRecord.java | 2 +- ...xternalDatasetIndexesOperatorDescriptor.java | 2 +- ...ExternalBTreeSearchOperatorNodePushable.java | 2 +- ...rnalIndexBulkModifyOperatorNodePushable.java | 2 +- .../ExternalLookupOperatorDescriptor.java | 6 +++--- ...ExternalRTreeSearchOperatorNodePushable.java | 4 ++-- .../ExternalScanOperatorDescriptor.java | 2 +- .../FeedCollectOperatorNodePushable.java | 2 +- .../operators/FeedMetaComputeNodePushable.java | 4 ++-- .../operators/FeedMetaStoreNodePushable.java | 2 +- .../external/parser/DelimitedDataParser.java | 8 +++---- .../external/parser/HiveRecordParser.java | 6 +++--- .../parser/RecordWithMetadataParser.java | 4 ++-- .../external/parser/RecordWithPKDataParser.java | 2 +- .../asterix/external/parser/TweetParser.java | 2 +- .../provider/DataflowControllerProvider.java | 2 +- .../asterix/external/util/FeedLogManager.java | 2 +- .../external/util/FileSystemWatcher.java | 2 +- .../asterix/external/classad/ClassAd.java | 2 +- .../asterix/external/library/ClassAdParser.java | 4 ++-- .../common/EditDistanceCheckEvaluator.java | 2 +- .../common/EditDistanceEvaluator.java | 2 +- .../evaluators/common/GramTokensEvaluator.java | 2 +- .../common/SimilarityJaccardCheckEvaluator.java | 2 +- .../common/SimilarityJaccardEvaluator.java | 2 +- .../SimilarityJaccardPrefixEvaluator.java | 2 +- .../evaluators/common/WordTokensEvaluator.java | 2 +- .../EditDistanceListIsFilterableDescriptor.java | 2 +- ...EditDistanceStringIsFilterableEvaluator.java | 2 +- .../functions/PrefixLenDescriptor.java | 2 +- .../functions/PrefixLenJaccardDescriptor.java | 2 +- .../DatatypeTupleTranslator.java | 2 +- .../asterix/builders/AbstractListBuilder.java | 2 +- .../apache/asterix/builders/RecordBuilder.java | 2 +- .../data/nontagged/MissingWriterFactory.java | 2 +- .../hash/ListItemBinaryHashFunctionFactory.java | 2 +- .../data/nontagged/printers/PrintTools.java | 12 +++++------ .../printers/adm/ABinaryHexPrinterFactory.java | 2 +- .../printers/adm/AInt16PrinterFactory.java | 2 +- .../printers/adm/AInt32PrinterFactory.java | 2 +- .../printers/adm/AInt64PrinterFactory.java | 2 +- .../printers/adm/AInt8PrinterFactory.java | 2 +- .../printers/adm/AStringPrinterFactory.java | 2 +- .../printers/csv/ABinaryHexPrinterFactory.java | 2 +- .../printers/csv/AStringPrinterFactory.java | 2 +- .../json/clean/ABinaryHexPrinterFactory.java | 2 +- .../json/clean/AStringPrinterFactory.java | 2 +- .../clean/AUnorderedlistPrinterFactory.java | 2 +- .../json/lossless/ABinaryHexPrinterFactory.java | 2 +- .../json/lossless/AStringPrinterFactory.java | 2 +- .../lossless/AUnorderedlistPrinterFactory.java | 2 +- .../SerializerDeserializerProvider.java | 2 +- .../java/org/apache/asterix/om/base/AUUID.java | 4 ++-- .../om/base/temporal/ADateParserFactory.java | 2 +- .../base/temporal/ADateTimeParserFactory.java | 2 +- .../base/temporal/ADurationParserFactory.java | 2 +- .../om/base/temporal/ATimeParserFactory.java | 2 +- .../om/base/temporal/DateTimeFormatUtils.java | 2 +- .../ListifyAggregateFunctionEvalFactory.java | 4 ++-- ...bstractSerializableAvgAggregateFunction.java | 6 +++--- ...tractSerializableCountAggregateFunction.java | 4 ++-- ...bstractSerializableSumAggregateFunction.java | 4 ++-- .../std/AbstractAvgAggregateFunction.java | 4 ++-- .../std/AbstractCountAggregateFunction.java | 2 +- .../std/AbstractMinMaxAggregateFunction.java | 6 +++--- .../std/AbstractSumAggregateFunction.java | 2 +- .../accessors/CircleCenterAccessor.java | 2 +- .../accessors/CircleRadiusAccessor.java | 2 +- .../accessors/LineRectanglePolygonAccessor.java | 2 +- .../accessors/PointXCoordinateAccessor.java | 2 +- .../accessors/PointYCoordinateAccessor.java | 2 +- .../accessors/TemporalDayAccessor.java | 2 +- .../accessors/TemporalHourAccessor.java | 2 +- .../accessors/TemporalIntervalEndAccessor.java | 2 +- .../TemporalIntervalEndDateAccessor.java | 2 +- .../TemporalIntervalEndDatetimeAccessor.java | 2 +- .../TemporalIntervalEndTimeAccessor.java | 2 +- .../TemporalIntervalStartAccessor.java | 2 +- .../TemporalIntervalStartDateAccessor.java | 2 +- .../TemporalIntervalStartDatetimeAccessor.java | 2 +- .../TemporalIntervalStartTimeAccessor.java | 2 +- .../accessors/TemporalMillisecondAccessor.java | 2 +- .../accessors/TemporalMinuteAccessor.java | 2 +- .../accessors/TemporalMonthAccessor.java | 2 +- .../accessors/TemporalSecondAccessor.java | 2 +- .../accessors/TemporalYearAccessor.java | 2 +- .../evaluators/common/CreateMBREvalFactory.java | 2 +- .../common/FullTextContainsEvaluator.java | 4 ++-- .../OrderedListConstructorDescriptor.java | 6 +++--- .../UnorderedListConstructorDescriptor.java | 6 +++--- .../functions/AbstractBinaryStringEval.java | 2 +- .../functions/AbstractQuadStringStringEval.java | 2 +- .../AbstractUnaryNumericFunctionEval.java | 2 +- .../AbstractUnaryStringStringEval.java | 2 +- .../functions/CreateCircleDescriptor.java | 2 +- .../functions/CreateLineDescriptor.java | 2 +- .../functions/CreatePointDescriptor.java | 2 +- .../functions/CreateRectangleDescriptor.java | 2 +- .../functions/DeepEqualityDescriptor.java | 2 +- .../evaluators/functions/LenDescriptor.java | 2 +- .../functions/SpatialAreaDescriptor.java | 2 +- .../functions/SpatialCellDescriptor.java | 2 +- .../functions/SpatialDistanceDescriptor.java | 2 +- .../functions/StringLengthDescriptor.java | 2 +- .../functions/StringRepeatDescriptor.java | 2 +- .../functions/StringSplitDescriptor.java | 2 +- .../functions/StringToCodePointDescriptor.java | 2 +- .../functions/Substring2Descriptor.java | 4 ++-- .../functions/SubstringAfterDescriptor.java | 2 +- .../functions/SubstringBeforeDescriptor.java | 2 +- .../functions/SubstringDescriptor.java | 4 ++-- .../binary/AbstractSubBinaryEvaluator.java | 2 +- .../functions/binary/PrintBinaryDescriptor.java | 2 +- .../records/GetRecordFieldsEvalFactory.java | 3 +-- .../records/RecordConcatEvalFactory.java | 4 ++-- .../records/RecordMergeDescriptor.java | 2 +- .../records/RecordPairsDescriptor.java | 2 +- .../records/RecordRemoveFieldsEvalFactory.java | 2 +- .../AdjustDateTimeForTimeZoneDescriptor.java | 2 +- .../AdjustTimeForTimeZoneDescriptor.java | 2 +- .../temporal/OverlapBinsDescriptor.java | 2 +- .../functions/temporal/PrintDateDescriptor.java | 2 +- .../temporal/PrintDateTimeDescriptor.java | 2 +- .../functions/temporal/PrintTimeDescriptor.java | 2 +- .../LSMPrimaryUpsertOperatorNodePushable.java | 4 ++-- .../std/SubsetCollectionDescriptor.java | 2 +- .../LockThenSearchOperationCallbackFactory.java | 2 +- ...maryIndexInstantSearchOperationCallback.java | 2 +- ...exInstantSearchOperationCallbackFactory.java | 2 +- .../PrimaryIndexSearchOperationCallback.java | 4 ++-- ...maryIndexSearchOperationCallbackFactory.java | 2 +- ...xInstanctSearchOperationCallbackFactory.java | 2 +- ...daryIndexInstantSearchOperationCallback.java | 2 +- ...ndaryIndexModificationOperationCallback.java | 2 +- .../UpsertOperationCallbackFactory.java | 2 +- .../management/runtime/CommitRuntime.java | 6 +++--- .../data/impl/IntegerPrinterFactory.java | 3 +-- .../data/impl/UTF8StringPrinterFactory.java | 2 +- .../TupleCountAggregateFunctionFactory.java | 2 +- ...pleCountRunningAggregateFunctionFactory.java | 2 +- .../operators/std/SinkWriterRuntimeFactory.java | 2 +- .../operators/std/SplitOperatorDescriptor.java | 2 +- .../std/StringStreamingRuntimeFactory.java | 2 +- .../operators/std/UnnestRuntimeFactory.java | 2 +- .../writers/SerializedDataWriterFactory.java | 2 +- .../tests/pushruntime/IntArrayUnnester.java | 2 +- .../pushruntime/IntegerAddEvalFactory.java | 3 +-- .../hyracks/api/client/HyracksConnection.java | 4 ++-- .../api/exceptions/HyracksDataException.java | 22 +------------------- .../api/exceptions/HyracksException.java | 20 ++---------------- .../api/job/JobSerializerDeserializer.java | 6 +++--- .../api/test/TestControlledFrameWriter.java | 2 +- .../hyracks/api/test/TestFrameWriter.java | 2 +- .../hyracks/client/dataset/HyracksDataset.java | 2 +- .../channels/DatasetNetworkInputChannel.java | 2 +- .../comm/channels/NetworkInputChannel.java | 2 +- .../comm/channels/NetworkOutputChannel.java | 2 +- .../control/cc/ClusterControllerService.java | 2 +- .../control/cc/executor/JobExecutor.java | 2 +- .../hyracks/control/cc/job/JobManager.java | 2 +- .../ClassLoaderJobSerializerDeserializer.java | 8 +++---- .../common/deployment/DeploymentUtils.java | 8 +++---- .../hyracks/control/common/work/WorkQueue.java | 2 +- .../nc/dataset/DatasetPartitionWriter.java | 2 +- .../hyracks/control/nc/dataset/ResultState.java | 6 +++--- .../apache/hyracks/control/nc/io/IOManager.java | 8 +++---- .../MaterializedPartitionInputChannel.java | 2 +- .../ReceiveSideMaterializingCollector.java | 2 +- .../ByteArraySerializerDeserializer.java | 4 ++-- .../parsers/ByteArrayBase64ParserFactory.java | 2 +- .../data/parsers/ByteArrayHexParserFactory.java | 2 +- .../data/parsers/DoubleParserFactory.java | 4 ++-- .../common/data/parsers/FloatParserFactory.java | 4 ++-- .../data/parsers/IntegerParserFactory.java | 2 +- .../common/data/parsers/LongParserFactory.java | 2 +- .../data/parsers/UTF8StringParserFactory.java | 2 +- .../AbstractReplicateOperatorDescriptor.java | 2 +- .../NonDeterministicChannelReader.java | 2 +- .../NonDeterministicPartitionBatchManager.java | 2 +- .../LocalityAwarePartitionDataWriter.java | 4 ++-- .../MToNBroadcastConnectorDescriptor.java | 2 +- ...tDeserializedFileScanOperatorDescriptor.java | 4 ++-- .../file/DelimitedDataTupleParserFactory.java | 2 +- .../std/file/FileRemoveOperatorDescriptor.java | 2 +- .../std/file/FileScanOperatorDescriptor.java | 4 ++-- .../file/FrameFileWriterOperatorDescriptor.java | 2 +- .../file/LineFileWriteOperatorDescriptor.java | 2 +- .../file/PlainFileWriterOperatorDescriptor.java | 4 ++-- .../hyracks/dataflow/std/file/RecordWriter.java | 2 +- .../MinMaxStringFieldAggregatorFactory.java | 2 +- .../std/group/external/ExternalHashGroupBy.java | 2 +- .../intersect/IntersectOperatorDescriptor.java | 2 +- ...ConstantTupleSourceOperatorNodePushable.java | 2 +- .../sort/InMemorySortOperatorDescriptor.java | 2 +- .../btree/helper/DataGenOperatorDescriptor.java | 2 +- ...onOnCreatePushRuntimeOperatorDescriptor.java | 2 +- .../tests/util/NoopMissingWriterFactory.java | 2 +- .../examples/text/WordTupleParserFactory.java | 2 +- .../hyracks/hdfs/MiniDFSClusterFactory.java | 2 +- .../hyracks/hdfs/MiniDFSClusterFactory.java | 2 +- .../dataflow/HDFSReadOperatorDescriptor.java | 4 ++-- .../dataflow/HDFSWriteOperatorDescriptor.java | 2 +- .../hdfs/dataflow/InputSplitsFactory.java | 2 +- .../hdfs/lib/TextTupleWriterFactory.java | 2 +- .../hyracks/hdfs/scheduler/Scheduler.java | 8 +++---- .../hdfs2/dataflow/FileSplitsFactory.java | 2 +- .../dataflow/HDFSReadOperatorDescriptor.java | 4 ++-- .../dataflow/HDFSWriteOperatorDescriptor.java | 2 +- .../hyracks/hdfs2/scheduler/Scheduler.java | 2 +- ...xInsertUpdateDeleteOperatorNodePushable.java | 4 ++-- .../IndexSearchOperatorNodePushable.java | 2 +- .../TreeIndexStatsOperatorNodePushable.java | 2 +- ...xInsertUpdateDeleteOperatorNodePushable.java | 2 +- .../lsm/common/impls/ExternalIndexHarness.java | 2 +- .../search/AbstractTOccurrenceSearcher.java | 2 +- .../InvertedIndexTokenizingTupleIterator.java | 2 +- ...nedInvertedIndexTokenizingTupleIterator.java | 2 +- .../hyracks/storage/am/rtree/impls/RTree.java | 2 +- 241 files changed, 317 insertions(+), 358 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/result/ResultPrinter.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/result/ResultPrinter.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/result/ResultPrinter.java index c8d25f1..a6d2da9 100644 --- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/result/ResultPrinter.java +++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/result/ResultPrinter.java @@ -123,7 +123,7 @@ public class ResultPrinter { try { output.resultPrefix(new AlgebricksAppendable(output.out())); } catch (AlgebricksException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } if (conf.is(SessionConfig.FORMAT_WRAPPER_ARRAY)) { @@ -155,7 +155,7 @@ public class ResultPrinter { try { output.resultPostfix(new AlgebricksAppendable(output.out())); } catch (AlgebricksException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } if (conf.is(SessionConfig.FORMAT_HTML)) { output.out().println("</pre>"); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java index aabb7c2..453bcb5 100644 --- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java +++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java @@ -2015,7 +2015,7 @@ public class QueryTranslator extends AbstractLangTranslator implements IStatemen MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); } catch (RemoteException | ACIDException e) { abort(e, e, mdTxnCtx); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { metadataProvider.getLocks().unlock(); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml b/asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml index a2108be..5c6b100 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml +++ b/asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml @@ -1689,13 +1689,13 @@ <test-case FilePath="dml"> <compilation-unit name="load-with-autogenerated-pk_adm_02"> <output-dir compare="Text">load-with-autogenerated-pk_adm_02</output-dir> - <expected-error>org.apache.asterix.external.parser.ADMDataParser$ParseException</expected-error> + <expected-error>ASX3058: This record is closed, you can not add extra fields! new field name: id [HyracksDataException]</expected-error> </compilation-unit> </test-case> <test-case FilePath="dml"> <compilation-unit name="load-with-autogenerated-pk_adm_03"> <output-dir compare="Text">load-with-autogenerated-pk_adm_03</output-dir> - <expected-error>org.apache.asterix.external.parser.ADMDataParser$ParseException</expected-error> + <expected-error>ASX3058: This record is closed, you can not add extra fields! new field name: id [HyracksDataException]</expected-error> </compilation-unit> </test-case> <test-case FilePath="dml"> http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/config/AsterixProperties.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/config/AsterixProperties.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/config/AsterixProperties.java index 2c981c9..d192b49 100644 --- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/config/AsterixProperties.java +++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/config/AsterixProperties.java @@ -44,7 +44,7 @@ public class AsterixProperties { try { PropertiesAccessor.getInstance(configManager.getAppConfig()); } catch (AsterixException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } }); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/PrimaryIndexOperationTracker.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/PrimaryIndexOperationTracker.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/PrimaryIndexOperationTracker.java index 47f7ae8..74848d5 100644 --- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/PrimaryIndexOperationTracker.java +++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/PrimaryIndexOperationTracker.java @@ -148,7 +148,7 @@ public class PrimaryIndexOperationTracker extends BaseOperationTracker { try { logManager.log(logRecord); } catch (ACIDException e) { - throw new HyracksDataException("could not write flush log", e); + throw new IllegalStateException("could not write flush log", e); } flushLogCreated = true; } else { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/dataflow/LSMInsertDeleteOperatorNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/dataflow/LSMInsertDeleteOperatorNodePushable.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/dataflow/LSMInsertDeleteOperatorNodePushable.java index 3879fb8..b3936de 100644 --- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/dataflow/LSMInsertDeleteOperatorNodePushable.java +++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/dataflow/LSMInsertDeleteOperatorNodePushable.java @@ -100,7 +100,7 @@ public class LSMInsertDeleteOperatorNodePushable extends LSMIndexInsertUpdateDel (INcApplicationContext) ctx.getJobletContext().getServiceContext().getApplicationContext(); LSMIndexUtil.checkAndSetFirstLSN(lsmIndex, runtimeCtx.getTransactionSubsystem().getLogManager()); } catch (Throwable th) { - throw new HyracksDataException(th); + throw HyracksDataException.create(th); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java index ffa42e5..4deb422 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java @@ -77,7 +77,7 @@ public class FeedStreamDataFlowController extends AbstractFeedDataFlowController } stream.close(); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } return false; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RecordDataFlowController.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RecordDataFlowController.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RecordDataFlowController.java index aebdefb..9d72581 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RecordDataFlowController.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RecordDataFlowController.java @@ -56,7 +56,7 @@ public class RecordDataFlowController<T> extends AbstractDataFlowController { tupleForwarder.complete(); recordReader.close(); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/StreamDataFlowController.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/StreamDataFlowController.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/StreamDataFlowController.java index a28c484..8275953 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/StreamDataFlowController.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/StreamDataFlowController.java @@ -47,7 +47,7 @@ public class StreamDataFlowController extends AbstractDataFlowController { } tupleForwarder.complete(); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/LookupAdapter.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/LookupAdapter.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/LookupAdapter.java index aeeb04d..82e9bba 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/LookupAdapter.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/LookupAdapter.java @@ -98,7 +98,7 @@ public final class LookupAdapter<T> implements IFrameWriter { try { recordReader.fail(); } catch (Throwable th) { - throw new HyracksDataException(th); + throw HyracksDataException.create(th); } finally { writer.fail(); } @@ -138,7 +138,7 @@ public final class LookupAdapter<T> implements IFrameWriter { tupleIndex++; } } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameSpiller.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameSpiller.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameSpiller.java index e3630d3..c3aa36f 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameSpiller.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameSpiller.java @@ -79,7 +79,7 @@ public class FrameSpiller { this.bis = new BufferedInputStream(new FileInputStream(currentReadFile)); } catch (Exception e) { LOGGER.fatal("Unable to create spill file", e); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -129,7 +129,7 @@ public class FrameSpiller { } return frame.getBuffer(); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { synchronized (this) { notify(); @@ -160,7 +160,7 @@ public class FrameSpiller { return true; } catch (IOException e) { close(); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/FileOffsetIndexer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/FileOffsetIndexer.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/FileOffsetIndexer.java index a5bff74..34c8795 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/FileOffsetIndexer.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/FileOffsetIndexer.java @@ -56,7 +56,7 @@ public class FileOffsetIndexer implements IExternalIndexer { recordReader = dataSource.getReader(); offset.setValue(recordReader.getPos()); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -68,7 +68,7 @@ public class FileOffsetIndexer implements IExternalIndexer { // Get position for next index(tb) call offset.setValue(recordReader.getPos()); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/IndexingScheduler.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/IndexingScheduler.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/IndexingScheduler.java index a788a29..edac0fa 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/IndexingScheduler.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/IndexingScheduler.java @@ -68,7 +68,7 @@ public class IndexingScheduler { this.ncNameToNcInfos = hcc.getNodeControllerInfos(); loadIPAddressToNCMap(ncNameToNcInfos); } catch (Exception e) { - throw new HyracksException(e); + throw HyracksException.create(e); } } @@ -136,7 +136,7 @@ public class IndexingScheduler { scheduleNonLocalSlots(splits, workloads, locations, upperBoundSlots, scheduled, locationToNumOfAssignement); return locations; } catch (IOException e) { - throw new HyracksException(e); + throw HyracksException.create(e); } } @@ -325,7 +325,7 @@ public class IndexingScheduler { ncNameToIndex.put(NCs[i], i); } } catch (Exception e) { - throw new HyracksException(e); + throw HyracksException.create(e); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/RecordColumnarIndexer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/RecordColumnarIndexer.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/RecordColumnarIndexer.java index e6146d4..6cecc20 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/RecordColumnarIndexer.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/RecordColumnarIndexer.java @@ -64,7 +64,7 @@ public class RecordColumnarIndexer implements IExternalIndexer { nextOffset = offset.getLongValue(); rowNumber.setValue(0); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -82,7 +82,7 @@ public class RecordColumnarIndexer implements IExternalIndexer { tb.addField(intSerde, rowNumber); rowNumber.setValue(rowNumber.getIntegerValue() + 1); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java index 982cf5b..f830376 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java @@ -215,7 +215,7 @@ public class HDFSDataSourceFactory implements IRecordReaderFactory<Object>, IInd restoreConfig(ctx); return new HDFSRecordReader<>(read, inputSplits, readSchedule, nodeName, conf, files, indexer); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSRecordReader.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSRecordReader.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSRecordReader.java index 3500d32..5b3d04f 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSRecordReader.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSRecordReader.java @@ -145,7 +145,7 @@ public class HDFSRecordReader<K, V extends Writable> implements IRecordReader<Wr try { indexer.reset(this); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } return reader; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReaderFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReaderFactory.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReaderFactory.java index 6291ba1..2c07c35 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReaderFactory.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReaderFactory.java @@ -93,7 +93,7 @@ public class RSSRecordReaderFactory implements IRecordReaderFactory<SyndEntry> { try { return new RSSRecordReader(urls.get(partition)); } catch (MalformedURLException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/StreamRecordReaderFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/StreamRecordReaderFactory.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/StreamRecordReaderFactory.java index 776aa0c..f8cf648 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/StreamRecordReaderFactory.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/StreamRecordReaderFactory.java @@ -24,10 +24,8 @@ import java.util.Collections; import java.util.List; import java.util.Map; -import org.apache.asterix.common.exceptions.AsterixException; import org.apache.asterix.common.exceptions.CompilationException; import org.apache.asterix.common.exceptions.ErrorCode; -import org.apache.asterix.external.api.AsterixInputStream; import org.apache.asterix.external.api.IInputStreamFactory; import org.apache.asterix.external.api.IRecordReader; import org.apache.asterix.external.api.IRecordReaderFactory; @@ -100,7 +98,7 @@ public class StreamRecordReaderFactory implements IRecordReaderFactory<char[]> { return streamRecordReader; } catch (InstantiationException | IllegalAccessException | InvocationTargetException | NoSuchMethodException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java index bb9d8c9..2cf5396 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java @@ -72,7 +72,7 @@ public class TwitterPullRecordReader implements IRecordReader<String> { try { result = twitter.search(query); } catch (TwitterException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } nextTweetIndex = 0; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterRecordReaderFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterRecordReaderFactory.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterRecordReaderFactory.java index 8182dcd..8774762 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterRecordReaderFactory.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterRecordReaderFactory.java @@ -146,7 +146,7 @@ public class TwitterRecordReaderFactory implements IRecordReaderFactory<String> : new TwitterPushRecordReader(TwitterUtil.getTwitterStream(configuration), TwitterUtil.getTweetListener(), query); } catch (AsterixException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } break; case ExternalDataConstants.READER_USER_STREAM_TWITTER: http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/HDFSInputStream.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/HDFSInputStream.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/HDFSInputStream.java index 997c254..4cbfaa3 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/HDFSInputStream.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/HDFSInputStream.java @@ -206,7 +206,7 @@ public class HDFSInputStream extends AsterixInputStream implements IIndexingData try { indexer.reset(this); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } return reader; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/ExternalFunctionProvider.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/ExternalFunctionProvider.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/ExternalFunctionProvider.java index 9e8b9b7..05124dd 100755 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/ExternalFunctionProvider.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/ExternalFunctionProvider.java @@ -57,7 +57,7 @@ class ExternalScalarFunction extends ExternalFunction implements IExternalScalar try { initialize(functionHelper); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -69,7 +69,7 @@ class ExternalScalarFunction extends ExternalFunction implements IExternalScalar result.set(resultBuffer.getByteArray(), resultBuffer.getStartOffset(), resultBuffer.getLength()); functionHelper.reset(); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -82,7 +82,7 @@ class ExternalScalarFunction extends ExternalFunction implements IExternalScalar throw new RuntimeDataException(ErrorCode.EXTERNAL_UDF_RESULT_TYPE_ERROR); } } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JObject.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JObject.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JObject.java index 7338b31..411da33 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JObject.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JObject.java @@ -49,7 +49,7 @@ public abstract class JObject implements IJObject { try { dataOutput.writeByte(typeTag.serialize()); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JRecord.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JRecord.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JRecord.java index 2792cb4..7fa9d0b 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JRecord.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/library/java/base/JRecord.java @@ -147,7 +147,7 @@ public final class JRecord implements IJObject { } } } catch (IOException ae) { - throw new HyracksDataException(ae); + throw HyracksDataException.create(ae); } recordBuilder.write(output, writeTypeTag); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java index 8d83b9a..4a7635c 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java @@ -68,7 +68,7 @@ public abstract class AbstractExternalDatasetIndexesOperatorDescriptor performOpOnIndex(indexHelper, ctx); } } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalBTreeSearchOperatorNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalBTreeSearchOperatorNodePushable.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalBTreeSearchOperatorNodePushable.java index a966bbe..80ebb4c 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalBTreeSearchOperatorNodePushable.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalBTreeSearchOperatorNodePushable.java @@ -87,7 +87,7 @@ public class ExternalBTreeSearchOperatorNodePushable extends BTreeSearchOperator frameTuple = new FrameTupleReference(); } } catch (Throwable th) { - throw new HyracksDataException(th); + throw HyracksDataException.create(th); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalIndexBulkModifyOperatorNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalIndexBulkModifyOperatorNodePushable.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalIndexBulkModifyOperatorNodePushable.java index 242773e..aaca3f1 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalIndexBulkModifyOperatorNodePushable.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalIndexBulkModifyOperatorNodePushable.java @@ -69,7 +69,7 @@ public class ExternalIndexBulkModifyOperatorNodePushable extends IndexBulkLoadOp ((ITwoPCIndexBulkLoader) bulkLoader).delete(deleteTuple); } } catch (Throwable e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java index c096f69..e54b3d2 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java @@ -78,7 +78,7 @@ public class ExternalLookupOperatorDescriptor extends AbstractSingleActivityOper indexOpen = true; adapter.open(); } catch (Throwable th) { - throw new HyracksDataException(th); + throw HyracksDataException.create(th); } } @@ -111,7 +111,7 @@ public class ExternalLookupOperatorDescriptor extends AbstractSingleActivityOper try { adapter.fail(); } catch (Throwable th) { - throw new HyracksDataException(th); + throw HyracksDataException.create(th); } } @@ -120,7 +120,7 @@ public class ExternalLookupOperatorDescriptor extends AbstractSingleActivityOper try { adapter.nextFrame(buffer); } catch (Throwable th) { - throw new HyracksDataException(th); + throw HyracksDataException.create(th); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalRTreeSearchOperatorNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalRTreeSearchOperatorNodePushable.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalRTreeSearchOperatorNodePushable.java index 4c02b16..0b294de 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalRTreeSearchOperatorNodePushable.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalRTreeSearchOperatorNodePushable.java @@ -65,7 +65,7 @@ public class ExternalRTreeSearchOperatorNodePushable extends RTreeSearchOperator try { nonMatchWriter.writeMissing(out); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } nonMatchTupleBuild.addFieldEndOffset(); } @@ -88,7 +88,7 @@ public class ExternalRTreeSearchOperatorNodePushable extends RTreeSearchOperator frameTuple = new FrameTupleReference(); } } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalScanOperatorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalScanOperatorDescriptor.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalScanOperatorDescriptor.java index 93acb26..081d49e 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalScanOperatorDescriptor.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalScanOperatorDescriptor.java @@ -62,7 +62,7 @@ public class ExternalScanOperatorDescriptor extends AbstractSingleActivityOperat adapter.start(partition, writer); } catch (Exception e) { writer.fail(); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } finally { writer.close(); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java index 121d262..4ea282f 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java @@ -68,7 +68,7 @@ public class FeedCollectOperatorNodePushable extends AbstractUnaryInputUnaryOutp writer = new SyncFeedRuntimeInputHandler(ctx, writer, tAccessor); } } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java index 477a777..6d95d26 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java @@ -121,7 +121,7 @@ public class FeedMetaComputeNodePushable extends AbstractUnaryInputUnaryOutputOp writer.open(); } catch (Exception e) { e.printStackTrace(); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -144,7 +144,7 @@ public class FeedMetaComputeNodePushable extends AbstractUnaryInputUnaryOutputOp writer.nextFrame(buffer); } catch (Exception e) { LOGGER.log(Level.WARN, e.getMessage(), e); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java index ecd28be..b9cfac4 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java @@ -120,7 +120,7 @@ public class FeedMetaStoreNodePushable extends AbstractUnaryInputUnaryOutputOper insertOperator.open(); } catch (Exception e) { LOGGER.log(Level.WARN, "Failed to open feed store operator", e); - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/DelimitedDataParser.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/DelimitedDataParser.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/DelimitedDataParser.java index a7dbc30..a770671 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/DelimitedDataParser.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/DelimitedDataParser.java @@ -114,7 +114,7 @@ public class DelimitedDataParser extends AbstractDataParser implements IStreamDa } return false; } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -129,7 +129,7 @@ public class DelimitedDataParser extends AbstractDataParser implements IStreamDa break; } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } fieldValueBuffer.reset(); @@ -162,7 +162,7 @@ public class DelimitedDataParser extends AbstractDataParser implements IStreamDa recBuilder.addField(fldIds[i], fieldValueBuffer); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } } @@ -172,7 +172,7 @@ public class DelimitedDataParser extends AbstractDataParser implements IStreamDa try { cursor.nextRecord(record.get(), record.size()); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } parseRecord(); if (!areAllNullFields) { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/HiveRecordParser.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/HiveRecordParser.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/HiveRecordParser.java index ffeb941..1a88d08 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/HiveRecordParser.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/HiveRecordParser.java @@ -104,7 +104,7 @@ public class HiveRecordParser implements IRecordDataParser<Writable> { Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -130,7 +130,7 @@ public class HiveRecordParser implements IRecordDataParser<Writable> { } recBuilder.write(out, true); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -187,7 +187,7 @@ public class HiveRecordParser implements IRecordDataParser<Writable> { throw new RuntimeDataException(ErrorCode.PARSER_HIVE_FIELD_TYPE, itemType.getTypeTag()); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithMetadataParser.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithMetadataParser.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithMetadataParser.java index c92ee12..6c9298e 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithMetadataParser.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithMetadataParser.java @@ -82,7 +82,7 @@ public class RecordWithMetadataParser<T, O> implements IRecordWithMetadataParser recordParser.parse(rwm.getRecord(), out); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -102,7 +102,7 @@ public class RecordWithMetadataParser<T, O> implements IRecordWithMetadataParser metaBuilder.write(out, true); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithPKDataParser.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithPKDataParser.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithPKDataParser.java index 1f9fef2..aa0db53 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithPKDataParser.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithPKDataParser.java @@ -42,7 +42,7 @@ public class RecordWithPKDataParser<T> implements IRecordWithPKDataParser<T> { try { out.writeByte(ATypeTag.SERIALIZED_NULL_TYPE_TAG); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } else { recordParser.parse(record, out); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/TweetParser.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/TweetParser.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/TweetParser.java index e1c961a..0183196 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/TweetParser.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/TweetParser.java @@ -259,7 +259,7 @@ public class TweetParser extends AbstractDataParser implements IRecordDataParser ObjectMapper om = new ObjectMapper(); writeRecord(om.readTree(record.get()), out, recordType); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java index 3e53b52..f9b012e 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java @@ -108,7 +108,7 @@ public class DataflowControllerProvider { dataSourceFactory.getDataSourceType()); } } catch (IOException | AsterixException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java index 42ebbd4..57c9e2c 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java @@ -71,7 +71,7 @@ public class FeedLogManager implements Closeable { } open(); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java index 74a20f5..919b74f 100644 --- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java +++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java @@ -101,7 +101,7 @@ public class FileSystemWatcher { } } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/classad/ClassAd.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/classad/ClassAd.java b/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/classad/ClassAd.java index bc24227..2b04bac 100644 --- a/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/classad/ClassAd.java +++ b/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/classad/ClassAd.java @@ -839,7 +839,7 @@ public class ClassAd extends ExprTree { successfully_evaluated = false; } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } return successfully_evaluated; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParser.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParser.java b/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParser.java index 2f9faed..d19f89f 100644 --- a/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParser.java +++ b/asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParser.java @@ -582,7 +582,7 @@ public class ClassAdParser extends AbstractDataParser implements IRecordDataPars aDuration.setValue(0, duration.getTimeVal().getRelativeTime()); durationSerde.serialize(aDuration, out); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } @@ -1770,7 +1770,7 @@ public class ClassAdParser extends AbstractDataParser implements IRecordDataPars } parseRecord(recordType, rootAd, out); } catch (Exception e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java index dece292..4cc4975 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java @@ -86,7 +86,7 @@ public class EditDistanceCheckEvaluator extends EditDistanceEvaluator { editDistance = computeResult(argPtr1, argPtr2, firstTypeTag); writeResult(editDistance); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java index 85fd334..c3af387 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java @@ -91,7 +91,7 @@ public class EditDistanceEvaluator implements IScalarEvaluator { try { writeResult(editDistance); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/GramTokensEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/GramTokensEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/GramTokensEvaluator.java index ef727c9..d60c311 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/GramTokensEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/GramTokensEvaluator.java @@ -88,7 +88,7 @@ public class GramTokensEvaluator implements IScalarEvaluator { } listBuilder.write(out, true); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java index 60b5592..19f7869 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java @@ -93,7 +93,7 @@ public class SimilarityJaccardCheckEvaluator extends SimilarityJaccardEvaluator try { writeResult(jaccSim); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java index 1e5ad3c..29d5eb3 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java @@ -129,7 +129,7 @@ public class SimilarityJaccardEvaluator implements IScalarEvaluator { try { writeResult(jaccSim); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardPrefixEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardPrefixEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardPrefixEvaluator.java index b70c6ad..23b9d50 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardPrefixEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardPrefixEvaluator.java @@ -218,7 +218,7 @@ public class SimilarityJaccardPrefixEvaluator implements IScalarEvaluator { try { writeResult(); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/WordTokensEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/WordTokensEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/WordTokensEvaluator.java index e51d5cf..2ee5a96 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/WordTokensEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/common/WordTokensEvaluator.java @@ -64,7 +64,7 @@ public class WordTokensEvaluator implements IScalarEvaluator { } listBuilder.write(out, true); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java index 0f4ebee..70903cb 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java @@ -141,7 +141,7 @@ public class EditDistanceListIsFilterableDescriptor extends AbstractScalarFuncti booleanSerde.serialize(ABoolean.TRUE, output); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceStringIsFilterableEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceStringIsFilterableEvaluator.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceStringIsFilterableEvaluator.java index 0509f51..708c282 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceStringIsFilterableEvaluator.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceStringIsFilterableEvaluator.java @@ -114,7 +114,7 @@ public class EditDistanceStringIsFilterableEvaluator implements IScalarEvaluator booleanSerde.serialize(ABoolean.TRUE, output); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java index c9a865b..17637bc 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java @@ -124,7 +124,7 @@ public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor try { int32Serde.serialize(res, out); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java index 25d4be3..52bd8b1 100644 --- a/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java +++ b/asterixdb/asterix-fuzzyjoin/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java @@ -109,7 +109,7 @@ public class PrefixLenJaccardDescriptor extends AbstractScalarFunctionDynamicDes try { int32Serde.serialize(res, out); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatatypeTupleTranslator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatatypeTupleTranslator.java b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatatypeTupleTranslator.java index 6d7e25f..d0d7b00 100644 --- a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatatypeTupleTranslator.java +++ b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatatypeTupleTranslator.java @@ -382,7 +382,7 @@ public class DatatypeTupleTranslator extends AbstractTupleTranslator<Datatype> { // TODO: This should not be a HyracksDataException. Can't // fix this currently because of BTree exception model whose // fixes must get in. - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } return typeName; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/AbstractListBuilder.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/AbstractListBuilder.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/AbstractListBuilder.java index f15b1e5..35f6170 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/AbstractListBuilder.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/AbstractListBuilder.java @@ -136,7 +136,7 @@ public abstract class AbstractListBuilder implements IAsterixListBuilder { out.write(offsetArray, 0, metadataInfoSize); out.write(outputStorage.getByteArray(), 0, outputStorage.getLength()); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/RecordBuilder.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/RecordBuilder.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/RecordBuilder.java index 10863cd..95aef79 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/RecordBuilder.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/builders/RecordBuilder.java @@ -296,7 +296,7 @@ public class RecordBuilder implements IARecordBuilder { out.write(openPartOutputStream.getByteArray(), 0, openPartOutputStream.getLength()); } } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/MissingWriterFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/MissingWriterFactory.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/MissingWriterFactory.java index db1cb95..c1950df 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/MissingWriterFactory.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/MissingWriterFactory.java @@ -43,7 +43,7 @@ public class MissingWriterFactory implements IMissingWriterFactory { try { out.writeByte(ATypeTag.SERIALIZED_MISSING_TYPE_TAG); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/6453ecf2/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/hash/ListItemBinaryHashFunctionFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/hash/ListItemBinaryHashFunctionFactory.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/hash/ListItemBinaryHashFunctionFactory.java index a3a826e..e5e7467 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/hash/ListItemBinaryHashFunctionFactory.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/hash/ListItemBinaryHashFunctionFactory.java @@ -81,7 +81,7 @@ public class ListItemBinaryHashFunctionFactory implements IBinaryHashFunctionFac resetTaggedBytes(bytes, offset, length); return genericBinaryHash.hash(taggedBytes.getByteArray(), 0, length + 1); } catch (IOException e) { - throw new HyracksDataException(e); + throw HyracksDataException.create(e); } } else { return genericBinaryHash.hash(bytes, offset, length);
