You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2018/03/27 23:48:34 UTC
[11/12] asterixdb git commit: [NO ISSUE] Incremental cleanup of
deprecated exception ctors
[NO ISSUE] Incremental cleanup of deprecated exception ctors
Change-Id: I1e7c3655828fc6530cef83ea502a6cfbf41acddf
Reviewed-on: https://asterix-gerrit.ics.uci.edu/2533
Integration-Tests: Jenkins <je...@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Contrib: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Murtadha Hubail <mh...@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/master
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);