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 <[email protected]> Authored: Wed May 18 13:34:39 2016 -0700 Committer: Thomas Weise <[email protected]> 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(-) ----------------------------------------------------------------------
