a667c75d025a5b7ba40afba5503e88c44a76ad91 - storm

commit	a667c75d025a5b7ba40afba5503e88c44a76ad91	[log] [tgz]
author	P. Taylor Goetz <ptgoetz@gmail.com>	Wed Sep 28 15:11:08 2016 -0400
committer	P. Taylor Goetz <ptgoetz@gmail.com>	Wed Sep 28 15:11:08 2016 -0400
tree	d2d823bf738a3b61841c545ce7ca1998810cb4ff
parent	3654b8caf161768255b77a210d0234a373e86512 [diff]

SQE: Apply Apache license headers

external/storm-sqe/conf/multi-type-props.yaml[diff]
external/storm-sqe/conf/sample-conf.yaml[diff]
external/storm-sqe/pom.xml[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/QueryEngine.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/Topology.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/FromClause.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/InsertIntoClause.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/SelectClause.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/BaseCommand.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CommandType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CreateStream.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/Query.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/SetCommand.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/BaseExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ConstantExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ExpressionType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FieldExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/AggregationExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHll.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHllp.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Max.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Sum.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperatorType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/DivisionArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandKeys.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandValues.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/FormatDate.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetMapValue.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetTime.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/Hash.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/If.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ModulusArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/MultiplicationArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ParseDate.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/PlusArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/RoundDate.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/SubtractionArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/TransformExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/AndLogicalOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/CompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/Equals.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanCompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanEqualCompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/In.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanCompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanEqualCompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperatorType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotEqualCompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotLogicalOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NumberComparisonType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/OrLogicalOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/PredicateExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/RLike.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/XorLogicalOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/BaseDeserializer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/IdentityDeserializer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializerOptions.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateOperationType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/JwTridentKafkaStateFactory.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateOptions.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/SourcePartitionPartitioner.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/mongodb/MongoDBStateAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateFactory.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateOptions.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/InputStreamType.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamContainer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapterOptions.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutOptions.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutStreamAdapter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ListValuesCollector.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/SingleValuesCollector.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/StreamMetadata.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ValueFilter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorCombinerAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/AddField.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareNumbers.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareObjects.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ConvertMetadataToBytes.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpression.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandKeys.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandValues.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/FormatDate.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimation.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetIf.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetMapValue.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTime.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTupleFromAvro.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/Hash.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/IsIn.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/MapField.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ParseDate.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperator.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/RoundDate.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredOpaqueTridentKafkaSpout.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTransactionalTridentKafkaSpout.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollector.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentKafkaEmitter.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullScheme.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/BaseGsonSerializer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonOpaqueSerializer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonTransactionalSerializer.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBState.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBStateOptions.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/redis/RedisKeyFactory.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/util/FileHelper.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/util/YamlConfig.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystem.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystemProvider.java[diff]
external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourcePath.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/IntegrationTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/KafkaReplaysIntegrationTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/language/command/CommandDeserializationTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/ExpressionDeserializationTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/FunctionExpressionTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/GetTuplesFilter.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllAggregatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpAggregatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/AddFieldTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareNumbersTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareObjectsTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpressionTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandKeysTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandValuesTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/FormatDateTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimationTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetIfTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetMapValueTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetTimeTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/HashTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/IsInTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ParseDateTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperatorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/RoundDateTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollectorTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullSchemeTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/util/FileHelperTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/util/KafkaTestServer.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/util/YamlConfigTest.java[diff]
external/storm-sqe/src/test/java/com/jwplayer/sqe/util/ZookeeperTestServer.java[diff]

160 files changed

tree: d2d823bf738a3b61841c545ce7ca1998810cb4ff