You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ha...@apache.org on 2016/09/08 07:14:19 UTC
[18/18] incubator-eagle git commit: [EAGLE-530] Fix checkstyle
problems on eagle-alert module and enable failOnViolation
[EAGLE-530] Fix checkstyle problems on eagle-alert module and enable failOnViolation
https://issues.apache.org/jira/browse/EAGLE-530
Author: Hao Chen <ha...@apache.org>
Closes #424 from haoch/EAGLE-530.
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/a0fc8708
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/a0fc8708
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/a0fc8708
Branch: refs/heads/master
Commit: a0fc870849a5fa5d54c0980b21226977eef81920
Parents: 2958bc8
Author: Hao Chen <ha...@apache.org>
Authored: Thu Sep 8 15:13:33 2016 +0800
Committer: Hao Chen <ha...@apache.org>
Committed: Thu Sep 8 15:13:33 2016 +0800
----------------------------------------------------------------------
.../eagle/alert/app/AlertUnitTopologyApp.java | 10 +-
.../alert/resolver/AttributeResolvable.java | 8 +-
.../resolver/AttributeResolveException.java | 16 +-
.../resolver/AttributeResolveResource.java | 40 +-
.../resolver/AttributeResolverFactory.java | 22 +-
.../BadAttributeResolveRequestException.java | 6 +-
.../GenericAttributeResolveRequest.java | 10 +-
.../resolver/impl/BooleanAttributeResolver.java | 4 +-
.../resolver/impl/EntityAttributeResolver.java | 63 +-
.../eagle-alert/alert-common/pom.xml | 4 +-
.../eagle/alert/config/ConfigBusBase.java | 23 +-
.../eagle/alert/config/ConfigBusConsumer.java | 8 +-
.../eagle/alert/config/ConfigBusProducer.java | 19 +-
.../apache/eagle/alert/config/ConfigValue.java | 4 +-
.../org/apache/eagle/alert/config/ZKConfig.java | 4 +-
.../eagle/alert/config/ZKConfigBuilder.java | 2 +-
.../alert/coordination/model/AlertBoltSpec.java | 35 +-
.../coordination/model/Kafka2TupleMetadata.java | 9 +-
.../coordination/model/PolicyWorkerQueue.java | 29 +-
.../alert/coordination/model/PublishSpec.java | 8 +-
.../alert/coordination/model/RouterSpec.java | 4 -
.../alert/coordination/model/ScheduleState.java | 34 +-
.../alert/coordination/model/SpoutSpec.java | 34 +-
.../coordination/model/StreamNameSelector.java | 6 +-
.../model/StreamRepartitionMetadata.java | 10 +-
.../model/StreamRepartitionStrategy.java | 14 +-
.../coordination/model/StreamRouterSpec.java | 19 +-
.../model/Tuple2StreamConverter.java | 52 +-
.../model/Tuple2StreamMetadata.java | 20 +-
.../model/VersionedPolicyDefinition.java | 4 -
.../model/VersionedStreamDefinition.java | 4 -
.../alert/coordination/model/WorkSlot.java | 4 +-
.../model/internal/MonitoredStream.java | 17 +-
.../model/internal/PolicyAssignment.java | 5 +-
.../model/internal/ScheduleStateBase.java | 7 +-
.../model/internal/StreamGroup.java | 15 +-
.../model/internal/StreamWorkSlotQueue.java | 32 +-
.../coordination/model/internal/Topology.java | 10 +-
.../alert/engine/codec/IEventSerializer.java | 3 +-
.../engine/coordinator/PolicyDefinition.java | 92 +--
.../alert/engine/coordinator/Publishment.java | 11 +-
.../engine/coordinator/PublishmentType.java | 32 +-
.../alert/engine/coordinator/StreamColumn.java | 32 +-
.../engine/coordinator/StreamDefinition.java | 34 +-
.../engine/coordinator/StreamPartition.java | 56 +-
.../engine/coordinator/StreamSortSpec.java | 49 +-
.../engine/coordinator/StreamingCluster.java | 8 +-
.../alert/engine/model/AlertStreamEvent.java | 14 +-
.../alert/engine/model/PartitionedEvent.java | 64 +-
.../eagle/alert/engine/model/StreamEvent.java | 55 +-
.../alert/engine/model/StreamEventBuilder.java | 39 +-
.../eagle/alert/metric/IMetricSystem.java | 39 +-
.../apache/eagle/alert/metric/MetricSystem.java | 56 +-
.../eagle/alert/metric/entity/MetricEvent.java | 63 +-
.../alert/metric/reporter/KafkaReporter.java | 361 ++++++-----
.../eagle/alert/metric/sink/ConsoleSink.java | 21 +-
.../alert/metric/sink/ElasticSearchSink.java | 23 +-
.../apache/eagle/alert/metric/sink/JmxSink.java | 5 +-
.../eagle/alert/metric/sink/KafkaSink.java | 36 +-
.../eagle/alert/metric/sink/MetricSink.java | 9 +-
.../alert/metric/sink/MetricSinkRepository.java | 32 +-
.../eagle/alert/metric/sink/Slf4jSink.java | 52 +-
.../alert/metric/source/JVMMetricSource.java | 18 +-
.../eagle/alert/metric/source/MetricSource.java | 11 +-
.../metric/source/MetricSourceWrapper.java | 12 +-
.../eagle/alert/resource/SimpleCORSFiler.java | 7 +-
.../alert/service/IMetadataServiceClient.java | 29 +-
.../service/MetadataServiceClientImpl.java | 33 +-
.../eagle/alert/utils/AlertConstants.java | 18 +-
.../org/apache/eagle/alert/utils/ByteUtils.java | 304 ++++-----
.../apache/eagle/alert/utils/ConfigUtils.java | 23 +-
.../apache/eagle/alert/utils/DateTimeUtil.java | 199 +++---
.../org/apache/eagle/alert/utils/HostUtils.java | 2 +-
.../apache/eagle/alert/utils/KafkaEmbedded.java | 10 +-
.../eagle/alert/utils/StreamIdConversion.java | 25 +-
.../eagle/alert/utils/TimePeriodUtils.java | 27 +-
.../eagle/alert/utils/ZookeeperEmbedded.java | 9 +-
.../src/main/resources/log4j.properties | 2 -
.../eagle/alert/config/TestConfigBus.java | 18 +-
.../eagle/alert/metric/MetricSystemTest.java | 63 +-
.../service/TestMetadataServiceClientImpl.java | 6 +-
.../src/test/resources/application.conf | 24 +-
.../src/test/resources/log4j.properties | 2 -
.../src/test/resources/streamDef.json | 83 +--
.../eagle-alert/alert-coordinator/pom.xml | 12 +-
.../eagle/alert/coordinator/Coordinator.java | 258 ++++----
.../alert/coordinator/CoordinatorConstants.java | 4 -
.../alert/coordinator/CoordinatorListener.java | 18 +-
.../alert/coordinator/ExclusiveExecutor.java | 126 ++--
.../alert/coordinator/IPolicyScheduler.java | 3 +-
.../alert/coordinator/IScheduleContext.java | 9 +-
.../LockWebApplicationException.java | 14 +-
.../coordinator/PolicySchedulerFactory.java | 3 +-
.../eagle/alert/coordinator/ScheduleOption.java | 6 +-
.../alert/coordinator/TopologyMgmtService.java | 16 +-
.../coordinator/impl/GreedyPolicyScheduler.java | 105 ++--
.../impl/MonitorMetadataGenerator.java | 63 +-
.../alert/coordinator/impl/ScheduleResult.java | 9 +-
.../coordinator/impl/WorkQueueBuilder.java | 15 +-
.../impl/strategies/IWorkSlotStrategy.java | 6 +-
.../strategies/SameTopologySlotStrategy.java | 46 +-
.../alert/coordinator/model/AlertBoltUsage.java | 16 +-
.../alert/coordinator/model/GroupBoltUsage.java | 34 +-
.../alert/coordinator/model/TopologyUsage.java | 10 +-
.../provider/InMemScheduleConext.java | 14 +-
.../provider/NodataMetadataGenerator.java | 617 +++++++++----------
.../provider/ScheduleContextBuilder.java | 82 ++-
.../resource/CoordinatorResource.java | 20 +-
.../coordinator/trigger/CoordinatorTrigger.java | 19 +-
.../trigger/DynamicPolicyLoader.java | 29 +-
.../trigger/PolicyChangeListener.java | 3 +-
.../alert/coordinator/CoordinatorTest.java | 7 +-
.../coordinator/DynamicPolicyLoaderTest.java | 2 +-
.../MetadataServiceClientImplTest.java | 1 -
.../NodataMetadataGeneratorTest.java | 126 ++--
.../coordinator/ScheduleContextBuilderTest.java | 59 +-
.../apache/alert/coordinator/SchedulerTest.java | 6 +-
.../coordinator/TestExclusiveExecutor.java | 112 ++--
.../TestGreedyScheduleCoordinator.java | 208 ++++---
.../alert/coordinator/WorkSlotStrategyTest.java | 6 +-
.../mock/InMemMetadataServiceClient.java | 5 +-
.../mock/TestTopologyMgmtService.java | 2 +-
.../src/test/resources/application.conf | 68 +-
.../src/test/resources/log4j.properties | 2 -
.../src/test/resources/multi/datasources.json | 34 +-
.../src/test/resources/multi/publishments.json | 52 +-
.../test/resources/multi/streamdefinitions.json | 286 +++++----
.../src/test/resources/multi/topologies.json | 58 +-
.../src/test/resources/test-application.conf | 68 +-
.../alert-devtools/conf/kafka-server.properties | 28 -
.../alert/tools/KafkaConsumerOffsetFetcher.java | 7 +-
.../alert/tools/KafkaLatestOffsetFetcher.java | 22 +-
.../eagle/contrib/kafka/ProducerTool.scala | 4 +-
.../eagle/alert/tools/TestKafkaOffset.java | 8 +-
.../kafka-offset-test.application.conf | 16 +-
.../src/test/resources/log4j.properties | 2 -
.../eagle-alert/alert-engine/pom.xml | 13 +-
.../alert/engine/AlertStreamCollector.java | 3 +-
.../apache/eagle/alert/engine/Collector.java | 2 +-
.../alert/engine/PartitionedEventCollector.java | 4 +-
.../eagle/alert/engine/StreamContext.java | 1 -
.../eagle/alert/engine/StreamContextImpl.java | 3 +-
.../eagle/alert/engine/UnitTopologyMain.java | 26 +-
.../IMetadataChangeNotifyService.java | 18 +-
.../StreamDefinitionNotFoundException.java | 10 +-
.../AbstractMetadataChangeNotifyService.java | 29 +-
.../impl/ZKMetadataChangeNotifyService.java | 122 ++--
.../evaluator/CompositePolicyHandler.java | 5 +-
.../engine/evaluator/PolicyChangeListener.java | 18 +-
.../engine/evaluator/PolicyGroupEvaluator.java | 8 +-
.../engine/evaluator/PolicyHandlerContext.java | 15 +-
.../engine/evaluator/PolicyStreamHandler.java | 16 +-
.../engine/evaluator/PolicyStreamHandlers.java | 8 +-
.../evaluator/absence/AbsenceAlertDriver.java | 11 +-
.../evaluator/absence/AbsenceDailyRule.java | 2 +-
.../evaluator/absence/AbsencePolicyHandler.java | 60 +-
.../engine/evaluator/absence/AbsenceWindow.java | 2 +-
.../absence/AbsenceWindowGenerator.java | 18 +-
.../absence/AbsenceWindowProcessor.java | 41 +-
...ertBoltOutputCollectorThreadSafeWrapper.java | 33 +-
.../impl/AlertBoltOutputCollectorWrapper.java | 7 +-
.../evaluator/impl/AlertStreamCallback.java | 15 +-
.../impl/PolicyGroupEvaluatorImpl.java | 57 +-
.../evaluator/impl/SiddhiDefinitionAdapter.java | 133 ++--
.../evaluator/impl/SiddhiPolicyHandler.java | 52 +-
.../impl/SiddhiPolicyStateHandler.java | 8 +-
.../nodata/DistinctValuesInTimeBatchWindow.java | 196 +++---
.../nodata/DistinctValuesInTimeWindow.java | 65 +-
.../evaluator/nodata/NoDataPolicyHandler.java | 113 ++--
.../nodata/NoDataPolicyTimeBatchHandler.java | 252 ++++----
.../evaluator/nodata/NoDataWisbParser.java | 3 +-
.../nodata/NoDataWisbProvidedParser.java | 12 +-
.../engine/publisher/AlertDeduplicator.java | 4 +-
.../engine/publisher/AlertPublishListener.java | 14 +-
.../engine/publisher/AlertPublishPlugin.java | 10 +-
.../publisher/AlertPublishSpecListener.java | 16 +-
.../alert/engine/publisher/AlertPublisher.java | 23 +-
.../eagle/alert/engine/publisher/AlertSink.java | 18 +-
.../publisher/email/AlertEmailContext.java | 12 +-
.../publisher/email/AlertEmailGenerator.java | 28 +-
.../email/AlertEmailGeneratorBuilder.java | 22 +-
.../publisher/email/AlertEmailSender.java | 49 +-
.../engine/publisher/email/EagleMailClient.java | 399 ++++++------
.../publisher/impl/AbstractPublishPlugin.java | 11 +-
.../publisher/impl/AlertEmailPublisher.java | 48 +-
.../publisher/impl/AlertKafkaPublisher.java | 19 +-
.../impl/AlertPublishPluginsFactory.java | 7 +-
.../publisher/impl/AlertPublisherImpl.java | 54 +-
.../publisher/impl/DefaultDeduplicator.java | 229 ++++---
.../alert/engine/publisher/impl/EventUniq.java | 80 +--
.../publisher/impl/JsonEventSerializer.java | 3 +-
.../publisher/impl/KafkaProducerManager.java | 16 +-
.../engine/publisher/impl/PublishStatus.java | 6 +-
.../publisher/impl/StringEventSerializer.java | 9 +-
.../engine/router/AlertBoltSpecListener.java | 4 +-
.../alert/engine/router/SpoutSpecListener.java | 4 +-
.../eagle/alert/engine/router/StreamRoute.java | 45 +-
.../router/StreamRoutePartitionFactory.java | 6 +-
.../engine/router/StreamRoutePartitioner.java | 10 +-
.../engine/router/StreamRouteSpecListener.java | 18 +-
.../eagle/alert/engine/router/StreamRouter.java | 21 +-
.../router/StreamRouterBoltSpecListener.java | 8 +-
.../alert/engine/router/StreamSortHandler.java | 12 +-
.../engine/router/StreamSortSpecListener.java | 16 +-
.../impl/BasicStreamRoutePartitioner.java | 22 +-
.../router/impl/RoutePhysicalGrouping.java | 37 +-
.../engine/router/impl/ShuffleGrouping.java | 21 +-
.../impl/StreamRouterBoltOutputCollector.java | 78 ++-
.../engine/router/impl/StreamRouterImpl.java | 44 +-
.../alert/engine/runner/AbstractStreamBolt.java | 43 +-
.../eagle/alert/engine/runner/AlertBolt.java | 72 +--
.../alert/engine/runner/AlertPublisherBolt.java | 31 +-
.../alert/engine/runner/MapComparator.java | 21 +-
.../engine/runner/StormMetricConsumer.java | 69 +--
.../runner/StormMetricTaggedConsumer.java | 67 +-
.../alert/engine/runner/StreamRouterBolt.java | 46 +-
.../alert/engine/runner/UnitTopologyRunner.java | 126 ++--
.../eagle/alert/engine/scheme/JsonScheme.java | 23 +-
.../scheme/JsonStringStreamNameSelector.java | 19 +-
.../alert/engine/scheme/PlainStringScheme.java | 19 +-
.../scheme/PlainStringStreamNameSelector.java | 14 +-
.../PartitionedEventDigestSerializer.java | 16 +-
.../PartitionedEventSerializer.java | 17 +-
.../SerializationMetadataProvider.java | 6 +-
.../alert/engine/serialization/Serializer.java | 3 +-
.../alert/engine/serialization/Serializers.java | 47 +-
.../serialization/impl/BooleanSerializer.java | 4 +-
.../serialization/impl/DoubleSerializer.java | 4 +-
.../serialization/impl/FloatSerializer.java | 4 +-
.../serialization/impl/IntegerSerializer.java | 4 +-
.../impl/JavaObjectSerializer.java | 6 +-
.../serialization/impl/LongSerializer.java | 4 +-
.../impl/PartitionedEventSerializerImpl.java | 39 +-
.../impl/StreamEventSerializer.java | 53 +-
.../impl/StreamPartitionDigestSerializer.java | 38 +-
.../impl/StreamPartitionSerializer.java | 26 +-
.../serialization/impl/StringSerializer.java | 4 +-
.../extension/AttributeCollectAggregator.java | 8 +-
.../AttributeCollectWithDistinctAggregator.java | 27 +-
.../extension/ContainsIgnoreCaseExtension.java | 18 +-
.../extension/EqualsIgnoreCaseExtension.java | 22 +-
.../RegexpIgnoreCaseFunctionExtension.java | 16 +-
.../alert/engine/sorter/BaseStreamWindow.java | 88 +--
.../alert/engine/sorter/StreamTimeClock.java | 13 +-
.../engine/sorter/StreamTimeClockListener.java | 3 +-
.../engine/sorter/StreamTimeClockManager.java | 15 +-
.../engine/sorter/StreamTimeClockTrigger.java | 19 +-
.../eagle/alert/engine/sorter/StreamWindow.java | 54 +-
.../engine/sorter/StreamWindowManager.java | 23 +-
.../engine/sorter/StreamWindowRepository.java | 171 +++--
.../sorter/impl/CachedEventGroupSerializer.java | 31 +-
.../impl/PartitionedEventGroupSerializer.java | 45 +-
.../PartitionedEventTimeOrderingComparator.java | 18 +-
.../impl/StreamSortWindowHandlerImpl.java | 32 +-
.../sorter/impl/StreamSortedWindowInMapDB.java | 86 ++-
.../sorter/impl/StreamSortedWindowOnHeap.java | 30 +-
.../impl/StreamTimeClockInLocalMemory.java | 22 +-
.../sorter/impl/StreamTimeClockManagerImpl.java | 73 ++-
.../sorter/impl/StreamWindowManagerImpl.java | 47 +-
.../alert/engine/spout/CorrelationSpout.java | 98 ++-
.../alert/engine/spout/CreateTopicUtils.java | 18 +-
.../eagle/alert/engine/spout/ISpoutSpecLCM.java | 9 +-
.../engine/spout/KafkaMessageIdWrapper.java | 8 +-
.../eagle/alert/engine/spout/SchemeBuilder.java | 10 +-
.../spout/SpoutOutputCollectorWrapper.java | 72 +--
.../alert/engine/utils/CompressionUtils.java | 6 +-
.../alert/engine/utils/MetadataSerDeser.java | 43 +-
.../alert/engine/utils/SerializableUtils.java | 25 +-
.../main/java/storm/kafka/KafkaSpoutMetric.java | 23 +-
.../java/storm/kafka/KafkaSpoutWrapper.java | 26 +-
.../src/main/resources/ALERT_DEFAULT.vm | 488 ++++++++-------
.../src/main/resources/application.conf | 32 +-
.../src/main/resources/log4j.properties | 3 -
.../alert/engine/absence/TestAbsenceDriver.java | 34 +-
.../absence/TestAbsencePolicyHandler.java | 14 +-
.../absence/TestAbsenceWindowGenerator.java | 16 +-
.../absence/TestAbsenceWindowProcessor.java | 4 +-
.../alert/engine/e2e/CoordinatorClient.java | 16 +-
.../eagle/alert/engine/e2e/Integration1.java | 17 +-
.../eagle/alert/engine/e2e/Integration2.java | 55 +-
.../eagle/alert/engine/e2e/Integration3.java | 17 +-
.../engine/e2e/Integration4NoDataAlert.java | 20 +-
.../engine/e2e/Integration5AbsenceAlert.java | 8 +-
.../e2e/MetadataServiceClientImpTest.java | 10 +-
.../eagle/alert/engine/e2e/SampleClient1.java | 17 +-
.../eagle/alert/engine/e2e/SampleClient2.java | 19 +-
.../eagle/alert/engine/e2e/SampleClient3.java | 17 +-
.../engine/e2e/SampleClient4NoDataAlert.java | 41 +-
.../engine/e2e/SampleClient5AbsenceAlert.java | 14 +-
...oltOutputCollectorThreadSafeWrapperTest.java | 49 +-
.../engine/evaluator/PoilcyExtendedTest.java | 2 +-
.../SiddhiCEPPolicyEventHandlerTest.java | 136 ++--
.../integration/MockMetadataServiceClient.java | 24 +-
.../engine/metric/MemoryUsageGaugeSetTest.java | 17 +-
.../engine/mock/MockPartitionedCollector.java | 15 +-
.../engine/mock/MockSampleMetadataFactory.java | 160 +++--
.../alert/engine/mock/MockStreamCollector.java | 15 +-
.../engine/mock/MockStreamMetadataService.java | 18 +-
.../alert/engine/mock/MockStreamReceiver.java | 41 +-
.../TestDistinctValuesInTimeBatchWindow.java | 86 ++-
.../nodata/TestDistinctValuesInTimeWindow.java | 20 +-
.../alert/engine/nodata/TestEventTable.java | 16 +-
.../alert/engine/nodata/TestNoDataAlert.java | 46 +-
.../engine/nodata/TestNoDataPolicyHandler.java | 27 +-
.../TestNoDataPolicyTimeBatchHandler.java | 228 +++----
.../alert/engine/perf/TestSerDeserPer.java | 48 +-
.../alert/engine/router/TestAlertBolt.java | 102 +--
.../engine/router/TestAlertPublisherBolt.java | 8 +-
.../engine/runner/TestStreamRouterBolt.java | 120 ++--
.../serialization/JavaSerializationTest.java | 54 +-
.../PartitionedEventSerializerTest.java | 132 ++--
.../alert/engine/siddhi/SiddhiPolicyTest.java | 105 ++--
.../AttributeCollectAggregatorTest.java | 37 +-
.../alert/engine/sorter/MapDBTestSuite.java | 20 +-
.../engine/sorter/StreamSortHandlerTest.java | 100 ++-
.../sorter/StreamWindowBenchmarkTest.java | 104 ++--
.../engine/sorter/StreamWindowTestSuite.java | 93 ++-
.../sorter/TreeMultisetComparatorTest.java | 37 +-
.../engine/statecheck/TestStateCheckPolicy.java | 11 +-
.../engine/topology/AlertTopologyTest.java | 52 +-
.../CoordinatorSpoutIntegrationTest.java | 33 +-
.../engine/topology/CorrelationSpoutTest.java | 65 +-
.../engine/topology/FastWordCountTopology.java | 56 +-
.../MockMetadataChangeNotifyService.java | 28 +-
.../engine/topology/SendData2KafkaTest.java | 20 +-
.../eagle/alert/engine/topology/TestBolt.java | 16 +-
.../alert/engine/topology/TestByteBuffer.java | 10 +-
.../topology/TestMetadataSpecSerDeser.java | 61 +-
.../TestStormCustomGroupingRouting.java | 76 +--
.../engine/topology/TestStormParallelism.java | 57 +-
.../topology/TestStormStreamIdRouting.java | 41 +-
.../topology/TestTuple2StreamConverter.java | 14 +-
.../engine/topology/TestUnitTopologyMain.java | 19 +-
.../engine/utils/CompressionUtilsTest.java | 12 +-
.../alert/engine/utils/TimePeriodUtilsTest.java | 26 +-
.../resources/absence/application-absence.conf | 48 +-
.../src/test/resources/absence/datasources.json | 30 +-
.../src/test/resources/absence/policies.json | 46 +-
.../test/resources/absence/publishments.json | 36 +-
.../resources/absence/streamdefinitions.json | 54 +-
.../src/test/resources/absence/topologies.json | 58 +-
.../test/resources/application-test-backup.conf | 58 +-
.../src/test/resources/application-test.conf | 54 +-
.../correlation/application-integration-2.conf | 48 +-
.../test/resources/correlation/datasources.json | 69 +--
.../test/resources/correlation/policies.json | 74 +--
.../resources/correlation/publishments.json | 32 +-
.../correlation/streamdefinitions.json | 181 +++---
.../test/resources/correlation/topologies.json | 58 +-
.../test/resources/correlation_spouttest.conf | 42 +-
.../src/test/resources/e2e/application-e2e.conf | 48 +-
.../src/test/resources/e2e/datasources.json | 36 +-
.../src/test/resources/e2e/policies.json | 50 +-
.../src/test/resources/e2e/publishments.json | 30 +-
.../src/test/resources/e2e/sherlock.json | 3 +-
.../test/resources/e2e/streamdefinitions.json | 155 ++---
.../src/test/resources/e2e/topologies.json | 58 +-
.../src/test/resources/e2e/ump_demo_schema.json | 321 +++++-----
.../src/test/resources/log4j.properties | 3 -
.../test/resources/loopback/publishments.json | 27 +-
.../resources/loopback/streamdefinitions.json | 140 ++---
.../resources/nodata/application-nodata.conf | 48 +-
.../src/test/resources/nodata/datasources.json | 30 +-
.../nodata/policies-provided-wisb.json | 42 +-
.../src/test/resources/nodata/policies.json | 46 +-
.../src/test/resources/nodata/publishments.json | 36 +-
.../resources/nodata/streamdefinitions.json | 54 +-
.../src/test/resources/nodata/topologies.json | 58 +-
.../router/publishments-empty-dedup-field.json | 17 +-
.../src/test/resources/router/publishments.json | 43 +-
.../src/test/resources/sample_perfmon_data.json | 9 +-
.../simple/application-integration.conf | 60 +-
.../src/test/resources/simple/datasources.json | 34 +-
.../src/test/resources/simple/policies.json | 158 ++---
.../src/test/resources/simple/publishments.json | 59 +-
.../resources/simple/streamdefinitions.json | 87 +--
.../src/test/resources/simple/topologies.json | 78 +--
.../statecheck/application-statecheck.conf | 48 +-
.../test/resources/statecheck/datasources.json | 34 +-
.../test/resources/statecheck/topologies.json | 58 +-
.../src/test/resources/testPublishForAdd0.json | 20 +-
.../src/test/resources/testPublishForAdd1.json | 32 +-
.../test/resources/testPublishForMdyValue.json | 21 +-
.../src/test/resources/testPublishSpec.json | 28 +-
.../src/test/resources/testPublishSpec2.json | 26 +-
.../alert-metadata-service/pom.xml | 12 +-
.../metadata/resource/MetadataResource.java | 65 +-
.../topology/resource/TopologyMgmtResource.java | 6 +-
.../impl/TopologyMgmtResourceHelper.java | 8 +-
.../resource/impl/TopologyMgmtResourceImpl.java | 67 +-
.../src/test/resources/application.conf | 6 +-
.../eagle/alert/metadata/IMetadataDao.java | 8 +-
.../eagle/alert/metadata/MetadataUtils.java | 8 +-
.../metadata/impl/InMemMetadataDaoImpl.java | 34 +-
.../metadata/impl/JdbcDatabaseHandler.java | 32 +-
.../metadata/impl/JdbcMetadataDaoImpl.java | 44 +-
.../alert/metadata/impl/JdbcSchemaManager.java | 35 +-
.../alert/metadata/impl/MetadataDaoFactory.java | 10 +-
.../metadata/impl/MongoMetadataDaoImpl.java | 126 ++--
.../eagle/alert/metadata/resource/Models.java | 13 +-
.../eagle/alert/metadata/resource/OpResult.java | 3 +-
.../alert/resource/impl/InMemoryTest.java | 12 +-
.../alert/resource/impl/JdbcImplTest.java | 23 +-
.../alert/resource/impl/MongoImplTest.java | 15 +-
.../src/test/resources/application-mongo.conf | 8 +-
.../src/test/resources/application.conf | 12 +-
.../eagle-alert/alert-metadata-parent/pom.xml | 28 +-
.../eagle-alert/alert-service/pom.xml | 364 +++++------
.../app/AlertDropWizardConfiguration.java | 3 +-
.../apache/eagle/service/app/ServiceApp.java | 24 +-
.../src/main/resources/application.conf | 74 +--
.../src/main/resources/log4j.properties | 2 -
.../src/main/webapp/WEB-INF/web.xml | 49 +-
.../eagle/service/app/TestServiceAppWithZk.java | 162 +++--
eagle-core/eagle-alert-parent/pom.xml | 18 +-
415 files changed, 8790 insertions(+), 8965 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-app/src/main/java/org/apache/eagle/alert/app/AlertUnitTopologyApp.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-app/src/main/java/org/apache/eagle/alert/app/AlertUnitTopologyApp.java b/eagle-core/eagle-alert-parent/eagle-alert-app/src/main/java/org/apache/eagle/alert/app/AlertUnitTopologyApp.java
index a80c3b8..63e92ff 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-app/src/main/java/org/apache/eagle/alert/app/AlertUnitTopologyApp.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-app/src/main/java/org/apache/eagle/alert/app/AlertUnitTopologyApp.java
@@ -15,12 +15,14 @@
* limitations under the License.
*/
-package org.apache.eagle.alert.app;import backtype.storm.generated.StormTopology;
-import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
+package org.apache.eagle.alert.app;
+
import org.apache.eagle.alert.engine.UnitTopologyMain;
import org.apache.eagle.app.StormApplication;
import org.apache.eagle.app.environment.impl.StormEnvironment;
+import backtype.storm.generated.StormTopology;
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
/**
* since 8/25/16.
@@ -31,7 +33,7 @@ public class AlertUnitTopologyApp extends StormApplication {
return UnitTopologyMain.createTopology(config);
}
- public static void main(String[] args){
+ public static void main(String[] args) {
Config config = ConfigFactory.load();
AlertUnitTopologyApp app = new AlertUnitTopologyApp();
app.run(config);
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolvable.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolvable.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolvable.java
index ecfd47f..86b78c1 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolvable.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolvable.java
@@ -21,24 +21,24 @@ import java.util.List;
/**
* @param <R>
* @param <V>
- * @since 6/16/15
+ * @since 6/16/15.
*/
public interface AttributeResolvable<R extends GenericAttributeResolveRequest, V> {
/**
- * @param request request type
+ * @param request request type.
* @return List<V>
* @throws AttributeResolveException
*/
List<V> resolve(R request) throws AttributeResolveException;
/**
- * validate request
+ * validate request.
* @throws BadAttributeResolveRequestException
*/
void validateRequest(R request) throws BadAttributeResolveRequestException;
/**
- * @return Class<R>
+ * @return Class<R>.
*/
Class<R> getRequestClass();
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveException.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveException.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveException.java
index 56cd942..4c4f1dd 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveException.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveException.java
@@ -17,10 +17,18 @@
package org.apache.eagle.service.alert.resolver;
/**
- * @since 6/16/15
+ * @since 6/16/15.
*/
public class AttributeResolveException extends Exception {
- public AttributeResolveException(String s, Exception e) { super(s,e); }
- public AttributeResolveException(Exception e) { super(e); }
- public AttributeResolveException(String s) { super(s); }
+ public AttributeResolveException(String s, Exception e) {
+ super(s, e);
+ }
+
+ public AttributeResolveException(Exception e) {
+ super(e);
+ }
+
+ public AttributeResolveException(String s) {
+ super(s);
+ }
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveResource.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveResource.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveResource.java
index 20207ab..9375b6a 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveResource.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolveResource.java
@@ -16,18 +16,18 @@
*/
package org.apache.eagle.service.alert.resolver;
-import com.google.inject.Inject;
-import com.typesafe.config.Config;
import org.apache.eagle.log.entity.GenericServiceAPIResponseEntity;
-import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.eagle.metadata.service.ApplicationEntityService;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.inject.Inject;
+import com.typesafe.config.Config;
-import javax.ws.rs.*;
import java.io.InputStream;
import java.util.List;
+import javax.ws.rs.*;
/**
- * @since 6/17/15
+ * @since 6/17/15.
*/
@Path("/stream")
public class AttributeResolveResource {
@@ -35,24 +35,28 @@ public class AttributeResolveResource {
private Config eagleServerConfig;
@Inject
- public AttributeResolveResource(ApplicationEntityService entityService, Config eagleServerConfig){
+ public AttributeResolveResource(ApplicationEntityService entityService, Config eagleServerConfig) {
this.entityService = entityService;
this.eagleServerConfig = eagleServerConfig;
}
@POST
@Path("attributeresolve")
- @Consumes({"application/json"})
- @Produces({"application/json"})
+ @Consumes( {"application/json"})
+ @Produces( {"application/json"})
public GenericServiceAPIResponseEntity attributeResolve(InputStream request,
- @QueryParam("resolver") String resolver){
+ @QueryParam("resolver") String resolver) {
GenericServiceAPIResponseEntity response = new GenericServiceAPIResponseEntity();
try {
- if(resolver == null) throw new AttributeResolveException("resolver is null");
+ if (resolver == null) {
+ throw new AttributeResolveException("resolver is null");
+ }
AttributeResolvable resolvable = AttributeResolverFactory.getAttributeResolver(resolver, entityService, eagleServerConfig);
ObjectMapper objectMapper = new ObjectMapper();
Class<?> resolveRequestClass = resolvable.getRequestClass();
- if(resolveRequestClass == null) throw new AttributeResolveException("Request class is null for resolver "+resolver);
+ if (resolveRequestClass == null) {
+ throw new AttributeResolveException("Request class is null for resolver " + resolver);
+ }
GenericAttributeResolveRequest resolveRequest = (GenericAttributeResolveRequest) objectMapper.readValue(request, resolvable.getRequestClass());
resolvable.validateRequest(resolveRequest);
List result = resolvable.resolve(resolveRequest);
@@ -68,16 +72,20 @@ public class AttributeResolveResource {
@GET
@Path("attributeresolve")
- @Produces({"application/json"})
+ @Produces( {"application/json"})
public GenericServiceAPIResponseEntity attributeResolver(
- @QueryParam("resolver") String resolver, @QueryParam("site") String site, @QueryParam("query") String query){
+ @QueryParam("resolver") String resolver, @QueryParam("site") String site, @QueryParam("query") String query) {
GenericServiceAPIResponseEntity response = new GenericServiceAPIResponseEntity();
try {
- if(resolver == null) throw new AttributeResolveException("resolver is null");
+ if (resolver == null) {
+ throw new AttributeResolveException("resolver is null");
+ }
AttributeResolvable resolvable = AttributeResolverFactory.getAttributeResolver(resolver, entityService, eagleServerConfig);
Class<?> resolveRequestClass = resolvable.getRequestClass();
- if(resolveRequestClass == null) throw new AttributeResolveException("Request class is null for resolver "+resolver);
- GenericAttributeResolveRequest resolveRequest = new GenericAttributeResolveRequest(query,site);
+ if (resolveRequestClass == null) {
+ throw new AttributeResolveException("Request class is null for resolver " + resolver);
+ }
+ GenericAttributeResolveRequest resolveRequest = new GenericAttributeResolveRequest(query, site);
resolvable.validateRequest(resolveRequest);
List result = resolvable.resolve(resolveRequest);
response.setSuccess(true);
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolverFactory.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolverFactory.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolverFactory.java
index a184aa0..010d8c3 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolverFactory.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/AttributeResolverFactory.java
@@ -16,36 +16,36 @@
*/
package org.apache.eagle.service.alert.resolver;
-import com.typesafe.config.Config;
import org.apache.eagle.metadata.service.ApplicationEntityService;
+import com.typesafe.config.Config;
import java.util.Collections;
import java.util.HashMap;
-import java.util.List;
import java.util.Map;
/**
-* @since 6/16/15
-*/
+ * @since 6/16/15.
+ */
public final class AttributeResolverFactory {
- private final static Map<String,AttributeResolvable> fieldResolvableCache = Collections.synchronizedMap(new HashMap<>());
+ private static final Map<String, AttributeResolvable> fieldResolvableCache = Collections.synchronizedMap(new HashMap<>());
+
public static AttributeResolvable getAttributeResolver(String fieldResolverName,
ApplicationEntityService entityService,
Config eagleServerConfig) throws AttributeResolveException {
AttributeResolvable instance;
- if(fieldResolvableCache.containsKey(fieldResolverName)){
+ if (fieldResolvableCache.containsKey(fieldResolverName)) {
instance = fieldResolvableCache.get(fieldResolverName);
} else {
try {
- instance = (AttributeResolvable) Class.forName(fieldResolverName).
- getConstructor(ApplicationEntityService.class, Config.class).
- newInstance(entityService, eagleServerConfig);
+ instance = (AttributeResolvable) Class.forName(fieldResolverName)
+ .getConstructor(ApplicationEntityService.class, Config.class)
+ .newInstance(entityService, eagleServerConfig);
fieldResolvableCache.put(fieldResolverName, instance);
} catch (ClassNotFoundException e) {
- throw new AttributeResolveException("Attribute Resolver in type of "+fieldResolverName+" is not found",e);
+ throw new AttributeResolveException("Attribute Resolver in type of " + fieldResolverName + " is not found", e);
} catch (InstantiationException | IllegalAccessException e) {
throw new AttributeResolveException(e);
- } catch (Exception ex){
+ } catch (Exception ex) {
throw new AttributeResolveException(ex);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/BadAttributeResolveRequestException.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/BadAttributeResolveRequestException.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/BadAttributeResolveRequestException.java
index 5a2d7e6..741dd31 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/BadAttributeResolveRequestException.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/BadAttributeResolveRequestException.java
@@ -17,15 +17,15 @@
package org.apache.eagle.service.alert.resolver;
public class BadAttributeResolveRequestException extends Exception {
- public BadAttributeResolveRequestException(Exception ex){
+ public BadAttributeResolveRequestException(Exception ex) {
super(ex);
}
- public BadAttributeResolveRequestException(String msg){
+ public BadAttributeResolveRequestException(String msg) {
super(msg);
}
- public BadAttributeResolveRequestException(String msg, Exception ex){
+ public BadAttributeResolveRequestException(String msg, Exception ex) {
super(msg, ex);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/GenericAttributeResolveRequest.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/GenericAttributeResolveRequest.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/GenericAttributeResolveRequest.java
index 97899b7..ee7ac99 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/GenericAttributeResolveRequest.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/GenericAttributeResolveRequest.java
@@ -20,16 +20,16 @@ import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
/**
- * @since 6/16/15
+ * @since 6/16/15.
*/
public class GenericAttributeResolveRequest {
/**
- * @param query whatever is in input box of attribute
- * @param site which site this policy belongs to
+ * @param query whatever is in input box of attribute.
+ * @param site which site this policy belongs to.
*/
@JsonCreator
- public GenericAttributeResolveRequest(@JsonProperty("query") String query, @JsonProperty("site") String site){
- this.query = query;
+ public GenericAttributeResolveRequest(@JsonProperty("query") String query, @JsonProperty("site") String site) {
+ this.query = query;
this.site = site;
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/BooleanAttributeResolver.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/BooleanAttributeResolver.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/BooleanAttributeResolver.java
index 3dc70e1..72bf056 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/BooleanAttributeResolver.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/BooleanAttributeResolver.java
@@ -16,15 +16,15 @@
*/
package org.apache.eagle.service.alert.resolver.impl;
+import org.apache.eagle.service.alert.resolver.AttributeResolvable;
import org.apache.eagle.service.alert.resolver.AttributeResolveException;
import org.apache.eagle.service.alert.resolver.GenericAttributeResolveRequest;
-import org.apache.eagle.service.alert.resolver.AttributeResolvable;
import java.util.Arrays;
import java.util.List;
/**
- * @since 6/16/15
+ * @since 6/16/15.
*/
public class BooleanAttributeResolver implements AttributeResolvable<GenericAttributeResolveRequest,String> {
@Override
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/EntityAttributeResolver.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/EntityAttributeResolver.java b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/EntityAttributeResolver.java
index 9758863..affb54b 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/EntityAttributeResolver.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert-service/src/main/java/org/apache/eagle/service/alert/resolver/impl/EntityAttributeResolver.java
@@ -16,8 +16,9 @@
*/
package org.apache.eagle.service.alert.resolver.impl;
-import org.apache.eagle.log.entity.GenericServiceAPIResponseEntity;
+import org.apache.eagle.common.DateTimeUtil;
import org.apache.eagle.log.base.taggedlog.TaggedLogAPIEntity;
+import org.apache.eagle.log.entity.GenericServiceAPIResponseEntity;
import org.apache.eagle.log.entity.meta.EntityDefinition;
import org.apache.eagle.log.entity.meta.EntityDefinitionManager;
import org.apache.eagle.service.alert.resolver.AttributeResolvable;
@@ -25,8 +26,6 @@ import org.apache.eagle.service.alert.resolver.AttributeResolveException;
import org.apache.eagle.service.alert.resolver.BadAttributeResolveRequestException;
import org.apache.eagle.service.alert.resolver.GenericAttributeResolveRequest;
import org.apache.eagle.service.generic.GenericEntityServiceResource;
-import org.apache.eagle.common.DateTimeUtil;
-
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import org.apache.commons.lang3.StringUtils;
@@ -36,42 +35,42 @@ import java.util.List;
import java.util.Map;
/**
- * @since 6/16/15
+ * @since 6/16/15.
*/
-public class EntityAttributeResolver implements AttributeResolvable<EntityAttributeResolver.EntityAttributeResolveRequest,String> {
+public class EntityAttributeResolver implements AttributeResolvable<EntityAttributeResolver.EntityAttributeResolveRequest, String> {
- private final static GenericEntityServiceResource entityServiceResource = new GenericEntityServiceResource();
+ private static final GenericEntityServiceResource entityServiceResource = new GenericEntityServiceResource();
@Override
public List<String> resolve(EntityAttributeResolveRequest request) throws AttributeResolveException {
- if(request.getFieldName()==null){
+ if (request.getFieldName() == null) {
throw new AttributeResolveException("fieldName is required");
}
String attributeName = request.getFieldName();
EntityDefinition entityDefinition;
try {
- if(request.getServiceName()!=null){
+ if (request.getServiceName() != null) {
entityDefinition = EntityDefinitionManager.getEntityByServiceName(request.getServiceName());
- }else if (request.getEntityClassName()!=null){
+ } else if (request.getEntityClassName() != null) {
Class<? extends TaggedLogAPIEntity> entityClass = (Class<? extends TaggedLogAPIEntity>) Class.forName(request.getEntityClassName());
entityDefinition = EntityDefinitionManager.getEntityDefinitionByEntityClass(entityClass);
- }else {
+ } else {
throw new AttributeResolveException("At least serviceName or entityClassName is required, but neither found");
}
} catch (InstantiationException | IllegalAccessException | ClassNotFoundException e) {
throw new AttributeResolveException(e);
}
List<String> filterCondition = new ArrayList<>();
- if(request.getTags()!=null){
- for(Map.Entry<String,String> tag:request.getTags().entrySet()) {
+ if (request.getTags() != null) {
+ for (Map.Entry<String, String> tag : request.getTags().entrySet()) {
filterCondition.add("@" + tag.getKey() + " = \"" + tag.getValue() + "\"");
}
}
- if(request.getQuery() != null) {
- filterCondition.add("@" + attributeName + "~= \".*" + request.getQuery()+".*\"");
+ if (request.getQuery() != null) {
+ filterCondition.add("@" + attributeName + "~= \".*" + request.getQuery() + ".*\"");
}
String query = entityDefinition.getService() + "[" + StringUtils.join(filterCondition, " AND ") + "]<@" + attributeName + ">{count}";
- return aggregateQuery(query, DateTimeUtil.millisecondsToHumanDateWithSeconds(0), DateTimeUtil.millisecondsToHumanDateWithSeconds(System.currentTimeMillis()),request.getMetricName());
+ return aggregateQuery(query, DateTimeUtil.millisecondsToHumanDateWithSeconds(0), DateTimeUtil.millisecondsToHumanDateWithSeconds(System.currentTimeMillis()), request.getMetricName());
}
@Override
@@ -84,16 +83,16 @@ public class EntityAttributeResolver implements AttributeResolvable<EntityAttrib
}
- private List<String> aggregateQuery(String query,String startTime,String endTime,String metricName) throws AttributeResolveException {
+ private List<String> aggregateQuery(String query, String startTime, String endTime, String metricName) throws AttributeResolveException {
List<String> result = new ArrayList<>();
GenericServiceAPIResponseEntity response = entityServiceResource.search(query, startTime, endTime, Integer.MAX_VALUE, null, false, false, 0, Integer.MAX_VALUE, true, 0, metricName, false);
- if(response.isSuccess()){
+ if (response.isSuccess()) {
List objs = response.getObj();
- for(Object item:objs){
+ for (Object item : objs) {
// TODO: get keys as result
throw new IllegalArgumentException("not implemented yet");
}
- }else{
+ } else {
throw new AttributeResolveException(response.getException());
}
return result;
@@ -103,39 +102,47 @@ public class EntityAttributeResolver implements AttributeResolvable<EntityAttrib
public Map<String, String> getTags() {
return tags;
}
+
private final Map<String, String> tags;
+
public String getMetricName() {
return metricName;
}
+
private final String metricName;
+
@JsonCreator
public EntityAttributeResolveRequest(
- @JsonProperty("query") String query,
- @JsonProperty("site") String site,
- @JsonProperty("serviceName") String serviceName,
- @JsonProperty("entityClassName") String entityClassName,
- @JsonProperty("metricName") String metricName,
- @JsonProperty("fieldName") String fieldName,
- @JsonProperty("tags") Map<String, String> tags
- ){
+ @JsonProperty("query") String query,
+ @JsonProperty("site") String site,
+ @JsonProperty("serviceName") String serviceName,
+ @JsonProperty("entityClassName") String entityClassName,
+ @JsonProperty("metricName") String metricName,
+ @JsonProperty("fieldName") String fieldName,
+ @JsonProperty("tags") Map<String, String> tags
+ ) {
super(query, site);
this.serviceName = serviceName;
this.entityClassName = entityClassName;
this.fieldName = fieldName;
this.metricName = metricName;
- this.tags = tags;
+ this.tags = tags;
}
private final String serviceName;
+
public String getEntityClassName() {
return entityClassName;
}
+
public String getServiceName() {
return serviceName;
}
+
public String getFieldName() {
return fieldName;
}
+
private final String entityClassName;
private final String fieldName;
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/pom.xml
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/pom.xml b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/pom.xml
index 0fb2bb7..57a0157 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/pom.xml
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/pom.xml
@@ -83,8 +83,8 @@
<artifactId>jackson-jaxrs-json-provider</artifactId>
</dependency>
<!--<dependency>-->
- <!--<groupId>org.codehaus.jackson</groupId>-->
- <!--<artifactId>jackson-jaxrs</artifactId>-->
+ <!--<groupId>org.codehaus.jackson</groupId>-->
+ <!--<artifactId>jackson-jaxrs</artifactId>-->
<!--</dependency>-->
<dependency>
<groupId>joda-time</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusBase.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusBase.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusBase.java
index 5cedba6..71f1d59 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusBase.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusBase.java
@@ -18,41 +18,38 @@
*/
package org.apache.eagle.alert.config;
-import java.io.Closeable;
-
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.RetryNTimes;
-
+import java.io.Closeable;
/**
* Abstraction of asynchronized configuration management
* This is used for config change notification between processes, without this one process has to pull changes triggered by another process
- *
- * Config bus is similar to message bus, config change producer can publish config change(message) to config bus,
- * while config change consumer can subscribe config change and do business logic in callback
+ * <p>Config bus is similar to message bus, config change producer can publish config change(message) to config bus,
+ * while config change consumer can subscribe config change and do business logic in callback
+ * </p>
* 1. use zookeeper as media to notify config consumer of config changes
* 2. each type of config is represented by topic
* 3. each config change can contain actual value or contain reference Id which consumer uses to retrieve actual value. This mechanism will reduce zookeeper overhed
- *
*/
-public class ConfigBusBase implements Closeable{
+public class ConfigBusBase implements Closeable {
protected String zkRoot;
protected CuratorFramework curator;
public ConfigBusBase(ZKConfig config) {
this.zkRoot = config.zkRoot;
curator = CuratorFrameworkFactory.newClient(
- config.zkQuorum,
- config.zkSessionTimeoutMs,
- config.connectionTimeoutMs,
- new RetryNTimes(config.zkRetryTimes, config.zkRetryInterval)
+ config.zkQuorum,
+ config.zkSessionTimeoutMs,
+ config.connectionTimeoutMs,
+ new RetryNTimes(config.zkRetryTimes, config.zkRetryInterval)
);
curator.start();
}
@Override
- public void close(){
+ public void close() {
curator.close();
}
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusConsumer.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusConsumer.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusConsumer.java
index 3db30e5..c2849a2 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusConsumer.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusConsumer.java
@@ -22,8 +22,7 @@ import org.slf4j.Logger;
/**
* 1. When consumer is started, it always get notified of config
- * 2. When config is changed, consumer always get notified of config change
- *
+ * 2. When config is changed, consumer always get notified of config change.
* Reliability issue:
* TODO How to ensure config change message is always delivered to consumer
*/
@@ -31,12 +30,13 @@ public class ConfigBusConsumer extends ConfigBusBase {
private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(ConfigBusConsumer.class);
private NodeCache cache;
+
public ConfigBusConsumer(ZKConfig config, String topic, ConfigChangeCallback callback) {
super(config);
String zkPath = zkRoot + "/" + topic;
LOG.info("monitor change for zkPath " + zkPath);
cache = new NodeCache(curator, zkPath);
- cache.getListenable().addListener( () -> {
+ cache.getListenable().addListener(() -> {
// get node value and notify callback
byte[] value = curator.getData().forPath(zkPath);
ObjectMapper mapper = new ObjectMapper();
@@ -46,7 +46,7 @@ public class ConfigBusConsumer extends ConfigBusBase {
);
try {
cache.start();
- } catch(Exception ex) {
+ } catch (Exception ex) {
LOG.error("error start NodeCache listener", ex);
throw new RuntimeException(ex);
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusProducer.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusProducer.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusProducer.java
index c2b0165..8f30e5c 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusProducer.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigBusProducer.java
@@ -16,36 +16,31 @@
*/
package org.apache.eagle.alert.config;
+import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.zookeeper.CreateMode;
import org.slf4j.Logger;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
public class ConfigBusProducer extends ConfigBusBase {
private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(ConfigBusProducer.class);
- public ConfigBusProducer(ZKConfig config){
+ public ConfigBusProducer(ZKConfig config) {
super(config);
}
- /**
- * @param topic
- * @param config
- */
- public void send(String topic, ConfigValue config){
+ public void send(String topic, ConfigValue config) {
// check if topic exists, create this topic if not existing
String zkPath = zkRoot + "/" + topic;
try {
if (curator.checkExists().forPath(zkPath) == null) {
curator.create()
- .creatingParentsIfNeeded()
- .withMode(CreateMode.PERSISTENT)
- .forPath(zkPath);
+ .creatingParentsIfNeeded()
+ .withMode(CreateMode.PERSISTENT)
+ .forPath(zkPath);
}
ObjectMapper mapper = new ObjectMapper();
byte[] content = mapper.writeValueAsBytes(config);
curator.setData().forPath(zkPath, content);
- }catch(Exception ex){
+ } catch (Exception ex) {
LOG.error("error creating zkPath " + zkPath, ex);
throw new RuntimeException(ex);
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigValue.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigValue.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigValue.java
index f47e1be..b4d6fc3 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigValue.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ConfigValue.java
@@ -23,7 +23,7 @@ package org.apache.eagle.alert.config;
* Config body contains actual data for one topic
* this is serialized with json format into zookeeper
* value can be versionId which is used for referencing outside data
- * or value can be actual config value
+ * or value can be actual config value.
*/
public class ConfigValue {
private boolean isValueVersionId;
@@ -45,7 +45,7 @@ public class ConfigValue {
this.value = value;
}
- public String toString(){
+ public String toString() {
return "isValueVersionId: " + isValueVersionId + ", value: " + value;
}
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfig.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfig.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfig.java
index 086210a..5e0c952 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfig.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfig.java
@@ -21,9 +21,9 @@ package org.apache.eagle.alert.config;
import java.io.Serializable;
/**
- * Memory representation of key zookeeper configurations
+ * Memory representation of key zookeeper configurations.
*/
-public class ZKConfig implements Serializable{
+public class ZKConfig implements Serializable {
private static final long serialVersionUID = -1287231022807492775L;
public String zkQuorum;
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfigBuilder.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfigBuilder.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfigBuilder.java
index d7b3232..97c0797 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfigBuilder.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/config/ZKConfigBuilder.java
@@ -25,7 +25,7 @@ import com.typesafe.config.Config;
* Since 4/28/16.
*/
public class ZKConfigBuilder {
- public static ZKConfig getZKConfig(Config config){
+ public static ZKConfig getZKConfig(Config config) {
ZKConfig zkConfig = new ZKConfig();
zkConfig.zkQuorum = config.getString("zkConfig.zkQuorum");
zkConfig.zkRoot = config.getString("zkConfig.zkRoot");
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/AlertBoltSpec.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/AlertBoltSpec.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/AlertBoltSpec.java
index 83d307c..b3adda5 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/AlertBoltSpec.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/AlertBoltSpec.java
@@ -16,18 +16,17 @@
*/
package org.apache.eagle.alert.coordination.model;
+import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
-
-import com.fasterxml.jackson.annotation.JsonIgnore;
-
/**
* The alert specification for topology bolts.
- *
+ *
* @since Apr 29, 2016
*/
public class AlertBoltSpec {
@@ -64,19 +63,19 @@ public class AlertBoltSpec {
this.topologyName = topologyName;
}
-// public List<PolicyDefinition> getBoltPolicy(String boltId) {
-// return boltPoliciesMap.get(boltId);
-// }
-//
-// public void addBoltPolicy(String boltId, PolicyDefinition pd) {
-// if (boltPoliciesMap.containsKey(boltId)) {
-// boltPoliciesMap.get(boltId).add(pd);
-// } else {
-// List<PolicyDefinition> list = new ArrayList<PolicyDefinition>();
-// boltPoliciesMap.put(boltId, list);
-// list.add(pd);
-// }
-// }
+ // public List<PolicyDefinition> getBoltPolicy(String boltId) {
+ // return boltPoliciesMap.get(boltId);
+ // }
+ //
+ // public void addBoltPolicy(String boltId, PolicyDefinition pd) {
+ // if (boltPoliciesMap.containsKey(boltId)) {
+ // boltPoliciesMap.get(boltId).add(pd);
+ // } else {
+ // List<PolicyDefinition> list = new ArrayList<PolicyDefinition>();
+ // boltPoliciesMap.put(boltId, list);
+ // list.add(pd);
+ // }
+ // }
public void addBoltPolicy(String boltId, String policyName) {
if (boltPolicyIdsMap.containsKey(boltId)) {
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/Kafka2TupleMetadata.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/Kafka2TupleMetadata.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/Kafka2TupleMetadata.java
index 6c4f576..e3ec774 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/Kafka2TupleMetadata.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/Kafka2TupleMetadata.java
@@ -16,15 +16,13 @@
*/
package org.apache.eagle.alert.coordination.model;
-import java.util.Map;
-
-import org.apache.commons.lang3.builder.HashCodeBuilder;
-
import com.google.common.base.Objects;
+import org.apache.commons.lang3.builder.HashCodeBuilder;
+import java.util.Map;
/**
+ * This metadata model controls how to convert kafka topic into tuple stream.
* @since Apr 5, 2016
- * this metadata model controls how to convert kafka topic into tuple stream
*/
public class Kafka2TupleMetadata {
private String type;
@@ -78,6 +76,7 @@ public class Kafka2TupleMetadata {
public String getTopic() {
return this.topic;
}
+
public String getSchemeCls() {
return this.schemeCls;
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PolicyWorkerQueue.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PolicyWorkerQueue.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PolicyWorkerQueue.java
index e32d13c..44fad90 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PolicyWorkerQueue.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PolicyWorkerQueue.java
@@ -16,31 +16,14 @@
*/
package org.apache.eagle.alert.coordination.model;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
-
+import org.apache.eagle.alert.engine.coordinator.StreamPartition;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.builder.HashCodeBuilder;
-import org.apache.eagle.alert.engine.coordinator.StreamPartition;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with this
- * work for additional information regarding copyright ownership. The ASF
- * licenses this file to You under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * <p/>
- * http://www.apache.org/licenses/LICENSE-2.0
- * <p/>
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
public class PolicyWorkerQueue {
private StreamPartition partition;
@@ -85,8 +68,8 @@ public class PolicyWorkerQueue {
return false;
}
PolicyWorkerQueue that = (PolicyWorkerQueue) other;
- return Objects.equals(partition, that.partition) &&
- CollectionUtils.isEqualCollection(workers, that.workers);
+ return Objects.equals(partition, that.partition)
+ && CollectionUtils.isEqualCollection(workers, that.workers);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PublishSpec.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PublishSpec.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PublishSpec.java
index 06e819a..c1f9b24 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PublishSpec.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/PublishSpec.java
@@ -16,16 +16,10 @@
*/
package org.apache.eagle.alert.coordination.model;
+import org.apache.eagle.alert.engine.coordinator.Publishment;
import java.util.ArrayList;
import java.util.List;
-import org.apache.eagle.alert.engine.coordinator.Publishment;
-
-/**
- *
- * @since May 1, 2016
- *
- */
public class PublishSpec {
private String topologyName;
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/RouterSpec.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/RouterSpec.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/RouterSpec.java
index 9a576a3..fc13c56 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/RouterSpec.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/RouterSpec.java
@@ -22,10 +22,6 @@ import java.util.ArrayList;
import java.util.List;
-/**
- * @since Apr 29, 2016
- *
- */
public class RouterSpec {
private String version;
private String topologyName;
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/ScheduleState.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/ScheduleState.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/ScheduleState.java
index 93d038f..40ac85d 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/ScheduleState.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/ScheduleState.java
@@ -14,8 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.apache.eagle.alert.coordination.model;
+import org.apache.eagle.alert.coordination.model.internal.MonitoredStream;
+import org.apache.eagle.alert.coordination.model.internal.PolicyAssignment;
+import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
+import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
@@ -23,11 +28,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import org.apache.eagle.alert.coordination.model.internal.MonitoredStream;
-import org.apache.eagle.alert.coordination.model.internal.PolicyAssignment;
-import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
-import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
-
/**
* A global wise of schedule status <br/>
* <br/>
@@ -36,10 +36,8 @@ import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
* <br/>
* The solution is in metadata resource, have specs/monitoredStreams/policy
* assignments stored in different table/collections with tage version.
- *
- *
- * @since Apr 26, 2016
*
+ * @since Apr 26, 2016
*/
public class ScheduleState {
@@ -68,15 +66,15 @@ public class ScheduleState {
this.generateTime = String.valueOf(new Date().getTime());
}
- public ScheduleState(String version,
- Map<String, SpoutSpec> topoSpoutSpecsMap,
- Map<String, RouterSpec> groupSpecsMap,
- Map<String, AlertBoltSpec> alertSpecsMap,
- Map<String, PublishSpec> pubMap,
- Collection<PolicyAssignment> assignments,
- Collection<MonitoredStream> monitoredStreams,
- Collection<PolicyDefinition> definitions,
- Collection<StreamDefinition> streams) {
+ public ScheduleState(String version,
+ Map<String, SpoutSpec> topoSpoutSpecsMap,
+ Map<String, RouterSpec> groupSpecsMap,
+ Map<String, AlertBoltSpec> alertSpecsMap,
+ Map<String, PublishSpec> pubMap,
+ Collection<PolicyAssignment> assignments,
+ Collection<MonitoredStream> monitoredStreams,
+ Collection<PolicyDefinition> definitions,
+ Collection<StreamDefinition> streams) {
this.spoutSpecs = topoSpoutSpecsMap;
this.groupSpecs = groupSpecsMap;
this.alertSpecs = alertSpecsMap;
@@ -113,7 +111,7 @@ public class ScheduleState {
for (PolicyDefinition def : definitions) {
this.policySnapshots.add(new VersionedPolicyDefinition(version, def));
}
- for (StreamDefinition sd :streams) {
+ for (StreamDefinition sd : streams) {
this.streamSnapshots.add(new VersionedStreamDefinition(version, sd));
}
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/SpoutSpec.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/SpoutSpec.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/SpoutSpec.java
index c0e8ec1..f5c7399 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/SpoutSpec.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/SpoutSpec.java
@@ -23,19 +23,18 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
-
/**
* SpoutSpec metadata control 3 phases for data transformation for one specific topic
* phase 1: kafka topic to tuple, controlled by Kafka2TupleMetadata, i.e. Scheme
* phase 2: tuple to stream, controlled by Tuple2StreamMetadata, i.e. stream name selector etc.
* phase 3: stream repartition, controlled by StreamRepartitionMetadata, i.e. groupby spec
- * @since Apr 18, 2016
*
+ * @since Apr 18, 2016
*/
public class SpoutSpec {
private String version;
-// private String spoutId;
+ // private String spoutId;
private String topologyId;
// topicName -> kafka2TupleMetadata
@@ -45,27 +44,28 @@ public class SpoutSpec {
// topicName -> list of StreamRepartitionMetadata, here it is list because one topic(data source) may spawn multiple streams.
private Map<String, List<StreamRepartitionMetadata>> streamRepartitionMetadataMap = new HashMap<String, List<StreamRepartitionMetadata>>();
- public SpoutSpec(){}
+ public SpoutSpec() {
+ }
public SpoutSpec(
- String topologyId,
-// String spoutId,
- Map<String, List<StreamRepartitionMetadata>> streamRepartitionMetadataMap,
- Map<String, Tuple2StreamMetadata> tuple2StreamMetadataMap,
- Map<String, Kafka2TupleMetadata> kafka2TupleMetadataMap) {
+ String topologyId,
+ // String spoutId,
+ Map<String, List<StreamRepartitionMetadata>> streamRepartitionMetadataMap,
+ Map<String, Tuple2StreamMetadata> tuple2StreamMetadataMap,
+ Map<String, Kafka2TupleMetadata> kafka2TupleMetadataMap) {
this.topologyId = topologyId;
-// this.spoutId = spoutId;
+ // this.spoutId = spoutId;
this.streamRepartitionMetadataMap = streamRepartitionMetadataMap;
this.tuple2StreamMetadataMap = tuple2StreamMetadataMap;
this.kafka2TupleMetadataMap = kafka2TupleMetadataMap;
}
-// public String getSpoutId() {
-// return spoutId;
-// }
-// public void setSpoutId(String spoutId) {
-// this.spoutId = spoutId;
-// }
+ // public String getSpoutId() {
+ // return spoutId;
+ // }
+ // public void setSpoutId(String spoutId) {
+ // this.spoutId = spoutId;
+ // }
public String getTopologyId() {
return topologyId;
@@ -75,7 +75,7 @@ public class SpoutSpec {
return streamRepartitionMetadataMap;
}
- public Map<String, Tuple2StreamMetadata> getTuple2StreamMetadataMap(){
+ public Map<String, Tuple2StreamMetadata> getTuple2StreamMetadataMap() {
return this.tuple2StreamMetadataMap;
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamNameSelector.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamNameSelector.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamNameSelector.java
index bc7952c..f613b11 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamNameSelector.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamNameSelector.java
@@ -19,13 +19,11 @@ package org.apache.eagle.alert.coordination.model;
import java.util.Map;
/**
- * This metadata controls how to figure out stream name from incoming tuple
+ * This metadata controls how to figure out stream name from incoming tuple.
*/
public interface StreamNameSelector {
/**
- * field name to value mapping
- * @param tuple
- * @return
+ * field name to value mapping.
*/
String getStreamName(Map<String, Object> tuple);
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionMetadata.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionMetadata.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionMetadata.java
index 86b1d27..d1ce9da 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionMetadata.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionMetadata.java
@@ -21,20 +21,20 @@ import com.fasterxml.jackson.annotation.JsonIgnore;
import java.util.ArrayList;
import java.util.List;
-
/**
+ * This meta-data controls how tuple streamId is repartitioned.
* @since Apr 25, 2016
- * This meta-data controls how tuple streamId is repartitioned
*/
public class StreamRepartitionMetadata {
private String topicName;
private String streamId;
/**
- * each stream may have multiple different grouping strategies,for example groupby some fields or even shuffling
+ * each stream may have multiple different grouping strategies,for example groupby some fields or even shuffling.
*/
public List<StreamRepartitionStrategy> groupingStrategies = new ArrayList<StreamRepartitionStrategy>();
- public StreamRepartitionMetadata(){}
+ public StreamRepartitionMetadata() {
+ }
public StreamRepartitionMetadata(String topicName, String stream) {
this.topicName = topicName;
@@ -44,6 +44,7 @@ public class StreamRepartitionMetadata {
public String getStreamId() {
return streamId;
}
+
public void setStreamId(String streamId) {
this.streamId = streamId;
}
@@ -51,6 +52,7 @@ public class StreamRepartitionMetadata {
public String getTopicName() {
return topicName;
}
+
public void setTopicName(String topicName) {
this.topicName = topicName;
}
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionStrategy.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionStrategy.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionStrategy.java
index 203114e..118347f 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionStrategy.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRepartitionStrategy.java
@@ -16,19 +16,19 @@
*/
package org.apache.eagle.alert.coordination.model;
-import java.util.ArrayList;
-import java.util.List;
+import org.apache.eagle.alert.engine.coordinator.StreamPartition;
import org.apache.commons.collections.CollectionUtils;
-import org.apache.eagle.alert.engine.coordinator.StreamPartition;
+import java.util.ArrayList;
+import java.util.List;
public class StreamRepartitionStrategy {
- public StreamPartition partition ;
+ public StreamPartition partition;
public int numTotalParticipatingRouterBolts = 0; // how many group-by bolts participate policy evaluation
public int startSequence = 0; // what is the sequence for the first bolt in this topology among all bolts
public List<String> totalTargetBoltIds = new ArrayList<String>();
-
+
public int hashCode() {
int hashcode = 1 * 31;
hashcode += partition.hashCode();
@@ -37,14 +37,14 @@ public class StreamRepartitionStrategy {
}
return hashcode;
}
-
+
public boolean equals(Object obj) {
if (!(obj instanceof StreamRepartitionStrategy)) {
return false;
}
StreamRepartitionStrategy o = (StreamRepartitionStrategy) obj;
return partition.equals(o.partition)
- && CollectionUtils.isEqualCollection(totalTargetBoltIds, o.totalTargetBoltIds);
+ && CollectionUtils.isEqualCollection(totalTargetBoltIds, o.totalTargetBoltIds);
}
public StreamPartition getPartition() {
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/a0fc8708/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRouterSpec.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRouterSpec.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRouterSpec.java
index 195c8d9..96dfc59 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRouterSpec.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/main/java/org/apache/eagle/alert/coordination/model/StreamRouterSpec.java
@@ -16,24 +16,23 @@
*/
package org.apache.eagle.alert.coordination.model;
+import org.apache.eagle.alert.engine.coordinator.StreamPartition;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.builder.HashCodeBuilder;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang3.builder.HashCodeBuilder;
-import org.apache.eagle.alert.engine.coordinator.StreamPartition;
-
/**
* One RouteSpec means one rule mapping [streamId -> StreamPartition ->
* PolicyExecutionQueue]
*
- * Key is StreamPartition
+ * <p>Key is StreamPartition.
*/
public class StreamRouterSpec {
private String streamId;
private StreamPartition partition; // The meta-data to build
- // StreamPartitioner
+ // StreamPartitioner
private List<PolicyWorkerQueue> targetQueue = new ArrayList<PolicyWorkerQueue>();
public StreamPartition getPartition() {
@@ -72,7 +71,7 @@ public class StreamRouterSpec {
@Override
public String toString() {
return String.format("StreamRouterSpec[streamId=%s,partition=%s, queue=[%s]]", this.getStreamId(),
- this.getPartition(), this.getTargetQueue());
+ this.getPartition(), this.getTargetQueue());
}
@Override
@@ -84,8 +83,8 @@ public class StreamRouterSpec {
return false;
}
StreamRouterSpec that = (StreamRouterSpec) other;
- return Objects.equals(streamId, that.streamId) &&
- Objects.equals(partition, that.partition) &&
- CollectionUtils.isEqualCollection(targetQueue, that.targetQueue);
+ return Objects.equals(streamId, that.streamId)
+ && Objects.equals(partition, that.partition)
+ && CollectionUtils.isEqualCollection(targetQueue, that.targetQueue);
}
}
\ No newline at end of file