You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/05/18 20:42:12 UTC
[22/22] incubator-apex-malhar git commit: Merge branch
'APEXMALHAR-2095' of https://github.com/chandnisingh/incubator-apex-malhar
Merge branch 'APEXMALHAR-2095' of https://github.com/chandnisingh/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/3ce83708
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/3ce83708
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/3ce83708
Branch: refs/heads/master
Commit: 3ce83708f795b081d564be357a8333928154398e
Parents: 029291d 3735316
Author: Thomas Weise <th...@datatorrent.com>
Authored: Wed May 18 13:34:39 2016 -0700
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Wed May 18 13:34:39 2016 -0700
----------------------------------------------------------------------
library/library-checkstyle-suppressions.xml | 34 +
library/pom.xml | 7 +-
.../lib/algo/AbstractStreamPatternMatcher.java | 5 +-
.../datatorrent/lib/algo/BottomNUnifier.java | 6 +-
.../com/datatorrent/lib/algo/FilterKeyVals.java | 9 +-
.../datatorrent/lib/algo/FilterKeysHashMap.java | 4 +-
.../com/datatorrent/lib/algo/FilterKeysMap.java | 11 +-
.../com/datatorrent/lib/algo/FilterValues.java | 2 +-
.../java/com/datatorrent/lib/algo/FirstN.java | 3 +-
.../com/datatorrent/lib/algo/InsertSort.java | 3 +-
.../datatorrent/lib/algo/InsertSortDesc.java | 9 +-
.../lib/algo/LeastFrequentKeyArrayUnifier.java | 2 +-
.../lib/algo/LeastFrequentKeyMap.java | 6 +-
.../lib/algo/LeastFrequentKeyUnifier.java | 2 +-
.../lib/algo/LeastFrequentValue.java | 4 +-
.../java/com/datatorrent/lib/algo/MatchMap.java | 5 +-
.../com/datatorrent/lib/algo/MergeSort.java | 224 ++--
.../datatorrent/lib/algo/MergeSortNumber.java | 94 +-
.../lib/algo/MostFrequentKeyMap.java | 4 +-
.../datatorrent/lib/algo/MostFrequentValue.java | 2 +-
.../com/datatorrent/lib/algo/UniqueCounter.java | 9 +-
.../com/datatorrent/lib/appdata/QueueUtils.java | 11 +-
.../com/datatorrent/lib/appdata/StoreUtils.java | 35 +-
.../datastructs/CacheLRUSynchronousFlush.java | 27 +-
.../appdata/datastructs/DimensionalTable.java | 69 +-
.../lib/appdata/gpo/GPOByteArrayList.java | 10 +-
.../datatorrent/lib/appdata/gpo/GPOGetters.java | 4 +-
.../datatorrent/lib/appdata/gpo/GPOMutable.java | 96 +-
.../datatorrent/lib/appdata/gpo/GPOType.java | 244 ++--
.../datatorrent/lib/appdata/gpo/GPOUtils.java | 1176 +++++++-----------
.../com/datatorrent/lib/appdata/gpo/Serde.java | 5 +-
.../lib/appdata/gpo/SerdeFieldsDescriptor.java | 10 +-
.../lib/appdata/gpo/SerdeListGPOMutable.java | 19 +-
.../lib/appdata/gpo/SerdeListPrimitive.java | 14 +-
.../lib/appdata/gpo/SerdeListString.java | 12 +-
.../query/AbstractWindowEndQueueManager.java | 89 +-
.../query/AppDataWindowEndQueueManager.java | 15 +-
.../lib/appdata/query/QueryBundle.java | 4 +-
.../lib/appdata/query/QueryExecutor.java | 4 +-
.../appdata/query/QueryManagerAsynchronous.java | 37 +-
.../appdata/query/QueryManagerSynchronous.java | 23 +-
.../lib/appdata/query/QueueList.java | 25 +-
.../lib/appdata/query/QueueManager.java | 5 +
.../appdata/query/SimpleDoneQueueManager.java | 4 +-
.../lib/appdata/query/SimpleQueueManager.java | 16 +-
.../lib/appdata/query/WindowBoundedService.java | 11 +-
.../appdata/query/WindowEndQueueManager.java | 9 +-
.../query/serde/CustomMessageDeserializer.java | 4 +-
.../serde/DataQuerySnapshotDeserializer.java | 81 +-
.../query/serde/DataQuerySnapshotValidator.java | 11 +-
.../serde/DataResultSnapshotSerializer.java | 14 +-
.../query/serde/MessageDeserializerFactory.java | 84 +-
.../query/serde/MessageSerializerFactory.java | 52 +-
.../query/serde/SchemaQueryDeserializer.java | 21 +-
.../query/serde/SimpleDataDeserializer.java | 3 +-
.../query/serde/SimpleDataSerializer.java | 3 +-
.../lib/appdata/schemas/CustomTimeBucket.java | 18 +-
.../lib/appdata/schemas/DataQuerySnapshot.java | 40 +-
.../lib/appdata/schemas/DataResultSnapshot.java | 14 +-
.../schemas/DimensionalConfigurationSchema.java | 11 +-
.../lib/appdata/schemas/DimensionalSchema.java | 5 +-
.../datatorrent/lib/appdata/schemas/Fields.java | 17 +-
.../lib/appdata/schemas/FieldsDescriptor.java | 84 +-
.../datatorrent/lib/appdata/schemas/QRBase.java | 7 +-
.../datatorrent/lib/appdata/schemas/Query.java | 21 +-
.../datatorrent/lib/appdata/schemas/Result.java | 3 +-
.../lib/appdata/schemas/ResultFormatter.java | 58 +-
.../datatorrent/lib/appdata/schemas/Schema.java | 5 +
.../lib/appdata/schemas/SchemaQuery.java | 13 +-
.../lib/appdata/schemas/SchemaRegistry.java | 3 +
.../appdata/schemas/SchemaRegistryMultiple.java | 7 +-
.../appdata/schemas/SchemaRegistrySingle.java | 18 +-
.../lib/appdata/schemas/SchemaResult.java | 10 +-
.../appdata/schemas/SchemaResultSerializer.java | 23 +-
.../lib/appdata/schemas/SchemaUtils.java | 144 +--
.../lib/appdata/schemas/SnapshotSchema.java | 61 +-
.../lib/appdata/schemas/TimeBucket.java | 11 +-
.../datatorrent/lib/appdata/schemas/Type.java | 52 +-
.../snapshot/AbstractAppDataSnapshotServer.java | 16 +-
.../snapshot/AppDataSnapshotServerMap.java | 15 +-
.../snapshot/AppDataSnapshotServerPOJO.java | 2 +-
.../lib/codec/JavaSerializationStreamCodec.java | 62 +-
.../ByteArrayToStringConverterOperator.java | 7 +-
.../datatorrent/lib/converter/Converter.java | 3 +-
.../MapToKeyHashValuePairConverter.java | 8 +-
.../converter/MapToKeyValuePairConverter.java | 11 +-
.../StringValueToNumberConverterForMap.java | 14 +-
.../datatorrent/lib/counters/BasicCounters.java | 11 +-
...nsactionableKeyValueStoreOutputOperator.java | 2 +-
...BatchTransactionableStoreOutputOperator.java | 10 +-
.../db/AbstractKeyValueStoreInputOperator.java | 6 +-
...nsactionableKeyValueStoreOutputOperator.java | 2 +-
...sThruTransactionableStoreOutputOperator.java | 3 +-
.../lib/db/AbstractStoreInputOperator.java | 8 +-
.../lib/db/AbstractStoreOutputOperator.java | 8 +-
...tractTransactionableStoreOutputOperator.java | 8 +-
...bcNonTransactionableBatchOutputOperator.java | 20 +-
.../db/jdbc/JDBCDimensionalOutputOperator.java | 8 +-
.../lib/db/jdbc/JdbcNonTransactionalStore.java | 11 +-
.../lib/fileaccess/DTFileReader.java | 5 +-
.../lib/fileaccess/FileAccessFSImpl.java | 6 +-
.../datatorrent/lib/fileaccess/TFileImpl.java | 13 +-
.../datatorrent/lib/fileaccess/TFileReader.java | 9 +-
.../datatorrent/lib/fileaccess/TFileWriter.java | 8 +-
.../datatorrent/lib/formatter/Formatter.java | 2 +-
.../lib/io/AbstractHttpGetOperator.java | 3 +-
.../lib/io/AbstractHttpInputOperator.java | 11 +-
.../lib/io/AbstractHttpOperator.java | 6 +-
.../io/AbstractKeyValueStoreOutputOperator.java | 12 +-
.../lib/io/AbstractSocketInputOperator.java | 16 +-
.../datatorrent/lib/io/ApacheGenRandomLogs.java | 315 ++---
.../CollectionMultiConsoleOutputOperator.java | 8 +-
.../lib/io/ConsoleOutputOperator.java | 11 +-
.../lib/io/HttpJsonChunksInputOperator.java | 13 +-
.../lib/io/HttpLinesInputOperator.java | 6 +-
.../lib/io/HttpPostOutputOperator.java | 7 +-
.../lib/io/IdempotentStorageManager.java | 15 +-
.../lib/io/MapMultiConsoleOutputOperator.java | 8 +-
.../lib/io/PubSubWebSocketAppDataQuery.java | 17 +-
.../lib/io/PubSubWebSocketAppDataResult.java | 17 +-
.../lib/io/PubSubWebSocketInputOperator.java | 3 +-
.../lib/io/SimpleSinglePortInputOperator.java | 20 +-
.../datatorrent/lib/io/SmtpOutputOperator.java | 30 +-
.../lib/io/WebSocketInputOperator.java | 25 +-
.../lib/io/WebSocketOutputOperator.java | 6 +-
.../lib/io/WebSocketServerInputOperator.java | 14 +-
.../lib/io/WidgetOutputOperator.java | 28 +-
.../lib/io/fs/AbstractFileInputOperator.java | 182 ++-
.../lib/io/fs/AbstractReconciler.java | 17 +-
.../fs/AbstractThroughputFileInputOperator.java | 34 +-
.../com/datatorrent/lib/io/fs/FileSplitter.java | 101 +-
.../lib/io/fs/FilterStreamContext.java | 2 +-
.../lib/io/fs/FilterStreamProvider.java | 13 +-
.../lib/io/fs/TailFsInputOperator.java | 6 +-
.../com/datatorrent/lib/io/fs/package-info.java | 2 +-
.../lib/io/jms/AbstractJMSOutputOperator.java | 38 +-
.../AbstractJMSSinglePortOutputOperator.java | 3 +-
.../io/jms/FSPsuedoTransactionableStore.java | 69 +-
.../com/datatorrent/lib/io/jms/JMSBase.java | 18 +-
.../lib/io/jms/JMSMultiPortOutputOperator.java | 34 +-
.../lib/io/jms/JMSObjectInputOperator.java | 39 +-
.../lib/io/jms/JMSTransactionableStore.java | 56 +-
.../datatorrent/lib/io/jms/package-info.java | 2 +-
.../logs/ApacheLogParseMapOutputOperator.java | 13 +-
.../lib/logs/ApacheLogParseOperator.java | 193 ++-
.../lib/logs/ApacheVirtualLogParseOperator.java | 296 ++---
.../lib/logs/DimensionAggregationUnifier.java | 6 +-
.../datatorrent/lib/logs/DimensionObject.java | 11 +-
.../lib/logs/FilteredLineToTokenArrayList.java | 5 +-
.../lib/logs/FilteredLineToTokenHashMap.java | 57 +-
.../lib/logs/FilteredLineTokenizerKeyVal.java | 57 +-
.../lib/logs/LineToTokenArrayList.java | 14 +-
.../lib/logs/LineToTokenHashMap.java | 5 +-
.../com/datatorrent/lib/logs/LineTokenizer.java | 31 +-
.../lib/logs/LineTokenizerKeyVal.java | 14 +-
.../logs/MultiWindowDimensionAggregation.java | 30 +-
.../lib/logs/RegexMatchMapOperator.java | 15 +-
.../lib/math/AbstractAggregateCalc.java | 88 +-
.../datatorrent/lib/math/AbstractOutput.java | 42 +-
.../lib/math/AbstractXmlCartesianProduct.java | 42 +-
.../AbstractXmlKeyValueCartesianProduct.java | 3 +-
.../java/com/datatorrent/lib/math/Average.java | 138 +-
.../com/datatorrent/lib/math/AverageKeyVal.java | 167 +--
.../java/com/datatorrent/lib/math/Change.java | 102 +-
.../com/datatorrent/lib/math/ChangeAlert.java | 114 +-
.../datatorrent/lib/math/ChangeAlertKeyVal.java | 136 +-
.../datatorrent/lib/math/ChangeAlertMap.java | 2 +-
.../com/datatorrent/lib/math/ChangeKeyVal.java | 6 +-
.../datatorrent/lib/math/CompareExceptMap.java | 9 +-
.../com/datatorrent/lib/math/CompareMap.java | 11 +-
.../com/datatorrent/lib/math/CountKeyVal.java | 114 +-
.../java/com/datatorrent/lib/math/Division.java | 12 +-
.../com/datatorrent/lib/math/ExceptMap.java | 58 +-
.../datatorrent/lib/math/LogicalCompare.java | 102 +-
.../lib/math/LogicalCompareToConstant.java | 130 +-
.../java/com/datatorrent/lib/math/Margin.java | 160 +--
.../com/datatorrent/lib/math/MarginKeyVal.java | 254 ++--
.../com/datatorrent/lib/math/MarginMap.java | 16 +-
.../main/java/com/datatorrent/lib/math/Max.java | 5 +-
.../com/datatorrent/lib/math/MaxKeyVal.java | 10 +-
.../main/java/com/datatorrent/lib/math/Min.java | 15 +-
.../com/datatorrent/lib/math/MinKeyVal.java | 16 +-
.../lib/math/MultiplyByConstant.java | 8 +-
.../java/com/datatorrent/lib/math/Quotient.java | 108 +-
.../com/datatorrent/lib/math/QuotientMap.java | 342 ++---
.../java/com/datatorrent/lib/math/Range.java | 106 +-
.../com/datatorrent/lib/math/RangeKeyVal.java | 146 ++-
.../datatorrent/lib/math/RunningAverage.java | 114 +-
.../java/com/datatorrent/lib/math/Sigma.java | 40 +-
.../main/java/com/datatorrent/lib/math/Sum.java | 366 +++---
.../com/datatorrent/lib/math/SumCountMap.java | 444 +++----
.../com/datatorrent/lib/math/SumKeyVal.java | 13 +-
.../math/XmlKeyValueStringCartesianProduct.java | 7 +-
.../lib/multiwindow/AbstractSlidingWindow.java | 210 ++--
.../AbstractSlidingWindowKeyVal.java | 184 +--
.../lib/multiwindow/MultiWindowRangeKeyVal.java | 2 +-
.../lib/multiwindow/MultiWindowSumKeyVal.java | 75 +-
.../lib/multiwindow/SimpleMovingAverage.java | 150 +--
.../lib/multiwindow/SortedMovingWindow.java | 10 +-
.../StatsAwareStatelessPartitioner.java | 37 +-
.../lib/script/JavaScriptOperator.java | 43 +-
.../datatorrent/lib/script/ScriptOperator.java | 13 +-
.../lib/statistics/MedianOperator.java | 12 +-
.../lib/statistics/ModeOperator.java | 4 +-
.../lib/statistics/StandardDeviation.java | 12 +-
.../lib/statistics/WeightedMeanOperator.java | 14 +-
.../lib/stream/AbstractAggregator.java | 166 +--
.../datatorrent/lib/stream/ArrayListToItem.java | 43 +-
.../lib/stream/ConsolidatorKeyVal.java | 266 ++--
.../com/datatorrent/lib/stream/Counter.java | 92 +-
.../com/datatorrent/lib/stream/DevNull.java | 24 +-
.../datatorrent/lib/stream/DevNullCounter.java | 264 ++--
.../lib/stream/HashMapToKeyValPair.java | 85 +-
.../lib/stream/JsonByteArrayOperator.java | 10 +-
.../lib/stream/KeyValPairToHashMap.java | 43 +-
.../lib/stream/RoundRobinHashMap.java | 97 +-
.../lib/stream/StreamDuplicater.java | 6 +-
.../datatorrent/lib/stream/StreamMerger.java | 10 +-
.../streamquery/AbstractSqlStreamOperator.java | 11 +-
.../lib/streamquery/DeleteOperator.java | 2 +-
.../lib/streamquery/DerbySqlStreamOperator.java | 93 +-
.../lib/streamquery/GroupByHavingOperator.java | 23 +-
.../lib/streamquery/InnerJoinOperator.java | 47 +-
.../lib/streamquery/OrderByOperator.java | 100 +-
.../lib/streamquery/OrderByRule.java | 2 +-
.../lib/streamquery/OuterJoinOperator.java | 4 +-
.../lib/streamquery/SelectFunctionOperator.java | 4 +-
.../lib/streamquery/SelectOperator.java | 5 +-
.../lib/streamquery/SelectTopOperator.java | 17 +-
.../lib/streamquery/UpdateOperator.java | 33 +-
.../streamquery/condition/BetweenCondition.java | 18 +-
.../condition/CompoundCondition.java | 19 +-
.../lib/streamquery/condition/Condition.java | 13 +-
.../condition/EqualValueCondition.java | 15 +-
.../condition/HavingCompareValue.java | 4 +-
.../streamquery/condition/HavingCondition.java | 7 +-
.../lib/streamquery/condition/InCondition.java | 12 +-
.../condition/JoinColumnEqualCondition.java | 9 +-
.../streamquery/condition/LikeCondition.java | 14 +-
.../streamquery/function/AverageFunction.java | 10 +-
.../lib/streamquery/function/CountFunction.java | 12 +-
.../streamquery/function/FirstLastFunction.java | 24 +-
.../lib/streamquery/function/FunctionIndex.java | 18 +-
.../streamquery/function/MaxMinFunction.java | 14 +-
.../lib/streamquery/function/SumFunction.java | 8 +-
.../lib/streamquery/index/BinaryExpression.java | 8 +-
.../lib/streamquery/index/ColumnIndex.java | 4 +-
.../lib/streamquery/index/Index.java | 2 +-
.../lib/streamquery/index/MidIndex.java | 16 +-
.../lib/streamquery/index/NegateExpression.java | 8 +-
.../lib/streamquery/index/RoundDoubleIndex.java | 16 +-
.../lib/streamquery/index/StringCaseIndex.java | 10 +-
.../lib/streamquery/index/StringLenIndex.java | 10 +-
.../lib/streamquery/index/SumExpression.java | 14 +-
.../lib/streamquery/index/UnaryExpression.java | 6 +-
.../lib/testbench/ArrayListTestSink.java | 7 +-
.../lib/testbench/CollectorTestSink.java | 14 +-
.../lib/testbench/CompareFilterTuples.java | 117 +-
.../testbench/CountAndLastTupleTestSink.java | 4 +-
.../lib/testbench/CountOccurance.java | 116 +-
.../lib/testbench/CountTestSink.java | 3 +-
.../lib/testbench/EventClassifier.java | 92 +-
.../EventClassifierNumberToHashDouble.java | 17 +-
.../lib/testbench/EventGenerator.java | 27 +-
.../lib/testbench/EventIncrementer.java | 15 +-
.../lib/testbench/FilterClassifier.java | 13 +-
.../lib/testbench/FilteredEventClassifier.java | 13 +-
.../datatorrent/lib/testbench/HashTestSink.java | 22 +-
.../lib/testbench/HttpStatusFilter.java | 105 +-
.../datatorrent/lib/testbench/KeyValSum.java | 72 +-
.../lib/testbench/RandomEventGenerator.java | 15 +-
.../lib/testbench/RandomWordGenerator.java | 11 +-
.../datatorrent/lib/testbench/RedisSumOper.java | 70 +-
.../lib/testbench/SeedEventClassifier.java | 12 +-
.../lib/testbench/SeedEventGenerator.java | 13 +-
.../datatorrent/lib/testbench/SumTestSink.java | 2 +-
.../lib/testbench/ThroughputCounter.java | 19 +-
.../lib/testbench/TopOccurrence.java | 162 ++-
.../lib/transform/TransformOperator.java | 3 +-
.../lib/util/AbstractBaseFrequentKey.java | 15 +-
.../util/AbstractBaseFrequentKeyValueMap.java | 11 +-
.../lib/util/AbstractBaseMatchOperator.java | 25 +-
.../util/AbstractBaseNNonUniqueOperatorMap.java | 7 +-
.../lib/util/AbstractBaseNOperatorMap.java | 4 +-
.../util/AbstractBaseNUniqueOperatorMap.java | 7 +-
.../lib/util/AbstractBaseSortOperator.java | 11 +-
.../AbstractDimensionTimeBucketOperator.java | 33 +-
.../lib/util/AbstractKeyValueStorageAgent.java | 2 +-
.../lib/util/ActiveMQMessageListener.java | 23 +-
.../util/ActiveMQMultiTypeMessageListener.java | 42 +-
.../lib/util/ArrayHashMapFrequent.java | 14 +-
.../lib/util/BaseFilteredKeyValueOperator.java | 2 +-
.../lib/util/BaseKeyValueOperator.java | 3 +-
.../datatorrent/lib/util/BaseLineTokenizer.java | 13 +-
.../datatorrent/lib/util/BaseMatchOperator.java | 5 +-
.../lib/util/BaseNumberKeyValueOperator.java | 32 +-
.../lib/util/BaseNumberValueOperator.java | 18 +-
.../util/DimensionTimeBucketSumOperator.java | 7 +-
.../com/datatorrent/lib/util/FieldInfo.java | 11 +-
.../datatorrent/lib/util/FilterOperator.java | 2 +-
.../lib/util/JavaScriptFilterOperator.java | 29 +-
.../datatorrent/lib/util/KeyHashValPair.java | 2 +-
.../com/datatorrent/lib/util/PojoUtils.java | 142 ++-
.../lib/util/ReusableStringReader.java | 6 +-
.../lib/util/ReversibleComparator.java | 1 +
.../com/datatorrent/lib/util/TableInfo.java | 2 +-
.../com/datatorrent/lib/util/TimeBucketKey.java | 36 +-
.../java/com/datatorrent/lib/util/TopNSort.java | 3 +-
.../datatorrent/lib/util/TopNUniqueSort.java | 7 +-
.../lib/util/UnifierArrayHashMapFrequent.java | 14 +-
.../datatorrent/lib/util/UnifierArrayList.java | 2 +-
.../datatorrent/lib/util/UnifierBooleanAnd.java | 2 +-
.../datatorrent/lib/util/UnifierBooleanOr.java | 2 +-
.../lib/util/UnifierCountOccurKey.java | 28 +-
.../datatorrent/lib/util/UnifierHashMap.java | 6 +-
.../lib/util/UnifierHashMapFrequent.java | 14 +-
.../lib/util/UnifierHashMapInteger.java | 11 +-
.../lib/util/UnifierHashMapRange.java | 11 +-
.../lib/util/UnifierHashMapSumKeys.java | 11 +-
.../lib/util/UnifierKeyValRange.java | 8 +-
.../com/datatorrent/lib/util/UnifierMap.java | 8 +-
.../com/datatorrent/lib/util/UnifierRange.java | 5 +-
.../datatorrent/lib/util/UnifierSumNumber.java | 2 +-
.../lib/xml/AbstractXmlDOMOperator.java | 12 +-
.../malhar/lib/fs/BytesFileOutputOperator.java | 2 -
.../lib/state/managed/ManagedTimeStateImpl.java | 5 +-
.../hadoop/io/file/tfile/CacheManager.java | 70 +-
.../tfile/ReusableByteArrayInputStream.java | 7 +-
.../algo/AbstractStreamPatternMatcherTest.java | 2 +-
.../lib/algo/AllAfterMatchMapTest.java | 12 +-
.../datatorrent/lib/algo/BottomNMapTest.java | 10 +-
.../lib/algo/BottomNUnifierTest.java | 10 +-
.../lib/algo/BottomNUniqueMapTest.java | 11 +-
.../datatorrent/lib/algo/DistinctMapTest.java | 6 +-
.../datatorrent/lib/algo/FilterKeysMapTest.java | 2 +-
.../datatorrent/lib/algo/FilterValuesTest.java | 4 +-
.../com/datatorrent/lib/algo/FirstNTest.java | 10 +-
.../lib/algo/InsertSortDescTest.java | 8 +-
.../datatorrent/lib/algo/InsertSortTest.java | 2 +-
.../lib/algo/InvertIndexArrayTest.java | 10 +-
.../datatorrent/lib/algo/InvertIndexTest.java | 10 +-
.../lib/algo/LeastFrequentKeyMapTest.java | 5 +-
.../lib/algo/LeastFrequentKeyTest.java | 15 +-
.../lib/algo/LeastFrequentKeyValueMapTest.java | 8 +-
.../datatorrent/lib/algo/MatchAllMapTest.java | 4 +-
.../datatorrent/lib/algo/MatchAnyMapTest.java | 2 +-
.../com/datatorrent/lib/algo/MatchMapTest.java | 8 +-
.../lib/algo/MergeSortNumberTest.java | 60 +-
.../lib/algo/MostFrequentKeyMapTest.java | 5 +-
.../lib/algo/MostFrequentKeyTest.java | 15 +-
.../lib/algo/MostFrequentKeyValueMapTest.java | 8 +-
.../java/com/datatorrent/lib/algo/TopNTest.java | 10 +-
.../datatorrent/lib/algo/TopNUniqueTest.java | 8 +-
.../datatorrent/lib/algo/UniqueCounterTest.java | 10 +-
.../lib/algo/UniqueValueCountTest.java | 85 +-
.../CacheLRUSynchronousFlushTest.java | 11 +-
.../datastructs/DimensionalTableTest.java | 18 +-
.../lib/appdata/gpo/GPOMutableTest.java | 4 +-
.../lib/appdata/gpo/GPOUtilsTest.java | 48 +-
.../appdata/gpo/SerdeFieldsDescriptorTest.java | 7 +-
.../appdata/gpo/SerdeListGPOMutableTest.java | 9 +-
.../lib/appdata/gpo/SerdeListPrimitiveTest.java | 17 +-
.../lib/appdata/gpo/SerdeListStringTest.java | 6 +-
.../lib/appdata/query/MockQuery.java | 14 +-
.../lib/appdata/query/MockResult.java | 10 +-
.../lib/appdata/query/MockResultSerializer.java | 5 +-
.../query/QueryManagerAsynchronousTest.java | 58 +-
.../query/QueryManagerSynchronousTest.java | 17 +-
.../lib/appdata/query/QueueUtilsTest.java | 4 +-
.../query/SimpleDoneQueryQueueManagerTest.java | 10 +-
.../appdata/query/WEQueryQueueManagerTest.java | 54 +-
.../appdata/query/WindowBoundedServiceTest.java | 6 +-
.../serde/MessageDeserializerFactoryTest.java | 6 +-
.../DataQuerySnapshotDeserializerTest.java | 15 +-
.../appdata/schemas/DataQuerySnapshotTest.java | 10 +-
.../DataResultSnapshotSerializerTest.java | 25 +-
.../DimensionalConfigurationSchemaTest.java | 190 ++-
.../appdata/schemas/DimensionalSchemaTest.java | 184 ++-
.../appdata/schemas/FieldsDescriptorTest.java | 30 +-
.../appdata/schemas/ResultFormatterTest.java | 16 +-
.../lib/appdata/schemas/SchemaQueryTest.java | 42 +-
.../schemas/SchemaRegistryMultipleTest.java | 12 +-
.../lib/appdata/schemas/SchemaTestUtils.java | 8 +-
.../lib/appdata/schemas/SchemaUtilsTest.java | 8 +-
.../lib/appdata/schemas/SnapshotSchemaTest.java | 14 +-
.../snapshot/AppDataSnapshotServerMapTest.java | 34 +-
.../snapshot/AppDataSnapshotServerPojoTest.java | 6 +-
.../codec/JavaSerializationStreamCodecTest.java | 196 +--
.../ByteArrayToStringConverterTest.java | 7 +-
.../MapToKeyValuePairConverterTest.java | 11 +-
.../StringValueToNumberConverterForMapTest.java | 30 +-
.../lib/counters/BasicCountersTest.java | 7 +-
.../lib/db/KeyValueStoreOperatorTest.java | 21 +-
...ransactionableKeyValueStoreOperatorTest.java | 5 +-
...NonTransactionalBatchOutputOperatorTest.java | 299 ++---
.../JdbcNonTransactionalOutputOperatorTest.java | 16 +-
.../db/jdbc/JdbcNonTransactionalStoreTest.java | 12 +-
.../lib/formatter/JsonFormatterTest.java | 12 +-
.../lib/formatter/XmlFormatterTest.java | 10 +-
.../lib/helper/OperatorContextTestHelper.java | 2 +-
.../helper/SamplePubSubWebSocketServlet.java | 12 +-
.../lib/io/ApacheRandomLogsTest.java | 63 +-
.../lib/io/HttpJsonChunksInputOperatorTest.java | 8 +-
.../lib/io/HttpLinesInputOperatorTest.java | 4 +-
.../io/HttpMultiValuedMapGetOperatorTest.java | 6 +-
.../lib/io/HttpPostOutputOperatorTest.java | 6 +-
.../lib/io/IdempotentStorageManagerTest.java | 11 +-
.../io/PubSubWebSocketAppDataOperatorTest.java | 3 +-
.../lib/io/PubSubWebSocketAppDataQueryTest.java | 4 +-
.../lib/io/PubSubWebSocketOperatorTest.java | 6 +-
.../lib/io/SmtpOutputOperatorTest.java | 17 +-
.../lib/io/SocketInputOperatorTest.java | 17 +-
.../io/WebSocketServerInputOperatorTest.java | 10 +-
...actFileInputOperatorFailureHandlingTest.java | 50 +-
.../io/fs/AbstractFileInputOperatorTest.java | 94 +-
.../io/fs/AbstractFileOutputOperatorTest.java | 675 +++-------
.../lib/io/fs/AbstractReconcilerTest.java | 6 +-
.../AbstractSingleFileOutputOperatorTest.java | 57 +-
.../AbstractWindowFileOutputOperatorTest.java | 46 +-
.../lib/io/fs/FSInputModuleAppTest.java | 2 +-
.../lib/io/fs/FileSplitterInputTest.java | 9 +-
.../lib/io/fs/TailFsInputOperatorTest.java | 6 +-
.../io/jms/JMSMultiPortOutputOperatorTest.java | 21 +-
.../lib/io/jms/JMSObjectInputOperatorTest.java | 39 +-
.../lib/io/jms/JMSOutputOperatorTest.java | 345 ++---
.../com/datatorrent/lib/io/jms/JMSTestBase.java | 7 +-
.../io/jms/JMSTransactionableStoreTestBase.java | 51 +-
.../lib/join/MapTimeBasedJoinOperator.java | 4 +-
.../lib/join/POJOTimeBasedJoinOperatorTest.java | 12 +-
.../lib/logs/ApacheLogParseOperatorTest.java | 100 +-
.../logs/FilteredLineToTokenArrayListTest.java | 9 +-
.../logs/FilteredLineToTokenHashMapTest.java | 102 +-
.../logs/FilteredLineTokenizerKeyValTest.java | 11 +-
.../lib/logs/LineToTokenArrayListTest.java | 126 +-
.../lib/logs/LineToTokenHashMapTest.java | 106 +-
.../lib/logs/LineTokenizerKeyValTest.java | 84 +-
.../MultiWindowDimensionAggregationTest.java | 7 +-
.../lib/logs/RegexMatchMapOperatorTest.java | 25 +-
.../lib/logs/TopNUniqueSiteStatsTest.java | 94 +-
.../datatorrent/lib/math/AverageKeyValTest.java | 93 +-
.../com/datatorrent/lib/math/AverageTest.java | 120 +-
.../lib/math/ChangeAlertKeyValTest.java | 116 +-
.../lib/math/ChangeAlertMapTest.java | 134 +-
.../datatorrent/lib/math/ChangeKeyValTest.java | 128 +-
.../com/datatorrent/lib/math/ChangeTest.java | 82 +-
.../lib/math/CompareExceptMapTest.java | 28 +-
.../datatorrent/lib/math/CompareMapTest.java | 8 +-
.../datatorrent/lib/math/CountKeyValTest.java | 14 +-
.../lib/math/CountOccuranceTest.java | 14 +-
.../com/datatorrent/lib/math/DivisionTest.java | 123 +-
.../com/datatorrent/lib/math/ExceptMapTest.java | 16 +-
.../lib/math/LogicalCompareTest.java | 120 +-
.../lib/math/LogicalCompareToConstantTest.java | 116 +-
.../datatorrent/lib/math/MarginKeyValTest.java | 92 +-
.../com/datatorrent/lib/math/MarginMapTest.java | 96 +-
.../com/datatorrent/lib/math/MarginTest.java | 2 +-
.../com/datatorrent/lib/math/MaxKeyValTest.java | 28 +-
.../java/com/datatorrent/lib/math/MaxTest.java | 6 +-
.../com/datatorrent/lib/math/MinKeyValTest.java | 188 ++-
.../java/com/datatorrent/lib/math/MinTest.java | 10 +-
.../lib/math/MultiplyByConstantTest.java | 2 +-
.../datatorrent/lib/math/QuotientMapTest.java | 100 +-
.../com/datatorrent/lib/math/QuotientTest.java | 117 +-
.../datatorrent/lib/math/RangeKeyValTest.java | 30 +-
.../com/datatorrent/lib/math/RangeTest.java | 152 +--
.../lib/math/RunningAverageTest.java | 58 +-
.../com/datatorrent/lib/math/SigmaTest.java | 68 +-
.../lib/math/SquareCalculusTest.java | 58 +-
.../datatorrent/lib/math/SumCountMapTest.java | 227 ++--
.../com/datatorrent/lib/math/SumKeyValTest.java | 14 +-
.../java/com/datatorrent/lib/math/SumTest.java | 124 +-
.../XmlKeyValueStringCartesianProductTest.java | 5 +-
.../multiwindow/MultiWindowRangeKeyValTest.java | 54 +-
.../multiwindow/MultiWindowSumKeyValTest.java | 54 +-
.../multiwindow/SimpleMovingAverageTest.java | 20 +-
.../lib/multiwindow/SlidingWindowTest.java | 110 +-
.../lib/multiwindow/SortedMovingWindowTest.java | 55 +-
.../partitioner/StatelessPartitionerTest.java | 21 +-
...StatelessThroughputBasedPartitionerTest.java | 12 +-
.../lib/script/JavaScriptOperatorTest.java | 2 +-
.../lib/statistics/MeridianOperatorTest.java | 6 +-
.../lib/statistics/ModeOperatorTest.java | 6 +-
.../statistics/WeightedMeanOperatorTest.java | 6 +-
.../lib/stream/ArrayListAggregatorTest.java | 53 +-
.../lib/stream/ArrayListToItemTest.java | 46 +-
.../lib/stream/ConsolidatorKeyValTest.java | 36 +-
.../com/datatorrent/lib/stream/CounterTest.java | 57 +-
.../lib/stream/DevNullCounterTest.java | 48 +-
.../com/datatorrent/lib/stream/DevNullTest.java | 17 +-
.../lib/stream/HashMapToKeyValPairTest.java | 54 +-
.../lib/stream/JsonByteArrayOperatorTest.java | 139 +--
.../lib/stream/KeyPairToHashMapTest.java | 48 +-
.../lib/stream/RoundRobinHashMapTest.java | 96 +-
.../lib/stream/StreamDuplicaterTest.java | 59 +-
.../lib/stream/StreamMergerTest.java | 4 +-
.../lib/streamquery/DeleteOperatorTest.java | 79 +-
.../streamquery/FullOuterJoinOperatorTest.java | 97 +-
.../lib/streamquery/GroupByOperatorTest.java | 83 +-
.../lib/streamquery/HavingOperatorTest.java | 83 +-
.../lib/streamquery/InnerJoinOperatorTest.java | 97 +-
.../streamquery/LeftOuterJoinOperatorTest.java | 95 +-
.../lib/streamquery/OrderByOperatorTest.java | 109 +-
.../streamquery/RightOuterJoinOperatorTest.java | 89 +-
.../lib/streamquery/SelectOperatorTest.java | 84 +-
.../lib/streamquery/SelectTopOperatorTest.java | 9 +-
.../lib/streamquery/UpdateOperatorTest.java | 82 +-
.../advanced/BetweenConditionTest.java | 84 +-
.../advanced/CompoundConditionTest.java | 90 +-
.../streamquery/advanced/InConditionTest.java | 83 +-
.../streamquery/advanced/LikeConditionTest.java | 81 +-
.../streamquery/advanced/NegateIndexTest.java | 72 +-
.../streamquery/advanced/SelectAverageTest.java | 72 +-
.../streamquery/advanced/SelectCountTest.java | 73 +-
.../advanced/SelectFirstLastTest.java | 73 +-
.../streamquery/advanced/SelectMaxMinTest.java | 73 +-
.../lib/streamquery/advanced/SumIndexTest.java | 73 +-
.../lib/testbench/ActiveMQMessageGenerator.java | 213 ++--
.../lib/testbench/EventClassifierTest.java | 348 +++---
.../lib/testbench/EventGeneratorTest.java | 36 +-
.../lib/testbench/EventIncrementerTest.java | 35 +-
.../testbench/FilteredEventClassifierTest.java | 61 +-
.../lib/testbench/RandomEventGeneratorTest.java | 8 +-
.../lib/testbench/SeedEventClassifierTest.java | 19 +-
.../lib/testbench/SeedEventGeneratorTest.java | 7 +-
.../lib/testbench/ThroughputCounterTest.java | 29 +-
.../lib/transform/TransformOperatorAppTest.java | 18 +-
.../DimensionTimeBucketSumOperatorTest.java | 11 +-
.../lib/util/JavaScriptFilterOperatorTest.java | 4 +-
.../lib/util/KryoCloneUtilsTest.java | 7 +-
.../com/datatorrent/lib/util/PojoUtilsTest.java | 65 +-
.../com/datatorrent/lib/util/TestUtils.java | 6 +-
.../CustomTimeBucketRegistryTest.java | 2 -
.../dimensions/DimensionsDescriptorTest.java | 18 +-
.../state/managed/ManagedStateTestUtils.java | 3 -
.../apache/hadoop/io/file/tfile/DTFileTest.java | 65 +-
.../apache/hadoop/io/file/tfile/TestDTFile.java | 108 +-
.../io/file/tfile/TestDTFileByteArrays.java | 255 ++--
537 files changed, 11424 insertions(+), 12366 deletions(-)
----------------------------------------------------------------------